This repository has been archived by the owner on Jun 7, 2019. It is now read-only.

Commits

Commits on Aug 29, 2018

[FLINK-9962] allow users to specify TimeZone in DateTimeBucketer

bowenli86
authored and
kl0u
committedAug 29, 2018

Commits on Aug 7, 2018

[FLINK-10055][javadocs] Fix in-progress file suffix in BucketingSink

bowenli86
authored and
zentol
committedAug 7, 2018

Commits on Jul 15, 2018

[FLINK-9483] 'Building Flink' doc doesn't highlight quick build command

bowenli86
authored and
dawidwys
committedJul 15, 2018

Commits on May 28, 2018

[hotfix] Removed unused scala imports.

bowenli86
authored and
StefanRRichter
committedMay 28, 2018

Commits on May 3, 2018

[FLINK-6719] [docs] Add details about timers to ProcessFunction docs.

bowenli86
authored and
fhueske
committedMay 3, 2018

Commits on Apr 11, 2018

[FLINK-9140][build] Simplify scalastyle configuration

bowenli86
authored and
zentol
committedApr 11, 2018

Commits on Apr 6, 2018

[FLINK-8837][annotations] Add @experimental annotation and annotate some classes

bowenli86
authored and
zentol
committedApr 6, 2018

Commits on Apr 4, 2018

[FLINK-8771][build] Upgrade scalastyle to 1.0.0

bowenli86
authored and
zentol
committedApr 4, 2018
[FLINK-8697] Rename DummyFlinkKafkaConsumer in Kinesis tests This closes apache#5809 .

bowenli86
authored and
zentol
committedApr 4, 2018

Commits on Mar 14, 2018

[hotfix][javadocs] Update javadoc of InternalTimerService.registerEventTimeTimer()

bowenli86
authored and
zentol
committedMar 14, 2018

Commits on Mar 6, 2018

[FLINK-8667] Expose key in KeyedBroadcastProcessFunction#onTimer()

bowenli86
authored and
kl0u
committedMar 6, 2018
[FLINK-8560] Add KeyedProcessFunction exposing key in onTimer().

bowenli86
authored and
kl0u
committedMar 6, 2018

Commits on Feb 27, 2018

[FLINK-8719] Add module description for flink-contrib to clarify its purpose

bowenli86
authored and
zentol
committedFeb 27, 2018

Commits on Feb 21, 2018

[FLINK-8710] [YARN] AbstractYarnClusterDescriptor doesn't use pre-defined configs in Hadoop's YarnConfiguration

bowenli86
authored and
tillrohrmann
committedFeb 21, 2018

Commits on Feb 14, 2018

[FLINK-8553][metrics][datadog] Switch to async mode

bowenli86
authored and
zentol
committedFeb 14, 2018

Commits on Jan 26, 2018

[hotfix] improve javadoc and logging of RocksDBKeyedStateBackend

bowenli86
authored and
tillrohrmann
committedJan 26, 2018

Commits on Jan 23, 2018

[FLINK-8469] Unify RocksDB params in RocksDBPerformanceTest

bowenli86
authored and
StefanRRichter
committedJan 23, 2018
[FLINK-8411] [State Backend] HeapListState#add(null) will wipe out entire list state

bowenli86
authored and
StefanRRichter
committedJan 23, 2018
[FLINK-8365] Relax List type in HeapListState and HeapKeyedStateBackend

bowenli86
authored and
StefanRRichter
committedJan 23, 2018
[FLINK-8441] [State Backend] [RocksDB] change RocksDBListState to serialize values and separators in stream to avoid extra bytes copying

bowenli86
authored and
StefanRRichter
committedJan 23, 2018

Commits on Jan 19, 2018

[FLINK-7938] Introduce addAll() to ListState

bowenli86
authored and
StefanRRichter
committedJan 19, 2018

Commits on Jan 16, 2018

[FLINK-8175] remove flink-streaming-contrib and migrate its classes to flink-streaming-java/scala

bowenli86
authored and
tillrohrmann
committedJan 16, 2018

Commits on Jan 12, 2018

[FLINK-8217] [kinesis] Properly annotate APIs of flink-connector-kinesis

bowenli86
authored and
tzulitai
committedJan 12, 2018
[FLINK-6951] [kinesis] Shade httpcomponents dependency for Kinesis connector

bowenli86
authored and
tzulitai
committedJan 12, 2018
[FLINK-8271] [kinesis] Remove usage of deprecated Kinesis APIs

bowenli86
authored and
tzulitai
committedJan 12, 2018

Commits on Jan 10, 2018

[FLINK-7475] [state] Introduce ListState#update()

bowenli86
authored and
StefanRRichter
committedJan 10, 2018

Commits on Dec 18, 2017

[FLINK-8216] [kinesis] Unify test utils in flink-connector-kinesis

bowenli86
authored and
tzulitai
committedDec 18, 2017
[FLINK-8218] [kinesis] Move flink-connector-kinesis examples from /src to /test

bowenli86
authored and
tzulitai
committedDec 18, 2017

Commits on Dec 13, 2017

[hotfix][javadocs] Clarify replacement for deprecated FoldingState

bowenli86
authored and
zentol
committedDec 13, 2017

Commits on Nov 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 23, 2017

[FLIN-6505] Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

bowenli86
authored and
StefanRRichter
committedNov 23, 2017

Commits on Nov 6, 2017

[hotfix][java] Add missing space to error message

bowenli86
authored and
zentol
committedNov 6, 2017

Commits on Oct 26, 2017

[hotfix] Reorder ProcessOperator methods so they conform to the order in the interface

bowenli86
authored and
aljoscha
committedOct 26, 2017
[FLINK-5967] Add support for AggregatingState in user functions

bowenli86
authored and
aljoscha
committedOct 26, 2017

Commits on Oct 24, 2017

[FLINK-7388] Don't set processing time as timestamp in ProcessFunction.onTimer()

bowenli86
authored and
aljoscha
committedOct 24, 2017