Skip to content

Commit 46c4530

Browse files
author
gituser
committed
Merge branch 'hotfix_1.10_4.0.x_33089' into 1.10_release_4.0.x
2 parents fd15a04 + d02ab01 commit 46c4530

File tree

1 file changed

+2
-12
lines changed

1 file changed

+2
-12
lines changed

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

Lines changed: 2 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,6 @@
2626
import com.google.common.collect.Maps;
2727
import org.apache.commons.lang3.StringUtils;
2828
import org.apache.flink.api.java.tuple.Tuple2;
29-
import org.slf4j.Logger;
30-
import org.slf4j.LoggerFactory;
3129

3230
import java.util.Arrays;
3331
import java.util.List;
@@ -46,8 +44,6 @@
4644

4745
public abstract class AbstractTableParser {
4846

49-
private static final Logger LOG = LoggerFactory.getLogger(AbstractTableParser.class);
50-
5147
private static final String PRIMARY_KEY = "primaryKey";
5248
private static final String NEST_JSON_FIELD_KEY = "nestFieldKey";
5349
private static final String CHAR_TYPE_NO_LENGTH = "CHAR";
@@ -119,14 +115,8 @@ public void parseFieldsInfo(String fieldsInfo, AbstractTableInfo tableInfo) {
119115
*/
120116
if (tableInfo instanceof AbstractSideTableInfo) {
121117
tableInfo.getPrimaryKeys().stream()
122-
.filter(pk -> !tableInfo.getFieldList().contains(pk))
123-
.forEach(pk -> {
124-
try {
125-
handleKeyNotHaveAlias(String.format("%s varchar", pk), tableInfo);
126-
} catch (Exception e) {
127-
LOG.error(String.format("Handle primary key failed. Reason: %s", e.getMessage()));
128-
}
129-
});
118+
.filter(pk -> (!tableInfo.getFieldList().contains(pk) && pk.equals("rowkey")))
119+
.forEach(pk -> handleKeyNotHaveAlias(String.format("%s varchar", pk), tableInfo));
130120
}
131121

132122
tableInfo.finish();

0 commit comments

Comments
 (0)