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

/ flink

New pull request New
620 Open 16,294 Closed
620 Open 16,294 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-18592][Connectors/FileSystem] StreamingFileSink fails due to truncating HDFS file failure component=Connectors/FileSystem review=description?
#16927 opened Aug 21, 2021 by link3280
2
[BP-1.12][FLINK-22333][tests] Harden Elasticsearch7DynamicSinkITCase.testWritingDocuments by setting parallelism to 4 component=Runtime/Coordination review=description?
#16926 opened Aug 21, 2021 by tillrohrmann
2
[BP-1.13][FLINK-22333][tests] Harden Elasticsearch7DynamicSinkITCase.testWritingDocuments by setting parallelism to 4 component=Runtime/Coordination review=description?
#16925 opened Aug 21, 2021 by tillrohrmann
2
[FLINK-22333][tests] Harden Elasticsearch7DynamicSinkITCase.testWritingDocuments by setting parallelism to 4 component=Runtime/Coordination review=description?
#16924 opened Aug 21, 2021 by tillrohrmann
2
[BP-1.12][FLINK-23906][tests] Increase the default akka.ask.timeout for the MiniCluster to 5 minutes component=Runtime/Coordination component=Tests review=description?
#16923 opened Aug 21, 2021 by tillrohrmann
2
[BP-1.13][FLINK-23906][tests] Increase the default akka.ask.timeout for the MiniCluster to 5 minutes component=Runtime/Coordination component=Tests review=description?
#16922 opened Aug 21, 2021 by tillrohrmann
2
[FLINK-23906][tests] Increase the default akka.ask.timeout for the MiniCluster to 5 minutes component=Runtime/Coordination component=Tests review=description?
#16921 opened Aug 21, 2021 by tillrohrmann
2
[BP-1.12][FLINK-21538][tests] Set default parallelism to 4 for Elasticsearch6DynamicSinkITCase.testWritingDocuments component=Connectors/ElasticSearch component=Runtime/Coordination review=description?
#16920 opened Aug 21, 2021 by tillrohrmann
2
[BP-1.13][FLINK-21538][tests] Set default parallelism to 4 for Elasticsearch6DynamicSinkITCase.testWritingDocuments component=Connectors/ElasticSearch component=Runtime/Coordination review=description?
#16919 opened Aug 21, 2021 by tillrohrmann
2
[FLINK-21538][tests] Set default parallelism to 4 for Elasticsearch6DynamicSinkITCase.testWritingDocuments component=Connectors/ElasticSearch component=Runtime/Coordination review=description?
#16918 opened Aug 21, 2021 by tillrohrmann
2
[FLINK-20461][tests] Check replication factor before asking for JobResult component=Deployment/YARN review=description?
#16917 opened Aug 21, 2021 by tillrohrmann
3
[BP-1.13][FLINK-23871][Runtime/Coordination] Dispatcher should handle finishing job exception when recover component=Runtime/Coordination review=description?
#16916 opened Aug 21, 2021 by tillrohrmann
2
[FLINK-9925][tests] Harden ClientTest by making handler shareable component=Runtime/QueryableState component=Tests review=description?
#16915 opened Aug 20, 2021 by tillrohrmann
2
[FLINK-22932][tests] Harden RocksDBStateBackendWindowITCase by using RpcUtils.INF_TIMEOUT for MiniCluster RPC timeout component=Runtime/Coordination review=description?
#16914 opened Aug 20, 2021 by tillrohrmann
2
[FLINK-23809][checkpoint] Respect the finished flag when extracting operator states due to skip in-flight data component=Runtime/Checkpointing review=description?
#16913 opened Aug 20, 2021 by gaoyunhaii
2
[FLINK-23902][connectors/hive] Make flink support Hive 2.3.8 version component=Connectors/Hive review=description?
#16911 opened Aug 20, 2021 by yangjf2019
2
[FLINK-23097][tests] Harden test_queryable_state_restart_tm.sh component=Runtime/QueryableState review=description?
#16910 opened Aug 20, 2021 by tillrohrmann
2
[FLINK-23898][akka] Fix log level mapping component=Runtime/Coordination review=description?
#16908 opened Aug 20, 2021 by zentol • Approved
5
[FLINK-23897][hive][doc] Fix obsolete doc about creating hive table w… component=Connectors/Hive component=Documentation review=description?
#16907 opened Aug 20, 2021 by lirui-apache
2
[FLINK-23896] Ensure KafkaSink is able to re-commit transaction after… component=Connectors/Kafka review=description?
#16906 opened Aug 20, 2021 by dmvk
2
[FLINK-23884][checkpoint] Fix the concurrent problem between triggering savepoint with drain and task finishing component=Runtime/Checkpointing review=description?
#16905 opened Aug 20, 2021 by gaoyunhaii
2
[FLINK-23579][table-runtime] Fix compile exception in hash functions with varbinary arguments component=TableSQL/Runtime review=description?
#16903 opened Aug 20, 2021 by tsreaper • Approved
3
[FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities component=Runtime/WebFrontend review=description?
#16902 opened Aug 20, 2021 by yangjunhan
7
[FLINK-23877][connector/pulsar] Provide an embedded pulsar broker for testing. component=Connectors/Pulsar review=description?
#16900 opened Aug 19, 2021 by syhily
7
[release-1.13][FLINK-22670][FLIP-150][connector/common] Hybrid source baseline component=Connectors/Common review=description?
#16899 opened Aug 19, 2021 by tweise
2
ProTip! Follow long discussions with comments:>50.