[IoTDB-1449] path already exist error in IoTDBSink (#3569)

flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java

@@ -97,8 +97,15 @@ public class IoTDBSink<IN> extends RichSinkFunction<IN> {
 
     for (IoTDBSinkOptions.TimeseriesOption option : options.getTimeseriesOptionList()) {
       if (!pool.checkTimeseriesExists(option.getPath())) {
-        pool.createTimeseries(
-            option.getPath(), option.getDataType(), option.getEncoding(), option.getCompressor());
+        try {
+          pool.createTimeseries(
+              option.getPath(), option.getDataType(), option.getEncoding(), option.getCompressor());
+        } catch (StatementExecutionException e) {
+          // path could have been created by the other process here
+          if (e.getStatusCode() != TSStatusCode.PATH_ALREADY_EXIST_ERROR.getStatusCode()) {
+            throw e;
+          }
+        }
       }
     }
   }