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

/ flink

New pull request New
615 Open 16,174 Closed
615 Open 16,174 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
👍 👎 😄 🎉 😕 ❤️ 🚀 👀
[hotfix][generating_watermarks][docs] - Updated generating watermark doc review=description?
#16802 opened Aug 12, 2021 by mans2singh
1
[FLINK-10052][ha] Tolerate temporarily suspended ZooKeeper connections component=Runtime/Coordination review=description?
#16801 opened Aug 12, 2021 by tillrohrmann
2
[FLINK-23741][checkpointing] Properly decline triggerCheckpoint RPC if StreamTask is not running component=Runtime/Checkpointing component=Runtime/Task review=description?
#16800 opened Aug 12, 2021 by pnowojski
2
[FLINK-23705][connectors/kinesis] Unregistering metric reporting for closed shards component=Connectors/Kinesis review=description?
#16799 opened Aug 12, 2021 by elphastori
2
[FLINK-23651][python] Support RabbitMQ in PyFlink component=API/Python review=description?
#16798 opened Aug 12, 2021 by EelisK
2
[FLINK-23680][streaming] Wait until all expected threads would be tri… component=Runtime/Task review=description?
#16797 opened Aug 12, 2021 by akalash
2
[FLINK-23735][connectors/kafka] Migrate BufferedUpsertSinkFunction to FLIP-143 Sink API component=<none> review=description?
#16796 opened Aug 12, 2021 by fapaul
18
[FLINK-14482][rocksdb] Bump FRocksDB version to 6.20.3 component=Runtime/StateBackends review=description?
#16794 opened Aug 12, 2021 by autophagy
2
[FLINK-20897][table-planner] Support batch mode in StreamTableEnvironment component=TableSQL/API review=description?
#16793 opened Aug 12, 2021 by twalthr
4
[FLINK-23739][table]BlackHoleSink & PrintSink implement SupportsParti… component=TableSQL/API review=description?
#16792 opened Aug 12, 2021 by YesOrNo828
2
[FLINK-22914][connector/kafka] Use FLIP-27 KafkaSource in Kafka table connector component=Connectors/Kafka component=TableSQL/Ecosystem review=description?
#16791 opened Aug 12, 2021 by PatrickRen
2
[hotfix][docs] Fix some typos in readme.md , kafka.md , schema_evolution.md docs review=description?
#16790 opened Aug 12, 2021 by yangjf2019
2
[FLINK-23734][table] Migrate ComponentFactory to the new Factory stack component=TableSQL/API review=description?
#16788 opened Aug 12, 2021 by Airblader
2
[FLINK-18080][docs-zh] Translate "security-kerberos" page into Chinese component=chinese-translation component=Documentation review=description?
#16787 opened Aug 12, 2021 by hapihu
2
[FLINK-23430][runtime][checkpoint] Allows taking snapshots for operator coordinators which all corresponding tasks finished component=Runtime/Checkpointing review=description?
#16784 opened Aug 11, 2021 by gaoyunhaii • Approved
4
[FLINK-23640][connectors/kafka] Add convenience valueOnly KafkaRecord… component=<none> review=description?
#16783 opened Aug 11, 2021 by fapaul
@AHeise
7
[FLINK-23720][table] Migrate ModuleFactory to the new factory stack component=TableSQL/API review=description?
#16781 opened Aug 11, 2021 by Airblader
2
[FLINK-13092][docs-zh] Translate "deployment/resource-providers/standalone/kubernetes.md" page into Chinese component=chinese-translation component=Documentation review=description?
#16780 opened Aug 11, 2021 by hapihu
2
[FLINK-22673][docs] Add docs about JAR related commands and remove th… component=Documentation component=TableSQL/Client review=description?
#16779 opened Aug 11, 2021 by fsk119
4
[FLINK-23715][parquet] Support for reading fields that do not exist in Parquet files component=Formats review=description?
#16778 opened Aug 11, 2021 by Tartarus0zm
3
[FLINK-16201][table] Support JSON_VALUE component=TableSQL/Planner review=description?
#16776 opened Aug 11, 2021 by Airblader
25
[FLINK-23708][FLINK-23698][task] Re emit and pass watermarks in finished on restore tasks component=Runtime/Task review=description?
#16774 opened Aug 10, 2021 by pnowojski
2
[FLINK-21090][tests] Add IT case for stop-with-savepoint component=API/DataStream component=Runtime/Checkpointing review=description?
#16773 opened Aug 10, 2021 by rkhachatryan • Draft
11
[FLINK-23560][runtime] Calculate absoluteTimeMillis only once for idle metric and throughput calculation. component=Benchmarks review=description?
#16772 opened Aug 10, 2021 by akalash
3
[FLINK-23652][datastream] FLIP-179: Add common connector metrics component=API/DataStream review=description?
#16770 opened Aug 10, 2021 by AHeise
44
ProTip! Updated in the last three days: updated:>2021-08-09.