Commits

History for

Commits on Mar 25, 2020

[FLINK-16692] Register custom JobListeners throug config.

liuyongvs
authored and
kl0u
committedMar 25, 2020

Commits on Mar 19, 2020

[FLINK-16684] Fix StreamingFileSink builder compilation for Scala
tillrohrmann
committedMar 19, 2020

Commits on Feb 28, 2020

[hotfix][test] Rename getStreamEdges to getStreamEdgesOrThrow
pnowojski
committedFeb 28, 2020

Commits on Feb 21, 2020

[FLINK-15672][build][tests] Migrate test log4j configurations to log4j2
zentol
committedFeb 21, 2020

Commits on Jan 14, 2020

[FLINK-15533] Deprecate text sink facilitation methods in DataStream
kl0u
committedJan 14, 2020

Commits on Dec 10, 2019

[FLINK-15093][streaming-java] StreamExecutionEnvironment#getStreamGraph should clear transformations

danny0405
authored and
kl0u
committedDec 10, 2019
[FLINK-14992][client] Add job listener to execution environments

tisonkun
authored and
aljoscha
committedDec 10, 2019
[FLINK-15129] Return JobClient instead of JobClient Future from executeAsync()
aljoscha
committedDec 10, 2019

Commits on Dec 9, 2019

Update version to 1.11-SNAPSHOT
GJL
committedDec 9, 2019

Commits on Dec 3, 2019

[FLINK-14854][client] Add executeAsync() method to execution environments

tisonkun
authored and
kl0u
committedDec 3, 2019

Commits on Nov 22, 2019

[FLINK-14787][configuration] Add configure method to StreamExecutionEnvironment
dawidwys
committedNov 22, 2019
[hotfix] Fix scaladocs links
dawidwys
committedNov 22, 2019

Commits on Nov 8, 2019

[FLINK-14380][ScalaAPI] Passing inferred outputType directly to map and flatMap function

mzuehlke
authored and
StephanEwen
committedNov 8, 2019

Commits on Oct 18, 2019

[FLINK-14366][tests] Enable TextOutputFormatITCase and CsvOutputFormatITCase to pass with NG scheduler

zhuzhurk
authored and
tillrohrmann
committedOct 18, 2019
[FLINK-7629] [scala] Fix KeyedStream.aggregate for nested field expressions

ggevay
authored and
aljoscha
committedOct 18, 2019
[hotfix] Only use types defined in CaseClassFieldAccessorTest in the test
aljoscha
committedOct 18, 2019
[FLINK-7629] [scala] Fix RecursiveProductFieldAccessor.fieldType

ggevay
authored and
aljoscha
committedOct 18, 2019

Commits on Oct 7, 2019

[FLINK-14044] [datastream] Incorporating FLINK-13635 by adding tests for proper timeout handling

Arvid Heise
authored and
pnowojski
committedOct 7, 2019

Commits on Sep 17, 2019

[FLINK-12958][runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

Arvid Heise
authored and
pnowojski
committedSep 17, 2019
[FLINK-12481][runtime] Use StreamTask mailbox for processing time triggered actions

1u0
authored and
pnowojski
committedSep 17, 2019

Commits on Aug 22, 2019

[FLINK-13761][scala] Deprecate Scala SplitStream

izhangzhihao
authored and
tillrohrmann
committedAug 22, 2019

Commits on Aug 7, 2019

[FLINK-13605][tests] Fix unstable case AsyncDataStreamITCase#testUnorderedWait

ifndef-SleePy
authored and
kl0u
committedAug 7, 2019

Commits on Aug 6, 2019

[FLINK-13486][tests] Harden AsyncDataStreamITCase to alleviate race condition

ifndef-SleePy
authored and
kl0u
committedAug 6, 2019

Commits on Jul 12, 2019

Update version to 1.10-SNAPSHOT
KurtYoung
committedJul 12, 2019
[FLINK-12602][travis] Correct the flink pom artifactId config and s… (apache#8563 )
sunjincheng121
committedJul 12, 2019

Commits on Jul 10, 2019

[FLINK-12929] Pass TypeInformation in addSource

authored and
aljoscha
committedJul 10, 2019

Commits on Jun 15, 2019

[FLINK-12297] Make Java ClosureCleaner recursive to handle nested functions

Aitozi
authored and
aljoscha
committedJun 15, 2019

Commits on Jun 14, 2019

[FLINK-12774][build] Pin build-helper-maven-plugin version to 1.7
zentol
committedJun 14, 2019

Commits on May 27, 2019

[FLINK-11283] Accessing the key when processing connected keyed stream

yanghua
authored and
aljoscha
committedMay 27, 2019

Commits on Feb 25, 2019

Update version to 1.9-SNAPSHOT
aljoscha
committedFeb 25, 2019

Commits on Feb 14, 2019

[hotfix] [tests] Make case class definition in tests top level

Igal Shilman
authored and
tzulitai
committedFeb 14, 2019

Commits on Jan 11, 2019

[FLINK-11084][datastream] Forbid using two consecutive split transformations

Clarkkkkk
authored and
dawidwys
committedJan 11, 2019

Commits on Dec 11, 2018

[FLINK-11090][streaming api] Remove unused parameter in WindowedStream.aggregate()

hequn8128
authored and
aljoscha
committedDec 11, 2018

Commits on Dec 4, 2018

[FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API suite

Clarkkkkk
authored and
dawidwys
committedDec 4, 2018

Commits on Nov 20, 2018

[FLINK-10763] [streaming] Fix interval join return type in Scala
twalthr
committedNov 20, 2018