Commits

History for

Commits on Nov 7, 2018

[hotfix][tests] Deduplicate the default timeout constants in FlinkKafkaProducerITCase
StefanRRichter
committedNov 7, 2018
[FLINK-10353][kafka] Support change of transactional semantics in Kafka Producer with existing state
StefanRRichter
committedNov 7, 2018

Commits on Nov 6, 2018

[FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

yanghua
authored and
pnowojski
committedNov 6, 2018

Commits on Nov 3, 2018

Update version to 1.8-SNAPSHOT
tillrohrmann
committedNov 3, 2018

Commits on Nov 1, 2018

[FLINK-10681] Harden ElasticsearchSinkITCase against wrong JNA library
tillrohrmann
committedNov 1, 2018

Commits on Oct 31, 2018

[FLINK-7811] Add Scala 2.12 profile
aljoscha
committedOct 31, 2018
[FLINK-7811] Update Kafka version of Kafka connector base
aljoscha
committedOct 31, 2018

Commits on Oct 30, 2018

[FLINK-10687] [table] Move format descriptors and validators to flink-table-common
twalthr
committedOct 30, 2018
[FLINK-10687] [table] Move DescriptorProperties to flink-table-common
twalthr
committedOct 30, 2018
[FLINK-10687] [table] Move TableSchema to flink-table-common
twalthr
committedOct 30, 2018

Commits on Oct 25, 2018

[FLINK-10613][hbase][tests] Remove logger casts
zentol
committedOct 25, 2018

Commits on Oct 24, 2018

[FLINK-10637] Use MiniClusterResource for tests in flink-runtime
tillrohrmann
committedOct 24, 2018

Commits on Oct 17, 2018

[hotfix][javadocs] Replace odd single quotes

xccui
authored and
zentol
committedOct 17, 2018
[FLINK-10440][cassandra] Add CassandraPojoOutputFormat

bmeriaux
authored and
zentol
committedOct 17, 2018

Commits on Oct 16, 2018

[FLINK-9697] Add new kafka connector module

yanghua
authored and
aljoscha
committedOct 16, 2018
[FLINK-9697] Add connector version value for kafka 2.0

yanghua
authored and
aljoscha
committedOct 16, 2018
[FLINK-9697] Remove usage of deprecated code in KafkaConsumerTestBase

yanghua
authored and
aljoscha
committedOct 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 Oct 12, 2018

[FLINK-10528][table] Remove methods that were deprecated in Flink 1.4.0.
fhueske
committedOct 12, 2018
[FLINK-10156][table] Deprecate Table.writeToSink().
fhueske
committedOct 12, 2018

Commits on Oct 10, 2018

[FLINK-10316] [kinesis] bug was preventing FlinkKinesisProducer to connect to Kinesalite

Diego Carvallo
authored and
tzulitai
committedOct 10, 2018
[FLINK-9377] [core] (part 1) Extend TypeSerializerConfigSnapshot as a factory for restoring serializers
tzulitai
committedOct 10, 2018

Commits on Oct 9, 2018

[FLINK-10310] Cassandra Sink - Handling failing requests.

wittyameta
authored and
dawidwys
committedOct 9, 2018
[hotfix][cassandra][tests] Close sources/sinks in finally block

bmeriaux
authored and
zentol
committedOct 9, 2018
[FLINK-9126][cassandra] Finalize Pojo InputFormat

bmeriaux
authored and
zentol
committedOct 9, 2018
[FLINK-9126][cassandra] Add Pojo InputFormat

Jicaar
authored and
zentol
committedOct 9, 2018

Commits on Oct 8, 2018

[FLINK-10208][build] Bump mockito to 2.21.0 / powermock to 2.0.0-beta.5
zentol
committedOct 8, 2018

Commits on Oct 1, 2018

[FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch
twalthr
committedOct 1, 2018
[hotfix] [connectors] Remove unused BulkProcessorIndexer class
twalthr
committedOct 1, 2018

Commits on Sep 20, 2018

[FLINK-10358] fix NPE when running flink-kinesis connector against dynamodb streams

yxu-valleytider
authored and
mxm
committedSep 20, 2018

Commits on Sep 13, 2018

[FLINK-10269] [connectors] Fix Elasticsearch 6 UpdateRequest binary incompatibility
twalthr
committedSep 13, 2018

Commits on Sep 6, 2018

[hotfix][flink-connector-filesystem] fix javadoc typo in BucketingSink

maqingxiang
authored and
dawidwys
committedSep 6, 2018

Commits on Aug 29, 2018

[FLINK-10189] Fix inefficient use of keySet iterators

Hiroaki Yoshida
authored and
zentol
committedAug 29, 2018