DWS-Connector Version Description
The latest release of the DWS-Connector includes three main components: dws-client, dws-connector-flink, and dws-flink-ingestion. The dws-client component is responsible for importing data into the database.
- dws-client is a high-performance database import tool that integrates DWS JDBC.
- dws-connector-flink is a tool that integrates dws-client and is used to connect to open-source Flink.
- dws-flink-ingestion is a Flink import job package provided by DWS based on the integration of the preceding two components. (To use it, contact technical support.)
The three components use the same dws-client version. The current version is 1.x or 2.x. For details about the version records, see Table 1. For details about the mapping between versions and JDBC, see Table 2.
- The 1.x version will not introduce new functions. Only existing functions will be hardened.
- The 2.x version will be evolved for a long time. Due to the overall design reconstruction, some functions of the 2.x version may be incompatible with those of the 1.x version.
As a result, the 1.x version will receive maintenance and bug fixes in the short term. Once the 2.x version is stable and widely adopted, further development of the 1.x version will cease.
Version |
Change Description |
Remarks |
---|---|---|
1.0 |
This issue is the first official release. |
dws-connector-flink only releases Scala2.11 Flink 1.12. |
1.0.2 |
Optimized the exception retry logic of dwsclient. The retry mode is changed from retry upon all exceptions to retry only upon five types of exceptions: connection exception, database read-only, timeout, excessive connections, and lock exception. |
Compatible versions of dws-connector-flink: Scala2.11: Flink 1.12 and 1.13 Scala2.12: Flink 1.12, 1.13, and 1.15 |
1.0.3 |
|
- |
1.0.4 |
Increased the SQL execution timeout interval to avoid long-time blocking. |
- |
1.0.5 |
Resolved the problem that duplicate data is lost when being written to a table without a primary key. |
- |
1.0.6 |
|
- |
1.0.7 |
|
- |
1.0.8 |
|
- |
1.0.9 |
Optimized the import of data of the time type. |
- |
1.0.10 |
|
- |
1.0.11 |
|
Scala 2.12 is added to connector-flink: Flink 1.17 |
1.1.0 |
Optimized the cache write performance of the DWS client. |
- |
1.1.0.1 |
|
- |
1.1.0.2 |
Fixed issues:
|
- |
1.1.0.3 |
Fixed issues:
|
- |
2.0.0-r0~r2 |
In the 2.x version initialization, DWS made the following enhancements:
|
- |
2.0.0-r3 |
Fixed issues:
Improved features:
|
- |
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.
For any further questions, feel free to contact us through the chatbot.
Chatbot