Skip to content

/ flink

New pull request New
504 Open 14,389 Closed
504 Open 14,389 Closed
Author
Filter by author
Label
Filter by label
Use alt + click/return to exclude labels.
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
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀
[FLINK-21274][runtime] Change the ClusterEntrypoint.runClusterEntrypoint to wait on the result of clusterEntrypoint.getTerminationFuture().get() and do the System.exit outside of the future callback component=Runtime/Coordination review=description?
#14906 opened Feb 9, 2021 by wjc920
2
[FLINK-19608][table-planner-blink] Support TVF based window aggreagte in planner component=TableSQL/Planner review=description?
#14905 opened Feb 9, 2021 by wuchong
2
[WIP][FLINK-20663][runtime] Instantly release unsafe memory on freeing segment. component=Runtime/Task review=description?
#14904 opened Feb 9, 2021 by xintongsong • Draft
2
[FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo component=Documentation review=description?
#14903 opened Feb 8, 2021 by sjwiesman
29
[FLINK-21138][queryableState] - User ClassLoader in KvStateServerHandler component=Runtime/QueryableState review=description?
#14902 opened Feb 8, 2021 by mproch • Approved
@tillrohrmann
6
(1.12) [FLINK-21312][checkpointing] Reset OperatorChain.isStoppingBySyncSavуpoint properly component=Runtime/Checkpointing review=description?
#14900 opened Feb 8, 2021 by rkhachatryan
3
(1.11) [FLINK-21312][checkpointing] Reset OperatorChain.isStoppingBySyncSavуpoint properly component=Runtime/Checkpointing review=description?
#14899 opened Feb 8, 2021 by rkhachatryan
2
[FLINK-21221][runtime] Deduplication for multiple ResourceCounters component=Runtime/Coordination review=description?
#14897 opened Feb 8, 2021 by KarmaGYZ • Changes requested
@tillrohrmann
6
[FLINK-21176][docs] translate the updates of 'avro-confluent.zh.md' to Chinese component=Documentation component=chinese-translation review=description?
#14896 opened Feb 8, 2021 by jjiey
3
[FLINK-21295][table] Support 'useModules' and 'listFullModules' in ModuleManager and TableEnvironment component=TableSQL/API review=description?
#14895 opened Feb 8, 2021 by LadyForest
5
[FLINK-20895][flink-table-planner-blink] support local aggregate push down in blink planner component=TableSQL/Planner review=description?
#14894 opened Feb 8, 2021 by sebastianliu
3
[FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator component=Runtime/StateBackends review=description?
#14893 opened Feb 8, 2021 by lgo
4
[FLINK-21312][checkpointing] Reset OperatorChain.isStoppingBySyncSavуpoint properly component=Runtime/Checkpointing review=description?
#14892 opened Feb 7, 2021 by rkhachatryan • Approved
6
[FLINK-21289][deployment] FIX missing load pipeline.classpaths in app… component=Client/JobSubmission component=Deployment/Kubernetes component=Deployment/YARN review=description?
#14891 opened Feb 7, 2021 by PChou
6
[FLINK-21178][Runtime/Checkpointing] Task failure should trigger master hook's reset() component=Runtime/Checkpointing review=description?
#14890 opened Feb 7, 2021 by crazyzhou
2
[hotfix][tests] Improve ProcessingTimeWindowCheckpointingITCase review=description?
#14889 opened Feb 6, 2021 by rkhachatryan • Draft
2
[hotfix][tests] Disable incremental checkpoints in CEPOperatorTest review=description?
#14888 opened Feb 6, 2021 by rkhachatryan
2
[FLINK-20847][checkpointing] Remove unused argument from shutdown() in CompletedCheckpointStore component=Runtime/Checkpointing review=description?
#14886 opened Feb 6, 2021 by rkhachatryan • Approved
3
[hotfix][checkpointing] Log detailed statistic (TRACE) review=description?
#14885 opened Feb 6, 2021 by rkhachatryan
2
[hotfix][state] Improve error messages in SharedStateRegistry and HeapRestoreOperation review=description?
#14884 opened Feb 6, 2021 by rkhachatryan
2
[hotfix][state] Serialize KeyGroupsStateHandle in shared Incremental … review=description?
#14883 opened Feb 6, 2021 by rkhachatryan
2
[hotfix][state] Improve logging in AbstractKeyedStateBackend review=description?
#14881 opened Feb 5, 2021 by rkhachatryan
4
[FLINK-21302][table-planner-blink] Fix NPE when use row_number() in over agg component=TableSQL/Planner review=description?
#14880 opened Feb 5, 2021 by beyond1920
2
[FLINK-21256][FLINK-21257] Add Restarting and Executing state for declarative scheduler component=Runtime/Coordination review=description?
#14879 opened Feb 5, 2021 by rmetzger • Changes requested
@tillrohrmann
58
[FLINK-21245][table-planner-blink] Support StreamExecCalc json serialization/deserialization component=TableSQL/Planner review=description?
#14878 opened Feb 5, 2021 by godfreyhe
7
ProTip! What’s not been updated in a month: updated:<2021-01-09.