apache / flink

Watch 913
Star 14k
Fork 7.7k

Code
Pull requests 469
Actions
Security
Insights

Code
Pull requests
Actions
Security
Insights

Labels 82 Milestones 0

New pull request New

469 Open 12,848 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-19004][table-planner-blink] Use FIRST_VALUE when re-write non-… component=Connectors/Hive component=TableSQL/Planner review=description?

#13330 opened Sep 4, 2020 by lirui-apache

[FLINK-19134][python] Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for Python DataStream API. component=API/Python review=description?

#13327 opened Sep 4, 2020 by shuiqiangchen

[FLINK-19133] Open custom partitioners in KafkaSerializationSchemaWrapper component=Connectors/Kafka review=description?

#13326 opened Sep 4, 2020 by dawidwys • Approved

FLINK-19137: Bump Parquet from 1.10.0 to 1.11.1 component=Formats review=description?

#13323 opened Sep 4, 2020 by C08061

[FLINK-17709][kubernetes][docs] Support running PyFlink on Kubernetes. component=Deployment/Kubernetes component=Runtime/Coordination review=description?

#13322 opened Sep 4, 2020 by shuiqiangchen

[FLINK-14870] Remove nullable assumption of task slot sharing group component=Runtime/Coordination review=description?

#13321 opened Sep 3, 2020 by zhuzhurk

[FLINK-19035] Remove fold from DataStream API component=API/DataStream review=description?

#13320 opened Sep 3, 2020 by dawidwys • Approved

[FLINK-19022][runtime]Register the TerminationFuture of ResourceManager and Dispatcher with DispatcherResourceManagerComponent component=Runtime/Coordination review=description?

#13319 opened Sep 3, 2020 by Tartarus0zm • Changes requested

[FLINK-14422][runtime] Expose network memory usage to TaskManagerDetailsHandler's endpoint component=Runtime/Task review=description?

#13316 opened Sep 3, 2020 by XComp

[FLINK-19070][hive] Hive connector should throw a meaningful exception if user reads/writes ACID tables component=Connectors/Hive review=description?

#13315 opened Sep 3, 2020 by SteNicholas

[FLINK-18913][docs][python] Add a "TableEnvironment" document under the "Python API" -> "Table API User's Guide" section component=Documentation review=description?

#13314 opened Sep 3, 2020 by WeiZhong94

[FLINK-18722][mesos] Migrate MesosResourceManager to the new MesosResourceManagerDriver component=Deployment/Mesos component=Runtime/Coordination review=description?

#13313 opened Sep 3, 2020 by xintongsong

[FLINK-18721] Migrate YarnResourceManager to the new YarnResourceManagerDriver component=Deployment/YARN component=Runtime/Coordination review=description?

#13311 opened Sep 3, 2020 by KarmaGYZ • Changes requested

[FLINK-19086] Revert "[FLINK-19052] [serialization] add constructor c… component=API/TypeSerializationSystem review=description?

#13310 opened Sep 2, 2020 by rkhachatryan • Approved

[Flink-14942][state-processor-api] savepoint deep copy component=API/StateProcessor review=description?

#13309 opened Sep 2, 2020 by qinjunjerry • Changes requested

[hotfix][docs-zh] Fix invalid links in "Concepts & Common API" page of "Table API & SQL" review=description?

#13308 opened Sep 2, 2020 by Shawn-Hx

[FLINK-19078][table-runtime] Import rowtime join temporal operator component=TableSQL/Runtime review=description?

#13307 opened Sep 2, 2020 by leonardBang

[FLINK-17779][Connectors/ORC]Orc file format support filter push down component=Connectors/ORC review=description?

#13306 opened Sep 2, 2020 by sujun1020 • Changes requested

[FLINK-19109][task] Ignore isLoopRunning in MailboxExecutor.isIdle component=<none> review=description?

#13305 opened Sep 2, 2020 by rkhachatryan • Approved

[FLINK-19098][format] Make row data converters public component=Formats component=TableSQL/Ecosystem review=description?

#13303 opened Sep 2, 2020 by crazyzhou

[FLINK-19077][table-runtime] Import process time temporal join operator. component=<none> review=description?

#13300 opened Sep 1, 2020 by leonardBang

[FLINK-19072][table-planner] Import Temporal Table join rule component=<none> review=description?

#13299 opened Sep 1, 2020 by leonardBang

[FLINK-19038][table] It doesn't support to call Table.limit() continuously component=TableSQL/API review=description?

#13298 opened Sep 1, 2020 by SteNicholas

[FLINK-18774][format][debezium] Support debezium-avro format component=Formats review=description?

#13296 opened Sep 1, 2020 by caozhen1937 • Changes requested

[FLINK-18598][python][docs] Add instructions for asynchronous execute in PyFlink doc. component=API/Python component=Documentation review=description?

#13295 opened Sep 1, 2020 by shuiqiangchen

Previous 1 2 3 4 5 … 18 19 Next

Previous Next

ProTip! Add no:assignee to see everything that’s not assigned.