Commits

Commits on Jan 12, 2024

Revert "[FLINK-33973 ] Add new interfaces for SinkV2 to synchronize the API with the SourceV2 API"
gyfora
committedJan 12, 2024

Commits on Nov 10, 2023

[FLINK-32380 ] Support Java Records with PojoTypeInfo/Serializer
gyfora
committedNov 10, 2023

Commits on Oct 22, 2023

[FLINK-33318 ] Expose aggregated collector metrics and measure timeMsPerSecond
gyfora
committedOct 22, 2023

Commits on Jul 19, 2023

[FLINK-32623 ] Return correct vertex resource lower bound

gyfora
authored and
zentol
committedJul 19, 2023

Commits on Jun 1, 2023

[FLINK-31974 ] Do not crash jobmanager on Kubernetes client errors

gyfora
authored and
reswqa
committedJun 1, 2023

Commits on May 30, 2023

[FLINK-31997 ] Upgrade to fabric8 6.6.2
gyfora
committedMay 30, 2023

Commits on Jan 12, 2023

[FLINK-30213 ] Fix logic for determining downstream subtasks for partitioner replacement
gyfora
committedJan 12, 2023

Commits on Nov 29, 2022

[FLINK-30090 ] Support timespan for TimerGauges
gyfora
committedNov 29, 2022

Commits on Apr 4, 2022

[FLINK-26368 ] [kafka] Add setProperty method to KafkaSinkBuilder
gyfora
committedApr 4, 2022

Commits on Sep 24, 2019

[FLINK-14145 ] Fix getLatestCheckpoint(true) returns wrong checkpoint
gyfora
committedSep 24, 2019

Commits on Sep 5, 2019

[FLINK-13842 ][docs] Improve Javadocs and web documentation of the StreamingFileSink
gyfora
committedSep 5, 2019

Commits on Nov 29, 2017

[FLINK-8165 ] ParameterTool serialization fix

gyfora
authored and
aljoscha
committedNov 29, 2017

Commits on Aug 24, 2016

[FLINK-4441 ] Make RocksDB backend return null on empty state + add test for all backends
gyfora
committedAug 24, 2016

Commits on Apr 21, 2016

Commits on Mar 16, 2016

[FLINK-3620 ] [streaming] Remove DbStateBackend
gyfora
committedMar 16, 2016

Commits on Feb 15, 2016

[FLINK-3354 ] Determine correct size for RocksDB snapshots
gyfora
committedFeb 15, 2016

Commits on Nov 29, 2015

[FLINK-3075 ] Change Either creation method names and expose Right/Left classes
gyfora
committedNov 29, 2015

Commits on Nov 25, 2015

[FLINK-3072 ] [streaming] Ensure Derby server starts before running any tests
gyfora
committedNov 25, 2015

Commits on Nov 24, 2015

Commits on Oct 6, 2015

[FLINK-2822 ] [streaming] Remove scala.Serializable imports

gyfora
authored and
mbalassi
committedOct 6, 2015

Commits on Oct 4, 2015

[FLINK-2802 ] [streaming] Remove cyclic watermark dependencies for iterations
gyfora
committedOct 4, 2015

Commits on Sep 21, 2015

[FLINK-2713 ] [streaming] Set state restore to lazy to avoid StateCheckpointer issues and reduce checkpoint overhead
gyfora
committedSep 21, 2015

Commits on Sep 18, 2015

[FLINK-2707 ] [streaming] Set StateCheckpointer before default state value
gyfora
committedSep 18, 2015

Commits on Sep 14, 2015

[FLINK-2664 ] [streaming] Allow partitioned state removal
gyfora
committedSep 14, 2015

Commits on Aug 2, 2015

[FLINK-2436 ] [streaming] Make ByteStreamStateHandles more robust
gyfora
committedAug 2, 2015

Commits on Jul 30, 2015

[FLINK-2324 ] [streaming] Added test for different StateHandle wrappers
gyfora
committedJul 30, 2015
[FLINK-2324 ] [streaming] ITCase added for partitioned states
gyfora
committedJul 30, 2015