Optimize code & update clickhouse module to 1.12.2

Author: pyscala

flink-connector-clickhouse/pom.xml

@@ -61,13 +61,13 @@ under the License.
         <dependency>
             <groupId>org.slf4j</groupId>
             <artifactId>slf4j-log4j12</artifactId>
-            <version>1.7.7</version>
+            <version>${slf4j.version}</version>
             <scope>runtime</scope>
         </dependency>
         <dependency>
             <groupId>log4j</groupId>
             <artifactId>log4j</artifactId>
-            <version>1.2.17</version>
+            <version>${log4j.version}</version>
             <scope>runtime</scope>
         </dependency>
 

flink-connector-clickhouse/src/main/java/com/apache/flink/streaming/connectors/clickhouse/ClickHouseTableSink.java

@@ -74,15 +74,6 @@ public ClickHouseTableSink(String address, String username, String password, Str
 
     }
 
-    /**
-     * @param dataStream
-     * @deprecated
-     */
-    @Override
-    public void emitDataStream(DataStream<Row> dataStream) {
-        consumeDataStream(dataStream);
-    }
-
     /**
      *
      * @return ClickHouseAppendSinkFunction

flink-connector-clickhouse/src/main/java/com/apache/flink/streaming/connectors/clickhouse/ClickHouseTableSourceSinkFactory.java

@@ -75,8 +75,6 @@ public List<String> supportedProperties() {
         properties.add(SCHEMA + ".#." + SCHEMA_DATA_TYPE);
         properties.add(SCHEMA + ".#." + SCHEMA_TYPE);
         properties.add(SCHEMA + ".#." + SCHEMA_NAME);
-        // computed column
-        properties.add(SCHEMA + ".#." + TABLE_SCHEMA_EXPR);
 
         // watermark
         properties.add(SCHEMA + "." + WATERMARK + ".#."  + WATERMARK_ROWTIME);