minor improvement

Author: wangxianghu

hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/processor/maxwell/MaxwellJsonKafkaSourcePostProcessor.java

@@ -30,8 +30,6 @@
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.node.ObjectNode;
-import org.apache.log4j.LogManager;
-import org.apache.log4j.Logger;
 import org.apache.spark.api.java.JavaRDD;
 
 import java.util.Locale;
@@ -50,12 +48,15 @@
  */
 public class MaxwellJsonKafkaSourcePostProcessor extends JsonKafkaSourcePostProcessor {
 
-  private static final Logger LOG = LogManager.getLogger(MaxwellJsonKafkaSourcePostProcessor.class);
-
   private static final ObjectMapper MAPPER = new ObjectMapper();
 
+  private final String databaseRegex;
+  private final String tableRegex;
+
   public MaxwellJsonKafkaSourcePostProcessor(TypedProperties props) {
     super(props);
+    databaseRegex = this.props.getString(Config.DATABASE_NAME_REGEX_PROP.key(), null);
+    tableRegex = this.props.getString(Config.TABLE_NAME_REGEX_PROP.key());
   }
 
   // ------------------------------------------------------------------------
@@ -112,9 +113,6 @@ public JavaRDD<String> process(JavaRDD<String> maxwellJsonRecords) {
 
       // filter out target databases and tables
       if (isTargetTable(database, table)) {
-
-        LOG.info(String.format("Maxwell source processor starts process table : %s.%s", database, table));
-
         ObjectNode result = (ObjectNode) inputJson.get(DATA);
         String type = inputJson.get(OPERATION_TYPE).textValue();
 
@@ -183,9 +181,6 @@ private String processDelete(JsonNode inputJson, ObjectNode result) {
    * @param table    table the data belong to
    */
   private boolean isTargetTable(String database, String table) {
-    String databaseRegex = this.props.getString(Config.DATABASE_NAME_REGEX_PROP.key(), null);
-    String tableRegex = this.props.getString(Config.TABLE_NAME_REGEX_PROP.key());
-
     if (StringUtils.isNullOrEmpty(databaseRegex)) {
       return Pattern.matches(tableRegex, table);
     } else {