The Wayback Machine - https://web.archive.org/web/20210901164317/https://github.com/apache/flink/pulls
Skip to content

/ flink

New pull request New
636 Open 16,456 Closed
636 Open 16,456 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
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀
[FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers review=description?
#17105 opened Sep 1, 2021 by SteNicholas
2
[FLINK-22367][streaming] Reset syncSavepointId only if it is equal to… review=description?
#17104 opened Sep 1, 2021 by akalash
2
[FLINK-24069][tests] Fail IgnoreInFlightData test when there is not enough data for it for all checkpoints not only the first one component=Runtime/Checkpointing review=description?
#17103 opened Sep 1, 2021 by akalash
2
[FLINK-23960][streaming] checkScheduledTimestamps changed according to semantic of the calculation processing time delay component=Runtime/Task review=description?
#17102 opened Sep 1, 2021 by akalash
3
Update yarn.md review=description?
#17101 opened Sep 1, 2021 by datayjz
2
[FLINK-23916][python][docs] Expose in python and update the documentation how to set tolerable checkpoint failure number component=Documentation component=Runtime/Checkpointing review=description?
#17100 opened Sep 1, 2021 by pnowojski
2
[FLINK-24106][docs] Remove notice that pyflink does not support state TTL component=Documentation review=description?
#17099 opened Sep 1, 2021 by Myasuka
2
[FLINK-15648][flink-kubernetes] Support to configure limit for CPU component=Deployment/Kubernetes review=description?
#17098 opened Sep 1, 2021 by dnutiu
2
[FLINK-24047][tests] Retry if leader election is in progress component=Runtime/Coordination review=description?
#17097 opened Sep 1, 2021 by zentol
2
[FLINK-24097][python] Remove is_streaming_mode checks in StreamTableEnvironment component=API/Python review=description?
#17094 opened Sep 1, 2021 by dianfu • Approved
2
[FLINK-24088][streaming] Log FlinkJobNotFoundException in debug instead of warn level in CollectResultFetcher for a cleaner log component=API/DataStream component=TableSQL/API review=description?
#17093 opened Sep 1, 2021 by tsreaper
3
[FLINK-24093] Supports setting the percentage of kubernetes Request resources component=Deployment/Kubernetes review=description?
#17092 opened Sep 1, 2021 by spoon-lz
2
[FLINK-24083][python] Fix Python UDTF to handle properly when the result is str component=API/Python review=description?
#17091 opened Sep 1, 2021 by dianfu • Approved
3
[FLINK-24082][python] Fix Python UDTF to handle properly when the result is a generator of Row component=API/Python review=description?
#17090 opened Sep 1, 2021 by dianfu
5
[FLINK-22601][table-planner] PushWatermarkIntoScan should produce digest created by Expression. component=TableSQL/Planner review=description?
#17089 opened Sep 1, 2021 by xuyangzhong
3
[FLINK-24081][table-blink-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType component=TableSQL/Planner review=description?
#17085 opened Aug 31, 2021 by leonardBang
3
[FLINK-24054][table-runtime] Let SinkUpsertMaterializer produce +U's when possible component=TableSQL/Runtime review=description?
#17079 opened Aug 31, 2021 by twalthr • Approved
11
[FLINK-24058][coordination][tests] Harden TaskSlotTableImplTest#runDeactivateSlotTimeoutTest component=Runtime/Coordination review=description?
#17073 opened Aug 31, 2021 by zentol • Approved
@tillrohrmann
5
[FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base component=Connectors/Common review=description?
#17068 opened Aug 31, 2021 by CrynetLogistics
2
FLINK-24066 component=Deployment/Kubernetes review=description?
#17066 opened Aug 31, 2021 by spoon-lz
2
[FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden component=Connectors/Common review=description?
#17064 opened Aug 31, 2021 by crazyzhou
2
[FLINK-24060][Tests]Move ZooKeeperUtilTest to right class component=Tests review=description?
#17063 opened Aug 31, 2021 by Aitozi
2
[FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint (1.14) component=API/DataStream component=Runtime/Checkpointing review=description?
#17062 opened Aug 31, 2021 by gaoyunhaii
3
[FLINK-23977][elasticsearch] Added DynamicElasticsearchSink for Dynamic ES Cluster Routing component=Connectors/ElasticSearch review=description?
#17061 opened Aug 30, 2021 by rionmonster
2
[FLINK-24005][coordination] Only return fulfilled requirements for reserved slots component=Runtime/Coordination review=description?
#17059 opened Aug 30, 2021 by zentol • Approved
@tillrohrmann
6
ProTip! Adding no:label will show everything without a label.