Commits

Commits on May 28, 2018

[FLINK-9386] Embed netty router

pnowojski
authored and
uce
committedMay 28, 2018
[hotfix][tests] Report failure with error level instead of debug

pnowojski
authored and
uce
committedMay 28, 2018
[hotfix][docs] Add 1.5 to list of previous versions
zentol
committedMay 28, 2018

Commits on May 25, 2018

[hotfix] Bump japicmp reference version to Flink 1.5.0
tillrohrmann
committedMay 25, 2018
[hotfix] Don't swallow exception in CliFrontend#handleArgException
tillrohrmann
committedMay 25, 2018
[FLINK-9409] [formats] Remove flink-avro and flink-json from /opt
twalthr
committedMay 25, 2018
[FLINK-9384] [table] Fix KafkaAvroTableSource type mismatch

jerryjzhang
authored and
twalthr
committedMay 25, 2018
[hotfix][doc] Mention AggregationEnabled setting in kinesis docs

pnowojski
authored and
tzulitai
committedMay 25, 2018

Commits on May 24, 2018

[FLINK-9305] [s3] Also register flink-s3-fs-hadoop's factory for the s3a:https:// scheme

Nico Kruber
authored and
StephanEwen
committedMay 24, 2018
[hotfix] [s3] Port config key forwarding test from hadoop S3 to presto

Nico Kruber
authored and
StephanEwen
committedMay 24, 2018
[hotfix] [docs] Fix flink-s3-fs-* README entry for the service file

Nico Kruber
authored and
StephanEwen
committedMay 24, 2018
[FLINK-9286] [docs] (addendum) Update classloading docs for inverted classloading
StephanEwen
committedMay 24, 2018
[FLINK-9286] [docs] Update classloading docs

zentol
authored and
StephanEwen
committedMay 24, 2018
[FLINK-9088] [nifi-connector] Bump nifi-site-to-site-client to 1.6.0

zhouhai02
authored and
StephanEwen
committedMay 24, 2018
[FLINK-9420] [table] Add tests and docs for SQL IN sub-query operator in streaming

Xpray
authored and
twalthr
committedMay 24, 2018
[FLINK-9416] Make all RestClusterClient calls retriable
tillrohrmann
committedMay 24, 2018
[FLINK-9421] Remove job from RunningJobsRegistry when it reaches a terminal state
tillrohrmann
committedMay 24, 2018
[FLINK-9427] Fix registration and request slot race condition in TaskExecutor
tillrohrmann
committedMay 24, 2018
[FLINK-9425] Make release scripts compliant with ASF release policy
tillrohrmann
committedMay 24, 2018
[FLINK-8511] [table] Remove legacy code for the TableType annotation

blueszheng
authored and
twalthr
committedMay 24, 2018
[hotfix] [tests] Minor code cleanups in SavepointITCase
StephanEwen
committedMay 24, 2018
[FLINK-9428] [runtime] Add a 'pre-barrier-emit' checkpoint notification to stream operators.
StephanEwen
committedMay 24, 2018
[FLINK-9415] [scala, test] Remove ScalaStreamingMultipleProgramsTestBase

tweise
authored and
tzulitai
committedMay 24, 2018
[FLINK-9415] Remove reference to StreamingMultipleProgramsTestBase in docs

tweise
authored and
tzulitai
committedMay 24, 2018

Commits on May 23, 2018

[hotfix] [runtime] Eagerly create AccumulatorMap in StreamTask
StephanEwen
committedMay 23, 2018
[hotfix] [tests] Cleanup and lambda-ify StreamOperatorChainingTest
StephanEwen
committedMay 23, 2018
[hotfix] [runtime] Remove dead code for handling no longer thrown InterruptedException
StephanEwen
committedMay 23, 2018
[hotfix] [runtime] Restore interruption flag in StreamRecordWriter.close()
StephanEwen
committedMay 23, 2018
[hotfix] [runtime] Remove unused and unnecessary method from StreamTask
StephanEwen
committedMay 23, 2018
[FLINK-9426][test] Remove flaky asserts from RocksDBWriteBatchPerformanceTest.benchMark().

sihuazhou
authored and
StefanRRichter
committedMay 23, 2018
[FLINK-9338] Implemented RegistryAvroDeserializationSchema & provided implementation for Confluent Schema Registry
dawidwys
committedMay 23, 2018
[FLINK-9337] Implemented AvroDeserializationSchema
dawidwys
committedMay 23, 2018
[FLINK-9064][scaladocs] Add link to scaladocs to documentation sidebar.

yanghua
authored and
StefanRRichter
committedMay 23, 2018
[FLINK-8845][state] Introduce RocksDBWriteBatchWrapper to improve batched write performance in RocksDB backend.

sihuazhou
authored and
StefanRRichter
committedMay 23, 2018
[FLINK-7814] [table] Add BETWEEN and NOT BETWEEN expression to Table API

Xpray
authored and
twalthr
committedMay 23, 2018