Commits

History for

Commits on Jan 31, 2019

[FLINK-11064] [table] Setup a new flink-table module structure
twalthr
committedJan 31, 2019

Commits on Jan 30, 2019

[FLINK-11322] [kafka] Use try-with-resource for short-living connections in Kafka connectors

Fokko Driesprong
authored and
tzulitai
committedJan 30, 2019

Commits on Jan 4, 2019

[FLINK-11026][kafka][SQL] Rework kafka sql-client jar creation
zentol
committedJan 4, 2019

Commits on Nov 30, 2018

[FLINK-11015] Remove deprecated code for format-specific Kafka table connectors

yanghua
authored and
twalthr
committedNov 30, 2018

Commits on Nov 19, 2018

[FLINK-10922] Exclude transitive kafka-clients dependency from base flink-connector-kafka
tillrohrmann
committedNov 19, 2018

Commits on Nov 9, 2018

[FLINK-10823][metrics][jmx] Add scala suffix
zentol
committedNov 9, 2018

Commits on Nov 3, 2018

Update version to 1.8-SNAPSHOT
tillrohrmann
committedNov 3, 2018

Commits on Oct 16, 2018

[FLINK-9697] Rename KafkaConsumerCallBridge to KafkaConsumerCallBridge09

yanghua
authored and
aljoscha
committedOct 16, 2018
[FLINK-9697] Rename KafkaTableSink to KafkaTableSinkBase

yanghua
authored and
aljoscha
committedOct 16, 2018
[FLINK-9697] Rename KafkaTableSource to KafkaTableSourceBase

yanghua
authored and
aljoscha
committedOct 16, 2018

Commits on Aug 1, 2018

[FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory
twalthr
committedAug 1, 2018

Commits on Jul 23, 2018

[FLINK-9846] [table] Add a Kafka table sink factory
twalthr
committedJul 23, 2018

Commits on Jul 20, 2018

[FLINK-9886] [sql-client] Build SQL jars with every build
twalthr
committedJul 20, 2018
[FLINK-9852] [table] Expose descriptor-based sink creation and introduce update mode
twalthr
committedJul 20, 2018

Commits on Jul 16, 2018

Update version to 1.7-SNAPSHOT
tillrohrmann
committedJul 16, 2018

Commits on Jul 15, 2018

[FLINK-8866] [table] Merge table source/sink/format factories
twalthr
committedJul 15, 2018
[FLINK-8866] [table] Create unified interfaces to configure and instatiate TableSinks

Shuyi Chen
authored and
twalthr
committedJul 15, 2018
[FLINK-8558] [table] Add unified format interfaces and separate formats from connectors
twalthr
committedJul 15, 2018

Commits on Jun 29, 2018

[FLINK-9217][kafka-tests] Ignore testTimestamps for Kafka 0.10
pnowojski
committedJun 29, 2018

Commits on May 4, 2018

[FLINK-9292] [core] Remove TypeInfoParser (part 1)
StephanEwen
committedMay 4, 2018

Commits on Apr 24, 2018

[FLINK-8537] [table] Add a Kafka table source factory with Avro format support

xccui
authored and
twalthr
committedApr 24, 2018

Commits on Apr 6, 2018

[hotfix][tests] Remove Kafka testFailOnDeploy test
zentol
committedApr 6, 2018

Commits on Mar 2, 2018

[FLINK-6352] [kafka] Further improvements for timestamped-based startup mode
tzulitai
committedMar 2, 2018
[FLINK-6352] [kafka] Support to set offset of Kafka with specific date

FangYongs
authored and
tzulitai
committedMar 2, 2018

Commits on Feb 27, 2018

[FLINK-8538] [table] Improve unified table sources
twalthr
committedFeb 27, 2018
[FLINK-8538][table]Add a Kafka table source factory with JSON format support

xccui
authored and
twalthr
committedFeb 27, 2018
Update version to 1.6-SNAPSHOT
tillrohrmann
committedFeb 27, 2018

Commits on Feb 15, 2018

[FLINK-8630] [formats] Add proper support for JSON formats
twalthr
committedFeb 15, 2018

Commits on Feb 6, 2018

[FLINK-8419] [kafka] Move consumer metric group registration to FlinkKafkaConsumerBase
tzulitai
committedFeb 6, 2018

Commits on Jan 12, 2018

[FLINK-8276] [kafka] Properly annotate APIs for Kafka connector

zhangminglei
authored and
tzulitai
committedJan 12, 2018

Commits on Jan 6, 2018

Commits on Dec 4, 2017

[FLINK-8190] [kafka] Add constructors to expose topic pattern-based subscription
tzulitai
committedDec 4, 2017