You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/04/30 14:52:26 UTC
[incubator-inlong] branch master updated: [INLONG-4048][Sort] Fix metadata type process error and hive-exec dependency scope error (#4049)
This is an automated email from the ASF dual-hosted git repository.
healchow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 6f8c649d9 [INLONG-4048][Sort] Fix metadata type process error and hive-exec dependency scope error (#4049)
6f8c649d9 is described below
commit 6f8c649d96d78edf42d5cbfaab666aa3ea14caf9
Author: pacino <ge...@gmail.com>
AuthorDate: Sat Apr 30 22:52:20 2022 +0800
[INLONG-4048][Sort] Fix metadata type process error and hive-exec dependency scope error (#4049)
---
inlong-sort/sort-single-tenant/pom.xml | 1 -
.../flink/cdc/mysql/table/MySqlReadableMetadata.java | 15 ++++++++-------
2 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/inlong-sort/sort-single-tenant/pom.xml b/inlong-sort/sort-single-tenant/pom.xml
index 9a10e77a1..0acd78995 100644
--- a/inlong-sort/sort-single-tenant/pom.xml
+++ b/inlong-sort/sort-single-tenant/pom.xml
@@ -156,7 +156,6 @@
<artifactId>calcite-druid</artifactId>
</exclusion>
</exclusions>
- <scope>provided</scope>
</dependency>
diff --git a/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/cdc/mysql/table/MySqlReadableMetadata.java b/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/cdc/mysql/table/MySqlReadableMetadata.java
index 5e4d4bf3d..f3cad6383 100644
--- a/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/cdc/mysql/table/MySqlReadableMetadata.java
+++ b/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/cdc/mysql/table/MySqlReadableMetadata.java
@@ -23,11 +23,6 @@ import io.debezium.data.Envelope;
import io.debezium.data.Envelope.FieldName;
import io.debezium.relational.Table;
import io.debezium.relational.history.TableChanges;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import javax.annotation.Nullable;
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.flink.table.api.DataTypes;
import org.apache.flink.table.data.GenericArrayData;
@@ -42,6 +37,12 @@ import org.apache.inlong.sort.singletenant.flink.cdc.debezium.table.MetadataConv
import org.apache.kafka.connect.data.Struct;
import org.apache.kafka.connect.source.SourceRecord;
+import javax.annotation.Nullable;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
/**
* Defines the supported metadata columns for {@link MySqlTableSource}.
*/
@@ -157,7 +158,7 @@ public enum MySqlReadableMetadata {
@Override
public Object read(SourceRecord record) {
- return getMetaData(record, AbstractSourceInfo.TABLE_NAME_KEY);
+ return StringData.fromString(getMetaData(record, AbstractSourceInfo.TABLE_NAME_KEY));
}
}),
@@ -172,7 +173,7 @@ public enum MySqlReadableMetadata {
@Override
public Object read(SourceRecord record) {
- return getMetaData(record, AbstractSourceInfo.DATABASE_NAME_KEY);
+ return StringData.fromString(getMetaData(record, AbstractSourceInfo.DATABASE_NAME_KEY));
}
}),