[fix] send parallelism default value 1

Author: FlechazoW

cassandra/cassandra-sink/src/main/java/com/dtstack/flink/sql/sink/cassandra/CassandraSink.java

@@ -58,7 +58,7 @@ public class CassandraSink implements RetractStreamTableSink<Row>, IStreamSinkGe
     protected Integer readTimeoutMillis;
     protected Integer connectTimeoutMillis;
     protected Integer poolTimeoutMillis;
-    protected Integer parallelism = -1;
+    protected Integer parallelism = 1;
     protected String registerTableName;
 
     public CassandraSink() {

core/src/main/java/com/dtstack/flink/sql/table/AbstractTableInfo.java

@@ -59,7 +59,7 @@ public abstract class AbstractTableInfo implements Serializable {
 
     private List<String> primaryKeys;
 
-    private Integer parallelism = -1;
+    private Integer parallelism = 1;
 
     public String[] getFieldTypes() {
         return fieldTypes;

elasticsearch5/elasticsearch5-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/ElasticsearchSink.java

@@ -76,7 +76,7 @@ public class ElasticsearchSink implements RetractStreamTableSink<Row>, IStreamSi
 
     private TypeInformation[] fieldTypes;
 
-    private int parallelism = -1;
+    private int parallelism = 1;
 
     protected String registerTableName;
 

elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/ElasticsearchSink.java

@@ -69,7 +69,7 @@ public class ElasticsearchSink implements RetractStreamTableSink<Row>, IStreamSi
 
     private TypeInformation[] fieldTypes;
 
-    private int parallelism = -1;
+    private int parallelism = 1;
 
     protected String registerTableName;
 

hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseSink.java

@@ -63,7 +63,7 @@ public class HbaseSink implements RetractStreamTableSink<Row>, IStreamSinkGener<
 
     private String clientPrincipal;
     private String clientKeytabFile;
-    private int parallelism = -1;
+    private int parallelism = 1;
 
 
     public HbaseSink() {

kafka-base/kafka-base-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/AbstractKafkaSink.java

@@ -58,7 +58,7 @@ public abstract class AbstractKafkaSink implements RetractStreamTableSink<Row>,
     protected String[] partitionKeys;
     protected String sinkOperatorName;
     protected Properties properties;
-    protected int parallelism = -1;
+    protected int parallelism = 1;
     protected String topic;
     protected String tableName;
     protected String updateMode;

rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/AbstractRdbSink.java

@@ -72,7 +72,7 @@ public abstract class AbstractRdbSink implements RetractStreamTableSink<Row>, Se
 
     private TypeInformation[] fieldTypes;
 
-    private int parallelism = -1;
+    private int parallelism = 1;
 
     protected String schema;