Commits

History for

Commits on Aug 28, 2021

Update version to 1.15-SNAPSHOT
xintongsong
committedAug 28, 2021

Commits on Aug 15, 2021

[FLINK-23738][state] Remove ChangelogBackend from the public APIs
rkhachatryan
committedAug 15, 2021

Commits on Aug 13, 2021

[FLINK-20897][table-planner] Support batch mode in StreamTableEnvironment
twalthr
committedAug 13, 2021

Commits on Aug 11, 2021

[FLINK-23646][streaming-java][table] Use pipeline name consistently across DataStream API and Table API
twalthr
committedAug 11, 2021

Commits on Aug 4, 2021

Commits on Jul 21, 2021

[FLINK-18783] Load Akka with separate classloader
zentol
committedJul 21, 2021

Commits on Jul 14, 2021

Revert "[FLINK-18783] Load Akka with separate classloader"
pnowojski
committedJul 14, 2021

Commits on Jul 13, 2021

[FLINK-18783] Load Akka with separate classloader
zentol
committedJul 13, 2021

Commits on Jul 7, 2021

[FLINK-23165][python] Add StreamExecutionEnvironment#registerSlotSharingGroup to PyFlink and Scala

SteNicholas
authored and
HuangXingBo
committedJul 7, 2021

Commits on Jul 6, 2021

[FLINK-21448] Add dependency for ChangelogStateBackend ITTests

zhangyy91
authored and
rkhachatryan
committedJul 6, 2021

Commits on Jul 5, 2021

[FLINK-21925][core] Introduce StreamExecutionEnvironment#registerSlotSharingGroup

KarmaGYZ
authored and
xintongsong
committedJul 5, 2021

Commits on Jun 22, 2021

[FLINK-22678][state][changelog] Configurations and user APIs for ChangelogStateBackend
Zakelly
committedJun 22, 2021

Commits on Apr 18, 2021

Update version to 1.14-SNAPSHOT
guoweiM
committedApr 18, 2021

Commits on Feb 25, 2021

Commits on Dec 28, 2020

[FLINK-20651] Format code with Spotless/google-java-format

Rufus Refactor
authored and
zentol
committedDec 28, 2020

Commits on Nov 26, 2020

Update version to 1.13-SNAPSHOT
dianfu
committedNov 26, 2020

Commits on Nov 20, 2020

[FLINK-20240] Add execution.runtime-mode setter in StreamExecutionEnvironment
kl0u
committedNov 20, 2020

Commits on Nov 3, 2020

[FLINK-19931] Do not emit intermediate results for reduce operation BATCH execution mode
dawidwys
committedNov 3, 2020
[hotfix] Add Operator suffix to StreamGroupedReduce
dawidwys
committedNov 3, 2020
[FLINK-19924][config] Add an option to force Unaligned Checkpoints

rkhachatryan
authored and
AHeise
committedNov 3, 2020
[hotfix][config] Add env.isUnalignedCheckpointsEnabled() (java/scala/python)

rkhachatryan
authored and
AHeise
committedNov 3, 2020

Commits on Nov 2, 2020

[FLINK-19736] Add SinkTransformation along with Translator

guoweiM
authored and
aljoscha
committedNov 2, 2020

Commits on Oct 27, 2020

[hotfix] Fix StreamExecutionEnvironmentTest
aljoscha
committedOct 27, 2020
[FLINK-19494] Add StreamExecutionEnvironment.fromSequence()

SteNicholas
authored and
aljoscha
committedOct 27, 2020
[FLINK-19508][DataStream] Add collect() operation on DataStream
sjwiesman
committedOct 27, 2020

Commits on Oct 6, 2020

[FLINK-19318] Deprecate timeWindow() operations in DataStream API
aljoscha
committedOct 6, 2020

Commits on Oct 1, 2020

[FLINK-19319] Deprecate setStreamTimeCharacteristic() and TimeCharacteristic
aljoscha
committedOct 1, 2020
[FLINK-19317] Remove unnecessary calls to setStreamTimeCharacteristic (scala)
aljoscha
committedOct 1, 2020
[FLINK-19317] Make EventTime the default TimeCharacteristic
aljoscha
committedOct 1, 2020

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