Fix row.clear()

GoogleCloudPlatform · May 13, 2024 · 3716524 · 3716524
1 parent 77e9c92
commit 3716524
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 24 deletions.
diff --git a/...r/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerDatatypeIT.java b/...r/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerDatatypeIT.java
@@ -259,7 +259,7 @@ private void assertAllDatatypeColumnsTableBackfillContents() {
     row.put("bit_column", "102");
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("varchar_column", "value2");
     row.put("tinyint_column", "5");
     row.put("date_column", "2024-02-09T00:00:00Z");
@@ -388,7 +388,7 @@ private void assertAllDatatypeColumns2TableBackfillContents() {
     row.put("bit_column", "AQI=");
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("varchar_column", "value2");
     row.put("tinyint_column", 5);
     row.put("text_column", "text2");

diff --git a/...eleport/v2/templates/DataStreamToSpannerShardedMigrationWithMigrationShardIdColumnIT.java b/...eleport/v2/templates/DataStreamToSpannerShardedMigrationWithMigrationShardIdColumnIT.java
@@ -282,77 +282,77 @@ private void assertUsersTableContents() {
     row.put("migration_shard_id", "L1");
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 3);
     row.put("name", "Tester3");
     row.put("age_spanner", 103);
     row.put("migration_shard_id", "L1");
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 13);
     row.put("name", "Tester13");
     row.put("age_spanner", 113);
     row.put("migration_shard_id", "L1");
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 4);
     row.put("name", "Tester4");
     row.put("age_spanner", 21);
     row.put("migration_shard_id", "L2");
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 6);
     row.put("name", "Tester6");
     row.put("age_spanner", 106);
     row.put("migration_shard_id", "L2");
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 14);
     row.put("name", "Tester14");
     row.put("age_spanner", 114);
     row.put("migration_shard_id", "L2");
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 7);
     row.put("name", "Tester7");
     row.put("age_spanner", 22);
     row.put("migration_shard_id", "L3");
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 9);
     row.put("name", "Tester9");
     row.put("age_spanner", 109);
     row.put("migration_shard_id", "L3");
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 15);
     row.put("name", "Tester15");
     row.put("age_spanner", 115);
     row.put("migration_shard_id", "L3");
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 10);
     row.put("name", "Tester10");
     row.put("age_spanner", 23);
     row.put("migration_shard_id", "L4");
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 12);
     row.put("name", "Tester12");
     row.put("age_spanner", 12);
     row.put("migration_shard_id", "L4");
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 16);
     row.put("name", "Tester16");
     row.put("age_spanner", 116);

diff --git a/...port/v2/templates/DataStreamToSpannerShardedMigrationWithoutMigrationShardIdColumnIT.java b/...port/v2/templates/DataStreamToSpannerShardedMigrationWithoutMigrationShardIdColumnIT.java
@@ -226,67 +226,67 @@ private void assertUsersTableContents() {
     row.put("age", 20);
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 3);
     row.put("name", "Tester3");
     row.put("age", 103);
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 13);
     row.put("name", "Tester13");
     row.put("age", 113);
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 4);
     row.put("name", "Tester4");
     row.put("age", 21);
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 6);
     row.put("name", "Tester6");
     row.put("age", 106);
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 14);
     row.put("name", "Tester14");
     row.put("age", 114);
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 7);
     row.put("name", "Tester7");
     row.put("age", 22);
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 9);
     row.put("name", "Tester9");
     row.put("age", 109);
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 15);
     row.put("name", "Tester15");
     row.put("age", 115);
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 10);
     row.put("name", "Tester10");
     row.put("age", 23);
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 12);
     row.put("name", "Tester12");
     row.put("age", 12);
     events.add(row);
 
-    row.clear();
+    row = new HashMap<>();
     row.put("id", 16);
     row.put("name", "Tester16");
     row.put("age", 116);