Skip to content

Pull requests: apache/flink

New pull request New
1,025 Open 22,048 Closed
1,025 Open 22,048 Closed
Author
Filter by author
Label
Filter by label
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Milestones
Filter by milestone
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[FLINK-32686][network] Avoid creating tiered internal shuffle master before enabling the tiered storage
#23086 opened Jul 27, 2023 by WencongLiu Loading…
[FLINK-32680][streaming] Fix the messed up JobVertex name when the source nodes chained with a MultipleInput node.
#23085 opened Jul 27, 2023 by JunRuiLee Loading…
1
[FLINK-32691] SELECT fcn does not work with an unset catalog or database
#23084 opened Jul 26, 2023 by jnh5y Loading…
1
[FLINK-32682] Make it possible to use query time based time functions in streaming mode
#23083 opened Jul 26, 2023 by dawidwys Loading…
1
[FLINK-32683][rpc] Update Pekko from 1.0.0 to 1.0.1
#23080 opened Jul 26, 2023 by mdedetrich Loading…
2
[FLINK-32670] Annotate interfaces that inherit from SourceFunction as deprecated
#23079 opened Jul 26, 2023 by afedulov Loading…
1
[FLINK-32676][doc] Add doc for catalog modification listener
#23078 opened Jul 26, 2023 by FangYongs Loading…
@PatrickRen
1
[FLINK-32675][doc] Add document for the tiered storage of hybrid shuffle
#23077 opened Jul 26, 2023 by TanYuxin-tyx Loading…
1
[FLINK-32674][doc] Add documentation for the new getTargetColumns in DynamicTableSink
#23075 opened Jul 26, 2023 by lincoln-lil Loading…
12
[BP-1.17][FLINK-30629][Client/Job Submission] Increase clientHeartbeatTimeout …
#23074 opened Jul 25, 2023 by snuyanzin Loading…
2
Remove parameter in WindowAssigner#getDefaultTrigger()
#23073 opened Jul 25, 2023 by WencongLiu Loading…
1
Deprecate IOReadableWritable serialization in Path
#23072 opened Jul 25, 2023 by WencongLiu Loading…
1
[FLINK-32565][table] Support Cast From NUMBER to BYTES
#23067 opened Jul 24, 2023 by hanyuzheng7 Loading…
1
[FLINK-32656][table] Deprecate ManagedTable related APIs
#23065 opened Jul 24, 2023 by LadyForest Loading…
2
[FLINK-32660][table] Introduce external FS compatible FileCatalogStore implementation
#23063 opened Jul 24, 2023 by ferenc-csaky Loading…
1
[FLINK-32519][docs] Add doc for [CREATE OR] REPLACE TABLE AS statement
#23060 opened Jul 24, 2023 by Tartarus0zm Loading…
12
Remove parameter in RichFunction#open
#23058 opened Jul 24, 2023 by WencongLiu Loading…
1
[FLINK-32564][table] Support Cast From BYTES to NUMBER
#23057 opened Jul 24, 2023 by hanyuzheng7 Loading…
2
[FLINK-32649][runtime/Metrics] fix the dimension order for promethues reporter
#23053 opened Jul 23, 2023 by chenyuzhi459 Loading…
@zentol
4
Bump org.apache.calcite:calcite-core from 1.16.0 to 1.32.0 in /flink-connectors/flink-sql-connector-hive-3.1.3 dependencies Pull requests that update a dependency file java Pull requests that update Java code
#23052 opened Jul 23, 2023 by dependabot bot Loading…
1
[FLINK-32648][table] Reuse Calcite's SqlWindowTableFunction
#23051 opened Jul 22, 2023 by snuyanzin Loading…
2
[FLINK-32287][docs] Add doc for truncate table statement
#23046 opened Jul 22, 2023 by ruanhang1993 Loading…
11
[python][docs] Fix broken syntax in Flink Table API query example
#23043 opened Jul 21, 2023 by deepyaman Loading…
1
[FLINK-32418][formats-protobuf] Fix ClassNotFoundException when using protobuf in SQL-Client
#23032 opened Jul 20, 2023 by m-kay Loading…
1
[FLINK-32508][metrics][prometheus] Add support for native counters an…
#23031 opened Jul 20, 2023 by hlteoh37 • Draft
1
ProTip! What’s not been updated in a month: updated:<2023-06-26.