ADded debug logs

Author: Deep1998

v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDb.java

@@ -635,6 +635,7 @@ public static PipelineResult run(Options options) {
       }
     }
     ISchemaMapper schemaMapper = getSchemaMapper(options, ddl);
+    LOG.info("schemaMapper : " + schemaMapper);
 
     boolean isRegularMode = "regular".equals(options.getRunMode());
     PCollectionTuple reconsumedElements = null;
@@ -706,6 +707,8 @@ public static PipelineResult run(Options options) {
                 options.getTransformationJarPath(), options.getTransformationClassName())
             .setCustomParameters(options.getTransformationCustomParameters())
             .build();
+    LOG.info("custom transformation builder created");
+
     SourceWriterTransform.Result sourceWriterOutput =
         mergedRecords
             .apply(
@@ -746,6 +749,7 @@ public static PipelineResult run(Options options) {
                     connectionPoolSizePerWorker,
                     options.getSourceType(),
                     customTransformation));
+    LOG.info("SourceWriterTransform builder created");
 
     PCollection<FailsafeElement<String, String>> dlqPermErrorRecords =
         reconsumedElements
@@ -830,6 +834,7 @@ public static PipelineResult run(Options options) {
                 .withTmpDirectory(options.getDeadLetterQueueDirectory() + "/tmp_skip/")
                 .setIncludePaneInfo(true)
                 .build());
+    LOG.info("Starting pipeline run");
 
     return pipeline.run();
   }