We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 6386fb4 + c46cb5c commit d8a2b0aCopy full SHA for d8a2b0a
core/src/main/java/com/dtstack/flink/sql/table/AbstractTableInfo.java
@@ -26,6 +26,7 @@
26
import java.io.Serializable;
27
import java.util.List;
28
import java.util.Map;
29
+import java.util.Objects;
30
import java.util.Properties;
31
32
/**
@@ -104,6 +105,10 @@ public void setFieldClasses(Class<?>[] fieldClasses) {
104
105
}
106
107
public List<String> getPrimaryKeys() {
108
+ if (this instanceof AbstractSideTableInfo &&
109
+ Objects.isNull(primaryKeys)) {
110
+ throw new IllegalArgumentException("Side table must contain [primary key]!");
111
+ }
112
return primaryKeys;
113
114
0 commit comments