)]}' { "commit": "3d803c292059f21a90c578904139e21fa9642f9e", "tree": "f962fb2cab8058e4c8cfb289fff34b1d5d804bd9", "parents": [ "fce246bda5d2a17edd6d793f3b6cb54deb18872d" ], "author": { "name": "lizhimins", "email": "707364882@qq.com", "time": "Wed Jul 22 11:56:35 2026 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Jul 22 11:56:35 2026 +0800" }, "message": "[ISSUE #133] refactor: restructure to multi-module layout and harden the remoting connector (#134)\n\nSplit the single-module project into flink-connector-rocketmq +\nflink-sql-connector-rocketmq, move legacy classes under\nstreaming.connectors.rocketmq, and fix a batch of issues found in\nreview and verified against an Aliyun commercial instance:\n\n- implement the no-op SQL row deserialization (source rows were empty)\n- close the producer in RocketMQWriter, rework AT_LEAST_ONCE to async\n send with pending counter and flush barrier, call\n serializationSchema.open() on construction\n- propagate fetch()/fetchOffsets failures instead of swallowing them\n- add consumer-side fallback for min/max/committed/timestamp offset\n lookup when admin broker-name resolution fails on cloud instances\n- implement sanityCheck() in source/sink builders\n- apply parameter passthrough fixes (send timeout/retry, batch size,\n namespace, filters, scan.mode auto-infer, transaction timeout unit)\n- wire USE_TLS, MQ_CLIENT_API_TIMEOUT, CLIENT_CALLBACK_EXECUTOR_THREADS\n and the pull flow-control options; drop dead options and unused code\n\nTests: migrate unit tests to the new layout and add manual integration\ntests against a real commercial instance (FLIP-27 datastream pipeline,\nEXACTLY_ONCE two-phase commit, SQL DDL end-to-end); credentials are\nread from the environment.\n\nCI and docs: add GitHub Actions (spotless:check + clean package on a\nJDK 11/17 matrix, replacing the stale .travis.yml), rewrite the README\nfollowing the official Flink connector layout, split detailed\nconfiguration into docs/ (remoting-connector.md, sql-connector.md,\nlegacy-connector.md) and add url/licenses/mailing lists to the pom.", "tree_diff": [ { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "7f8acaa97d5745412b106b0748d25b8d16ee3958", "new_mode": 33188, "new_path": ".github/workflows/build.yml" }, { "type": "modify", "old_id": "7c74295c84c65aec1ffe818cd893ede587a66c6d", "old_mode": 33188, "old_path": ".gitignore", "new_id": "b16b39388b1dbb9610aa10d6836c923358d6faf6", "new_mode": 33188, "new_path": ".gitignore" }, { "type": "delete", "old_id": "17624cac0ae63773f2e26d287ac4517a9518be35", "old_mode": 33188, "old_path": ".travis.yml", "new_id": "0000000000000000000000000000000000000000", "new_mode": 0, "new_path": "/dev/null" }, { "type": "modify", "old_id": "67d04dea60c81f7bbd9bb8ee188cc2e10a629a49", "old_mode": 33188, "old_path": "README.md", "new_id": "37084b22867a143a81cffa75d3e40c17f39e7aca", "new_mode": 33188, "new_path": "README.md" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "0d2cb6521ee8ed43e0d50a284261d45418cf71d4", "new_mode": 33188, "new_path": "docs/connector-overview.md" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "a799a673daf0c0f36ddc62401748976a472c4391", "new_mode": 33188, "new_path": "docs/grpc-connector.md" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "1a2bb66741d0f24a2f8933ae59104fe79572f2c0", "new_mode": 33188, "new_path": "docs/legacy-connector.md" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "74981f2b4ac939ae34dec7f940c24ab6be967b7b", "new_mode": 33188, "new_path": "docs/remoting-connector.md" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "9f0b015bf40ced3e75ed8108a6c39682029f52cf", "new_mode": 33188, "new_path": "docs/sql-connector.md" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "8f71191a5b8abaa1372334d2c02f9ca178a7e3fe", "new_mode": 33188, "new_path": "flink-connector-rocketmq/pom.xml" }, { "type": "rename", "old_id": "e56e2e470c5ff5f6104e6703466d3e1b943a8029", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java", "new_id": "e56e2e470c5ff5f6104e6703466d3e1b943a8029", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java", "score": 100 }, { "type": "rename", "old_id": "67b048d6b7f4fc046ee018b61b41fee5834a2198", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactory.java", "new_id": "67b048d6b7f4fc046ee018b61b41fee5834a2198", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactory.java", "score": 100 }, { "type": "rename", "old_id": "308a1a36ffc6a9e603e980eab53f41c568e1cafd", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactoryOptions.java", "new_id": "870809be0f8f74f5e6a6a5839bedd452aa865d56", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactoryOptions.java", "score": 94 }, { "type": "rename", "old_id": "7b610a7b599c4f58db4ad0daa4b1117dd71265ee", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java", "new_id": "7b610a7b599c4f58db4ad0daa4b1117dd71265ee", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java", "score": 100 }, { "type": "rename", "old_id": "96610426f84e8a1a4b66f17e02cf1393f9e01bbe", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigValidator.java", "new_id": "39ada1073885abcba57d0d88c2521c45fee9257d", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigValidator.java", "score": 89 }, { "type": "rename", "old_id": "a698fd4329adbf1b6cbea1592d0c077cb15bb0fc", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfiguration.java", "new_id": "a698fd4329adbf1b6cbea1592d0c077cb15bb0fc", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfiguration.java", "score": 100 }, { "type": "rename", "old_id": "444db5955b090458dbceb6f251e6d194ccdc6884", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java", "new_id": "3df6b418ce41b3b351a4ea3ce1ce9811bad3f692", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java", "score": 82 }, { "type": "rename", "old_id": "bed9418f58d3890b9e1d4ee305e02a1688680672", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/common/constant/RocketMqCatalogConstant.java", "new_id": "bed9418f58d3890b9e1d4ee305e02a1688680672", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/common/constant/RocketMqCatalogConstant.java", "score": 100 }, { "type": "rename", "old_id": "416bb0f639694e95ba1ac3671c3b6cee9c134f77", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/common/constant/SchemaRegistryConstant.java", "new_id": "dc999fbccdb579924a111dc31cbcab30796d7889", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/common/constant/SchemaRegistryConstant.java", "score": 97 }, { "type": "rename", "old_id": "70a72062fd484ab0336234235003df001b9ddab7", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java", "new_id": "70a72062fd484ab0336234235003df001b9ddab7", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java", "score": 100 }, { "type": "rename", "old_id": "af8c4e315cc312b7db9b8705ac4c10df3b1a184f", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java", "new_id": "af8c4e315cc312b7db9b8705ac4c10df3b1a184f", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java", "score": 100 }, { "type": "rename", "old_id": "347ec51d61e90c0688b123283a41e756a19a0629", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java", "new_id": "347ec51d61e90c0688b123283a41e756a19a0629", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java", "score": 100 }, { "type": "rename", "old_id": "d8502568649169f8095b1da8fe352eecda9e52a6", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java", "new_id": "d8502568649169f8095b1da8fe352eecda9e52a6", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java", "score": 100 }, { "type": "rename", "old_id": "dbb32c2ec45ac69f64dc2aec0c651a06bf147ed8", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/common/lock/SpinLock.java", "new_id": "c4d9845cceb0c36689c5fc7e28ed8adaf1bf97f6", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/common/lock/SpinLock.java", "score": 94 }, { "type": "rename", "old_id": "9d1669bfd5a5adb3ff415bef1be05c63c1b23c0a", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducer.java", "new_id": "9d1669bfd5a5adb3ff415bef1be05c63c1b23c0a", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducer.java", "score": 100 }, { "type": "rename", "old_id": "24897c782018fc74ad73b33461b86121392bbd80", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java", "new_id": "84581b22b2abb0e806f3454b08265df172368bbd", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java", "score": 82 }, { "type": "rename", "old_id": "5ea2fd895c61d9ba8eed29e21550bcc121b5062a", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSink.java", "new_id": "f2562e5957de2edd9157b0e5d4f6568558a6b1ad", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSink.java", "score": 96 }, { "type": "rename", "old_id": "426d43c99eb54ca4f355e070257786f126e3a4b0", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkBuilder.java", "new_id": "5895612a573d3936e9f3c09e1d1f96faf61158be", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkBuilder.java", "score": 90 }, { "type": "rename", "old_id": "0ddd850f72c0ccaf96f56e54fc97b579d971733c", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkOptions.java", "new_id": "61e7263133229d3d143fceb1b1e9022d9c48cccd", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkOptions.java", "score": 79 }, { "type": "rename", "old_id": "da72ac8ccc3a53443a1340f5c4ea8884d40349ea", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/TransactionResult.java", "new_id": "da72ac8ccc3a53443a1340f5c4ea8884d40349ea", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/TransactionResult.java", "score": 100 }, { "type": "rename", "old_id": "55bacca6d4eb3e543257c71189045ace24b0d9f1", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java", "new_id": "4262b7b06e47f87ebe763ad1cbd529a3b3035188", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java", "score": 96 }, { "type": "rename", "old_id": "a69e7372442e98b7bd798d10a7a11c6e72f42ab5", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java", "new_id": "a69e7372442e98b7bd798d10a7a11c6e72f42ab5", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java", "score": 100 }, { "type": "rename", "old_id": "4b64873f228ccac12fc244b67e63b44d31e99848", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittableSerializer.java", "new_id": "4b64873f228ccac12fc244b67e63b44d31e99848", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittableSerializer.java", "score": 100 }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "a5f2a6f5c9356cf9437cff4de0e88940b64f7d77", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java" }, { "type": "rename", "old_id": "24573eb838eb786d3afe2a3f77837bae2533db38", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/writer/context/RocketMQSinkContext.java", "new_id": "24573eb838eb786d3afe2a3f77837bae2533db38", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/writer/context/RocketMQSinkContext.java", "score": 100 }, { "type": "rename", "old_id": "032c1fe40a244983fe9bea8a9a010ada492de649", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/writer/context/RocketMQSinkContextImpl.java", "new_id": "032c1fe40a244983fe9bea8a9a010ada492de649", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/writer/context/RocketMQSinkContextImpl.java", "score": 100 }, { "type": "rename", "old_id": "14591fdde8aa70197ad28eacc293bf507e3ab140", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializationSchema.java", "new_id": "14591fdde8aa70197ad28eacc293bf507e3ab140", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializationSchema.java", "score": 100 }, { "type": "rename", "old_id": "67b5089d263df611b9f72b678474d80722752e70", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializerWrapper.java", "new_id": "67b5089d263df611b9f72b678474d80722752e70", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializerWrapper.java", "score": 100 }, { "type": "rename", "old_id": "09bc777a0026f1451e8c6d70ce797536493bb2fe", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumer.java", "new_id": "09bc777a0026f1451e8c6d70ce797536493bb2fe", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumer.java", "score": 100 }, { "type": "rename", "old_id": "a76a198daa4270a78cd1f726b742af7d202b67b4", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java", "new_id": "c1c69078cc1d4c3bd22b766aea7283824e0829ce", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java", "score": 62 }, { "type": "rename", "old_id": "cfdc0a1427f652597023355ff9bf9fb66f008033", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java", "new_id": "7f26d87388e0077b316f584792fd0cae22a71ad2", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java", "score": 97 }, { "type": "rename", "old_id": "00237a4a8e836de77a1b2ed361d37bfe907c2012", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceBuilder.java", "new_id": "9f24bd9c99e4724376a440e05394087e57cf1f4c", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceBuilder.java", "score": 90 }, { "type": "rename", "old_id": "22992fde8a040eb0866064d908f8272c4c148aed", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java", "new_id": "e14667f960ccbbc3971fab5d8c0c707e497ba4ff", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java", "score": 98 }, { "type": "rename", "old_id": "4fee0d6d2fafff7ef7123483ab3e85258568c77a", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/config/OffsetVerification.java", "new_id": "4fee0d6d2fafff7ef7123483ab3e85258568c77a", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/config/OffsetVerification.java", "score": 100 }, { "type": "rename", "old_id": "aa295784bf1c329a2e5e7bd416ba5fe72939923e", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumState.java", "new_id": "aa295784bf1c329a2e5e7bd416ba5fe72939923e", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumState.java", "score": 100 }, { "type": "rename", "old_id": "960e6228a7770ed99089eefd9e0f3d72420fc96a", "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": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java", "score": 100 }, { "type": "rename", "old_id": "c228309e86d7ff732782d9a7c92b86a40013daf4", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java", "new_id": "45b11324a70e3b6915d2cd77da55c1af906f7509", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java", "score": 97 }, { "type": "rename", "old_id": "6386b2293a948ed5b21494ff2f48634ba7ef0556", "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": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java", "score": 100 }, { "type": "rename", "old_id": "442afb9d03ff02d387a013ad694bd6f8740eefa6", "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": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java", "score": 100 }, { "type": "rename", "old_id": "f808133b5461d7dcc6eb4cab96b08b67480a927a", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java", "new_id": "f808133b5461d7dcc6eb4cab96b08b67480a927a", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java", "score": 100 }, { "type": "rename", "old_id": "f37cf046ecbd3cd46b73568264117f145dd0dc98", "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": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java", "score": 100 }, { "type": "rename", "old_id": "7cd10c4e6ad737fb43c948d5e422f4c3c94c75d5", "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": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java", "score": 100 }, { "type": "rename", "old_id": "14ada53f21b7a04c079b5195ca71b7e6311671d1", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelector.java", "new_id": "68ceff2fe8f0d4013b3c78a9e7471d97e25c3f6b", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelector.java", "score": 98 }, { "type": "rename", "old_id": "edf7010b8280946f631b95fed1de1838b525e271", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorBySpecified.java", "new_id": "1c10cc1239ea0417ac3443ff2e0cbeb7741fd8d7", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorBySpecified.java", "score": 96 }, { "type": "rename", "old_id": "b6be92da2a83716ec155387b51ca181f97fc697b", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorByStrategy.java", "new_id": "5c9a66747061748eb9d326fb7bb000a672f2926a", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorByStrategy.java", "score": 96 }, { "type": "rename", "old_id": "b68566109c0264a96fe963c6b315291d3114552c", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorByTimestamp.java", "new_id": "e5ea0ed76c6eb7fa02552e21b9570c02399d3236", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorByTimestamp.java", "score": 96 }, { "type": "rename", "old_id": "ccd916f9c5564e96e442f32af105df8902339c24", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorNoStopping.java", "new_id": "78c58928139b3210b6f65f3978a8a81e6132adf3", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorNoStopping.java", "score": 94 }, { "type": "rename", "old_id": "18581c88e56a4d31f3cc94322a3fccdbb3093083", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsValidator.java", "new_id": "18581c88e56a4d31f3cc94322a3fccdbb3093083", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsValidator.java", "score": 100 }, { "type": "rename", "old_id": "57c8a6381494bd19388ce8bcd262a52d9189ddad", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java", "new_id": "f21e12a387fa32830855308f784eabc04e644009", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java", "score": 93 }, { "type": "rename", "old_id": "84ce64b193cb1f212706d53722a335c3ce13fea4", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageView.java", "new_id": "84ce64b193cb1f212706d53722a335c3ce13fea4", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageView.java", "score": 100 }, { "type": "rename", "old_id": "b289f206a470f2fbc88d49102c9d530f76e32692", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java", "new_id": "b289f206a470f2fbc88d49102c9d530f76e32692", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java", "score": 100 }, { "type": "rename", "old_id": "7ba42d6ffa5e28daea30341e8f5cf3c166142136", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQRecordEmitter.java", "new_id": "7ba42d6ffa5e28daea30341e8f5cf3c166142136", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQRecordEmitter.java", "score": 100 }, { "type": "rename", "old_id": "242e19e6a19b17cefb4566828ea5fbf30160e34d", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java", "new_id": "e04b77161c048b35f511b9ba1ca2acb875328373", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java", "score": 96 }, { "type": "rename", "old_id": "042c12af9824457060e65c2b19881a5c2ad2fd8a", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java", "new_id": "db68893a424ae4bf873f3bb9b1af52c2f1ddb0de", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java", "score": 97 }, { "type": "rename", "old_id": "9a0833c202981eebe298762d69230daa83252043", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java", "new_id": "b8349e543189d922b123572769662f99c31be8cc", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java", "score": 86 }, { "type": "rename", "old_id": "d3173e0c27fa626eed30aee4c41e63df63e210ef", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/BytesMessage.java", "new_id": "d3173e0c27fa626eed30aee4c41e63df63e210ef", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/BytesMessage.java", "score": 100 }, { "type": "rename", "old_id": "2770e8a9c069974fcfbe82b8e8a2710cc93e3f87", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/DirtyDataStrategy.java", "new_id": "2770e8a9c069974fcfbe82b8e8a2710cc93e3f87", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/DirtyDataStrategy.java", "score": 100 }, { "type": "rename", "old_id": "4dfcebeb6b284755ef83df4b9ede7244fca6fe26", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/QueryableSchema.java", "new_id": "4dfcebeb6b284755ef83df4b9ede7244fca6fe26", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/QueryableSchema.java", "score": 100 }, { "type": "rename", "old_id": "5985ada49c96d5501554e9327ab62c25872ffe78", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQDeserializationSchema.java", "new_id": "5985ada49c96d5501554e9327ab62c25872ffe78", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQDeserializationSchema.java", "score": 100 }, { "type": "rename", "old_id": "bbfe8799d5e0801e06cec546adcb98bc4d05ed54", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQDeserializationSchemaWrapper.java", "new_id": "bbfe8799d5e0801e06cec546adcb98bc4d05ed54", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQDeserializationSchemaWrapper.java", "score": 100 }, { "type": "rename", "old_id": "c4cefca5aacbbcf6b556e079b9567b6bea0efed0", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchema.java", "new_id": "ac9ef7d9df6ce51349babe42afe9b1875484dd5d", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchema.java", "score": 67 }, { "type": "rename", "old_id": "408c6a373afb2aa0a0c7b9c56a1e42a83e95ccc4", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQSchemaWrapper.java", "new_id": "408c6a373afb2aa0a0c7b9c56a1e42a83e95ccc4", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQSchemaWrapper.java", "score": 100 }, { "type": "rename", "old_id": "98baef78b643581ac9ac1000ddaa539e484f466b", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java", "new_id": "98baef78b643581ac9ac1000ddaa539e484f466b", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java", "score": 100 }, { "type": "rename", "old_id": "eb37e19a9b86ed5b7fb1e9b8b97dc0ea3066c132", "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": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java", "score": 100 }, { "type": "rename", "old_id": "a94044da79d1b5f25f7570468e3016649d216bad", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java", "new_id": "d8211a4e369be535954b83b61f7c61a80ad5c7f5", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java", "score": 96 }, { "type": "rename", "old_id": "5f16a809d4105f4bd618880aae2b5e735ef01d3e", "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": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java", "score": 100 }, { "type": "rename", "old_id": "efaac6e5b35ddde4df302a9071dd422f62e194d2", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java", "new_id": "efaac6e5b35ddde4df302a9071dd422f62e194d2", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java", "score": 100 }, { "type": "rename", "old_id": "6ec0768613628235449234c0a6bd8fb44164782c", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteUtils.java", "new_id": "6ec0768613628235449234c0a6bd8fb44164782c", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteUtils.java", "score": 100 }, { "type": "rename", "old_id": "d89eb9861e0a40149adedfff7937c10b5f9574cc", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/util/StringSerializer.java", "new_id": "d89eb9861e0a40149adedfff7937c10b5f9574cc", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/util/StringSerializer.java", "score": 100 }, { "type": "rename", "old_id": "567cecab28f3e80a134f5c24b64fc1221614846a", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/util/UtilAll.java", "new_id": "567cecab28f3e80a134f5c24b64fc1221614846a", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/connector/rocketmq/source/util/UtilAll.java", "score": 100 }, { "type": "rename", "old_id": "d94188a6015a061309e7e8f26ca22b876cd04fda", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQConfig.java", "new_id": "6273d5147bc77de9bc803f753f77785b33b4e15a", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/RocketMQConfig.java", "score": 96 }, { "type": "rename", "old_id": "9ff28129f1fd4000f9f3bf0b49682f07a915e78f", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java", "new_id": "d95c21259cd5565d4635b014656fc4f3dc4fe3e5", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/RocketMQSink.java", "score": 97 }, { "type": "rename", "old_id": "91d1d39d024c64edec0289839a738666e580f5a4", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java", "new_id": "c660335be6427b4cec11a40c0b01a253bb100452", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/RocketMQSourceFunction.java", "score": 74 }, { "type": "rename", "old_id": "961a302913ac5951e69e965737e28f26df03458d", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/RunningChecker.java", "new_id": "6d5a8acb7d3838e7a1ff5ed47abd1f238c198b35", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/RunningChecker.java", "score": 94 }, { "type": "rename", "old_id": "7a9f13a10cad5e0eb145b19f16e413505e7607c9", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config/OffsetResetStrategy.java", "new_id": "808a84ea8e47c46d0f363e5006969711e1b6ccf7", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/config/OffsetResetStrategy.java", "score": 93 }, { "type": "rename", "old_id": "d56e6057527f01fb25bdbef38740f13158a814f3", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config/StartupMode.java", "new_id": "13963d49de6d31b998f34cc132389b5445d7ff24", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/config/StartupMode.java", "score": 92 }, { "type": "rename", "old_id": "d98ff715e1a75946f9e0db372be467e2eba8aae9", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/DefaultTopicSelector.java", "new_id": "abf8843aa4197add97bf686aed2b511594588523", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/selector/DefaultTopicSelector.java", "score": 94 }, { "type": "rename", "old_id": "a3b5db36ded7287c8ff6fa6364de28b3e6a95569", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/HashMessageQueueSelector.java", "new_id": "0fc66ff2bdc1623711b44929c9d401fdbef47b15", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/selector/HashMessageQueueSelector.java", "score": 94 }, { "type": "rename", "old_id": "0eac1bf5e16e2a6a924b3c521b7027923de7a3e1", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/MessageQueueSelector.java", "new_id": "ef5c26203bf86e7048f298acdd2741ea2c3ce44a", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/selector/MessageQueueSelector.java", "score": 92 }, { "type": "rename", "old_id": "7580684ea71e300c2faa71d887daf611c5f0231a", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/RandomMessageQueueSelector.java", "new_id": "a3d5a57475241a62564bd8488d39422bc2e93e64", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/selector/RandomMessageQueueSelector.java", "score": 94 }, { "type": "rename", "old_id": "d74e52c7c3d3fec8eec9f1d5b4790b00c2433cd0", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/SimpleTopicSelector.java", "new_id": "003cbcce3c150eec1842fe350a385a7068255058", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/selector/SimpleTopicSelector.java", "score": 97 }, { "type": "rename", "old_id": "b24cfb41e186fdc5c2341ace93e9228c0ba8b48b", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/TopicSelector.java", "new_id": "71b9564e8ae12139fe5f7c01d4843c31bb8ac0ef", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/selector/TopicSelector.java", "score": 92 }, { "type": "rename", "old_id": "598d72a0503b8ef20b64e3c3a52ab300c21bcb56", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/ForwardMessageExtDeserialization.java", "new_id": "8ab4755358af97379acfcbbde1d344385ab78ccd", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/serialization/ForwardMessageExtDeserialization.java", "score": 94 }, { "type": "rename", "old_id": "21aa48563a58cfec42451a29a30897645851ceed", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueDeserializationSchema.java", "new_id": "b491fca77beedf50a714527793223e62b9535c8f", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/serialization/KeyValueDeserializationSchema.java", "score": 92 }, { "type": "rename", "old_id": "a19a445ac0d3771f136bc57ddeb9034d8bc3e142", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueSerializationSchema.java", "new_id": "ddc9189f74424d537817991c94ac03a901eaa28e", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/serialization/KeyValueSerializationSchema.java", "score": 92 }, { "type": "rename", "old_id": "5ee8da7fe319d9b7363793947223d522d4e9060a", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/MessageExtDeserializationScheme.java", "new_id": "cc0daaa282d430bde15040c03870fc813452b3cb", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/serialization/MessageExtDeserializationScheme.java", "score": 94 }, { "type": "rename", "old_id": "ca934bdf43fad36bb6546b47159d030f2b157e6f", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java", "new_id": "bf7d58dc1a61657a399a1546c5a48d1ddae1847d", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/serialization/RowKeyValueDeserializationSchema.java", "score": 99 }, { "type": "rename", "old_id": "c3e54c9e5af9162db0dfc20d51d57c7983192dae", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueDeserializationSchema.java", "new_id": "a6202ebd19825822fbb1ad542bb278307142834c", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/serialization/SimpleKeyValueDeserializationSchema.java", "score": 96 }, { "type": "rename", "old_id": "830cfb68e2005cdec5610c61568979276beb5cc1", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueSerializationSchema.java", "new_id": "97dd631924e110d6ce31d431ca4c5e1e05412819", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/serialization/SimpleKeyValueSerializationSchema.java", "score": 96 }, { "type": "rename", "old_id": "7f8c4c6f669938cbd05a6b9dff95f4dc4c880f48", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleStringDeserializationSchema.java", "new_id": "be657e4ad8b9595cdb147eb1f90fd7abafe5a333", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/serialization/SimpleStringDeserializationSchema.java", "score": 94 }, { "type": "rename", "old_id": "28e94ba33e26eed6a359933ada014a1e0e3a59f4", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleTupleDeserializationSchema.java", "new_id": "a471b50ee48f23a7b4faf89b968af547ff64f075", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/serialization/SimpleTupleDeserializationSchema.java", "score": 95 }, { "type": "rename", "old_id": "d98e3c3418ea05489073ac3c5bd68c1258e4c768", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/MetricUtils.java", "new_id": "7ecebc5c8db1dc00f67e8d3a4d2a0abf9552c1c3", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/util/MetricUtils.java", "score": 97 }, { "type": "rename", "old_id": "d11105b9a79d8063f06c9a90f907ae4e15ececa1", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java", "new_id": "453ad25e635860be24c35a2874cbfe00a1f7bf62", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/util/RetryUtil.java", "score": 94 }, { "type": "rename", "old_id": "9f3d913498f39ec5a16f94e97f5db74e8bcc6cec", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RocketMQUtils.java", "new_id": "cf38c0b8d5bdd6fa1123a46aa8bbc24bc1f03a96", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/util/RocketMQUtils.java", "score": 97 }, { "type": "rename", "old_id": "1bde818ba6c03ee333a7ce70a7114f49e048d357", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java", "new_id": "f030d82b7bc34c27650cafd0224cd64cda57caf4", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/common/util/TestUtils.java", "score": 95 }, { "type": "rename", "old_id": "8cda235c4c3a7713d03b7c70080d486442fb9ffb", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/function/SinkMapFunction.java", "new_id": "1a73b920e8fa60babaf84f5ed422738fa5689060", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/function/SinkMapFunction.java", "score": 95 }, { "type": "rename", "old_id": "1945c70eb670550eac560958899329c6befed960", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/function/SourceMapFunction.java", "new_id": "8a7a456fd28e621b3925a1889e3968d26bed12d2", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/function/SourceMapFunction.java", "score": 94 }, { "type": "rename", "old_id": "98a15e60690d1929d7f081db39f21d74979e2f04", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java", "new_id": "bb05b67cf4241ddb9c0d63dafb43f9f0c160ee6b", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQDynamicTableSink.java", "score": 75 }, { "type": "rename", "old_id": "9c1ca113de97197ef6e2855705bfc623456ff15c", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java", "new_id": "12102680c1e0c5fb437cc729079e7d78c8a51874", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQDynamicTableSinkFactory.java", "score": 85 }, { "type": "rename", "old_id": "21613856e76a0fe5f4cfd4c887d6bf706620658f", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java", "new_id": "4807c4d2a4d241d0ecd3b790e956d661df4d7d4e", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQDynamicTableSourceFactory.java", "score": 83 }, { "type": "rename", "old_id": "dc14363aa45e89e70691ab8ca548bb3b9aa246c0", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataConverter.java", "new_id": "c4cff01c21a350312b6e2367ecc9d8cdfc3e4a0e", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQRowDataConverter.java", "score": 94 }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "5cc0755f559180636897424a317fe51e49888c7f", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQRowDataSerializationSchema.java" }, { "type": "rename", "old_id": "c7d9a7176b1b9b64a71466e7048e5bc39212ef2f", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataSink.java", "new_id": "138d79c573354fe68019febbc132e8c7949f69b1", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQRowDataSink.java", "score": 93 }, { "type": "rename", "old_id": "21ccdb92ed0592c09fac75c9fa14970a9cf487b1", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQScanTableSource.java", "new_id": "32afa6e45d199d94bc012811c52111ee6aa4399e", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/main/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQScanTableSource.java", "score": 73 }, { "type": "rename", "old_id": "6c70939729c813caff8536f35b8e16d5b00b050d", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactoryTest.java", "new_id": "6c70939729c813caff8536f35b8e16d5b00b050d", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactoryTest.java", "score": 100 }, { "type": "rename", "old_id": "767822d79d44402eaa63302ae329cce29b7b7414", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogTest.java", "new_id": "e8f2c1f95415dee85dd59617a5cce4a245893b29", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogTest.java", "score": 70 }, { "type": "rename", "old_id": "22360921deb23de4451924bbc33f49a0ac0b71ee", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilderTest.java", "new_id": "22360921deb23de4451924bbc33f49a0ac0b71ee", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilderTest.java", "score": 100 }, { "type": "rename", "old_id": "111c2208e8e2d316ebb742dbe227aa18e7f56cf5", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/example/ConnectorConfig.java", "new_id": "06c34f4789281a71a8a3f6540ca8c301a0cb8335", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/example/ConnectorConfig.java", "score": 88 }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "27c4f3aaf14d6422a1f1893036ab0bc9423faca0", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/example/ConnectorIntegrationTest.java" }, { "type": "rename", "old_id": "c16ce83c3e4fc0decfddaa3ca9da1e7812e7c4d1", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/example/SimpleAdmin.java", "new_id": "c16ce83c3e4fc0decfddaa3ca9da1e7812e7c4d1", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/example/SimpleAdmin.java", "score": 100 }, { "type": "rename", "old_id": "85238fd27dee5caf74b4cc6380179acd47860d6e", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/example/SimpleConsumer.java", "new_id": "892f108073999dee486654c7558593912540bc5f", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/example/SimpleConsumer.java", "score": 93 }, { "type": "rename", "old_id": "ac47bdbdcca9eca193e6dea342e3a22f135c150c", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/example/SimpleProducer.java", "new_id": "9f6dec67c4113303c89f0c3c577ccb1501565ee9", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/example/SimpleProducer.java", "score": 85 }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "9d78fe6fcfdbfc9a9f213db792e6fc2da02a736c", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/example/SqlIntegrationTest.java" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "7bbd01503d004bc1077b4d62d378a0ad886bf99b", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/example/TransactionSinkIntegrationTest.java" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "7de3db77d506b43e23e58ab6353deabd31edd5be", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImplTest.java" }, { "type": "rename", "old_id": "207b9633502ec69d17a3647dde170a0955cf92d3", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java", "new_id": "207b9633502ec69d17a3647dde170a0955cf92d3", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkTest.java", "score": 100 }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "d93239b70beb59fc375bd6fb7e808ae3ae7e33b9", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImplTest.java" }, { "type": "rename", "old_id": "0982fbd1ee66cc794f4a58b7bcb64954edcb534e", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceTest.java", "new_id": "0982fbd1ee66cc794f4a58b7bcb64954edcb534e", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceTest.java", "score": 100 }, { "type": "rename", "old_id": "49855711ce60d5e6c0bc26127585bdd9e2ef8062", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializerTest.java", "new_id": "49855711ce60d5e6c0bc26127585bdd9e2ef8062", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializerTest.java", "score": 100 }, { "type": "rename", "old_id": "f63c8d17465988b55a8304dd372e024d5c9c4d20", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategyTest.java", "new_id": "f63c8d17465988b55a8304dd372e024d5c9c4d20", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategyTest.java", "score": 100 }, { "type": "rename", "old_id": "23e1b85547326c4817953f4818acce13201dd97c", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategyTest.java", "new_id": "23e1b85547326c4817953f4818acce13201dd97c", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategyTest.java", "score": 100 }, { "type": "rename", "old_id": "441916a6e31c82d10bb4ae49d2b5a9599e277d03", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategyTest.java", "new_id": "441916a6e31c82d10bb4ae49d2b5a9599e277d03", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategyTest.java", "score": 100 }, { "type": "rename", "old_id": "6c81cef8c1c0664f0d418356c299799bfe3fe37f", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQRecordEmitterTest.java", "new_id": "6a357e3b2bf1111818c5d13d4dea746bcce20d8f", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQRecordEmitterTest.java", "score": 95 }, { "type": "rename", "old_id": "60050937f4ac8b7e3741870c5d386008e1e981e0", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchemaTest.java", "new_id": "2c1e23300f69a531951f1e564ee74ce5900b59ca", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchemaTest.java", "score": 92 }, { "type": "rename", "old_id": "432994e3fdcf422096eb089ce76c3db69cf854ae", "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": "flink-connector-rocketmq/src/test/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializerTest.java", "score": 100 }, { "type": "rename", "old_id": "e1eb863e5aa565091201984d9e141f92a00dc913", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSinkTest.java", "new_id": "ee3cf4543f824e8ef4c4a974e02bf11539737b2a", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/RocketMQSinkTest.java", "score": 81 }, { "type": "rename", "old_id": "35a0eb76579754b4b67e5ecc69c50dd7af7f29b2", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java", "new_id": "1e6093791a237ab08fb79d393a8219cef9b6f6d0", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/RocketMQSourceTest.java", "score": 89 }, { "type": "rename", "old_id": "d91a045e22e8c01c52ff4fb46f20e9722cdb6642", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/legacy/common/selector/DefaultTopicSelectorTest.java", "new_id": "d1d9ec058785cee97fb1c64b482401d17457e8ba", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/common/selector/DefaultTopicSelectorTest.java", "score": 94 }, { "type": "rename", "old_id": "ddb88fabd6c3fca6a67583f25c3e20ee86629871", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/legacy/common/selector/HashMessageQueueSelectorTest.java", "new_id": "b9f65f8357069bca9cd4089cbdd7dbadaafdacf8", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/common/selector/HashMessageQueueSelectorTest.java", "score": 95 }, { "type": "rename", "old_id": "cad43a3c335aab3bfc7d5a4ef23a1675044c8b29", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/legacy/common/selector/RandomMessageQueueSelectorTest.java", "new_id": "f67ffdeae8ef20bff5ba52e31c78dad2c33c25a8", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/common/selector/RandomMessageQueueSelectorTest.java", "score": 96 }, { "type": "rename", "old_id": "be555142e98ae8876ad579a1fec0f64da8041a53", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/legacy/common/selector/SimpleTopicSelectorTest.java", "new_id": "548bc67f4cc166559a8987ac088c79d565021dc7", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/common/selector/SimpleTopicSelectorTest.java", "score": 95 }, { "type": "rename", "old_id": "a8ff892ee2294fc7379ce8b3b430d532c8c9cdea", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchemaTest.java", "new_id": "66253eaec57a61581d7954de62605c84940a686a", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/common/serialization/RowKeyValueDeserializationSchemaTest.java", "score": 95 }, { "type": "rename", "old_id": "680aab6e52c47b8d9f2e0ec039ba87916e557613", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueSerializationSchemaTest.java", "new_id": "9f798a6f0c1c9376cbfe91b9b3d13cfe8468900b", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/common/serialization/SimpleKeyValueSerializationSchemaTest.java", "score": 95 }, { "type": "rename", "old_id": "d719aa34d080eeaaffb337378a2cfeb06f0168c5", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtilTest.java", "new_id": "3e58384436e1a6aed37ecf72d09f6b4649ff6a52", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/common/util/RetryUtilTest.java", "score": 75 }, { "type": "rename", "old_id": "d9ec7115c02ad0c6001e12169c159fec2a9258ef", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/example/LegacyConnectorExample.java", "new_id": "c65fa1ec9c63aacd7af3d072fb6e20e641b91337", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/example/LegacyConnectorExample.java", "score": 87 }, { "type": "rename", "old_id": "78ffd17f63fac66875030dc5fc043b09ade42779", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/legacy/sourceFunction/RocketMQSourceFunctionTest.java", "new_id": "af70aacff3c9b20e1a8303df230a22dfda253db6", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/sourceFunction/RocketMQSourceFunctionTest.java", "score": 89 }, { "type": "rename", "old_id": "0da51c39d21a9d2fe1124415d86a579202da6176", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactoryTest.java", "new_id": "a06c8af0f44fb2e8ae2b519c403c9c0e438f215e", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQDynamicTableSinkFactoryTest.java", "score": 98 }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "ad0986946e84a74bd187edc5251d0f2c70bc9640", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQDynamicTableSinkMigrationTest.java" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "c9db6f14b0cb038e3ae6e18a53cd4573ed4ac96a", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQDynamicTableSourceFactoryOffsetTest.java" }, { "type": "rename", "old_id": "dab7f4414aa7691cc7d93d3f9ddacaa980388b4d", "old_mode": 33188, "old_path": "src/test/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactoryTest.java", "new_id": "5f4eff7562c2423e2675ea8f1d03b2062e13dcdf", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQDynamicTableSourceFactoryTest.java", "score": 95 }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "f6759c51aab610d5cb7047c7211813f7cf908b8e", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQParameterChainTest.java" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "bcf163ba360d87dc7a3f4a5e1781220dbf553c5b", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQScanTableSourceFilterTest.java" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "0000f9fc10c37c0dc105d7f1ffb09831b94e7970", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/java/org/apache/flink/streaming/connectors/rocketmq/table/RocketMQScanTableSourceTest.java" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "9aea4bcb0c7eaf8cf39efda0a3e1faa5553f300a", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "c0b887d0c7542edb4f79c852a069d5d2e4cdce89", "new_mode": 33188, "new_path": "flink-connector-rocketmq/src/test/resources/log4j2-test.xml" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "1724963b1a9ef9f68383680136b17b6ddd484843", "new_mode": 33188, "new_path": "flink-sql-connector-rocketmq/pom.xml" }, { "type": "rename", "old_id": "00a2a7fb72fa5513e7815430a4ad2bbb2ca5222e", "old_mode": 33188, "old_path": "src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory", "new_id": "8dbf8bf49b5afce42b9afa6555401559ba513a50", "new_mode": 33188, "new_path": "flink-sql-connector-rocketmq/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory", "score": 82 }, { "type": "modify", "old_id": "2eddd1aeff9df289669d857cbfac201d328d2860", "old_mode": 33188, "old_path": "pom.xml", "new_id": "c92cf4fc086e6466fa5e5ecf560fb75b235da0a1", "new_mode": 33188, "new_path": "pom.xml" }, { "type": "delete", "old_id": "528d0fe706125746a668918174ad1c3dc7f4411a", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/MetricUtil.java", "new_id": "0000000000000000000000000000000000000000", "new_mode": 0, "new_path": "/dev/null" }, { "type": "delete", "old_id": "68dea07bc8ddc42485a1aad174c64960217b528d", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGenerator.java", "new_id": "0000000000000000000000000000000000000000", "new_mode": 0, "new_path": "/dev/null" }, { "type": "delete", "old_id": "4aeb17113c30791c36bd888d3f51ac4070cb9751", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGeneratorPerQueue.java", "new_id": "0000000000000000000000000000000000000000", "new_mode": 0, "new_path": "/dev/null" }, { "type": "delete", "old_id": "49914630a08afafa14b779a2ed13624edb62c00c", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/PunctuatedAssigner.java", "new_id": "0000000000000000000000000000000000000000", "new_mode": 0, "new_path": "/dev/null" }, { "type": "delete", "old_id": "de33fcb64a120004749d682005832a3aac5b76b5", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/TimeLagWatermarkGenerator.java", "new_id": "0000000000000000000000000000000000000000", "new_mode": 0, "new_path": "/dev/null" }, { "type": "delete", "old_id": "b8d58c5b164da7b61db83bdc54260e256e0d3e74", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkForAll.java", "new_id": "0000000000000000000000000000000000000000", "new_mode": 0, "new_path": "/dev/null" }, { "type": "delete", "old_id": "fd20322b566b4de9df691a241e8d70374e60b856", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java", "new_id": "0000000000000000000000000000000000000000", "new_mode": 0, "new_path": "/dev/null" }, { "type": "delete", "old_id": "5118e0bee1214cb74b732b005b82ee76214d0d74", "old_mode": 33188, "old_path": "src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java", "new_id": "0000000000000000000000000000000000000000", "new_mode": 0, "new_path": "/dev/null" }, { "type": "delete", "old_id": "5f4507d7422f1a0d48d36fdffb3f6222944faa66", "old_mode": 33188, "old_path": "src/test/resources/logback-test.xml", "new_id": "0000000000000000000000000000000000000000", "new_mode": 0, "new_path": "/dev/null" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "2048fd1869bd475cb1cd5df214b71fa5ea0eb1db", "new_mode": 33188, "new_path": "tools/maven/checkstyle.xml" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "38f7a83f4f9e55030329f664bb711579f85af4b7", "new_mode": 33188, "new_path": "tools/maven/suppressions.xml" } ] }