Commits

Branch selector

 main

User selector

mxm

All time

Commit History

Commits on Sep 29, 2025

• Flink: Backport #14182: Ensure DynamicCommitter Idempotence in the presence of failures (#14213)

  mxm

  authored
  441597e

  Copy full SHA for 441597e

• Flink: Ensure DynamicCommitter Idempotence in the presence of failures (#14182)

  mxm

  authored
  3860284

  Copy full SHA for 3860284

Commits on Sep 19, 2025

• Flink: Remove support for Flink 1.19

  

  mxm

  authored and

  stevenzwu

  committed
  487ea1a

  Copy full SHA for 487ea1a

• Flink: Code changes for Flink 2.1

  

  mxm

  authored and

  stevenzwu

  committed
  c56f497

  Copy full SHA for c56f497

• Flink: Adjust build scripts for Flink 2.1

  

  mxm

  authored and

  stevenzwu

  committed
  58da086

  Copy full SHA for 58da086

• Flink: Add back v2.0 directory

  

  mxm

  authored and

  stevenzwu

  committed
  f4d892e

  Copy full SHA for f4d892e

• Flink: Move Flink v2.0 to v2.1 directory

  

  mxm

  authored and

  stevenzwu

  committed
  ded2d0a

  Copy full SHA for ded2d0a

Commits on Sep 12, 2025

• Docs: Update supported Flink versions (#13611)

  mxm

  authored
  723d099

  Copy full SHA for 723d099

Commits on Sep 11, 2025

• Flink: Backport fix flaky tests for Iceberg sink (#14050)

  Show description for d177120
  mxm

  authored
  d177120

  Copy full SHA for d177120

• Flink: Fix flaky tests for Iceberg sink and improve assert description (#14044)

  mxm

  authored
  a5f6f44

  Copy full SHA for a5f6f44

Commits on Aug 19, 2025

• Docs: Fix table of contents in Flink docs (#13864)

  mxm

  authored
  0478ff7

  Copy full SHA for 0478ff7

Commits on Jul 24, 2025

• Flink: Backport: DynamicSink: Convert existing required fields to optional when missing in the data schema (#13660)

  Show description for 16012af
  mxm

  authored
  16012af

  Copy full SHA for 16012af

• Backport: Flink: Clean up UpdateSchema instantiator method in TestEvolveSchemaVisitor (#13658)

  Show description for a5bae2f
  mxm

  authored
  a5bae2f

  Copy full SHA for a5bae2f

• Flink: DynamicSink: Convert existing required fields to optional when missing in the data schema (#13659)

  mxm

  authored
  be4db90

  Copy full SHA for be4db90

• Flink: Dynamic Sink: Ensure parent for newly added struct is resolved from current schema (#13656)

  Show description for 60edd9b
  mxm

  authored
  60edd9b

  Copy full SHA for 60edd9b

• Flink: Clean up UpdateSchema instantiator method in TestEvolveSchemaVisitor (#13640)

  mxm

  authored
  a8c3a59

  Copy full SHA for a8c3a59

Commits on Jul 23, 2025

• Flink: Dynamic Sink: Ensure parent for newly added struct is resolved from current schema (#13639)

  mxm

  authored
  ae7636c

  Copy full SHA for ae7636c

Commits on Jun 18, 2025

• Flink: Backport dynamic Iceberg Sink: Rename method in DynamicRecordGenerator to Flink 1.19 / 1.20 (#13346)

  mxm

  authored
  e473519

  Copy full SHA for e473519

• Flink: Dynamic Iceberg Sink: Rename method in DynamicRecordGenerator (#13342)

  mxm

  authored
  cea7f9c

  Copy full SHA for cea7f9c

• Flink: Backport dynamic Iceberg Sink: Add sink / core processing logic / benchmarking to Flink 1.19 / 1.20 (#13341)

  Show description for 81b74fc
  mxm

  authored
  81b74fc

  Copy full SHA for 81b74fc

Commits on Jun 17, 2025

• Flink: Dynamic Iceberg Sink: Add sink / core processing logic / benchmarking (#13304)

  mxm

  authored
  68651a3

  Copy full SHA for 68651a3

Commits on Jun 12, 2025

• Flink: Backport dynamic Iceberg Sink: Add HashKeyGenerator / RowDataEvolver / TableUpdateOperator to Flink 1.19 / 1.20 (#13303)

  Show description for e141ff7
  mxm

  authored
  e141ff7

  Copy full SHA for e141ff7

Commits on Jun 11, 2025

• Flink: Dynamic Iceberg Sink: Add HashKeyGenerator / RowDataEvolver / TableUpdateOperator (#13277)

  mxm

  authored
  76972ef

  Copy full SHA for 76972ef

Commits on Jun 5, 2025

• Flink: Backport Dynamic Iceberg Sink: Add dynamic writer and committer to Flink 1.19 / 1.20 (#13248)

  Show description for e631db6
  mxm

  authored
  e631db6

  Copy full SHA for e631db6

• Flink: Backport Dynamic Iceberg Sink: Add table update code for schema comparison and evolution to Flink 1.19 / 1.20 (#13247)

  Show description for 6c9e641
  mxm

  authored
  6c9e641

  Copy full SHA for 6c9e641

• Flink: Backport add DynamicRecord / DynamicRecordInternal / DynamicRecordInternalSerializer to Flink 1.19 / 1.20 (#13246)

  Show description for 1996ff9
  mxm

  authored
  1996ff9

  Copy full SHA for 1996ff9

Commits on Jun 4, 2025

• Flink: Dynamic Iceberg Sink: Add dynamic writer and committer (#13080)

  mxm

  authored
  b8cc8eb

  Copy full SHA for b8cc8eb

• Flink: Dynamic Iceberg Sink: Add table update code for schema comparison and evolution (#13032)

  mxm

  authored
  1260522

  Copy full SHA for 1260522

Commits on May 14, 2025

• Flink: Add DynamicRecord / DynamicRecordInternal / DynamicRecordInternalSerializer (#12996)

  mxm

  authored
  268661a

  Copy full SHA for 268661a

Commits on Apr 23, 2025

• Flink: Remove Flink 1.18 support

  

  mxm

  authored and

  stevenzwu

  committed
  d7f8e54

  Copy full SHA for d7f8e54

• Flink: Add support for Flink 2.0

  

  mxm

  authored and

  stevenzwu

  committed
  b6477ed

  Copy full SHA for b6477ed

• Flink: Copy back v1.20 directory

  

  mxm

  authored and

  stevenzwu

  committed
  f5489ae

  Copy full SHA for f5489ae

• Flink: Move v1.20 to v2.0 directory

  

  mxm

  authored and

  stevenzwu

  committed
  e996688

  Copy full SHA for e996688

Commits on Feb 5, 2025

• Flink: Add null check to writers to prevent resurrecting null values (#12049)

  mxm

  authored
  d990dbc

  Copy full SHA for d990dbc

Commits on Jan 21, 2025

• Flink: Upgrade Flink version 1.19.0 => 1.19.1 (#12021)

  mxm

  authored
  8dee55d

  Copy full SHA for 8dee55d