apache / flink

Watch 927
Star 15.1k
Fork 8.3k

Code
Pull requests 458
Actions
Security
Insights

Code
Pull requests
Actions
Security
Insights

Labels 85 Milestones 0

New pull request New

458 Open 14,068 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-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input component=Formats component=TableSQL/Ecosystem review=description?

#14539 opened Dec 31, 2020 by xuewang

[FLINK-20681][yarn] Support remote path for shipping archives and files component=Deployment/YARN review=description?

#14538 opened Dec 31, 2020 by yuruguo

[FLINK-20826][table] Fix minor bug in `UpdatingTopCityExample` component=TableSQL/API review=description?

#14537 opened Dec 31, 2020 by cshuo • Approved

[FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter. component=Connectors/HBase component=TableSQL/Ecosystem review=description?

#14536 opened Dec 31, 2020 by chaozwn

[FLINK-20026][Connector][Jdbc] Jdbc connector support regular expression component=Connectors/JDBC component=TableSQL/Ecosystem review=description?

#14535 opened Dec 31, 2020 by xiaoHoly

[FLINK-20822][hive] Don't check whether a function is generic in hive… component=Connectors/Hive review=description?

#14534 opened Dec 31, 2020 by lirui-apache

Draft for Web-UI review=description?

#14532 opened Dec 31, 2020 by curcur • Draft

[FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disable for bounded mode component=Connectors/Kafka review=description?

#14531 opened Dec 31, 2020 by xiaoHoly

[FLINK-20348][kafka] Make "schema-registry.subject" optional for Kafka sink with avro-confluent format component=Formats component=TableSQL/Ecosystem review=description?

#14530 opened Dec 31, 2020 by zhuxiaoshang

FLINK-20359 Added Owner Reference to Job Manager in native kubernetes component=Deployment/Kubernetes review=description?

#14529 opened Dec 31, 2020 by blublinsky

[FLINK-20615] Clean PartitionRequestClientFactory up if createPartitionRequestClient fails component=Runtime/StateBackends component=Runtime/Task review=description?

#14528 opened Dec 30, 2020 by tillrohrmann

[FLINK-14814][WebUI] Highlight back pressured and busy nodes in the WebUI component=Runtime/Metrics component=Runtime/Network component=Runtime/REST component=Runtime/WebFrontend review=description?

#14526 opened Dec 30, 2020 by pnowojski

[FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join component=<none> review=description?

#14516 opened Dec 29, 2020 by wenlong88

[FLINK-20770][k8s] Correct the description of kubernetes config option 'kubernetes.rest-service.exposed.type' component=Deployment/Kubernetes component=Documentation review=description?

#14515 opened Dec 29, 2020 by wangyang0918

FLINK-20359 Added Owner Reference to Job Manager in native kubernetes component=Deployment/Kubernetes review=description?

#14512 opened Dec 29, 2020 by blublinsky

[FLINK-19656] [metrics] filter delimiter in metrics components component=Runtime/Metrics review=description?

#14510 opened Dec 28, 2020 by echauchot

[FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format. component=Formats review=description?

#14508 opened Dec 28, 2020 by V1ncentzzZ

[FLINK-20782][table-planner-blink] Separate implementation of BatchExecRank component=<none> review=description?

#14506 opened Dec 28, 2020 by wenlong88

[Flink-20766][table-planner-blink] Separate implementations of sort ExecNode and PhysicalNode. component=TableSQL/Planner review=description?

#14502 opened Dec 28, 2020 by wenlong88

[FLINK-20778] the comment for the type of kafka consumer is wrong at KafkaPartitionSplit component=Connectors/Kafka review=description?

#14501 opened Dec 28, 2020 by meijies

[FLINK-15156] Warn user if System.exit() is called in user code component=Runtime/Coordination review=description?

#14499 opened Dec 27, 2020 by hwanju

[hotfix][typo]Fix typo in StreamingJobGraphGenerator.areOperatorsChainable review=description?

#14498 opened Dec 27, 2020 by reswqa

[FLINK-20768][Connectors/ElasticSearch] Support routing field for Elasticsearch connector component=Connectors/ElasticSearch review=description?

#14493 opened Dec 25, 2020 by jrthe42

[FLINK-19667] Add AWS Glue Schema Registry integration component=Formats review=description?

#14490 opened Dec 25, 2020 by LinyuYao1021

[FLINK-20722][hive] HiveTableSink should copy the record when convert… component=Connectors/Hive review=description?

#14484 opened Dec 24, 2020 by lirui-apache

Previous 1 2 3 4 5 … 18 19 Next

Previous Next

ProTip! Updated in the last three days: updated:>2020-12-28.