Skip to content

Pull requests: apache/flink

New pull request New
1,087 Open 22,785 Closed
1,087 Open 22,785 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-25565][Formats][Parquet] write and read parquet int64 timestamp
#23887 opened Dec 6, 2023 by tweise Loading…
1
[FLINK-33676] Implement RestoreTests for WindowAggregate
#23886 opened Dec 6, 2023 by jnh5y Loading…
1
[FLINK-33718][table] Cleanup the usage of deprecated StreamTableEnvironment#toAppendStream
#23885 opened Dec 6, 2023 by snuyanzin Loading…
4
[FLINK-33754] Serialize QueryOperations into SQL string
#23884 opened Dec 6, 2023 by dawidwys • Draft
1
[hotfix][test] Migrate JsonRowDeserializationSchemaTest/JsonRowSerializationSchemaTest to Junit5 and Assertj
#23882 opened Dec 6, 2023 by swuferhong Loading…
1
[FLINK-33759] flink parquet writer support write nested array or map type
#23881 opened Dec 6, 2023 by LoveHeat Loading…
1
[FLINK-33500][Runtime] Run storing the JobGraph an asynchronous operation
#23880 opened Dec 6, 2023 by zhengzhili333 Loading…
1
[FLINK-33758] Implement restore tests for TemporalSort node
#23879 opened Dec 5, 2023 by jnh5y Loading…
8
[FLINK-33757] Implement restore tests for Rank node
#23878 opened Dec 5, 2023 by jnh5y Loading…
7
[FLINK-33666][table] Use the same constraint name in MergeTableLikeUtil and Schema
#23877 opened Dec 5, 2023 by jeyhunkarimov Loading…
2
[FLINK-25857] Add committer metrics to track the status of committables - non-breaking
#23876 opened Dec 5, 2023 by pvary Loading…
2
[FLINK-33751] use modules correctly when deserializing json plan
#23874 opened Dec 5, 2023 by shuaiqig Loading…
1
[FLINK-24150][k8s] Support to configure cpu resource request and limit in pod template
#23872 opened Dec 5, 2023 by Sucran Loading…
5
[DRAFT] Experiment of bulk sync task states
#23871 opened Dec 5, 2023 by KarmaGYZ Loading…
1
[FLINK-32949][core]collect tm port binding with TaskManagerOptions
#23870 opened Dec 4, 2023 by JingGe Loading…
1
[FLINK-33726][sql-client] print time cost for streaming queries
#23868 opened Dec 4, 2023 by JingGe Loading…
6
[FLINK-33737][Scheduler] Merge multiple Exceptions into one attempt for exponential-delay restart-strategy
#23867 opened Dec 4, 2023 by 1996fanrui • Draft
1
[FLIP-321] Update the docs to add migration periods for deprecated APIs.
#23865 opened Dec 4, 2023 by becketqin Loading…
12
[hotfix][sql-client] remove duplicated code in CliUtils
#23860 opened Dec 3, 2023 by JingGe Loading…
1
[FLINK-33730][doc] update the Flink upgrade savepoint compatibility table doc
#23859 opened Dec 3, 2023 by JingGe Loading…
3
[hotfix][table] refactoring to template method to separate concerns
#23857 opened Dec 2, 2023 by JingGe Loading…
4
[FLINK-33684][datastream] Use IncrementalDelayRetryStrategy in CollectResultFetcher
#23856 opened Dec 2, 2023 by xiangyuf Loading…
1
[FLINK-33672] Use MapState.entries() instead of keys() and get() in over window
#23855 opened Dec 1, 2023 by Zakelly Loading…
1
Clarity And Impact: Revamped Flink Feature Descriptions
#23854 opened Dec 1, 2023 by Tharanishwaran Loading…
1
[FLINK-33723] Disallow triggering incremental checkpoint explicitly from REST API
#23853 opened Dec 1, 2023 by Zakelly Loading…
1
ProTip! no:milestone will show everything without a milestone.