more kafka bugfix

sishu@dtstack.com · sishu@dtstack.com · commit 4540349ea5d6 · 2018-12-26T19:18:56.000+08:00
diff --git a/kafka08/kafka08-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/table/KafkaSinkTableInfo.java b/kafka08/kafka08-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/table/KafkaSinkTableInfo.java
@@ -42,7 +42,7 @@ public KafkaSinkTableInfo(){
         super.setType(CURR_TYPE);
     }
 
-    public static Map<String,String> kafkaParam = new HashMap<String,String>();
+    public Map<String,String> kafkaParam = new HashMap<String,String>();
 
     public void addKafkaParam(String key,String value){
         kafkaParam.put(key,value);
diff --git a/kafka08/kafka08-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceTableInfo.java b/kafka08/kafka08-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceTableInfo.java
@@ -52,7 +52,7 @@ public KafkaSourceTableInfo(){
         super.setType(CURR_TYPE);
     }
 
-    public static Map<String,String> kafkaParam = new HashMap<>();
+    public Map<String,String> kafkaParam = new HashMap<>();
 
     public void addKafkaParam(String key,String value){
         kafkaParam.put(key,value);
diff --git a/kafka09/kafka09-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/table/KafkaSinkTableInfo.java b/kafka09/kafka09-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/table/KafkaSinkTableInfo.java
@@ -40,7 +40,7 @@ public KafkaSinkTableInfo(){
         super.setType(CURR_TYPE);
     }
 
-    public static Map<String,String> kafkaParam = new HashMap<String,String>();
+    public Map<String,String> kafkaParam = new HashMap<String,String>();
 
     public void addKafkaParam(String key,String value){
         kafkaParam.put(key,value);
diff --git a/kafka09/kafka09-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceTableInfo.java b/kafka09/kafka09-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceTableInfo.java
@@ -59,7 +59,7 @@ public KafkaSourceTableInfo(){
 	}
 
 
-	public static Map<String,String> kafkaParam = new HashMap<>();
+	public Map<String,String> kafkaParam = new HashMap<>();
 
 
 	public void addKafkaParam(String key,String value){
diff --git a/kafka10/kafka10-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/table/KafkaSinkTableInfo.java b/kafka10/kafka10-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/table/KafkaSinkTableInfo.java
@@ -42,7 +42,7 @@ public KafkaSinkTableInfo(){
         super.setType(CURR_TYPE);
     }
 
-    public static Map<String,String> kafkaParam = new HashMap<String,String>();
+    public Map<String,String> kafkaParam = new HashMap<String,String>();
 
     public void addKafkaParam(String key,String value){
         kafkaParam.put(key,value);
diff --git a/kafka10/kafka10-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceTableInfo.java b/kafka10/kafka10-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceTableInfo.java
@@ -57,8 +57,7 @@ public KafkaSourceTableInfo(){
         super.setType(CURR_TYPE);
     }
 
-    public static Map<String,String> kafkaParam = new HashMap<String,String>();
-
+    public Map<String,String> kafkaParam = new HashMap<String,String>();
 
     public void addKafkaParam(String key,String value){
         kafkaParam.put(key,value);
diff --git a/kafka11/kafka11-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/table/KafkaSinkTableInfo.java b/kafka11/kafka11-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/table/KafkaSinkTableInfo.java
@@ -41,7 +41,7 @@ public KafkaSinkTableInfo(){
         super.setType(CURR_TYPE);
     }
 
-    public static Map<String,String> kafkaParam = new HashMap<String,String>();
+    public Map<String,String> kafkaParam = new HashMap<String,String>();
 
     public void addKafkaParam(String key,String value){
         kafkaParam.put(key,value);
diff --git a/kafka11/kafka11-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceTableInfo.java b/kafka11/kafka11-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceTableInfo.java
@@ -56,7 +56,7 @@ public KafkaSourceTableInfo() {
 		super.setType(CURR_TYPE);
 	}
 
-	public static Map<String, String> kafkaParam = new HashMap<>();
+	public Map<String, String> kafkaParam = new HashMap<>();
 
 	public void addKafkaParam(String key, String value) {
 		kafkaParam.put(key, value);

Original file line number	Diff line number	Diff line change
`@@ -42,7 +42,7 @@ public KafkaSinkTableInfo(){`
`42`	`42`	`super.setType(CURR_TYPE);`
`43`	`43`	`}`
`44`	`44`
`45`		`- public static Map<String,String> kafkaParam = new HashMap<String,String>();`
	`45`	`+ public Map<String,String> kafkaParam = new HashMap<String,String>();`
`46`	`46`
`47`	`47`	`public void addKafkaParam(String key,String value){`
`48`	`48`	`kafkaParam.put(key,value);`
Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,7 @@ public KafkaSourceTableInfo(){`
`52`	`52`	`super.setType(CURR_TYPE);`
`53`	`53`	`}`
`54`	`54`
`55`		`- public static Map<String,String> kafkaParam = new HashMap<>();`
	`55`	`+ public Map<String,String> kafkaParam = new HashMap<>();`
`56`	`56`
`57`	`57`	`public void addKafkaParam(String key,String value){`
`58`	`58`	`kafkaParam.put(key,value);`
Original file line number	Diff line number	Diff line change
`@@ -40,7 +40,7 @@ public KafkaSinkTableInfo(){`
`40`	`40`	`super.setType(CURR_TYPE);`
`41`	`41`	`}`
`42`	`42`
`43`		`- public static Map<String,String> kafkaParam = new HashMap<String,String>();`
	`43`	`+ public Map<String,String> kafkaParam = new HashMap<String,String>();`
`44`	`44`
`45`	`45`	`public void addKafkaParam(String key,String value){`
`46`	`46`	`kafkaParam.put(key,value);`
Original file line number	Diff line number	Diff line change
`@@ -59,7 +59,7 @@ public KafkaSourceTableInfo(){`
`59`	`59`	`}`
`60`	`60`
`61`	`61`
`62`		`- public static Map<String,String> kafkaParam = new HashMap<>();`
	`62`	`+ public Map<String,String> kafkaParam = new HashMap<>();`
`63`	`63`
`64`	`64`
`65`	`65`	`public void addKafkaParam(String key,String value){`
Original file line number	Diff line number	Diff line change
`@@ -57,8 +57,7 @@ public KafkaSourceTableInfo(){`
`57`	`57`	`super.setType(CURR_TYPE);`
`58`	`58`	`}`
`59`	`59`
`60`		`- public static Map<String,String> kafkaParam = new HashMap<String,String>();`
`61`		`-`
	`60`	`+ public Map<String,String> kafkaParam = new HashMap<String,String>();`
`62`	`61`
`63`	`62`	`public void addKafkaParam(String key,String value){`
`64`	`63`	`kafkaParam.put(key,value);`
Original file line number	Diff line number	Diff line change
`@@ -41,7 +41,7 @@ public KafkaSinkTableInfo(){`
`41`	`41`	`super.setType(CURR_TYPE);`
`42`	`42`	`}`
`43`	`43`
`44`		`- public static Map<String,String> kafkaParam = new HashMap<String,String>();`
	`44`	`+ public Map<String,String> kafkaParam = new HashMap<String,String>();`
`45`	`45`
`46`	`46`	`public void addKafkaParam(String key,String value){`
`47`	`47`	`kafkaParam.put(key,value);`
Original file line number	Diff line number	Diff line change
`@@ -56,7 +56,7 @@ public KafkaSourceTableInfo() {`
`56`	`56`	`super.setType(CURR_TYPE);`
`57`	`57`	`}`
`58`	`58`
`59`		`- public static Map<String, String> kafkaParam = new HashMap<>();`
	`59`	`+ public Map<String, String> kafkaParam = new HashMap<>();`
`60`	`60`
`61`	`61`	`public void addKafkaParam(String key, String value) {`
`62`	`62`	`kafkaParam.put(key, value);`