Skip to content

Pull requests: apache/flink

New pull request New
987 Open 20,265 Closed
987 Open 20,265 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-29938][Connectors/Base] Add open() Method to AsyncSink ElementConverter component=Connectors/Common
#21265 opened Nov 8, 2022 by dannycranmer Loading…
2
[WIP][FLINK-29928][runtime, state] Share RocksDB memory across TM slots component=Runtime/Configuration component=Runtime/StateBackends component=Runtime/Task
#21264 opened Nov 8, 2022 by rkhachatryan Loading…
1
[hotfix] fix syntax errors
#21263 opened Nov 8, 2022 by muggleChen Loading…
1
[FLINK-29860][Connectors / Pulsar] Pulsar connector bug when using Hybrid.Builder component=Connectors/Pulsar
#21262 opened Nov 8, 2022 by noelo Loading…
1
[FLINK-29929][table] Correct conversions from ResolvedSchema to TableSchema component=TableSQL/Planner
#21260 opened Nov 8, 2022 by liyubin117 Loading…
1
[FLINK-29927][akka] Use singleton ExtensionId
#21259 opened Nov 8, 2022 by zentol Loading…
1
[Flink]Support accumulator in source reader.
#21258 opened Nov 8, 2022 by hk-lrzy Loading…
2
[FLINK-29879][filesystem] introduce operators for merging files in batch mode. component=Connectors/FileSystem
#21257 opened Nov 8, 2022 by luoyuxia Loading…
1
[hotfix][flink-runtime] Fix the typo of RecordingChannelStateWriter class.
#21256 opened Nov 8, 2022 by liuzhuang2017 Loading…
3
[hotfix][docs] Update the missing parts of this fault_tolerance Chinese documentation.
#21255 opened Nov 8, 2022 by liuzhuang2017 Loading…
3
Update docker.md
#21254 opened Nov 8, 2022 by mattfysh Loading…
1
[FLINK-29920][doc] Minor reformat Kafka connector documentation component=Documentation
#21253 opened Nov 7, 2022 by liuml07 Loading…
2
[FLINK-29830][Connector/Pulsar] Create the topic with schema before consuming messages in PulsarSinkITCase component=Connectors/Pulsar
#21252 opened Nov 7, 2022 by syhily Loading…
2
[FLINK-26027][Connector/Pulsar] Expose Pulsar metrics component=Connectors/Pulsar
#21249 opened Nov 7, 2022 by syhily Loading…
12
[FLINK-29914][tests] Wait for Kafka topic creation/deletion component=Connectors/Kafka
#21247 opened Nov 7, 2022 by gaborgsomogyi Loading…
15
Update json.md
#21246 opened Nov 7, 2022 by mattfysh Loading…
1
[FLINK-29458][docs-zh]Update "Table API sql queries joins module case component=Documentation component=TableSQL/API
#21244 opened Nov 6, 2022 by ZmmBigdata Loading…
2
[FLINK-29610] [flink-runtime]: Use ASK_TIMEOUT_DURATION instead of RpcUtils.INF_TIMEOUT in SavepointHandlers and CheckpointTriggerHandler component=Runtime/REST
#21239 opened Nov 4, 2022 by leletan Loading…
1
[FLINK-29870] [ResourceManager]Split ResourceNotEnoughNotifier from ResourceActions component=Runtime/Coordination
#21233 opened Nov 3, 2022 by huwh Loading…
1
[FLINK-29857][hive] Fix failure to connect to 'HiveServer2Endpoint' when using hive3 beeline component=Connectors/Hive
#21229 opened Nov 3, 2022 by yuzelin Loading…
3
[FLINK-29866][build] Split flink-dist component=BuildSystem
#21228 opened Nov 3, 2022 by zentol • Draft
1
[FLINK-29492] Return Kafka producer to the pool when the Kafka sink is not the end of the chain component=Connectors/Kafka
#21226 opened Nov 3, 2022 by ruanhang1993 Loading…
1
[FLINK-29781][table-planner] Fix ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule component=TableSQL/Planner
#21225 opened Nov 3, 2022 by lincoln-lil Loading…
2
[FLINK-15462][connectors] Add Trino dialect component=Connectors/JDBC
#21223 opened Nov 2, 2022 by eskabetxe Loading…
2
[BP-1.15][FLINK-29849 & FLINK-29781][table-planner] Fix event time temporal join on an upsert source may produce incorrect execution plan component=TableSQL/Planner
#21222 opened Nov 2, 2022 by lincoln-lil Loading…
1
ProTip! What’s not been updated in a month: updated:<2022-10-08.