Merge 96a9f5b into 027a670

epiphanous · Nov 1, 2022 · 5ba544d · 5ba544d
2 parents 027a670 + 96a9f5b
commit 5ba544d
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/src/main/scala/io/epiphanous/flinkrunner/model/sink/JdbcSinkConfig.scala b/src/main/scala/io/epiphanous/flinkrunner/model/sink/JdbcSinkConfig.scala
@@ -531,11 +531,12 @@ case class JdbcSinkConfig[ADT <: FlinkEvent](
         sqlBuilder.append(");").getSqlAndClear
       }
 
-      logger.info(
-        s"creating hypertable for [$table]: \n====\n$createHypertableDml\n====\n"
-      )
-
-      stmt.executeQuery(createHypertableDml)
+      if (createTable) {
+        logger.info(
+          s"creating hypertable for [$table]: \n====\n$createHypertableDml\n====\n"
+        )
+        stmt.executeQuery(createHypertableDml)
+      }
     }
 
     stmt.close()