This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 47e5cd6d8 [hotfix][pipeline-connector][maxcompute] Fix MaxCompute
Pipeline Connector tests by upgrading maxcompute-emulator
47e5cd6d8 is described below
commit 47e5cd6d89899e78b2ffa4e9c2f8132f2862b5fc
Author: Jason Zhang <50667759+dingxin-t...@users.noreply.github.com>
AuthorDate: Thu Jan 16 16:40:20 2025 +0800
[hotfix][pipeline-connector][maxcompute] Fix MaxCompute Pipeline Connector
tests by upgrading maxcompute-emulator
This closes #3862
---
.github/workflows/flink_cdc_base.yml | 3 ++-
.../org/apache/flink/cdc/connectors/maxcompute/EmulatorTestBase.java | 2 +-
.../flink/cdc/connectors/maxcompute/utils/TypeConvertUtilsTest.java | 4 ++--
3 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/.github/workflows/flink_cdc_base.yml
b/.github/workflows/flink_cdc_base.yml
index 153002804..e45373f62 100644
--- a/.github/workflows/flink_cdc_base.yml
+++ b/.github/workflows/flink_cdc_base.yml
@@ -58,7 +58,8 @@ env:
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka,\
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon,\
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch,\
-
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase"
+
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase,\
+
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute"
MODULES_MYSQL: "\
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc,\
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/test/java/org/apache/flink/cdc/connectors/maxcompute/EmulatorTestBase.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/test/java/org/apache/flink/cdc/connectors/maxcompute/EmulatorTestBase.java
index 717058ec6..9062871fb 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/test/java/org/apache/flink/cdc/connectors/maxcompute/EmulatorTestBase.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/test/java/org/apache/flink/cdc/connectors/maxcompute/EmulatorTestBase.java
@@ -41,7 +41,7 @@ public class EmulatorTestBase {
private static final Logger LOG =
LoggerFactory.getLogger(EmulatorTestBase.class);
public static final DockerImageName MAXCOMPUTE_IMAGE =
- DockerImageName.parse("maxcompute/maxcompute-emulator:v0.0.4");
+ DockerImageName.parse("maxcompute/maxcompute-emulator:v0.0.7");
@ClassRule
public static GenericContainer<?> maxcompute =
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/test/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtilsTest.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/test/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtilsTest.java
index 09c1b0111..1244e5a79 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/test/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtilsTest.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/test/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtilsTest.java
@@ -167,7 +167,7 @@ public class TypeConvertUtilsTest {
123456.789d,
12345,
12345,
-
TimestampData.fromTimestamp(Timestamp.from(Instant.ofEpochSecond(0))),
+
TimestampData.fromTimestamp(Timestamp.valueOf("1970-01-01 00:00:00")),
LocalZonedTimestampData.fromInstant(Instant.ofEpochSecond(0)),
ZonedTimestampData.fromZonedDateTime(
ZonedDateTime.ofInstant(
@@ -179,7 +179,7 @@ public class TypeConvertUtilsTest {
TypeConvertUtils.toMaxComputeRecord(schemaWithoutComplexType, record1,
arrayRecord);
String expect =
-
"char,varchar,string,false,=01=02=03=04=05,=01=02=03=04=05=06=07=08=09=0A,0.00,1,2,12345,12345,123.456,123456.789,00:00:00.012345,2003-10-20,1970-01-01T08:00,1970-01-01T00:00:00Z,1970-01-01T00:00:00Z";
+
"char,varchar,string,false,=01=02=03=04=05,=01=02=03=04=05=06=07=08=09=0A,0.00,1,2,12345,12345,123.456,123456.789,00:00:00.012345,2003-10-20,1970-01-01T00:00,1970-01-01T00:00:00Z,1970-01-01T00:00:00Z";
Assert.assertEquals(expect, arrayRecord.toString());
}
}
