From 12662c51853b87b663fa9802d50754aec4df54c4 Mon Sep 17 00:00:00 2001 From: ismail simsek <6005685+ismailsimsek@users.noreply.github.com> Date: Wed, 13 Mar 2024 11:05:51 +0100 Subject: [PATCH 1/4] Update IcebergChangeConsumerMangodbTest.java --- .../server/iceberg/IcebergChangeConsumerMangodbTest.java | 1 - 1 file changed, 1 deletion(-) diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java index 9b58c99b..995f24ab 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java @@ -31,7 +31,6 @@ * @author Ismail Simsek */ @QuarkusTest -@Disabled // @TODO fix @QuarkusTestResource(value = S3Minio.class, restrictToAnnotatedClass = true) @QuarkusTestResource(value = SourceMangoDB.class, restrictToAnnotatedClass = true) @TestProfile(IcebergChangeConsumerMangodbTest.TestProfile.class) From d4339d4a2b902e5a9672e4281833b18622d1befa Mon Sep 17 00:00:00 2001 From: ismail simsek <6005685+ismailsimsek@users.noreply.github.com> Date: Wed, 13 Mar 2024 11:08:52 +0100 Subject: [PATCH 2/4] Update SourceMangoDB.java --- .../debezium/server/iceberg/testresources/SourceMangoDB.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/testresources/SourceMangoDB.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/testresources/SourceMangoDB.java index 28ea68e4..4d3ce466 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/testresources/SourceMangoDB.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/testresources/SourceMangoDB.java @@ -11,6 +11,7 @@ import io.quarkus.test.common.QuarkusTestResourceLifecycleManager; import java.time.Duration; +import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; @@ -31,6 +32,8 @@ public class SourceMangoDB implements QuarkusTestResourceLifecycleManager { @Override public Map start() { + container.setPortBindings(List.of(MONGODB_PORT+":"+MONGODB_PORT)); + container.withExposedPorts(MONGODB_PORT).start(); Map params = new ConcurrentHashMap<>(); From f21b2eeed32e5815fd52339c60cf1c20746e5d42 Mon Sep 17 00:00:00 2001 From: ismail simsek <6005685+ismailsimsek@users.noreply.github.com> Date: Wed, 13 Mar 2024 11:09:29 +0100 Subject: [PATCH 3/4] Update IcebergChangeEvent.java --- .../java/io/debezium/server/iceberg/IcebergChangeEvent.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeEvent.java b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeEvent.java index eb468f43..8ea3af9b 100644 --- a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeEvent.java +++ b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeEvent.java @@ -149,7 +149,7 @@ private static Object jsonValToIcebergVal(Types.NestedField field, JsonNode node val = node.isValueNode() ? UUID.fromString(node.asText(null)) : UUID.fromString(node.toString()); break; case TIMESTAMP: - if (node.isLong() && TS_MS_FIELDS.contains(field.name())) { + if ((node.isLong() || node.isNumber()) && TS_MS_FIELDS.contains(field.name())) { val = OffsetDateTime.ofInstant(Instant.ofEpochMilli(node.longValue()), ZoneOffset.UTC); } else if (node.isTextual()) { val = OffsetDateTime.parse(node.asText()); From 740e3074ea1b1bcb1bf76ce17efd7645ee6a13ab Mon Sep 17 00:00:00 2001 From: ismail simsek <6005685+ismailsimsek@users.noreply.github.com> Date: Wed, 13 Mar 2024 11:10:25 +0100 Subject: [PATCH 4/4] Update SourceMangoDB.java --- .../io/debezium/server/iceberg/testresources/SourceMangoDB.java | 1 - 1 file changed, 1 deletion(-) diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/testresources/SourceMangoDB.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/testresources/SourceMangoDB.java index 4d3ce466..f54bc7b1 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/testresources/SourceMangoDB.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/testresources/SourceMangoDB.java @@ -33,7 +33,6 @@ public class SourceMangoDB implements QuarkusTestResourceLifecycleManager { @Override public Map start() { container.setPortBindings(List.of(MONGODB_PORT+":"+MONGODB_PORT)); - container.withExposedPorts(MONGODB_PORT).start(); Map params = new ConcurrentHashMap<>();