apache / flink

Watch 907
Star 13.5k
Fork 7.4k

Code
Pull requests 419
Actions
Security
Insights

Code
Pull requests
Actions
Security
Insights

Labels 81 Milestones 0

New pull request New

419 Open 12,468 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-18537][table] Remove RowDataTypeInfo review=description?

#12900 opened Jul 14, 2020 by twalthr

[FLINK-16699][k8s] Support accessing secured services via K8s secrets review=description?

#12899 opened Jul 14, 2020 by zhoulii

[FLINK-17636][tests] Fix unstable test SingleInputGateTest#testConcurrentReadStateAndProcessAndClose review=description?

#12898 opened Jul 14, 2020 by wsry

[FLINK-18594][doc] The link is broken in kafka doc component=Documentation review=description?

#12897 opened Jul 14, 2020 by leonardBang

[hotfix][docs-zh] Fix invalid links in the page 'dev/table/streaming/match_recognize.zh.md' review=description?

#12895 opened Jul 14, 2020 by RocMarshal

[FLINK-18588] hive ddl create table support 'if not exists' component=TableSQL/Planner review=description?

#12888 opened Jul 13, 2020 by wtog

[FLINK-18573][metrics] Ensure metric reporters could be loaded via SPI component=Runtime/Metrics review=description?

#12883 opened Jul 13, 2020 by Myasuka • Changes requested

[FLINK-18579][FLINK-15728][jdbc] Introduce FieldNamedPreparedStatement to support fields are bound multiple times in update statement component=Connectors/JDBC component=TableSQL/Ecosystem review=description?

#12882 opened Jul 13, 2020 by wuchong

[FLINK-18512][kinesis] Introducing RecordPublisher. Refactor ShardConsumer to use PollingRecordPublisher component=<none> review=description?

#12881 opened Jul 13, 2020 by dannycranmer

[FLINK-18555][table sql/api] Make TableConfig options can be configur… component=TableSQL/API review=description?

#12880 opened Jul 13, 2020 by fsk119

[FLINK-17636][tests] Fix unstable test SingleInputGateTest#testConcur… component=Runtime/Network component=Tests review=description?

#12879 opened Jul 13, 2020 by wsry • Approved

[hotfix][docs] fix scala udf example review=description?

#12874 opened Jul 12, 2020 by contrun

[FLINK-18548][table-planner] Improve FlinkCalcMergeRule to merge calc nodes better component=TableSQL/Planner review=description?

#12873 opened Jul 10, 2020 by leonardBang

[FLINK-18550][sql-client] use TableResult#collect to get select result for sql client component=TableSQL/Client review=description?

#12872 opened Jul 10, 2020 by godfreyhe

[FLINK-18558][streaming] Introduce collect iterator with at least once semantics and exactly once semantics without fault tolerance component=API/DataStream component=TableSQL/API review=description?

#12867 opened Jul 10, 2020 by TsReaper

[FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource. component=TableSQL/Planner review=description?

#12866 opened Jul 10, 2020 by liuyongvs

[FLINK-18264][doc] Translate External Resources page to Chinese component=Documentation component=chinese-translation review=description?

#12865 opened Jul 10, 2020 by KarmaGYZ

[FLINK-18487][table] Datagen and Blackhole factory omits unrecognized properties silently component=TableSQL/API review=description?

#12864 opened Jul 10, 2020 by JingsongLi

[FLINK-17426][blink plannger] Dynamic Source supportsLimit pushdown component=TableSQL/Planner review=description?

#12860 opened Jul 9, 2020 by liuyongvs

[FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource. component=TableSQL/Planner review=description?

#12851 opened Jul 8, 2020 by liuyongvs

[FLINK-18483][kinesis] Test coverage improvements for FlinkKinesisConsumer/ShardConsumer component=Connectors/Kinesis review=description?

#12850 opened Jul 8, 2020 by dannycranmer

[FLINK-18521][release] Add script for creating snapshot branch component=ReleaseSystem review=description?

#12847 opened Jul 7, 2020 by zentol

[FLINK-18448][pubsub] Update Google Cloud PubSub dependencies component=Connectors/GoogleCloudPubSub review=description?

#12846 opened Jul 7, 2020 by nielsbasjes • Draft

[hotfix] Fix the typo when describing checkpointed data size review=description?

#12837 opened Jul 7, 2020 by Myasuka • Approved

[hotfix] Fix the typo when describing checkpointed data size review=description?

#12835 opened Jul 7, 2020 by Myasuka • Approved

Previous 1 2 3 4 5 … 16 17 Next

Previous Next

ProTip! Follow long discussions with comments:>50.