Skip to content

/ flink

New pull request New
471 Open 13,490 Closed
471 Open 13,490 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
👍 👎 😄 🎉 😕 ❤️ 🚀 👀
[hotfix][doc] Fix a concurrent issue in testing.md review=description?
#13974 opened Nov 7, 2020 by xccui
2
[FLINK-19850] Add e2e tests for the new File Sink in the streaming mode component=<none> review=description?
#13973 opened Nov 6, 2020 by gaoyunhaii
2
[FLINK-19912][json] Fix JSON format fails to serialize map value with… component=Formats review=description?
#13972 opened Nov 6, 2020 by wangxlong
2
[FLINK-19510][sink][filesystem] Support processing time in FileSink component=API/DataStream review=description?
#13971 opened Nov 6, 2020 by gaoyunhaii
2
[FLINK-20031] Keep the uid of SinkWriter same as the SinkTransformation component=API/DataStream review=description?
#13970 opened Nov 6, 2020 by guoweiM
2
[FLINK-19963] Make SinkWriter support processing timer service. component=API/DataStream review=description?
#13969 opened Nov 6, 2020 by guoweiM
7
[FLINK-20008] Close LeaderElectionDriver outside of lock in DefaultLeaderElectionService.stop() component=Runtime/Coordination review=description?
#13968 opened Nov 6, 2020 by tillrohrmann
10
[FLINK-20019][core] Support all conversion classes in Row.equals/hashCode component=API/Core component=TableSQL/API review=description?
#13967 opened Nov 6, 2020 by twalthr • Approved
5
[FLINK-20018] Allow escaping in 'pipeline.cached-files' and 'pipeline.default-kryo-serializers' component=Runtime/Configuration review=description?
#13965 opened Nov 6, 2020 by dawidwys
2
[FLINK-19314][coordination] Add DeclarativeSlotPoolBridge component=Runtime/Coordination review=description?
#13964 opened Nov 6, 2020 by zentol
2
[FLINK-19888][hive] Migrate Hive source to FLIP-27 source interface for streaming component=Connectors/Hive review=description?
#13963 opened Nov 6, 2020 by lirui-apache
3
[FLINK-20024][docs][docker] Add link to flink-docker repository component=Documentation component=flink-docker review=description?
#13962 opened Nov 6, 2020 by zentol • Approved
3
[FLINK-20023][docs] Remove note about downloading hadoop-specific Flink distribution component=Documentation review=description?
#13961 opened Nov 6, 2020 by zentol
2
[FLINK-20022][docs] Move statebackend tradeoffs out of checklist component=Documentation review=description?
#13960 opened Nov 6, 2020 by zentol
3
[FLINK-20021][docs] Cleanup misuses of Dispatcher/JobManager component=Documentation review=description?
#13959 opened Nov 6, 2020 by zentol
2
[FLINK-19994][runtime] Do not force iteration job to generate one only pipelined region component=Runtime/Coordination review=description?
#13958 opened Nov 6, 2020 by zhuzhurk
@azagrebin
8
[FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema component=Connectors/FileSystem component=Connectors/Hive component=Formats component=TableSQL/Ecosystem review=description?
#13957 opened Nov 6, 2020 by JingsongLi
10
[FLINK-19934][Connector] Add a new API: SplitEnumeratorContext.runInC… component=API/DataStream review=description?
#13955 opened Nov 6, 2020 by stevenzwu
3
[FLINK-19903][Table SQL / API] Metadata fields for filesystem csv format component=TableSQL/API review=description?
#13954 opened Nov 5, 2020 by ecerulm
2
[FLINK-19998] Fixing links for checkpoints & savepoints in the first … component=Documentation review=description?
#13951 opened Nov 5, 2020 by vintageplayer
3
[hotfix][doc] Chage link format in some docs review=description?
#13949 opened Nov 5, 2020 by Shawn-Hx
3
Update kafka.md review=description?
#13947 opened Nov 5, 2020 by huzekang
2
[FLINK-20002] Add a StreamExecutionEnvironment#getExecutionEnvironment(Configuration) method component=API/DataStream review=description?
#13944 opened Nov 5, 2020 by dawidwys • Approved
@aljoscha
10
[FLINK-19990][table-planner-blink] MultipleInputNodeCreationProcessor#isChainableSource now considers DataStreamScanProvider component=<none> review=description?
#13942 opened Nov 5, 2020 by TsReaper • Approved
5
[FLINK-19946][Connectors / HBase]Support sink parallelism configuration for Hbase connector component=Connectors/HBase review=description?
#13933 opened Nov 5, 2020 by zhuxiaoshang
2
ProTip! What’s not been updated in a month: updated:<2020-10-06.
You can’t perform that action at this time.