Commits

History for

Commits on Dec 4, 2017

[hotfix] [kafka] Fix outdated Javadoc reference to non-existing restoreState method
tzulitai
committedDec 4, 2017
[FLINK-8190] [kafka] Add constructors to expose topic pattern-based subscription
tzulitai
committedDec 4, 2017

Commits on Nov 30, 2017

[FLINK-8149] [kinesis] Replace usages of deprecated SerializationSchema

yew1eb
authored and
tzulitai
committedNov 30, 2017
[FLINK-8076] [kinesis] Upgrade KinesisProducer to 0.10.6 to set properties approperiately

bowenli86
authored and
tzulitai
committedNov 30, 2017

Commits on Nov 27, 2017

[FLINK-8105] Remove "unnecessary 'null' check before 'instanceof' expression"

yew1eb
authored and
greghogan
committedNov 27, 2017
[FLINK-8142] [config] Cleanup references to deprecated constants in ConfigConstants

yew1eb
authored and
greghogan
committedNov 27, 2017
[FLINK-8022][kafka] Bump at-least-once timeout in tests
pnowojski
committedNov 27, 2017

Commits on Nov 24, 2017

[FLINK-6294] Fix potential NPE in BucketingSink.close()
aljoscha
committedNov 24, 2017

Commits on Nov 23, 2017

[FLINK-8118] [table] Fix documentation mistakes
twalthr
committedNov 23, 2017
[FLINK-8118] [table] Allow to specify the offsets of KafkaTableSources

xccui
authored and
twalthr
committedNov 23, 2017
[hotfix][kafka] Remove unused method in kafka tests

pnowojski
authored and
aljoscha
committedNov 23, 2017
[FLINK-8132][kafka] Re-initialize transactional KafkaProducer on each checkpoint

pnowojski
authored and
aljoscha
committedNov 23, 2017
[hotfix][kafka] Throw FlinkKafkaProducer011Exception with error codes instead of generic Exception

pnowojski
authored and
aljoscha
committedNov 23, 2017

Commits on Nov 22, 2017

[FLINK-2170] [connectors] Add OrcRowInputFormat and OrcTableSource.
fhueske
committedNov 22, 2017
[FLINK-2170] [connectors] Add OrcRowInputFormat and OrcTableSource.

uybhatti
authored and
fhueske
committedNov 22, 2017
[FLINK-8131] Update to Kafka 0.11.0.2
aljoscha
committedNov 22, 2017
[FLINK-8113][build] Bump maven-shade-plugin to 3.0.0
zentol
committedNov 22, 2017
[FLINK-8126] [build] Fix and update checkstyle

greghogan
authored and
zentol
committedNov 22, 2017

Commits on Nov 20, 2017

[FLINK-8086][kafka] Ignore ProducerFencedException during recovery

pnowojski
authored and
aljoscha
committedNov 20, 2017
[hotfix][kafka] Improve logging in FlinkKafkaProducer011

pnowojski
authored and
aljoscha
committedNov 20, 2017

Commits on Nov 16, 2017

[FLINK-8014] [table] Add Kafka010JsonTableSink.
fhueske
committedNov 16, 2017

Commits on Nov 10, 2017

[FLINK-7702] Add maven-bundle-plugin to root pom
aljoscha
committedNov 10, 2017
[FLINK-4500] CassandraSinkBase implements CheckpointedFunction

mcfongtw
authored and
zentol
committedNov 10, 2017

Commits on Nov 9, 2017

[FLINK-7765][build] Enable dependency convergence by default

pnowojski
authored and
aljoscha
committedNov 9, 2017

Commits on Nov 8, 2017

[FLINK-7978][kafka] Ensure that transactional ids will never clash

pnowojski
authored and
aljoscha
committedNov 8, 2017
[hotfix][kafka] Extract TransactionalIdsGenerator class from FlinkKafkaProducer011

pnowojski
authored and
aljoscha
committedNov 8, 2017
[FLINK-8001] [kafka] Prevent PeriodicWatermarkEmitter from violating IDLE status
tzulitai
committedNov 8, 2017

Commits on Nov 6, 2017

Update version to 1.5-SNAPSHOT
aljoscha
committedNov 6, 2017
[FLINK-7997] [avro] Make Avro part of the user code space
StephanEwen
committedNov 6, 2017
[FLINK-7993][kafka] Sync curator shading patterns
zentol
committedNov 6, 2017

Commits on Nov 3, 2017

[FLINK-7420] [avro] Make flink-avro Scala independent
StephanEwen
committedNov 3, 2017
[FLINK-7420] [avro] Replace GenericData.Array by dummy when reading TypeSerializers

aljoscha
authored and
StephanEwen
committedNov 3, 2017
[FLINK-7420] [avro] Move all Avro code to flink-avro

twalthr
authored and
StephanEwen
committedNov 3, 2017
[FLINK-7972] [core] Move SerializationSchema to 'flink-core'
StephanEwen
committedNov 3, 2017

Commits on Nov 2, 2017

[FLINK-7421] [table] Fix serializability of AvroRowSerializationSchema + AvroRowDeserializationSchema.
fhueske
committedNov 2, 2017