We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 003b35e commit d02ab01Copy full SHA for d02ab01
core/src/main/java/com/dtstack/flink/sql/table/AbstractTableParser.java
@@ -26,8 +26,6 @@
26
import com.google.common.collect.Maps;
27
import org.apache.commons.lang3.StringUtils;
28
import org.apache.flink.api.java.tuple.Tuple2;
29
-import org.slf4j.Logger;
30
-import org.slf4j.LoggerFactory;
31
32
import java.util.Arrays;
33
import java.util.List;
@@ -46,8 +44,6 @@
46
44
47
45
public abstract class AbstractTableParser {
48
49
- private static final Logger LOG = LoggerFactory.getLogger(AbstractTableParser.class);
50
-
51
private static final String PRIMARY_KEY = "primaryKey";
52
private static final String NEST_JSON_FIELD_KEY = "nestFieldKey";
53
private static final String CHAR_TYPE_NO_LENGTH = "CHAR";
0 commit comments