Commits

Branch selector

 master

User selector

gyfora

Datepicker

All time

Commit History

Commits on Jan 12, 2024

• Revert "[FLINK-33973] Add new interfaces for SinkV2 to synchronize the API with the SourceV2 API"

  Show description for f0b28bf
  gyfora

  committed
  f0b28bf

Commits on Nov 10, 2023

• [FLINK-32380] Support Java Records with PojoTypeInfo/Serializer

  gyfora

  authored
  ba752b9

Commits on Oct 22, 2023

• [FLINK-33318] Expose aggregated collector metrics and measure timeMsPerSecond

  gyfora

  authored
  76dda5d

Commits on Jul 19, 2023

• [FLINK-32623] Return correct vertex resource lower bound

  

  gyfora

  authored and

  zentol

  committed
  6b3d291

Commits on Jun 1, 2023

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

  

  gyfora

  authored and

  reswqa

  committed
  3b9f7cf

Commits on May 30, 2023

• [FLINK-31997] Upgrade to fabric8 6.6.2

  gyfora

  authored
  c5808b0

Commits on Jan 12, 2023

• [FLINK-30213] Fix logic for determining downstream subtasks for partitioner replacement

  gyfora

  committed
  fb482fe

Commits on Nov 29, 2022

• [FLINK-30090] Support timespan for TimerGauges

  gyfora

  committed
  a7fdab8

Commits on Apr 4, 2022

• [FLINK-26368] [kafka] Add setProperty method to KafkaSinkBuilder

  gyfora

  authored
  a5a31de

Commits on Sep 24, 2019

• [FLINK-14145] Fix getLatestCheckpoint(true) returns wrong checkpoint

  Show description for de92c69
  gyfora

  committed
  de92c69

Commits on Sep 5, 2019

• [FLINK-13842][docs] Improve Javadocs and web documentation of the StreamingFileSink

  Show description for 7bda6f6
  gyfora

  committed
  7bda6f6

Commits on Nov 29, 2017

• [FLINK-8165] ParameterTool serialization fix

  Show description for 731896a
  

  gyfora

  authored and

  aljoscha

  committed
  731896a

Commits on Aug 24, 2016

• [FLINK-4441] Make RocksDB backend return null on empty state + add test for all backends

  Show description for c09ff03
  gyfora

  committed
  c09ff03

Commits on Apr 21, 2016

• [hotfix] [FLINK-3798] Make RocksDB state classes also public

  gyfora

  committed
  7478cba

• [FLINK-3790] [streaming] Use proper hadoop config in rolling sink

  Show description for d45cb69
  gyfora

  committed
  d45cb69

• [FLINK-3798] [streaming] Clean up RocksDB backend field/method access

  Show description for d636bf7
  gyfora

  committed
  d636bf7

Commits on Mar 16, 2016

• [FLINK-3620] [streaming] Remove DbStateBackend

  Show description for 33f4311
  gyfora

  committed
  33f4311

Commits on Feb 15, 2016

• [FLINK-3354] Determine correct size for RocksDB snapshots

  Show description for b17632d
  gyfora

  committed
  b17632d

Commits on Nov 29, 2015

• [FLINK-3075] Change Either creation method names and expose Right/Left classes

  Show description for 3e9d33e
  gyfora

  committed
  3e9d33e

Commits on Nov 25, 2015

• [FLINK-3072] [streaming] Ensure Derby server starts before running any tests

  Show description for 90c76ad
  gyfora

  committed
  90c76ad

Commits on Nov 24, 2015

• [FLINK-2924] [streaming] Execute compactions in background thread + keep connections alive on empty snapshots

  Show description for db2a964
  gyfora

  committed
  db2a964

• [FLINK-2924] [streaming] Use short job id for table names

  gyfora

  committed
  cd8be0b

• [FLINK-2924] [streaming] Improve compacting logic

  gyfora

  committed
  43b8e57

• [FLINK-2924] [streaming] Use timestamps to store checkpoints so it supports job shutdown/restart

  gyfora

  committed
  c254bda

• [FLINK-2924] [streaming] Improved sharding logic

  gyfora

  committed
  347e6f7

• [FLINK-2924] [streaming] Out-of-core state backend for JDBC databases

  gyfora

  committed
  75a7c4b

• [FLINK-2916] [streaming] Expose operator and task information to StateBackend

  gyfora

  committed
  ad6f826

Commits on Oct 6, 2015

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

  

  gyfora

  authored and

  mbalassi

  committed
  4c5d43b

Commits on Oct 4, 2015

• [FLINK-2802] [streaming] Remove cyclic watermark dependencies for iterations

  Show description for 88a9776
  gyfora

  committed
  88a9776

Commits on Sep 21, 2015

• [FLINK-2713] [streaming] Set state restore to lazy to avoid StateCheckpointer issues and reduce checkpoint overhead

  Show description for 63d9800
  gyfora

  committed
  63d9800

Commits on Sep 18, 2015

• [FLINK-2707] [streaming] Set StateCheckpointer before default state value

  gyfora

  committed
  3e233a3

Commits on Sep 14, 2015

• [FLINK-2664] [streaming] Allow partitioned state removal

  Show description for 8a75025
  gyfora

  committed
  8a75025

Commits on Aug 2, 2015

• [FLINK-2436] [streaming] Make ByteStreamStateHandles more robust

  Show description for 83102f0
  gyfora

  committed
  83102f0

Commits on Jul 30, 2015

• [FLINK-2324] [streaming] Added test for different StateHandle wrappers

  Show description for 83e14cb
  gyfora

  committed
  83e14cb

• [FLINK-2324] [streaming] ITCase added for partitioned states

  gyfora

  committed
  58cd4ea

Pagination

PreviousNext