This is an automated email from the ASF dual-hosted git repository.
zykkk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 666411c [Fix](mysql) fix mysql datetime missing millisecond digits
(#195)
666411c is described below
commit 666411c6a1a1cbb12be263944645d1e24665b3fc
Author: wudi <[email protected]>
AuthorDate: Fri Sep 15 11:33:35 2023 +0800
[Fix](mysql) fix mysql datetime missing millisecond digits (#195)
Co-authored-by: wudi <>
---
.../doris/flink/tools/cdc/{ => mysql}/DateToStringConverter.java | 6 +++---
.../org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java | 1 -
2 files changed, 3 insertions(+), 4 deletions(-)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DateToStringConverter.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java
similarity index 98%
rename from
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DateToStringConverter.java
rename to
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java
index 60a9718..e779be0 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DateToStringConverter.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java
@@ -15,7 +15,7 @@
// specific language governing permissions and limitations
// under the License.
-package org.apache.doris.flink.tools.cdc;
+package org.apache.doris.flink.tools.cdc.mysql;
import
com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.data.SchemaBuilder;
import io.debezium.spi.converter.CustomConverter;
@@ -47,9 +47,9 @@ public class DateToStringConverter implements
CustomConverter<SchemaBuilder, Rel
static {
DEFAULT_PROPS.setProperty("converters", "date");
- DEFAULT_PROPS.setProperty("date.type",
"org.apache.doris.flink.tools.cdc.DateToStringConverter");
+ DEFAULT_PROPS.setProperty("date.type",
"org.apache.doris.flink.tools.cdc.mysql.DateToStringConverter");
DEFAULT_PROPS.setProperty("date.format.date", "yyyy-MM-dd");
- DEFAULT_PROPS.setProperty("date.format.datetime", "yyyy-MM-dd
HH:mm:ss");
+ DEFAULT_PROPS.setProperty("date.format.datetime", "yyyy-MM-dd
HH:mm:ss.SSSSSS");
DEFAULT_PROPS.setProperty("date.format.timestamp", "yyyy-MM-dd
HH:mm:ss.SSSSSS");
DEFAULT_PROPS.setProperty("date.format.timestamp.zone", "UTC+8");
}
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java
index 05dd298..2235e0b 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java
@@ -29,7 +29,6 @@ import com.ververica.cdc.debezium.table.DebeziumOptions;
import org.apache.doris.flink.catalog.doris.DataModel;
import
org.apache.doris.flink.deserialization.DorisJsonDebeziumDeserializationSchema;
import org.apache.doris.flink.tools.cdc.DatabaseSync;
-import org.apache.doris.flink.tools.cdc.DateToStringConverter;
import org.apache.doris.flink.tools.cdc.SourceSchema;
import org.apache.flink.api.common.eventtime.WatermarkStrategy;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
