)]}'
{
  "commit": "72a35e5c9533411328fa672b45434b56c457291b",
  "tree": "7c7373d613b9aa20cd7e745399e8e9a61220e442",
  "parents": [
    "8e5821dad5850f4ab9acf58b1bf04cd85b3afe3f"
  ],
  "author": {
    "name": "Natea Eshetu Beshada",
    "email": "nbeshada+git@confluent.io",
    "time": "Wed Feb 04 02:38:29 2026 -0800"
  },
  "committer": {
    "name": "Rui Fan",
    "email": "1996fanrui@gmail.com",
    "time": "Sat May 23 12:30:26 2026 +0200"
  },
  "message": "[FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records\n\nWhen finishBundle() encounters a key with only retraction messages and no\nexisting state, it now uses \u0027continue\u0027 instead of \u0027return\u0027 to skip that key\nand continue processing remaining keys in the bundle.\n\nThis change adds a unit test using KeyedOneInputStreamOperatorTestHarness\nwith KeyedMapBundleOperator to verify the fix.\n",
  "tree_diff": [
    {
      "type": "modify",
      "old_id": "df3f5248a92e5037831ff10234a34a8c26da9bd1",
      "old_mode": 33188,
      "old_path": "flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/MiniBatchGroupAggFunction.java",
      "new_id": "2732bfd2603335e6582c19da6231b5282a3b4dba",
      "new_mode": 33188,
      "new_path": "flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/MiniBatchGroupAggFunction.java"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "de05aa440f59d804fdbdf3491434bbfc8cacbdad",
      "new_mode": 33188,
      "new_path": "flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/aggregate/MiniBatchGroupAggFunctionTest.java"
    }
  ]
}