Use the links below to download the Apache InLong from one of our mirrors.
2.2.0 release
You can download the latest version here.
| Name | Version | Date | 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] |
Release Integrity
You must verify the integrity of the downloaded files.
We provide OpenPGP signatures for every release file. This signature should be matched against the KEYS file which contains the OpenPGP keys of InLong's Release Managers.
We also provide SHA-512 checksums for every release file. After you download the file, you should calculate a checksum for your download, and make sure it is the same as ours.
Release 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. |