fix test

Author: shnapz

sdks/java/core/src/test/java/org/apache/beam/sdk/lineage/LineageRegistrarTest.java

@@ -190,7 +190,7 @@ public void testLineageIntegrationWithLastSegmentSeparator() {
 
     // Verify lineage was recorded with separator
     List<String> sources = TestLineage.getRecordedSources();
-    assertThat(sources, hasItem("gcs:bucket.path/to/file.txt"));
+    assertThat(sources, hasItem("gcs:bucket.`path/to/file.txt`"));
   }
 
   @Test
@@ -249,6 +249,7 @@ private static class RecordSourceLineageDoFn<T> extends DoFn<T, T> {
 
     @ProcessElement
     public void processElement(ProcessContext c) {
+      // !!! Lineage Caller !!!
       Lineage.getSources().add(system, segments);
       c.output(c.element());
     }
@@ -268,6 +269,7 @@ private static class RecordSourceLineageWithSubtypeDoFn extends DoFn<Integer, In
 
     @ProcessElement
     public void processElement(ProcessContext c) {
+      // !!! Lineage Caller !!!
       Lineage.getSources().add(system, subtype, segments, null);
       c.output(c.element());
     }
@@ -287,6 +289,7 @@ private static class RecordSourceLineageWithSeparatorDoFn extends DoFn<String, S
 
     @ProcessElement
     public void processElement(ProcessContext c) {
+      // !!! Lineage Caller !!!
       Lineage.getSources().add(system, segments, separator);
       c.output(c.element());
     }
@@ -296,7 +299,9 @@ public void processElement(ProcessContext c) {
   private static class RecordBothSourceAndSinkLineageDoFn extends DoFn<String, String> {
     @ProcessElement
     public void processElement(ProcessContext c) {
+      // !!! Lineage Caller !!!
       Lineage.getSources().add("input-system", ImmutableList.of("input-db", "input-table"));
+      // !!! Lineage Caller !!!
       Lineage.getSinks().add("output-system", ImmutableList.of("output-db", "output-table"));
       c.output(c.element());
     }