Skip to content

/ flink

New pull request New
494 Open 14,584 Closed
494 Open 14,584 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-16444][state] Count the get/put/seek/next/writeBatch latency of RocksDB as metrics
#15091 opened Mar 5, 2021 by Myasuka
[FLINK-21428] Fixes AdaptiveSchedulerSlotSharingITCase review=description?
#15090 opened Mar 5, 2021 by XComp
2
[FLINK-21614][sql-client] Introduce a new integration test framework for SQL Client component=TableSQL/Client review=description?
#15089 opened Mar 5, 2021 by wuchong
2
[FLINK-21328] Optimize the initialization of DefaultExecutionTopology component=Runtime/Coordination review=description?
#15088 opened Mar 5, 2021 by Thesharing
2
[FLINK-21299][table] Support 'SHOW [FULL] MODULES' syntax in SqlParser, TableEnvironment and SqlCli component=TableSQL/API component=TableSQL/Client review=description?
#15087 opened Mar 4, 2021 by LadyForest
16
[FLINK-21561] Predownload/Cache large E2E test artifacts component=BuildSystem/CI component=TestInfrastructure review=description?
#15086 opened Mar 4, 2021 by autophagy
10
[FLINK-20042][kinesis] Adding Kinesis Table API e2e test using the Java framework component=Connectors/Kinesis component=TableSQL/Ecosystem review=description?
#15085 opened Mar 4, 2021 by dannycranmer
2
[FLINK-21242][python] Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream component=API/Python review=description?
#15083 opened Mar 4, 2021 by WeiZhong94
2
[FLINK-21592][table-planner-blink] RemoveSingleAggregateRule fails du… component=TableSQL/Planner review=description?
#15082 opened Mar 4, 2021 by lirui-apache
2
[FLINK-21525] Move scheduler benchmarks to Flink and add unit tests component=Benchmarks component=Runtime/Coordination review=description?
#15075 opened Mar 3, 2021 by Thesharing
6
[FLINK-21135][coord] Adjust parallelism of job for reactive mode component=Runtime/Coordination review=description?
#15071 opened Mar 3, 2021 by rmetzger • Changes requested
@tillrohrmann
19
[FLINK-21523][Connectors / Hive] Bug fix: ArrayIndexOutOfBoundsException occurs while run a hive strea… component=Connectors/Hive review=description?
#15068 opened Mar 3, 2021 by KevinyhZou
4
[FLINK-21488] [connectors/jdbc] Embed JobID into XID's global transaction ID component=Connectors/JDBC review=description?
#15066 opened Mar 2, 2021 by mobuchowski
3
[FLINK-21074][FLINK-21076][docs][coord] Document Reactive Mode component=Documentation component=Runtime/Coordination review=description?
#15064 opened Mar 2, 2021 by rmetzger • Changes requested
30
[FLINK-21549][table-planner-blink] Support json serialization/deserialization for the push-down result of DynamicTableSource and DynamicTableSink component=TableSQL/Planner review=description?
#15062 opened Mar 2, 2021 by godfreyhe
6
[FLINK-21501][docs] Sync Chinese documentation with FLINK-21343 component=Documentation component=Runtime/StateBackends review=description?
#15061 opened Mar 2, 2021 by zhoulii
2
[FLINK-19944][Connectors / Hive]Support sink parallelism configuratio… component=Connectors/Hive review=description?
#15060 opened Mar 2, 2021 by shouweikun
4
[FLINK-21419][coordination] Remove GC cleaner mechanism for unsafe memory segments component=Runtime/Coordination review=description?
#15058 opened Mar 2, 2021 by SteNicholas • Approved
@xintongsong
4
[FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels component=API/DataStream component=Runtime/Checkpointing review=description?
#15055 opened Mar 2, 2021 by gaoyunhaii
3
[FLINK-13550][runtime][ui] Operator's Flame Graph component=Runtime/REST component=Runtime/WebFrontend review=description?
#15054 opened Mar 1, 2021 by afedulov
4
[FLINK-20379][connector/kafka] Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializationSchema component=Connectors/Kafka review=description?
#15051 opened Mar 1, 2021 by lindong28
4
[FLINK-21531][table-planner-blink][table-api-java][hive] Introduce pluggable Parser component=Connectors/Hive component=TableSQL/Planner review=description?
#15050 opened Mar 1, 2021 by lirui-apache
4
[FLINK-21190][runtime-web] Expose exception history component=Runtime/WebFrontend review=description?
#15049 opened Mar 1, 2021 by XComp • Draft
@zentol
17
[FLINK-21477][table-planner-blink] Lookup joins now deal with intermediate table scans containing just the table source correctly component=TableSQL/Planner review=description?
#15048 opened Mar 1, 2021 by TsReaper
4
[hotfix] [docs] Fix typo in learn-flink review=description?
#15045 opened Feb 28, 2021 by JohnTeslaa
3
ProTip! Filter pull requests by the default branch with base:master.