We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 88d1230 commit b89cd9cCopy full SHA for b89cd9c
core/src/main/java/com/dtstack/flink/sql/table/AbstractTableInfo.java
@@ -18,12 +18,14 @@
18
19
package com.dtstack.flink.sql.table;
20
21
+import com.dtstack.flink.sql.side.AbstractSideTableInfo;
22
import com.google.common.collect.Lists;
23
import com.google.common.collect.Maps;
24
25
import java.io.Serializable;
26
import java.util.List;
27
import java.util.Map;
28
+import java.util.Objects;
29
30
/**
31
* Reason:
@@ -84,6 +86,10 @@ public Class<?>[] getFieldClasses() {
84
86
}
85
87
88
public List<String> getPrimaryKeys() {
89
+ if (this instanceof AbstractSideTableInfo &&
90
+ Objects.isNull(primaryKeys)) {
91
+ throw new IllegalArgumentException("Side table must contain [primary key]!");
92
+ }
93
return primaryKeys;
94
95
0 commit comments