Commits

Commits on Mar 12, 2023

[FLINK-31401][streaming][tests] Make parallelism assumption explicit in StreamingJobGraphGeneratorTest
mbalassi
committedMar 12, 2023

Commits on Jan 18, 2023

[FLINK-30704][build] Skip SBOM creation in fast profile
mbalassi
committedJan 18, 2023

Commits on Jan 4, 2023

[hotfix][docs] Fix documentation build
mbalassi
committedJan 4, 2023

Commits on Dec 7, 2016

[hotfix][webfrontend] Added non-binary image assets to license check exceptions
mbalassi
committedDec 7, 2016

Commits on Nov 24, 2016

[FLINK-3702] FieldAccessor refactor to static factory
mbalassi
committedNov 24, 2016

Commits on Aug 3, 2016

[build] Bump version to 1.2-SNAPSHOT

mbalassi
authored and
StephanEwen
committedAug 3, 2016

Commits on Mar 20, 2016

[FLINK-3636] Add ThrottledIterator to WindowJoin jar
mbalassi
committedMar 20, 2016

Commits on Mar 11, 2016

[build] Consolidate scala checkstyle usage and update version to 0.8.0
mbalassi
committedMar 11, 2016

Commits on Mar 2, 2016

[FLINK-3422][streaming] Update tests reliant on hashing
mbalassi
committedMar 2, 2016

Commits on Feb 4, 2016

[streaming] [scala] Scala wrapper for DataStreamUtils

mbalassi
authored and
StephanEwen
committedFeb 4, 2016
[streaming] [scala] Revert removing getJavaStream() from DataStream

mbalassi
authored and
StephanEwen
committedFeb 4, 2016

Commits on Jan 30, 2016

[streaming] [scala] Exposed environment from DataStream
mbalassi
committedJan 30, 2016

Commits on Sep 24, 2015

[utils] Missing getters for ParameterTool
mbalassi
committedSep 24, 2015

Commits on Aug 27, 2015

[FLINK-2499] [scripts] Warning message for hosts starting multiple daemons
mbalassi
committedAug 27, 2015

Commits on Aug 18, 2015

[FLINK-2286] [streaming] ITCase for ParallelMerge behavior
mbalassi
committedAug 18, 2015

Commits on Aug 11, 2015

[FLINK-2423] [streaming] ITCase for checkpoint notifications
mbalassi
committedAug 11, 2015
[streaming] [tests] Checkpointing tests refactor & cleanup
mbalassi
committedAug 11, 2015

Commits on Jul 3, 2015

[streaming] Minor streaming code cleanups
mbalassi
committedJul 3, 2015
[FLINK-2285] [streaming] Removed duplicate call in close from GroupedActiveDiscretizer
mbalassi
committedJul 3, 2015

Commits on Jun 25, 2015

[FLINK-2257] [streaming] Properly forward rich window function calls to wrapped functions
mbalassi
committedJun 25, 2015

Commits on Jun 18, 2015

Version bumped to 0.10-SNAPSHOT
mbalassi
committedJun 18, 2015

Commits on Jun 16, 2015

[build] merge transitive notice files to shaded notices

mbalassi
authored and
mxm
committedJun 16, 2015
[docs] Update obsolate cluster execution guide
mbalassi
committedJun 16, 2015
[FLINK-2209] [docs] Document linking with jars not in the binary dist
mbalassi
committedJun 16, 2015
[FLINK-2221] [docs] Docs for not using local filesystem on the cluster as state backup
mbalassi
committedJun 16, 2015

Commits on Jun 15, 2015

[contrib] Added log properties files to contrib & minor clean ups
mbalassi
committedJun 15, 2015

Commits on Jun 14, 2015

[storm-compat] Moved Storm-compatibility to flink-contrib and split flink-contrib into small sub-projects
mbalassi
committedJun 14, 2015

Commits on Jun 12, 2015

[streaming] [api-breaking] Minor DataStream cleanups
mbalassi
committedJun 12, 2015
[build] [streaming] Streaming parents dependencies pushed to children
mbalassi
committedJun 12, 2015
[streaming] Logging update for checkpointed streaming topologies
mbalassi
committedJun 12, 2015