Commits

History for

Commits on Apr 18, 2021

Update version to 1.14-SNAPSHOT
guoweiM
committedApr 18, 2021

Commits on Mar 30, 2021

[FLINK-21945][streaming] Force aligned barriers on pointwise connections.

Arvid Heise
authored and
AHeise
committedMar 30, 2021

Commits on Mar 28, 2021

[FLINK-21626][core] Make RuntimeContext.jobID non-optional
rkhachatryan
committedMar 28, 2021

Commits on Mar 15, 2021

[FLINK-21354] Introduce ChangelogStateBackend to delegate state access

curcur
authored and
rkhachatryan
committedMar 15, 2021

Commits on Mar 11, 2021

[FLINK-19801][checkpoint] Expose rescale descriptors in TaskStateManager and add ambiguity of subtasks + max parallelism.

Arvid Heise
authored and
AHeise
committedMar 11, 2021

Commits on Mar 2, 2021

[hotfix][runtime] Add job ID to RuntimeContext
rkhachatryan
committedMar 2, 2021

Commits on Feb 27, 2021

[hotfix][tests] Disable incremental checkpoints in CEPOperatorTest
rkhachatryan
committedFeb 27, 2021

Commits on Feb 24, 2021

[FLINK-19970] State leak in CEP Operators
dawidwys
committedFeb 24, 2021
[hotfix] Drop compatibility with Flink <= 1.5
dawidwys
committedFeb 24, 2021

Commits on Feb 22, 2021

[FLINK-20536][tests] Update migration tests of CEPMigrationTest to cover migration from 1.12
dianfu
committedFeb 22, 2021

Commits on Feb 18, 2021

[FLINK-20534] Add Flink 1.12 snapshots for TypeSerializer upgrade tests
dianfu
committedFeb 18, 2021

Commits on Feb 11, 2021

[FLINK-21315][state-processor-api]set an operator name when collecting existing operator states.

qinjunjerry
authored and
sjwiesman
committedFeb 11, 2021
[FLINK-21315][state-processor-api]return DataSource<T> such that users can set operator names

qinjunjerry
authored and
sjwiesman
committedFeb 11, 2021

Commits on Jan 28, 2021

[FLINK-20675][checkpointing] Refactor interfaces to decline checkpoint with CheckpointException
Myasuka
committedJan 28, 2021

Commits on Jan 25, 2021

[FLINK-19462][checkpointing] Report aborted checkpoint stats

rkhachatryan
authored and
pnowojski
committedJan 25, 2021
[FLINK-19465][runtime / statebackends] Remove checkpoint storage methods from StateBackend interface
sjwiesman
committedJan 25, 2021

Commits on Dec 28, 2020

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

Rufus Refactor
authored and
zentol
committedDec 28, 2020
[FLINK-20651] Fix formatting that doesn't work with google-java-format/checkstyle

aljoscha
authored and
zentol
committedDec 28, 2020

Commits on Nov 26, 2020

Update version to 1.13-SNAPSHOT
dianfu
committedNov 26, 2020

Commits on Nov 7, 2020

[FLINK-19741] Let timer service skip reading raw keyed state if it isn't the writer
tzulitai
committedNov 7, 2020

Commits on Nov 6, 2020

[FLINK-19533][checkpoint] Add TaskStateAssignment to capture all intermediate state of StateAssignmentOperation.

Arvid Heise
authored and
AHeise
committedNov 6, 2020
[FLINK-19533][checkpoint] Introduce builder for OperatorSubtaskState.

Arvid Heise
authored and
AHeise
committedNov 6, 2020
[hotfix][tests] Chain unexpected exception to assertion error.

Arvid Heise
authored and
AHeise
committedNov 6, 2020

Commits on Nov 5, 2020

[FLINK-17295] Make ExecutionAttemptID random again (apache#13929 )
rmetzger
committedNov 5, 2020

Commits on Nov 2, 2020

[FLINK-19915][cep] fix comments bug of cep test.

liuyongvs
authored and
dawidwys
committedNov 2, 2020

Commits on Oct 29, 2020

[FLINK-19680][checkpointing] Provide alignment timeout checkpoint option
pnowojski
committedOct 29, 2020

Commits on Oct 27, 2020

Commits on Oct 26, 2020

[minor] Add Javadocs to CEP PatternStream
aljoscha
committedOct 26, 2020
[FLINK-19326][cep] Allow explicitly configuring time behaviour on CEP PatternStream

SteNicholas
authored and
aljoscha
committedOct 26, 2020

Commits on Oct 16, 2020

[hotfix] Fixes in CEP operator
dawidwys
committedOct 16, 2020

Commits on Oct 13, 2020

[FLINK-19180][state backends] Make rocksdb state backend respect managed memory fraction.
xintongsong
committedOct 13, 2020

Commits on Oct 9, 2020

[FLINK-18989][task] Remove non-sequental ChannelStateReader and the related code

rkhachatryan
authored and
AHeise
committedOct 9, 2020