From 492e4d1fe5b85ed7fb91aef3335555f0cb64ff7b Mon Sep 17 00:00:00 2001 From: Jiri Pechanec Date: Thu, 6 Jun 2024 11:43:42 +0200 Subject: [PATCH] DBZ-7265 Fix formatting --- .../connector/vitess/AbstractVitessConnectorTest.java | 3 +-- .../io/debezium/connector/vitess/VitessConnectorIT.java | 8 ++++---- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/src/test/java/io/debezium/connector/vitess/AbstractVitessConnectorTest.java b/src/test/java/io/debezium/connector/vitess/AbstractVitessConnectorTest.java index cebc9af8..664a1b0b 100644 --- a/src/test/java/io/debezium/connector/vitess/AbstractVitessConnectorTest.java +++ b/src/test/java/io/debezium/connector/vitess/AbstractVitessConnectorTest.java @@ -228,8 +228,7 @@ protected List schemasAndValuesForStringTypesTruncatedBlob( new SchemaAndValueField("binary_col", SchemaBuilder.bytes().optional() .parameter("truncateLength", "1").build(), byteBufferTruncatedBinary), new SchemaAndValueField("varbinary_col", SchemaBuilder.bytes().optional() - .parameter("truncateLength", "1").build(), byteBufferTruncatedVarBinary) - )); + .parameter("truncateLength", "1").build(), byteBufferTruncatedVarBinary))); return fields; } diff --git a/src/test/java/io/debezium/connector/vitess/VitessConnectorIT.java b/src/test/java/io/debezium/connector/vitess/VitessConnectorIT.java index c3302dff..4f187612 100644 --- a/src/test/java/io/debezium/connector/vitess/VitessConnectorIT.java +++ b/src/test/java/io/debezium/connector/vitess/VitessConnectorIT.java @@ -255,13 +255,13 @@ public void shouldTruncateByteArray() throws Exception { TestHelper.executeDDL("vitess_create_tables.ddl"); startConnector(builder -> builder.with( - "column.truncate.to.1.chars", - TEST_UNSHARDED_KEYSPACE + ".string_table.blob_col," + "column.truncate.to.1.chars", + TEST_UNSHARDED_KEYSPACE + ".string_table.blob_col," + TEST_UNSHARDED_KEYSPACE + ".string_table.mediumblob_col," + TEST_UNSHARDED_KEYSPACE + ".string_table.longblob_col," + TEST_UNSHARDED_KEYSPACE + ".string_table.varbinary_col," - + TEST_UNSHARDED_KEYSPACE + ".string_table.binary_col" - ), false, + + TEST_UNSHARDED_KEYSPACE + ".string_table.binary_col"), + false, false, 1, -1, -1, null, VitessConnectorConfig.SnapshotMode.NEVER, ""); assertConnectorIsRunning();