Commits

History for

Commits on Sep 14, 2020

[FLINK-19083] Remove deprecated DataStream#split
dawidwys
committedSep 14, 2020

Commits on Sep 7, 2020

[FLINK-19035] Remove fold from DataStream API
dawidwys
committedSep 7, 2020

Commits on Aug 26, 2020

[FLINK-19031] Remove deprecated StreamExecutionEnvironment#setStateBackend(AbstactStateBackend)
dawidwys
committedAug 26, 2020

Commits on Jul 29, 2020

[FLINK-18606][java-streaming] Remove unused generic parameter from SinkFunction.Context

nielsbasjes
authored and
aljoscha
committedJul 29, 2020

Commits on Jul 24, 2020

[FLINK-18629] Add type to ConnectedStreams#keyBy
dawidwys
committedJul 24, 2020

Commits on Jul 22, 2020

[FLINK-18607][build] Give the maven module a human readable name
nielsbasjes
committedJul 22, 2020

Commits on Jun 24, 2020

[FLINK-18428][API/DataStream] Rename StreamExecutionEnvironment#continuousSource() to StreamExecutionEnvironment#source().

becketqin
authored and
StephanEwen
committedJun 24, 2020

Commits on Jun 23, 2020

[FLINK-18283][API/Core,API/DataStream] Update outdated Javadoc for clear method of ProcessWindowFunction

Abhijit Shandilya
authored and
aljoscha
committedJun 23, 2020

Commits on Jun 3, 2020

[FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic
aljoscha
committedJun 3, 2020

Commits on May 27, 2020

Commits on May 18, 2020

Update version to 1.12-SNAPSHOT
pnowojski
committedMay 18, 2020
[FLINK-17661] Add Scala API for using new WatermarkStrategy/WatermarkGenerator
aljoscha
committedMay 18, 2020

Commits on May 17, 2020

[FLINK-15102][datastream/api] Add continuousSource() methods to the StreamExecutionEvironment.
becketqin
committedMay 17, 2020

Commits on May 14, 2020

[FLINK-17578] In StreamEdge, use output tag in hashCode and equals

damjad
authored and
aljoscha
committedMay 14, 2020
[FLINK-17655] Remove old and long deprecated TimestampExtractor

StephanEwen
authored and
aljoscha
committedMay 14, 2020

Commits on Apr 28, 2020

[FLINK-17074] Deprecate scala Datastream.partitionCustom methods that do not use KeySelector

echauchot
authored and
aljoscha
committedApr 28, 2020
[FLINK-17074] Deprecate scala Datastream.keyBy methods that do not use KeySelector

echauchot
authored and
aljoscha
committedApr 28, 2020

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