Skip to content

Commit a7bc70c

Browse files
committed
remove test logs
1 parent 2154315 commit a7bc70c

File tree

2 files changed

+1
-16
lines changed

2 files changed

+1
-16
lines changed

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableRowToStorageApiProto.java

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1380,14 +1380,7 @@ public static Object jsonValueFromMessageValue(
13801380
return BigDecimal.valueOf(doubleValue).stripTrailingZeros().toString();
13811381
} else {
13821382
throw new RuntimeException(
1383-
"Not implemented yet "
1384-
+ fieldDescriptor.getMessageType().getName()
1385-
+ " PARTIAL NAME "
1386-
+ fieldDescriptor.getMessageType().getName()
1387-
+ " FIELD NAME "
1388-
+ prefix
1389-
+ " CLASS TYPE "
1390-
+ fieldValue.getClass());
1383+
"Not implemented yet " + fieldDescriptor.getMessageType().getName());
13911384
}
13921385
default:
13931386
return fieldValue.toString();

sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOWriteTest.java

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -3679,7 +3679,6 @@ public void testStorageApiErrorsWriteTableRows() throws Exception {
36793679
expectedFailedRows.addAll(
36803680
goodRows.stream().filter(shouldFailRow::apply).collect(Collectors.toList()));
36813681

3682-
deadRows.apply(ParDo.of(new PrintingDoFn()));
36833682
PAssert.that(deadRows).containsInAnyOrder(expectedFailedRows);
36843683
PAssert.that(successfulRows)
36853684
.containsInAnyOrder(
@@ -3694,13 +3693,6 @@ public void testStorageApiErrorsWriteTableRows() throws Exception {
36943693
Iterables.filter(goodRows, r -> !shouldFailRow.apply(r)), TableRow.class)));
36953694
}
36963695

3697-
private static class PrintingDoFn extends DoFn<TableRow, Void> {
3698-
@ProcessElement
3699-
public void processElement(@Element TableRow element) {
3700-
System.err.println("FAILED " + element);
3701-
}
3702-
}
3703-
37043696
@Test
37053697
public void testStreamingInsertsWrongErrorConfigs() {
37063698
assumeTrue(!useStorageApi);

0 commit comments

Comments
 (0)