Use the links below to download the Apache InLong from one of our mirrors.
1.9.0 release
| Name | Version | Date | Downloads |
|---|---|---|---|
| InLong Source Code | 1.9.0 | September. 19, 2023 | [SRC] [ASC] [SHA512] |
| InLong Binary File | 1.9.0 | September. 19, 2023 | [BIN] [ASC] [SHA512] |
| Connector Binary File For Flink v1.13 | 1.9.0 | September. 19, 2023 | [BIN] [ASC] [SHA512] |
| Connector Binary File For Flink v1.15 | 1.9.0 | September. 19, 2023 | [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-8850 | [Improve][Agent] Remove unregister of MetricRegister when taskmanager is initialized |
| INLONG-8655 | [Bug][Agent] JobWrapper thread leaks when the job is stopped |
| INLONG-8652 | [Improve][Agent] Delete the capacity of setting blacklist |
| INLONG-8649 | [Bug][Agent] Thread leaks for ProxySink when the DataProxy SDK init failed |
| INLONG-8647 | [Improve][Agent] Stop sending task snapshot to Manager module |
| INLONG-8645 | [Improve][Agent] Delete the capacity of the loading trigger for local files |
| INLONG-8629 | [Bug][Agent] Sending invalid data to DataProxy failed blocks normal data sending |
| INLONG-8524 | [Improve][Agent] Update the JVM Options for Agent |
| INLONG-8520 | [Bug][Agent] File agent sent data to dataproxy was all json formatted 1.9.x/bugfix |
| INLONG-8146 | [Improve][Agent] Optimize agent-env.sh, and '-XX:NativeMemoryTracking' |
| INLONG-8799 | [Bug][Manager][Agent][DataProxy] The "opentelemetry" related configs may affect the startup of services |
| INLONG-8611 | [Feature][Manager][Agent][DataProxy] Support full link tracking to improve the observability of the project |
Audit
| ISSUE | Summary |
|---|---|
| INLONG-8836 | [Improve][Audit] Add audit_tag information to distinguish data sources and data targets |
| INLONG-8753 | [Improve][Audit] Separate commons-text from org.apache.flume |
| INLONG-8699 | [Improve][Audit] Optimize the service log of audit-proxy |
| INLONG-8642 | [Improve][Audit] Remove the audit commons-text dependency |
Dashboard
| ISSUE | Summary |
|---|---|
| INLONG-8882 | [Feature][Dashboard] Support management of Pulsar data node |
| INLONG-8881 | [Feature][Dashboard] Support management of Pulsar sink |
| INLONG-8843 | [Improve][Dashboard] StarRocks sink field optimization |
| INLONG-8841 | [Feature][Dashboard] Support management of Iceberg sources |
| INLONG-8810 | [Improve][Dashboard] Approval management process ID link optimization |
| INLONG-8800 | [Improve][Dashboard] Owners search component optimization |
| INLONG-8788 | [Improve][Dashboard] Data synchronization page optimization |
| INLONG-8779 | [Improve][Dashboard] Modify password verification optimization |
| INLONG-8760 | [Bug][Dashboard] The transform button was not at the center |
| INLONG-8757 | [Improve][Dashboard] Implement buttons using a link good first issue |
| INLONG-8755 | [Improve][Dashboard] Data synchronization field mapping optimization |
| INLONG-8727 | [Improve][Dashboard] Approval management Application details optimization |
| INLONG-8705 | [Improve][Dashboard] Source and sink title optimization |
| INLONG-8693 | [Feature][Dashboard] Data synchronization supports Audit |
| INLONG-8661 | [Bug][DashBoard] DatabaseWhiteList is required which is inconsistent with tips |
| INLONG-8624 | [Bug][Dashboard] Tenant Management Search Tenant Exceptions |
| INLONG-8621 | [Feature][Dashboard] Approval management supports approval data synchronization |
| INLONG-8575 | [Improve][Dashboard] Tenant management query optimization |
| INLONG-8560 | [Bug][Dashboard] No username and password when configuring hive. |
| INLONG-8548 | [Feature][Dashboard] Data access supports displaying transmission delay |
| INLONG-8546 | [Bug][Dashboard] Inlong group resource details display error good first issue |
| INLONG-8512 | [Bug][Dashboard] Create tube consumer failed when selecting topic 1.9.x/bugfix |
| INLONG-8502 | [Bug][Dashboard] Query data preview interface exception |
| INLONG-8500 | [Bug][Dashboard] Fix stream data preview url error |
| INLONG-8008 | [Improve][Dashboard] Add default icon for different data nodes good first issue |
DataProxy
| ISSUE | Summary |
|---|---|
| INLONG-8914 | [Improve][DataProxy] Optimize DataProxy event statistics |
| INLONG-8899 | [Improve][DataProxy] Optimize metadata update logic |
| INLONG-8819 | [Improve][DataProxy] Optimize ConfigHolder related subclass loading processing |
| INLONG-8758 | [Improve][DataProxy] Metadata synchronization management optimization |
| INLONG-8741 | [Bug][DataProxy] Wrong constant reference in CommonConfigHolder class |
| INLONG-8729 | [Bug][DataProxy] Wrong result in the addSendResultMetric function also reports success |
| INLONG-8725 | [Improve][DataProxy] Cache file metric output switch value at usage location |
| INLONG-8679 | [Improve][DataProxy] Migrate index-related variables to abstract classes |
| INLONG-8670 | [Improve][DataProxy] Define in detail the exceptions actively thrown in Source |
| INLONG-8657 | [Improve][DataProxy] Cache Source, Sink name and Channel object content |
| INLONG-8597 | [Improve][DataProxy] Adjust the format of the metric output to the file |
| INLONG-8589 | [Improve][DataProxy] Add callback parameter support for Http access |
| INLONG-8576 | [Improve][DataProxy] Adjust handling when messages are incomplete |
| INLONG-8507 | [Improve][Dataproxy] Modify nodeIp in dataproxy message to clientIp |
| INLONG-6364 | [Improve][DataProxy] Add DataProxy node load information stage/stale |
| INLONG-8799 | [Bug][Manager][Agent][DataProxy] The "opentelemetry" related configs may affect the startup of services |
| INLONG-8611 | [Feature][Manager][Agent][DataProxy] Support full link tracking to improve the observability of the project |
| INLONG-8936 | [Bug][DataProxy] The log's path for DataProxy is wrong |
Manager
| ISSUE | Summary |
|---|---|
| INLONG-8852 | [Improve][Manager] Supports fuzzy matching of username based on keyword |
| INLONG-8845 | [Feature][Manager] Support Tencent Cloud Log Service data flow |
| INLONG-8834 | [Bug][Manager] No relationship generated after setting the transformnode |
| INLONG-8832 | [Bug][Manager] The request type for transform/list in the client does not match the actual one |
| INLONG-8829 | [Improve][Manager] Support configuring whether to use zookeeper by request |
| INLONG-8827 | [Feature][Manager] Inlong manager sql directory is incorrect in docker README |
| INLONG-8823 | [Feature][Manager] Supporting data flow to Pulsar |
| INLONG-8816 | [INLONG-8815][Manager] Supports configuring iceberg streamSources |
| INLONG-8815 | [Improve][Manager] Supports configuring iceberg streamSources |
| INLONG-8813 | [Improve][Manager] Replacing whitespace characters in MySQL JDBC URL |
| INLONG-8805 | [Feature][Manager] Check tenant status before deleting tenant |
| INLONG-8799 | [Bug][Manager][Agent][DataProxy] The "opentelemetry" related configs may affect the startup of services |
| INLONG-8797 | [Feature][Manager][Sort] Audit has no data for data sync |
| INLONG-8794 | [Improve][Manager] Support add streamField and sinkField |
| INLONG-8781 | [Bug][Manager] When batch task is finished, exception is throw |
| INLONG-8773 | [Improve][Manager] Optimize Agent heartbeat logic |
| INLONG-8771 | [Bug][Manager] Audit data error for MySQL data source |
| INLONG-8751 | [Bug][Manager] Response of data preview was empty |
| INLONG-8749 | [Improve][Manager] Support configuring whether to initialize node state during startup |
| INLONG-8739 | [Bug][Manager] The file collection task was mistakenly deleted |
| INLONG-8675 | [Bug][Manager]Manager client InlongTenant get method request type error |
| INLONG-8671 | [Bug][Manager] Find no method parameter of form data in POST request |
| INLONG-8663 | [Improve][Manager] Add tenant related OpenAPI |
| INLONG-8627 | [Improve][Manager] Add parameters validation for the testConnection method |
| INLONG-8622 | [Improve][Manager] Optimize the permission control of user API |
| INLONG-8620 | [INLONG-8619][Manager] Remove the inlong role check of internal interfaces |
| INLONG-8619 | [Improve][Manager] Remove the inlong role check of internal interfaces |
| INLONG-8618 | [INLONG-8617][Manager] Optimize compatibility of SortSdk config interface 1.9.x/bugfix |
| INLONG-8617 | [Improve][Manager] Optimize compatibility of SortSdk config interface |
| INLONG-8611 | [Feature][Manager][Agent][DataProxy] Support full link tracking to improve the observability of the project |
| INLONG-8606 | [INLONG-8590][Manager] Make Cluster and ClusterTags as public resources |
| INLONG-8603 | [Bug][Manager] Fix the vulnerability to security attacks for the MySQL JDBC URL |
| INLONG-8590 | [Improve][Manager] Make Cluster and ClusterTags as public resources |
| INLONG-8586 | [Improve][Manager] Stop Stream Source which is still running after group is stopped |
| INLONG-8582 | [Improve][Manager] Remove unnecessary log information in InlongClusterServiceImpl |
| INLONG-8570 | [Bug][Manager] Modules in the wrong order cause UT execution to fail |
| INLONG-8568 | [INLONG-8567][Manager] Add new role INLONG_SERVICE for internal service query 1.9.x/bugfix |
| INLONG-8567 | [Feature][Manager] Add new role INLONG_SERVICE for internal service query |
| INLONG-8564 | [Bug][Manager] Unable to issue tasks after modifying data node info |
| INLONG-8563 | [Improve][Manager] Opitmize the permission check of tenant-related operation |
| INLONG-8556 | [Improve][Manager] Optimize the location of the manager-plugins-flink jar package |
| INLONG-8550 | [INLONG-8547][Manager] Add workflow approver automatically when create a new tenant |
| INLONG-8547 | [Feature][Manager] Add workflow approver automatically when create a new tenant |
| INLONG-8541 | [Bug][Manager] Save InlongGroup with error tenant 1.9.x/bugfix |
| INLONG-8539 | [Improve][Manager] Remove stream source when heartbeat of agent contains no group message |
| INLONG-8537 | [Bug][Manager] Insert group failed 1.9.x/bugfix |
| INLONG-8535 | [Bug][Manager] There is a null pointer when calling updateRuntimeConfig method |
| INLONG-8529 | [Improve][Manager] update stream source to heartbeat timeout when evit cluster node |
| INLONG-8522 | [Improve][Manager] Optimize log print for AgentService |
| INLONG-8516 | [Improve][Manager] Missing scala dependency for Flink 1.15 1.9.x/bugfix |
| INLONG-8514 | [Improve][Manager] Support ClickHouse field type special modifier Nullable |
| INLONG-8509 | [Improve][Manager] Optimize preProcessTemplateFileTask in AgentServiceImpl |
| INLONG-8492 | [INLONG-8490][Manager] Duplicate queried audit data according to all fields |
| INLONG-8491 | [Feature][Manager] manager client support list inlong streams with sources and sinks by paginating |
| INLONG-8490 | [Improve][Manager] Duplicate queried audit data according to all fields |
| INLONG-8488 | [INLONG-8374][Manager] Manager client tools support multiple tenant |
| INLONG-8448 | [INLONG-8447][Manager] Optimize paging logic |
| INLONG-8447 | [Improve][Manager] Optimize paging logic stage/stale |
| INLONG-8446 | [Feature][Manager] Remove the permission check logic in Services and DAOs good first issue |
| INLONG-8403 | [Feature][Manager] Support resource migrate to different tenant |
| INLONG-8374 | [Feature][Manager] Manager client tools support multiple tenant good first issue |
| INLONG-8360 | [Improve][Manager] Support previewing data of Kafka |
| INLONG-8939 | [Improve][Manager] Add a switch to initiate the delete data source task |
| INLONG-8946 | [Improve][Manager] Optimize the audit ID method issued by the manager |
| INLONG-8951 | [Improve][Manager] Support for configuring built-in fields for iceberg |
SDK
| ISSUE | Summary |
|---|---|
| INLONG-8916 | [Improve][SDK] Update SDK configuration file for dataproxy cpp sdk |
| INLONG-8910 | [Improve][SDK] Adjust some default configuration parameters |
| INLONG-8905 | [Improve][SDK] Code specifications for dataproxy cpp sdk |
| INLONG-8896 | [Improve][SDK] Remove old code before refactoring for dataproxy cpp sdk |
| INLONG-8891 | [Improve][SDK] Optimize compile for dataproxy cpp sdk |
| INLONG-8889 | [Improve][SDK] Optimize CmakeList for dataproxy cpp sdk |
| INLONG-8887 | [Improve][SDK] Optimize api framework for dataproxy cpp sdk |
| INLONG-8885 | [Improve][SDK] Optimize tcp manager framework for dataproxy cpp sdk |
| INLONG-8883 | [Improve][SDK] Optimize proxy config manager framework for dataproxy cpp sdk |
| INLONG-8868 | [Improve][SDK] Optimize send data framework for dataproxy cpp sdk |
| INLONG-8866 | [Improve][SDK] Optimize data receiving framework for dataproxy cpp sdk |
| INLONG-8864 | [Improve][SDK] Add memory utils for dataproxy cpp sdk |
| INLONG-8861 | [Improve][SDK] Add mutex utils for dataproxy cpp sdk |
| INLONG-8860 | [Improve][SDK] Add log utils for dataproxy cpp sdk |
| INLONG-8858 | [Improve][SDK] Add init helper information for dataproxy cpp sdk |
| INLONG-8856 | [Improve][SDK] Add msg information for dataproxy cpp sdk |
| INLONG-8854 | [Improve][SDK] Add return code information for dataproxy cpp sdk |
| INLONG-8784 | [INLONG-8766][SDK] SortSdk create consumer in parallel |
| INLONG-8766 | [Improve][SDK] SortSdk create consumer in parallel |
| INLONG-8747 | [Improve][SDK] Optimize the local configuration management of cpp sdk |
| INLONG-8728 | [Improve][SDK] Optimize the problem of third-party openssl library dependency failure |
| INLONG-8639 | [Improve][SDK] Improve send failed logic of DataProxy |
| INLONG-8637 | [Improve][SDK] Pool data request and batch request for DataProxy |
| INLONG-8635 | [Improve][SDK] Update dependency packages and required Go version for DataProxy |
| INLONG-8633 | [Improve][SDK] Update debug log level for DataProxy SDK |
| INLONG-8631 | [Improve][SDK] Handle context.Done() in Send() for DataProxy SDK |
Sort
| ISSUE | Summary |
|---|---|
| INLONG-8897 | [Bug][Sort] update dbz option name 'schema. whitelist' to 'schema.include.list' |
| INLONG-8848 | [Bug][Sort] Sort base dependency error |
| INLONG-8839 | [Feature][Sort] Add audit metric in starrocks connector on flink 1.15 |
| INLONG-8838 | [Improve][Sort] IcebergSource support metadata |
| INLONG-8825 | [Feature][Sort] Optimize the field type conversion between source and target in the whole database scenario |
| INLONG-8818 | [INLONG-8643][Sort] Support Iceberg source |
| INLONG-8808 | [Improve][Sort] Improve convertToBinary for RowDataDebeziumDeserializeSchema |
| INLONG-8796 | [Improve][Sort] Add SchemaChangeEventHandler to deal schema change event by each connector |
| INLONG-8786 | [Bug][Sort] The Doris schema should be changed in case of multiple URI |
| INLONG-8783 | [Bug][Sort] MySql connector jdbc version is incompatible with mysql-cdc version |
| INLONG-8776 | [Improve][Sort] MySql connector should add jdbc driver jar |
| INLONG-8745 | [Improve][Sort] Add incremental and postgre type in postgre connector |
| INLONG-8743 | [Feature][Sort] Support more type of ddl in all migration |
| INLONG-8667 | [Improve][Sort] The inner class name was wrong in OracleSnapshotContext |
| INLONG-8653 | [Bug][Sort] fix the query sql for jdbc pg dialect multiple table scenerios. |
| INLONG-8643 | [Feature][Sort] Add Iceberg source on flink 1.15 |
| INLONG-8641 | [Bug][Sort] SingleTableCustomFieldsPartitioner package name does not match path |
| INLONG-8616 | [INLONG-8598][Sort] Optimize sortstandalone pulsar sink |
| INLONG-8602 | [Bug][Sort] Fix StackOverflowError of Oracle CDC |
| INLONG-8598 | [Improve][Sort] Optimize sortstandalone pulsar sink |
| INLONG-8596 | [Feature][Sort] Iceberg supports dynamic switching between append and upsert |
| INLONG-8594 | [Bug][Sort] When change record is chunk range of snapshot phase, MongoDB cannot rewrite the record |
| INLONG-8579 | [INLONG-8578][Sort] Fix npe inside outputReadPhaseMetrics in mysql-cdc |
| INLONG-8578 | [Bug][Sort] NPE occurred inside outputReadPhaseMetrics of mysql-cdc |
| INLONG-8558 | [Improve][Sort] Use database name in upper case at the OracleTableSourceFactory |
| INLONG-8551 | [INLONG-8549][Sort] Fix incorrect use of maven plugin on integration test among sort-end-to-end-tests |
| INLONG-8549 | [Bug][Sort] Incorrect use of maven plugin on integration test among sort-end-to-end-tests |
| INLONG-8445 | [Feature][Sort] Support running tests on both Flink 1.13 and Flink 1.15 |
| INLONG-8436 | [Bug][Sort] The backfill task not running bug in oracle cdc connector |
| INLONG-8279 | [Bug][Sort] NPE when run MySqlLoadSqlParseTest |
| INLONG-8236 | [Feature][Sort] Iceberg supports dynamic switching between append and upsert |
| INLONG-7908 | [Feature][Sort] PostgreSQL connector supports parallel read |
| INLONG-7900 | [Feature][Sort] Support partition by custom fields when upsert single table of Kafka |
| INLONG-7763 | [Feature][Sort] Support ddl change for doris |
| INLONG-8797 | [Feature][Manager][Sort] Audit has no data for data sync |
| INLONG-8903 | [Bug][TubeMQ][Sort] int64 not recognized by the compiler and Missing @Override annotations |
| INLONG-8953 | [Bug][Sort] Iceberg source default the StartSnapshot to the latest |
TubeMQ
| ISSUE | Summary |
|---|---|
| INLONG-4972 | [Feature][TubeMQ] Add TubeMQ Command Tools stage/roadmap |
| INLONG-8903 | [Bug][TubeMQ][Sort] int64 not recognized by the compiler and Missing @Override annotations |
| INLONG-8871 | [Improve][TubeMQ] Use an error code in checkMessageAndStatus() to return the check result instead of throwing an exception |
| INLONG-8812 | [Improve][Tubemq] Missing parameter |
| INLONG-8793 | [INLONG-8791][TubeMQ] Tubemq-client-go lacks log level configuration API |
| INLONG-8768 | [Improve][TubeMQ] Adding restart-manager.sh for inlong-tubemq-manager |
| INLONG-8720 | [Improve][TubeMQ] Some unused return params in WebParamaterUtils |
| INLONG-8717 | [Bug][TubeMQ] Display wrong response message in TubeMQ master web panel |
| INLONG-8716 | [Bug][TubeMQ] set error code 0 when it works |
| INLONG-8701 | [Improve][TubeMQ] Master dashboard respond always true when some operation complete |
Other
| ISSUE | Summary |
|---|---|
| INLONG-8614 | [Bug][CI] Post maven cache failed for UT and build workflow service/ci |
| INLONG-8494 | [Bug][CI] Caught IOException "No space left on device" for Analyze by CodeQL workflow |
| INLONG-8846 | [Improve][Doc] Add ASF DOAP File for InLong |
| INLONG-8543 | [Bug][Docker] The path of the mysql connector is wrong when docker build service/docker |
| INLONG-8533 | [Improve][Docker] Add MySQL connector to the manager image service/docker |
| INLONG-8918 | [Bug][Script] A script parameter error in bin/inlong-daemon |
| INLONG-8690 | [Improve][Security] TemporaryFolder on unix-like systems does not limit access to created files |
| INLONG-8688 | [Improve][Security] Incorrect Authorization in MySQL Connector Java |
| INLONG-8687 | [Improve][Security] Apache Pulsar Java Client vulnerable to Improper Certificate Validation |
| INLONG-8686 | [Improve][Security] TemporaryFolder on unix-like systems does not limit access to created files |
| INLONG-8685 | [Improve][Security] Denial of service due to parser crash |
| INLONG-8684 | [Improve][Security] Vite Server Options (server.fs.deny) can be bypassed using double forward-slash (//) |
| INLONG-8683 | [Improve][Security] OutOfMemoryError for large multipart without filename in Eclipse Jetty |
| INLONG-8682 | [Improve][Security] Guava vulnerable to insecure use of temporary directory |
| INLONG-8681 | [Improve][Security] netty-handler SniHandler 16MB allocation |
| INLONG-8934 | [Feature][Distribution] Add Iceberg connectors into the bundle |
| INLONG-8942 | [Improve][Distribution]Support to merge all jar file of multiple modules in order to reduce version package size |
| INLONG-8965 | [Improve][Doc] Update the description for swagger API |