Commits

Commit history

1. 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
     f0b28bfView commit details

     Copy full SHA for f0b28bf

     Browse repository at this point
2. Commits on Nov 10, 2023

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

     gyfora

     authored
     ba752b9View commit details

     Copy full SHA for ba752b9

     Browse repository at this point
3. Commits on Oct 22, 2023

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

     gyfora

     authored
     76dda5dView commit details

     Copy full SHA for 76dda5d

     Browse repository at this point
4. Commits on Jul 19, 2023

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

     

     gyfora

     authored and

     zentol

     committed
     6b3d291View commit details

     Copy full SHA for 6b3d291

     Browse repository at this point
5. Commits on Jun 1, 2023

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

     

     gyfora

     authored and

     reswqa

     committed
     3b9f7cfView commit details

     Copy full SHA for 3b9f7cf

     Browse repository at this point
6. Commits on May 30, 2023

   • [FLINK-31997] Upgrade to fabric8 6.6.2

     gyfora

     authored
     c5808b0View commit details

     Copy full SHA for c5808b0

     Browse repository at this point
7. Commits on Jan 12, 2023

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

     gyfora

     committed
     fb482feView commit details

     Copy full SHA for fb482fe

     Browse repository at this point
8. Commits on Nov 29, 2022

   • [FLINK-30090] Support timespan for TimerGauges

     gyfora

     committed
     a7fdab8View commit details

     Copy full SHA for a7fdab8

     Browse repository at this point
9. Commits on Apr 4, 2022

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

     gyfora

     authored
     a5a31deView commit details

     Copy full SHA for a5a31de

     Browse repository at this point
10. Commits on Sep 24, 2019

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

      Show description for de92c69
      gyfora

      committed
      de92c69View commit details

      Copy full SHA for de92c69

      Browse repository at this point
11. Commits on Sep 5, 2019

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

      Show description for 7bda6f6
      gyfora

      committed
      7bda6f6View commit details

      Copy full SHA for 7bda6f6

      Browse repository at this point
12. Commits on Nov 29, 2017

    • [FLINK-8165] ParameterTool serialization fix

      Show description for 731896a
      

      gyfora

      authored and

      aljoscha

      committed
      731896aView commit details

      Copy full SHA for 731896a

      Browse repository at this point
13. 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
      c09ff03View commit details

      Copy full SHA for c09ff03

      Browse repository at this point
14. Commits on Apr 21, 2016

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

      gyfora

      committed
      7478cbaView commit details

      Copy full SHA for 7478cba

      Browse repository at this point

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

      Show description for d45cb69
      gyfora

      committed
      d45cb69View commit details

      Copy full SHA for d45cb69

      Browse repository at this point

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

      Show description for d636bf7
      gyfora

      committed
      d636bf7View commit details

      Copy full SHA for d636bf7

      Browse repository at this point
15. Commits on Mar 16, 2016

    • [FLINK-3620] [streaming] Remove DbStateBackend

      Show description for 33f4311
      gyfora

      committed
      33f4311View commit details

      Copy full SHA for 33f4311

      Browse repository at this point
16. Commits on Feb 15, 2016

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

      Show description for b17632d
      gyfora

      committed
      b17632dView commit details

      Copy full SHA for b17632d

      Browse repository at this point
17. Commits on Nov 29, 2015

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

      Show description for 3e9d33e
      gyfora

      committed
      3e9d33eView commit details

      Copy full SHA for 3e9d33e

      Browse repository at this point
18. Commits on Nov 25, 2015

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

      Show description for 90c76ad
      gyfora

      committed
      90c76adView commit details

      Copy full SHA for 90c76ad

      Browse repository at this point
19. 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
      db2a964View commit details

      Copy full SHA for db2a964

      Browse repository at this point

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

      gyfora

      committed
      cd8be0bView commit details

      Copy full SHA for cd8be0b

      Browse repository at this point

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

      gyfora

      committed
      43b8e57View commit details

      Copy full SHA for 43b8e57

      Browse repository at this point

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

      gyfora

      committed
      c254bdaView commit details

      Copy full SHA for c254bda

      Browse repository at this point

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

      gyfora

      committed
      347e6f7View commit details

      Copy full SHA for 347e6f7

      Browse repository at this point

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

      gyfora

      committed
      75a7c4bView commit details

      Copy full SHA for 75a7c4b

      Browse repository at this point

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

      gyfora

      committed
      ad6f826View commit details

      Copy full SHA for ad6f826

      Browse repository at this point
20. Commits on Oct 6, 2015

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

      

      gyfora

      authored and

      mbalassi

      committed
      4c5d43bView commit details

      Copy full SHA for 4c5d43b

      Browse repository at this point
21. Commits on Oct 4, 2015

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

      Show description for 88a9776
      gyfora

      committed
      88a9776View commit details

      Copy full SHA for 88a9776

      Browse repository at this point
22. 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
      63d9800View commit details

      Copy full SHA for 63d9800

      Browse repository at this point
23. Commits on Sep 18, 2015

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

      gyfora

      committed
      3e233a3View commit details

      Copy full SHA for 3e233a3

      Browse repository at this point
24. Commits on Sep 14, 2015

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

      Show description for 8a75025
      gyfora

      committed
      8a75025View commit details

      Copy full SHA for 8a75025

      Browse repository at this point
25. Commits on Aug 2, 2015

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

      Show description for 83102f0
      gyfora

      committed
      83102f0View commit details

      Copy full SHA for 83102f0

      Browse repository at this point
26. Commits on Jul 30, 2015

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

      Show description for 83e14cb
      gyfora

      committed
      83e14cbView commit details

      Copy full SHA for 83e14cb

      Browse repository at this point

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

      gyfora

      committed
      58cd4eaView commit details

      Copy full SHA for 58cd4ea

      Browse repository at this point