使用以下链接下载 InLong。
2.2.0 release。
| 名称 | 版本 | 日期 | Downloads |
|---|---|---|---|
| InLong Source Code | 2.2.0 | May. 14, 2025 | [SRC] [ASC] [SHA512] |
| InLong Binary File | 2.2.0 | May. 14, 2025 | [BIN] [ASC] [SHA512] |
| Connector Binary File For Flink v1.15 | 2.2.0 | May. 14, 2025 | [BIN] [ASC] [SHA512] |
| Connector Binary File For Flink v1.18 | 2.2.0 | May. 14, 2025 | [BIN] [ASC] [SHA512] |
发布完整性
您必须 验证 下载文件的完整性。
我们为每个发布文件提供 OpenPGP 签名。此签名应与包含 InLong 发布经理的 OpenPGP 密钥的 KEYS 文件匹配。
我们还为每个发布文件提供 SHA-512 校验和。下载文件后，您应该计算下载的校验和，并确保它与我们提供的相同。
版本 Notes
Agent
| ISSUE | Summary |
|---|---|
| INLONG-11815 | [Improve][Agent] Add a unified reporting point for events |
| INLONG-11813 | [Improve][Agent] Add Dataproxy SDK debug log |
| INLONG-11811 | [Improve][Agent] Increase the retention time of offset, default to 7 days |
| INLONG-11778 | [Improve][Agent] Separate the logs of the DataProxy SDK |
| INLONG-11776 | [Improve][Agent] Optimize the mechanism for controlling the number of instances |
| INLONG-11774 | [Improve][Agent] Modify the lifecycle of the DataProxy SDK object |
| INLONG-11762 | [Improve][Agent] Modify the logic for determining the end of the data source |
| INLONG-11760 | [Improve][Agent] Increase the number of global instances control |
| INLONG-11752 | [Improve][Agent] Modify the default collection range of data |
| INLONG-11687 | [Improve][Agent] Optimize task main thread exception handling to prevent exception exits |
| INLONG-11685 | [Improve][Agent] Agent needs to modify the logic of confirming its own IP address |
| INLONG-11681 | [Bug][Agent] Duplicate file collection |
Dashboard
| ISSUE | Summary |
|---|---|
| INLONG-11799 | [Bug][Dashboard] The page will not refresh after the access groupId is switched |
| INLONG-11772 | [Improve][Dashboard] User login verify fail |
Manager
| ISSUE | Summary |
|---|---|
| INLONG-11794 | [Improve][Manager][Sort]Pulsar source supports setting scan.startup.mode to null |
| INLONG-11764 | [Improve][Manager] Support SQL stream source |
| INLONG-11751 | [Bug][Manager] Failed to delete inlong group for groupId |
| INLONG-11746 | [Improve][Manager] When special characters appear in the JDBC URL, sensitive parameter validation can be bypassed |
| INLONG-11731 | [Improve][Manager]Sensitive parameters are bypassed during JDBC verification processing |
| INLONG-11722 | [Improve][Manager] Pulsar source supports Inlong properties field |
SDK
| ISSUE | Summary |
|---|---|
| INLONG-11843 | [Improve][SDK] Validate the input message of Golang SDK |
| INLONG-11830 | [Bug][SDK] NullPointerException while not configure factory permits |
| INLONG-11809 | [Improve][SDK] Adjust the default value of separateEventByLF to false |
| INLONG-11788 | [Improve][SDK] Add processing logic when DataProxyNodeResponse.nodeList field is null |
| INLONG-11787 | [Bug][SDK] Dataproxy Python SDK lacks mutex header file |
| INLONG-11782 | [Improve][SDK]Adjust the Sender initialization codes in example |
| INLONG-11770 | [Improve][Sort][SDK] Fix potential Null Pointer Exception |
| INLONG-11756 | [Improve][SDK] Add NPE check in MsgSender Factory class |
| INLONG-11754 | [Improve][SDK] Add the total number of in-flight requests and total size limits |
| INLONG-11749 | [Improve][SDK] Clean up unused configuration items and functions |
| INLONG-11745 | [Improve][SDK] Clean up HttpProxySender and related implementations |
| INLONG-11743 | [Improve][SDK] Adjustment of metric statistics |
| INLONG-11741 | [Improve][SDK] Clean up the MessageSender interface and related implementation classes |
| INLONG-11738 | [Improve][SDK] Optimize the metric output when MetricDataHolder exits |
| INLONG-11734 | [Improve][SDK] Optimize SDK stop processing flow |
| INLONG-11729 | [Improve][SDK] Optimize TcpClientExample and HttpClientExample codes |
| INLONG-11727 | [Improve][SDK] Replace the Sender used in the agent-plugins module with TcpMsgSender |
| INLONG-11725 | [Improve][SDK] Replace the Sender used in the agent-core module with TcpMsgSender |
| INLONG-11720 | [Improve][SDK] Optimize MsgSenderSingleFactory implementation |
| INLONG-11719 | [Improve][SDK] Replace the Sender object in the InlongSdkDirtySender class with TcpMsgSender |
| INLONG-11717 | [Improve][SDK] Add out-of-bounds check when in getClientByRoundRobin() |
| INLONG-11715 | [Improve][SDK] Optimize metric report content |
| INLONG-11713 | [Improve][SDK] Optimize BaseMsgSenderFactory and TimeCostInfo implementation |
| INLONG-11711 | [Improve][SDK] SortSDK shares the same PulsarClient among different SortTasks to avoid performance bottlenecks caused by too many PulsarClients. |
| INLONG-11706 | [Improve][SDK] Optimize HTTP Sender implementation |
| INLONG-11702 | [Improve][SDK] Optimize Sender factory implementation |
| INLONG-11700 | [Improve][SDK] Optimize TCP message reporting Sender implementation |
| INLONG-11698 | [Improve][SDK] Optimize TCP encode and decode implementation |
| INLONG-11695 | [Improve][SDK] MessageSender related interfaces abstraction |
| INLONG-11692 | [Improve][SDK] The metadata update function abstracted to ConfigHolder |
| INLONG-11689 | [Improve][SDK] Optimize user reporting information management |
| INLONG-11683 | [Improve][SDK] Optimize the functions return of the ProxyConfigManager class |
| INLONG-11680 | [Improve][SDK] Optimize metric-related implementation |
| INLONG-11678 | [Improve][SDK] Optimize the ProxyClientConfig class |
| INLONG-11675 | [Improve][SDK] Optimize IpUtils class related implementation |
| INLONG-11672 | [Improve][SDK] Remove the implementation of org.apache.inlong.sdk.dataproxy.pb.* |
| INLONG-11670 | [Improve][SDK] Rename the ProxysdkException class name to ProxySdkException |
| INLONG-11668 | [Feature][SDK] Add max life time support for the connections in conn pool of Golang SDK |
| INLONG-11663 | [Improve][SDK]Increase the conn pool size for Golang SDK |
| INLONG-11662 | [Improve][SDK]Enable TCP keep alive for Golang SDK |
| INLONG-11661 | [Improve][SDK]Do not mark endpoint unavailable when it is the only one in Golang SDK |
| INLONG-11660 | [Improve][SDK]Close exist conns if initConns() failed in Golang SDK |
| INLONG-11564 | [Improve][SDK] DataProxy SDK Implementation Optimization |
| INLONG-11228 | [Bug][SDK] Limitation of Transform Sql Statement Parser |
| INLONG-10465 | [Improve][SDK] Go SDK pressure test and optimization |
Sort
| ISSUE | Summary |
|---|---|
| INLONG-11841 | [Improve][Sort] When the SortTask is closed, the BufferQueueChannel must be released along with synchronously releasing the GlobalBufferQueue's token |
| INLONG-11836 | [Feature][Sort] Provide SortStandalone flow control to prevent single-task blocking from affecting the normal sorting of other tasks. |
| INLONG-11833 | [Improve][Sort] Appendmode configuration ignores case |
| INLONG-11829 | [Feature][Sort] Optimize MySQL-CDC changelog audit report |
| INLONG-11821 | [Feature][Sort] kv and csv deserialization configuration supports whether to remove and automatically add escape configuration |
| INLONG-11819 | [Feature][Sort] Sort kv/csv format must support keep escape, using line delimiter and call back when parse field has exception. |
| INLONG-11807 | [Feature][Sort] Support exactly metric report in mysql-cdc case |
| INLONG-11805 | [Improve][Sort] Restored Checkpoint Id as part of Tube Connector Session Key |
| INLONG-11803 | [Bug][Sort] When there is an issue with the format of the InLongmsg body, the parsing process will throw a Null Pointer Exception (NPE). |
| INLONG-11674 | [Feature][Sort] Pulsar Source supports InlongMsg metadata |
| INLONG-11658 | [Bug][Sort] Fix the NPE of the Kafka sink error log for some exceptions without metadata information |
| INLONG-11543 | [Improve][Sort] Upgrade pulsar connector to v4.1.0 |
| INLONG-10875 | [Feature][Sort]Apache Inlong official demo documentation issue |
| INLONG-10466 | [Feature][Sort] Add Iceberg connector on Flink 1.18 |
Audit
| ISSUE | Summary |
|---|---|
| INLONG-11831 | [Improve][Audit] Optimize the packaging of the Audit SDK |
| INLONG-11826 | [Feature][Audit] Add a new Audit item for MQ Pulsar |
| INLONG-11823 | [Improve][Audit] Add CDC audit ID for MySQL Binlog |
| INLONG-11817 | [Feature][Audit] Audit SDK supports CDC scenario audit reconciliation |
TubeMQ
| ISSUE | Summary |
|---|---|
| INLONG-11386 | [Improve][TubeMQ] Use local files to save consumer group offset information |
| INLONG-11446 | [Improve][TubeMQ] Remove legacy codes |
| INLONG-11583 | [Bug][TubeMQ] Go SDK load balance logic not perfect, causing consumption to stop suddenly |
| INLONG-11587 | [Bug][TubeMQ] Go SDK change filter order cause inconsistency error when registering to master. |