Commits

History for

Commits on Feb 6, 2018

[hotfix] [test] Remove stale savepoint files no longer used by migration tests
tzulitai
committedFeb 6, 2018
[FLINK-8472] [fs, test] Extend BucketingSinkMigrationTest for Flink 1.4
tzulitai
committedFeb 6, 2018
[FLINK-8472] [kafka, test] Extend FlinkKafkaConsumerBaseMigrationTest for Flink 1.4
tzulitai
committedFeb 6, 2018
[FLINK-8472] [kinesis, test] Extend FlinkKinesisConsumerMigrationTest for Flink 1.4
tzulitai
committedFeb 6, 2018
[hotfix] [kinesis] Use ArrayList for faster shard state updates
tzulitai
committedFeb 6, 2018
[FLINK-8484] [kinesis] Use an equivalence wrapper around restored StreamShardMetadatas to bypass out-of-sync shard infos
tzulitai
committedFeb 6, 2018
[hotfix] [kinesis, test] Use real test classes instead of Mockito in FlinkKinesisConsumerMigrationTest
tzulitai
committedFeb 6, 2018
[FLINK-8484] [kinesis] Synchronize local shard metainfo's on restore

pluppens
authored and
tzulitai
committedFeb 6, 2018
[hotfix][connectors] Fix log format strings

patricklucas
authored and
tzulitai
committedFeb 6, 2018
[FLINK-8022][kafka-tests] Disable at-least-once tests for Kafka 0.9

pnowojski
authored and
tzulitai
committedFeb 6, 2018
[hotfix] [kafka] Fix inapproriate access modifiers in AbstractFetcher
tzulitai
committedFeb 6, 2018
[FLINK-8419] [kafka] Register metrics for dynamically discovered Kafka partitions
tzulitai
committedFeb 6, 2018
[FLINK-8419] [kafka] Move consumer metric group registration to FlinkKafkaConsumerBase
tzulitai
committedFeb 6, 2018
[hotfix] [kafka] Make AbortedReassignmentException a static class
tzulitai
committedFeb 6, 2018
[FLINK-8409] [kafka] Fix offset committing race condition in KafkaConsumerThread
tzulitai
committedFeb 6, 2018
[FLINK-6004] [kinesis] Allow FlinkKinesisConsumer to skip records
tzulitai
committedFeb 6, 2018
[FLINK-8398] [kinesis, tests] Stabilize flaky KinesisDataFetcherTests
tzulitai
committedFeb 6, 2018
[FLINK-8398] [kinesis, tests] Cleanup confusing implementations in KinesisDataFetcherTest and related classes
tzulitai
committedFeb 6, 2018

Commits on Feb 5, 2018

Commits on Jan 31, 2018

[FLINK-8230] [orc] Fix NPEs when reading nested columns.

fhueske
authored and
twalthr
committedJan 31, 2018
[FLINK-8489][ES] Prevent side-effects when modifying user-config
zentol
committedJan 31, 2018
[FLINK-8240] [table] Create unified interfaces to configure and instatiate TableSources
twalthr
committedJan 31, 2018

Commits on Jan 26, 2018

[hotfix] [tests] Let BucketingSink extend TestLogger
tillrohrmann
committedJan 26, 2018

Commits on Jan 24, 2018

[FLINK-8406] [bucketing sink] Fix proper access of Hadoop File Systems
StephanEwen
committedJan 24, 2018

Commits on Jan 22, 2018

[FLINK-7720] [checkpoints] Centralize creation of backends and state related resources
StefanRRichter
committedJan 22, 2018

Commits on Jan 19, 2018

[FLINK-7938] Introduce addAll() to ListState

bowenli86
authored and
StefanRRichter
committedJan 19, 2018

Commits on Jan 18, 2018

[FLINK-7925] [checkpoints] Add CheckpointingOptions
StephanEwen
committedJan 18, 2018

Commits on Jan 12, 2018

[hotfix] [kafka] Add missing serialVersionUIDs to all Kafka connector Serializable classes
tzulitai
committedJan 12, 2018
[FLINK-8276] [kafka] Properly annotate APIs for Kafka connector

zhangminglei
authored and
tzulitai
committedJan 12, 2018
[FLINK-8199] [elasticsearch] Properly annotate APIs of Elasticsearch connector

zhangminglei
authored and
tzulitai
committedJan 12, 2018
[hotfix] [kinesis] Add serialVersionUID to KinesisPartitioner
tzulitai
committedJan 12, 2018
[FLINK-8217] [kinesis] Properly annotate APIs of flink-connector-kinesis

bowenli86
authored and
tzulitai
committedJan 12, 2018
[hotfix] [kafka] Remove stale comment on publishing procedures of AbstractFetcher
tzulitai
committedJan 12, 2018
[FLINK-8306] [kafka, tests] Fix mock verifications on final method
tzulitai
committedJan 12, 2018