)]}'
{
  "commit": "72027e11d1f2f613e53302394534b204182cc32c",
  "tree": "c52f45be2d7edd9bc2aa6955883b804321307c47",
  "parents": [
    "06dd48e9313ca81d8d0739b03d0850f129c08e56"
  ],
  "author": {
    "name": "Yi Hu",
    "email": "yathu@google.com",
    "time": "Wed Feb 25 17:49:01 2026 -0500"
  },
  "committer": {
    "name": "GitHub",
    "email": "noreply@github.com",
    "time": "Wed Feb 25 17:49:01 2026 -0500"
  },
  "message": "Fix DebeziumIO resuming from worker restart (#37689)\n\n* Fix DebeziumIO resuming from worker restart\n\n* Move startTime recording into setup to fix NPE in restarted worker\n\n* Fix DebeziumIO poll loop not exiting when record list isn\u0027t empty\n\n* Make pollTimeout configurable\n\n* Include first poll in stopWatch\n\n* Fix pipeline terminate when poll returns null, which is valid per spec\n\n* Adjust MaxNumRecord logic after previous fix. Previously if there is\n  in total N\u003dMaxNumRecord records the pipeline won\u0027t finish until N+1 record\n  appears. The test relied on null poll to return actually",
  "tree_diff": [
    {
      "type": "modify",
      "old_id": "e56ac370b7057411dedfdaddbafcb40fd4acf466",
      "old_mode": 33188,
      "old_path": "sdks/java/io/debezium/src/README.md",
      "new_id": "5352132188560bf4ae0b282d32d167148825864c",
      "new_mode": 33188,
      "new_path": "sdks/java/io/debezium/src/README.md"
    },
    {
      "type": "modify",
      "old_id": "b38c035adf2d6a13bc1d4203863c2f769b6d75f7",
      "old_mode": 33188,
      "old_path": "sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumIO.java",
      "new_id": "ebf91a4a095775b67ba2a672e6239ca85ab510fb",
      "new_mode": 33188,
      "new_path": "sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumIO.java"
    },
    {
      "type": "modify",
      "old_id": "00d7e6ac7411e1e4d6a0e39891c15aa159491cd0",
      "old_mode": 33188,
      "old_path": "sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/KafkaSourceConsumerFn.java",
      "new_id": "fb4c2f21458faaf883a77f638c8ab68c942c4160",
      "new_mode": 33188,
      "new_path": "sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/KafkaSourceConsumerFn.java"
    },
    {
      "type": "modify",
      "old_id": "1df50b5e9acde2375d068f65ae7e38e11e0d1f02",
      "old_mode": 33188,
      "old_path": "sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/KafkaSourceConsumerFnTest.java",
      "new_id": "354e2589753d6431b8df3e4493ecb6ee01f47900",
      "new_mode": 33188,
      "new_path": "sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/KafkaSourceConsumerFnTest.java"
    },
    {
      "type": "modify",
      "old_id": "dc4338ac04858c4f8480cb3004a8f5a60260f6e9",
      "old_mode": 33188,
      "old_path": "sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/OffsetTrackerTest.java",
      "new_id": "c4ddfbef4f2b4cd7de2e38bef9249a781600f947",
      "new_mode": 33188,
      "new_path": "sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/OffsetTrackerTest.java"
    }
  ]
}