fix: only run create_hypertable on new tables

epiphanous · Nov 1, 2022 · 96a9f5b · 96a9f5b
1 parent 027a670
commit 96a9f5b
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()