From 891cddff4520cd18a53f525f35d895a1bce1cda2 Mon Sep 17 00:00:00 2001 From: priyanshi-yb Date: Wed, 8 Jan 2025 12:56:38 +0530 Subject: [PATCH] cleanup --- .github/workflows/pg-13-migtests.yml | 2 +- .../server/ybexporter/PostgresToYbValueConverter.java | 3 --- migtests/scripts/run-test.sh | 4 ---- yb-voyager/src/dbzm/config.go | 2 +- 4 files changed, 2 insertions(+), 9 deletions(-) diff --git a/.github/workflows/pg-13-migtests.yml b/.github/workflows/pg-13-migtests.yml index 08e2f828a4..9b2d428cdc 100644 --- a/.github/workflows/pg-13-migtests.yml +++ b/.github/workflows/pg-13-migtests.yml @@ -11,7 +11,7 @@ jobs: strategy: matrix: version: [2024.2.0.0-b145, 2.20.8.0-b53, 2024.1.3.1-b8, 2.23.1.0-b220] - BETA_FAST_DATA_EXPORT: [1] + BETA_FAST_DATA_EXPORT: [0, 1] test_group: - offline - live_basic diff --git a/debezium-server-voyager/debezium-server-voyagerexporter/src/main/java/io/debezium/server/ybexporter/PostgresToYbValueConverter.java b/debezium-server-voyager/debezium-server-voyagerexporter/src/main/java/io/debezium/server/ybexporter/PostgresToYbValueConverter.java index 566fc2e89a..8d1e79a6cc 100644 --- a/debezium-server-voyager/debezium-server-voyagerexporter/src/main/java/io/debezium/server/ybexporter/PostgresToYbValueConverter.java +++ b/debezium-server-voyager/debezium-server-voyagerexporter/src/main/java/io/debezium/server/ybexporter/PostgresToYbValueConverter.java @@ -36,12 +36,9 @@ public void converterFor(RelationalColumn column, break; } - LOGGER.info("column={}", column); - LOGGER.info("registration={}", registration); switch (column.typeName()) { case "tsvector": case "tsquery": - case "hstore": registration.register(SchemaBuilder.string(), this::stringify); break; } diff --git a/migtests/scripts/run-test.sh b/migtests/scripts/run-test.sh index 1725eaab40..b7edc5a623 100755 --- a/migtests/scripts/run-test.sh +++ b/migtests/scripts/run-test.sh @@ -119,10 +119,6 @@ main() { echo "Error: pg_dump version not found in the log file." >&2 fi fi - - cat ${EXPORT_DIR}/data/hstore_example_data.sql - cat ${EXPORT_DIR}/data/schemas/source_db_exporter/hstore_example_schema.json - cat ${EXPORT_DIR}/logs/debezium-source_db_exporter.log step "Fix data." if [ -x "${TEST_DIR}/fix-data" ] diff --git a/yb-voyager/src/dbzm/config.go b/yb-voyager/src/dbzm/config.go index aabc9598f9..48739fee5d 100644 --- a/yb-voyager/src/dbzm/config.go +++ b/yb-voyager/src/dbzm/config.go @@ -123,7 +123,7 @@ debezium.source.connector.class=io.debezium.connector.postgresql.PostgresConnect debezium.source.database.dbname=%s debezium.source.schema.include.list=%s debezium.source.plugin.name=pgoutput -debezium.source.hstore.handling.mode=json +debezium.source.hstore.handling.mode=map debezium.source.converters=postgres_to_yb_converter debezium.source.postgres_to_yb_converter.type=io.debezium.server.ybexporter.PostgresToYbValueConverter debezium.source.provide.transaction.metadata=true