Commits

Commits on Dec 10, 2018

Commits on Dec 9, 2018

[FLINK-10543][table] Leverage efficient timer deletion in relational operators

hequn8128
authored and
sunjincheng121
committedDec 9, 2018

Commits on Dec 7, 2018

[hotfix][documentation] Mention limitation of local recovery with RocksDB in multi device setups.
StefanRRichter
committedDec 7, 2018

Commits on Dec 6, 2018

[FLINK-10482] Fix double counting of checkpoint stat

azagrebin
authored and
tillrohrmann
committedDec 6, 2018
[FLINK-11011][E2E][JM] Log error messages about null CheckpointCoordinator only if job is running (apache#7216 )

azagrebin
authored and
tillrohrmann
committedDec 6, 2018
[FLINK-10987] Add LICENSE & NOTICE files for flink-avro-confluent-registry
zentol
committedDec 6, 2018
[FLINK-10997][formats] Bundle kafka-scheme-registry-client
zentol
committedDec 6, 2018
[hotfix][docs] Fix invalid link in schema_evolution doc

KarmaGYZ
authored and
dawidwys
committedDec 6, 2018
[FLINK-9555][scala-shell] Support table api in scala shell.

shuiqiangchen
authored and
sunjincheng121
committedDec 6, 2018

Commits on Dec 5, 2018

[hotfix][docs] Fix typo in Windows documentation

KarmaGYZ
authored and
dawidwys
committedDec 5, 2018
[hotfix] Fixing the broken code examples

Igal Shilman
authored and
kl0u
committedDec 5, 2018
[FLINK-10522][fs-connector] Check if RecoverableWriter supportsResume() and act accordingly.
kl0u
committedDec 5, 2018
[FLINK-11045][table] Set correct UserCodeClassLoader for RuntimeUDFContext in CollectionExecutor

hequn8128
authored and
sunjincheng121
committedDec 5, 2018

Commits on Dec 4, 2018

[FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files.
kl0u
committedDec 4, 2018
[hotfix] Method renaming in the RecoverableMultiPartUploadImpl.
kl0u
committedDec 4, 2018
[hotfix] Consolidated all S3 accesses under the S3AccessHelper.
kl0u
committedDec 4, 2018
[hotfix][s3-connector] Renamed S3MultiPartUploader to S3AccessHelper.
kl0u
committedDec 4, 2018
[hotfix][fs-connector] Refactor Bucket to statically import Preconditions.
kl0u
committedDec 4, 2018
[hotfix][fs-connector] Refactor PartFileWriter to take stream.
kl0u
committedDec 4, 2018
[FLINK-11044] [docs] Fix registerTableSink docs

kgorman
authored and
twalthr
committedDec 4, 2018
[FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API suite

Clarkkkkk
authored and
dawidwys
committedDec 4, 2018
[FLINK-11047] Fix CoGroupGroupSortTranslationTest by specyfing types
tillrohrmann
committedDec 4, 2018

Commits on Dec 3, 2018

[FLINK-7603] [docs] Update documentation with WITHIN clause for MATCH_RECOGNIZE

dawidwys
authored and
twalthr
committedDec 3, 2018
[FLINK-7603] [table] Support WITHIN clause in MATCH_RECOGNIZE

dawidwys
authored and
twalthr
committedDec 3, 2018
[FLINK-10874][kafka-docs] Document likely cause of UnknownTopicOrPartitionException
pnowojski
committedDec 3, 2018
[FLINK-10689] [table] Improve docs and fix bugs of ported classes
twalthr
committedDec 3, 2018
[FLINK-10689] [table] Port UDF interfaces to flink-table-common

xueyumusic
authored and
twalthr
committedDec 3, 2018
[FLINK-11013] [table] Fix distinct aggregates for group window in Table API

dianfu
authored and
sunjincheng121
committedDec 3, 2018