)]}'
{
  "commit": "fce246bda5d2a17edd6d793f3b6cb54deb18872d",
  "tree": "77559a592d361ddf348ec3c324e84af6861bb8d2",
  "parents": [
    "5e13440321e1844adba3a75e6415d3ec08d60e9a"
  ],
  "author": {
    "name": "hqbfz",
    "email": "125714719+3424672656@users.noreply.github.com",
    "time": "Thu Mar 06 17:18:02 2025 +0800"
  },
  "committer": {
    "name": "GitHub",
    "email": "noreply@github.com",
    "time": "Thu Mar 06 17:18:02 2025 +0800"
  },
  "message": "[RIP-74] Implement dynamic load balancing in Flink-Connector-RocketMQ (#126)\n\n",
  "tree_diff": [
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "70a72062fd484ab0336234235003df001b9ddab7",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "af8c4e315cc312b7db9b8705ac4c10df3b1a184f",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "347ec51d61e90c0688b123283a41e756a19a0629",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "d8502568649169f8095b1da8fe352eecda9e52a6",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "dbb32c2ec45ac69f64dc2aec0c651a06bf147ed8",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/common/lock/SpinLock.java"
    },
    {
      "type": "modify",
      "old_id": "bedf97f856940fa741e2fddd5a415d15ee22aec0",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java",
      "new_id": "91d1d39d024c64edec0289839a738666e580f5a4",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java"
    },
    {
      "type": "modify",
      "old_id": "317031f20f7c41ea2ff9608800355e42941037c2",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java",
      "new_id": "a76a198daa4270a78cd1f726b742af7d202b67b4",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java"
    },
    {
      "type": "modify",
      "old_id": "25fd8c7513e9923d98f9196d6bc21f78316bbc8d",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java",
      "new_id": "cfdc0a1427f652597023355ff9bf9fb66f008033",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java"
    },
    {
      "type": "modify",
      "old_id": "805df1b5b5334c90744b3bb03b9516618af3264b",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java",
      "new_id": "960e6228a7770ed99089eefd9e0f3d72420fc96a",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java"
    },
    {
      "type": "modify",
      "old_id": "77c0c338dc9acdf4ebe50cc8baf7702d966b9144",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java",
      "new_id": "c228309e86d7ff732782d9a7c92b86a40013daf4",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java"
    },
    {
      "type": "modify",
      "old_id": "bfd814e88e2bf0344eb119adcfa3077b887a2ad6",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java",
      "new_id": "6386b2293a948ed5b21494ff2f48634ba7ef0556",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java"
    },
    {
      "type": "modify",
      "old_id": "6c9d72355d5f154709ac52210651c6f1c27110ad",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java",
      "new_id": "442afb9d03ff02d387a013ad694bd6f8740eefa6",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "f808133b5461d7dcc6eb4cab96b08b67480a927a",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java"
    },
    {
      "type": "modify",
      "old_id": "2e46419b3017036768de50420166c810c2ac93b2",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java",
      "new_id": "f37cf046ecbd3cd46b73568264117f145dd0dc98",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java"
    },
    {
      "type": "modify",
      "old_id": "6a3ad2c4f6f733d404afd11167aa5d34ae764172",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java",
      "new_id": "7cd10c4e6ad737fb43c948d5e422f4c3c94c75d5",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java"
    },
    {
      "type": "modify",
      "old_id": "09c10498721afdf53d121af93d5d9f5578f52a01",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java",
      "new_id": "57c8a6381494bd19388ce8bcd262a52d9189ddad",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java"
    },
    {
      "type": "modify",
      "old_id": "a635b17572650cebcb23bec4d8462c8c59f41dcf",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java",
      "new_id": "242e19e6a19b17cefb4566828ea5fbf30160e34d",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java"
    },
    {
      "type": "modify",
      "old_id": "9303f3597e20594e7d5c206b133a54ab5e5aca71",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java",
      "new_id": "042c12af9824457060e65c2b19881a5c2ad2fd8a",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java"
    },
    {
      "type": "modify",
      "old_id": "3a079665c4fdb20b51a343f7baaca65bd945c18a",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java",
      "new_id": "9a0833c202981eebe298762d69230daa83252043",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java"
    },
    {
      "type": "modify",
      "old_id": "36c7a0f40ac53a5e1b5b5f11ff7cde1dd72e5269",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java",
      "new_id": "eb37e19a9b86ed5b7fb1e9b8b97dc0ea3066c132",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java"
    },
    {
      "type": "modify",
      "old_id": "71240869c128bac6f9d57c233719adc227e4127c",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java",
      "new_id": "a94044da79d1b5f25f7570468e3016649d216bad",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java"
    },
    {
      "type": "modify",
      "old_id": "ca74d582697a2fa5f62e71001fe6467aca1e1b92",
      "old_mode": 33188,
      "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java",
      "new_id": "5f16a809d4105f4bd618880aae2b5e735ef01d3e",
      "new_mode": 33188,
      "new_path": "src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java"
    },
    {
      "type": "modify",
      "old_id": "08371b3350a4302a6076dcf83e95911d39915981",
      "old_mode": 33188,
      "old_path": "src/test/java/org/apache/flink/connector/rocketmq/legacy/sourceFunction/RocketMQSourceFunctionTest.java",
      "new_id": "78ffd17f63fac66875030dc5fc043b09ade42779",
      "new_mode": 33188,
      "new_path": "src/test/java/org/apache/flink/connector/rocketmq/legacy/sourceFunction/RocketMQSourceFunctionTest.java"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "f63c8d17465988b55a8304dd372e024d5c9c4d20",
      "new_mode": 33188,
      "new_path": "src/test/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategyTest.java"
    },
    {
      "type": "modify",
      "old_id": "f1fa5af1719ca1d02a6ea55e83ea27feb04caf1a",
      "old_mode": 33188,
      "old_path": "src/test/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializerTest.java",
      "new_id": "432994e3fdcf422096eb089ce76c3db69cf854ae",
      "new_mode": 33188,
      "new_path": "src/test/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializerTest.java"
    }
  ]
}