Skip to content

/ flink

New pull request New
513 Open 11,667 Closed
513 Open 11,667 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-17759][runtime] Remove unused RestartIndividualStrategy component=Runtime/Coordination review=description?
#12193 opened May 16, 2020 by zhuzhurk
2
[FLINK-17758][runtime] Remove unused AdaptedRestartPipelinedRegionStrategyNG component=Runtime/Coordination review=description?
#12192 opened May 16, 2020 by zhuzhurk
2
[FLINK-17757] Implement format factory for Avro serialization and deseriazation schema of RowData type component=TableSQL/API review=description?
#12190 opened May 16, 2020 by danny0405 • Approved
3
[FLINK-17376][API/DataStream]Deprecated methods and related code updated component=API/DataStream review=description?
#12189 opened May 16, 2020 by mghildiy
2
[FLINK-17728] [sql-client] sql client supports parser statements via sql parser component=TableSQL/Client review=description?
#12188 opened May 16, 2020 by godfreyhe
18
[FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators component=Connectors/Kafka component=Tests review=description?
#12186 opened May 15, 2020 by AHeise
15
[FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys component=Connectors/ElasticSearch component=TableSQL/Ecosystem review=description?
#12184 opened May 15, 2020 by dawidwys • Changes requested
22
[FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug. component=Runtime/Task review=description?
#12181 opened May 15, 2020 by wanglijie95
4
[FLINK-17163][docker] Remove flink-contrib/docker-flink component=Deployment/Docker review=description?
#12180 opened May 15, 2020 by zentol • Approved
@tillrohrmann
7
[FLINK-16144] get client.timeout for the client, with a fallback to the akka.client… component=CommandLineClient review=description?
#12179 opened May 15, 2020 by wtog
2
[FLINK-17029][jdbc]Introduce a new JDBC connector with new property keys component=Connectors/JDBC component=TableSQL/Ecosystem review=description?
#12176 opened May 15, 2020 by leonardBang
45
[FLINK-17692] Keep yarn.classpath in target folder to not pollute local builds component=Deployment/YARN review=description?
#12175 opened May 15, 2020 by rmetzger
3
[FLINK-17736] Add flink cep example component=Examples review=description?
#12174 opened May 15, 2020 by dengziming
2
[FLINK-17656][tests] Migrate docker e2e tests to flink-docker component=Tests review=description?
#12172 opened May 15, 2020 by zentol • Changes requested
20
[FLINK-17715][sql client] Supports function DDLs in SQL-CLI component=TableSQL/Client review=description?
#12171 opened May 15, 2020 by danny0405
6
[FLINK-17495][metrics][prometheus]Add custom labels on PrometheusReporter like PrometheusPushGatewayReporter's groupingKey component=Runtime/Metrics review=description?
#12169 opened May 15, 2020 by manbuyun
3
[WIP][FLINK-14255][hive] Integrate hive to streaming file sink component=TableSQL/Planner review=description?
#12168 opened May 15, 2020 by JingsongLi
2
[FLINK-17700][python] The callback client of JavaGatewayServer should… component=API/Python review=description?
#12166 opened May 15, 2020 by shuiqiangchen
2
[FLINK-17700][python] The callback client of JavaGatewayServer should… component=API/Python review=description?
#12165 opened May 15, 2020 by shuiqiangchen
3
[FLINK-17691][Connectors/Kafka] fix the bug FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode component=Connectors/Kafka review=description?
#12157 opened May 14, 2020 by freezhan
2
[FLINK-16966][metrics][infuxdb] Convert InfluxDB reporter to plugin component=Runtime/Metrics review=description?
#12153 opened May 14, 2020 by complone • Changes requested
@zentol
11
[FLINK-17026][kafka] Introduce a new Kafka connect or with new proper… component=Connectors/Kafka component=TableSQL/Ecosystem review=description?
#12150 opened May 14, 2020 by danny0405
25
[FLINK-17681] Correct type when converting Row, Map, Array to RexNodes component=TableSQL/API review=description?
#12149 opened May 14, 2020 by dawidwys
2
[FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners component=API/Core component=API/DataStream review=description?
#12147 opened May 14, 2020 by aljoscha • Approved
33
[hotfix][hbase]Fix HBaseRowInputFormat cannot get the zk address set … review=description?
#12146 opened May 14, 2020 by Tartarus0zm
3
ProTip! What’s not been updated in a month: updated:<2020-04-16.
You can’t perform that action at this time.