Skip to content

Commit

Permalink
[bugfix][writer][starRocks] remove the condition which is always true
Browse files Browse the repository at this point in the history
  • Loading branch information
wgzhao committed Feb 2, 2024
1 parent 3b7f919 commit fa2b95d
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@ public static void preCheckPrePareSQL(StarRocksWriterOptions options)
String table = options.getTable();
List<String> preSqls = options.getPreSqlList();
List<String> renderedPreSqls = StarRocksWriterUtil.renderPreOrPostSqls(preSqls, table);
if (null != renderedPreSqls && !renderedPreSqls.isEmpty()) {
if (!renderedPreSqls.isEmpty()) {
LOG.info("Begin to preCheck preSqls:[{}].", String.join(";", renderedPreSqls));
for (String sql : renderedPreSqls) {
try {
Expand All @@ -100,7 +100,7 @@ public static void preCheckPostSQL(StarRocksWriterOptions options)
String table = options.getTable();
List<String> postSqls = options.getPostSqlList();
List<String> renderedPostSqls = StarRocksWriterUtil.renderPreOrPostSqls(postSqls, table);
if (null != renderedPostSqls && !renderedPostSqls.isEmpty()) {
if (!renderedPostSqls.isEmpty()) {
LOG.info("Begin to preCheck postSqls:[{}].", String.join(";", renderedPostSqls));
for (String sql : renderedPostSqls) {
try {
Expand Down

0 comments on commit fa2b95d

Please sign in to comment.