Skip to content

Commit af9a317

Browse files
committed
Fix text.
1 parent 542da60 commit af9a317

File tree

1 file changed

+5
-12
lines changed

1 file changed

+5
-12
lines changed

sdks/python/apache_beam/io/external/xlang_jdbcio_it_test.py

Lines changed: 5 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -258,7 +258,7 @@ def test_xlang_jdbc_read_with_explicit_schema(self, database):
258258
JdbcTestRow(
259259
i,
260260
i + 0.1,
261-
f'Test{i}',
261+
f'Test{i}' + ' ' * (10 - len(f'Test{i}')),
262262
f'Test{i}',
263263
f'Test{i}'.encode(),
264264
f'Test{i}'.encode(),
@@ -316,7 +316,7 @@ def test_xlang_jdbc_read_with_explicit_schema(self, database):
316316
CustomSchemaRow(
317317
row.f_id,
318318
row.f_float,
319-
row.f_char + ' ' * (10 - len(row.f_char)),
319+
row.f_char,
320320
row.f_varchar,
321321
f_bytes,
322322
row.f_bytes,
@@ -332,16 +332,9 @@ def custom_equals(expected, actual):
332332
return (
333333
expected.renamed_id == actual.renamed_id and
334334
expected.renamed_float == actual.renamed_float and
335-
expected.renamed_char == actual.renamed_char and
336-
expected.renamed_varchar == actual.renamed_varchar and (
337-
expected.renamed_bytes == actual.renamed_bytes or
338-
# Handle potential padding differences in binary fields
339-
expected.renamed_bytes.rstrip(b'\0') ==
340-
actual.renamed_bytes.rstrip(b'\0')) and (
341-
expected.renamed_varbytes == actual.renamed_varbytes or
342-
# Handle potential padding differences in binary fields
343-
expected.renamed_varbytes.rstrip(b'\0') ==
344-
actual.renamed_varbytes.rstrip(b'\0')) and
335+
expected.renamed_char.rstrip() == actual.renamed_char.rstrip() and
336+
expected.renamed_varchar == actual.renamed_varchar and
337+
expected.renamed_bytes == actual.renamed_bytes and
345338
expected.renamed_timestamp == actual.renamed_timestamp and
346339
expected.renamed_decimal == actual.renamed_decimal and
347340
expected.renamed_date == actual.renamed_date and

0 commit comments

Comments
 (0)