Commits

Commits on Jan 8, 2018

[hotfix][test] Add timeout for joining with CheckedThread

pnowojski
authored and
StefanRRichter
committedJan 8, 2018
[FLINK-8178][network] Introduce not threadsafe write only BufferBuilder

pnowojski
authored and
StefanRRichter
committedJan 8, 2018
[FLINK-8214][streaming-tests] Collect results into proper mock in StreamMockEnvironment

pnowojski
authored and
StefanRRichter
committedJan 8, 2018
[FLINK-8210][network-tests] Collect results into proper mock in MockEnvironment

pnowojski
authored and
StefanRRichter
committedJan 8, 2018
[hotfix][runtime] Remove unused methods

pnowojski
authored and
StefanRRichter
committedJan 8, 2018
[FLINK-8209][network-tests] Make LocalBufferPoolDestroyTest less implementation dependent

pnowojski
authored and
StefanRRichter
committedJan 8, 2018
[FLINK-8208][network-tests] Reduce mockito usage in RecordWriterTest

pnowojski
authored and
StefanRRichter
committedJan 8, 2018
[hotfix][network-tests] Simplify TestPooledBufferProvider

pnowojski
authored and
StefanRRichter
committedJan 8, 2018
[FLINK-8207][network-tests] Unify TestInfiniteBufferProvider and TestPooledBufferProvider

pnowojski
authored and
StefanRRichter
committedJan 8, 2018
[hotfix][network] Drop redundant this reference usages

pnowojski
authored and
StefanRRichter
committedJan 8, 2018
[FLINK-7416][network] Implement Netty receiver outgoing pipeline for credit-based

zhijiangW
authored and
StefanRRichter
committedJan 8, 2018
[FLINK-7406][network] Implement Netty receiver incoming pipeline for credit-based

zhijiangW
authored and
StefanRRichter
committedJan 8, 2018

Commits on Jan 6, 2018

[FLINK-8283] [kafka] Stabalize FlinkKafkaConsumerBaseTest::testScaleUp()
tzulitai
committedJan 6, 2018
[FLINK-8298][tests] Properly shutdown MockEnvironment to release resources

pnowojski
authored and
tzulitai
committedJan 6, 2018
[FLINK-8268][streaming][tests] Improve TwoPhaseCommitSinkFunctionTest stability by using custom in memory storage

pnowojski
authored and
tzulitai
committedJan 6, 2018
[hotfix] [kafka] Add serialVersionUID to FlinkKafkaProducer010
tzulitai
committedJan 6, 2018
[hotfix] [kafka] Fix stale Javadoc link in FlinkKafkaProducer09
tzulitai
committedJan 6, 2018
[hotfix] [kafka] Properly deprecate FlinkKafkaProducer010Configuration
tzulitai
committedJan 6, 2018
[FLINK-8260] [kafka] Reorder deprecated / regular constructors of FlinkKafkaProducer010
tzulitai
committedJan 6, 2018
[FLINK-8287] [kafka] Improve Kafka producer Javadocs / doc to clarify partitioning behaviour
tzulitai
committedJan 6, 2018
[FLINK-8260] [kafka] Fix usage of deprecated instantiation methods in FlinkKafkaProducer docs
tzulitai
committedJan 6, 2018
[FLINK-8116] [DataStream] Provide proper checkpointed source function example in Javadocs
tzulitai
committedJan 6, 2018
[FLINK-8116] [DataStream] Fix stale comments referring to Checkpointed interface

0xparashar
authored and
tzulitai
committedJan 6, 2018

Commits on Jan 5, 2018

[FLINK-8265] Missing jackson dependency for flink-mesos

EronWright
authored and
aljoscha
committedJan 5, 2018
[hotfix] [core] Add a factory method to create Path from local file
StephanEwen
committedJan 5, 2018
[hotfix] [core] Pre-compile regex pattern in Path class
StephanEwen
committedJan 5, 2018
[hotfix] [checkpoints] Improve performance of ByteStreamStateHandle
StephanEwen
committedJan 5, 2018
[hotfix] [hdfs] Avoid re-parsing URIs for all Hadoop File System calls.
StephanEwen
committedJan 5, 2018
[hotfix] [core] Improve local fs exists() performance
StephanEwen
committedJan 5, 2018
[hotfix] [checkpoints] Remove never used method 'close()' on CheckpointStreamFactory
StephanEwen
committedJan 5, 2018
[hotfix] [core] Avoid redundant File path conversion in LocalFileSystem.getFileStatus(Path)
StephanEwen
committedJan 5, 2018
[hotfix] [tests] Remove unnecessary stack trace printing in StreamTaskTest
StephanEwen
committedJan 5, 2018
[FLINK-8373] [core, hdfs] Ensure consistent semantics of FileSystem.mkdirs() across file system implementations.
StephanEwen
committedJan 5, 2018
[FLINK-8346][docs] add v4 signature workaround for manual S3 setups

Nico Kruber
authored and
StephanEwen
committedJan 5, 2018
[hotfix] [misc] Fix some typos

王振涛
authored and
StephanEwen
committedJan 5, 2018