Commits

Commits on Apr 15, 2016

[FLINK-2544] [docs] Add Java 8 version for building PowerMock tests to docs

skavulya
authored and
fhueske
committedApr 15, 2016
[FLINK-3762] [core] Enable Kryo reference tracking

andrewpalumbo
authored and
fhueske
committedApr 15, 2016
[FLINK-3732] [core] Fix potential null deference in ExecutionConfig#equals()

Tianji Li
authored and
fhueske
committedApr 15, 2016
[FLINK-3759] [table] Throw exception if NULL literal is encountered in non-null mode.

twalthr
authored and
fhueske
committedApr 15, 2016
[FLINK-3738] [table] Refactor TableEnvironments. Remove Translators and TranslationContext.
fhueske
committedApr 15, 2016
[FLINK-3700] [core] Remove Guava dependency from flink-core

StephanEwen
authored and
fhueske
committedApr 15, 2016
[hotfix] Make initial currentWatermark==Long.MIN_VALUE everywhere
aljoscha
committedApr 15, 2016
[FLINK-3739] [table] Add a null literal to Table API
twalthr
committedApr 15, 2016

Commits on Apr 14, 2016

[FLINK-3760] Fix StateDescriptor.readObject
aljoscha
committedApr 14, 2016

Commits on Apr 13, 2016

[FLINK-3743] upgrading breeze from 0.11.2 to 0.12

Todd Lisonbee
authored and
StephanEwen
committedApr 13, 2016
[FLINK-3375] [Kafka Connector] Add tests for per-kafka-partition watermarks.
StephanEwen
committedApr 13, 2016
[FLINK-3747] Consolidate TimestampAssigner Methods in Kafka Consumer

aljoscha
authored and
StephanEwen
committedApr 13, 2016
[FLINK-3745] [runtime] Fix early stopping of stream sources
StephanEwen
committedApr 13, 2016
[hotfix] [kafka consumer] Increase Kafka test stability
StephanEwen
committedApr 13, 2016
[FLINK-2909] [gelly] Graph Generators

greghogan
authored and
EC2 Default User
committedApr 13, 2016
[FLINK-3589] Allow setting Operator parallelism to default value
greghogan
committedApr 13, 2016
[hotfix] [tests] Add cross transformation to OverwriteObjects manual test
greghogan
committedApr 13, 2016
[hotfix] [storm] Add proper exception forwarding to FlinkTopology.copyObject
tillrohrmann
committedApr 13, 2016
[FLINK-3735] Make DataSetUnionRule match only for union-all
vasia
committedApr 13, 2016
[FLINK-3730] Fix RocksDB Local Directory Initialization
aljoscha
committedApr 13, 2016

Commits on Apr 12, 2016

[FLINK-3126] [core] Remove accumulator type from "value" in web frontend

Zack Pierce
authored and
StephanEwen
committedApr 12, 2016
[FLINK-3737] [tests] Adding comment about SOCKS proxy server for WikipediaEditsSourceTest

Todd Lisonbee
authored and
StephanEwen
committedApr 12, 2016
[FLINK-3644] [web monitor] Add new config option to set web monitor tmp dir

xueyan.li
authored and
StephanEwen
committedApr 12, 2016
[FLINK-3444] [APIs] Add fromElements method with based class type to avoid the exception.

gallenvara
authored and
StephanEwen
committedApr 12, 2016
[FLINK-3541] [Kafka Connector] Clean up workaround in FlinkKafkaConsumer09

skyahead
authored and
StephanEwen
committedApr 12, 2016
[hotfix] [kafka consumer] Increase Kafka test stability by validating written data before consuming
StephanEwen
committedApr 12, 2016
[FLINK-3716] [kafka consumer] Decreasing socket timeout so testFailOnNoBroker() will pass before JUnit timeout

Todd Lisonbee
authored and
StephanEwen
committedApr 12, 2016
[FLINK-3375] [kafka connector] Rework/simplify Kafka Connector and have a WatermarkExtractor object per partition
StephanEwen
committedApr 12, 2016
[FLINK-3375] [kafka connector] Add per-Kafka-partition watermark generation to the FlinkKafkaConsumer

kl0u
authored and
StephanEwen
committedApr 12, 2016
[FLINK-3700] [core] Add 'Preconditions' utility class.
StephanEwen
committedApr 12, 2016
[FLINK-3700] [build] Add 'findbugs' (javax.annotation) annotations as a core dependency.
StephanEwen
committedApr 12, 2016
[FLINK-3721] Min and max accumulators
greghogan
committedApr 12, 2016
[FLINK-3736] [tableAPI] Move toRexNode logic into each expression's implementation.

yjshen
authored and
fhueske
committedApr 12, 2016
[hotfix] Minor edits to comments in code
greghogan
committedApr 12, 2016
[FLINK-3731] make embedded SQL outer joins fail during translation
vasia
committedApr 12, 2016