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 c92eb94 commit 2401a64Copy full SHA for 2401a64
fluss-common/src/main/java/org/apache/fluss/metadata/Schema.java
@@ -619,13 +619,11 @@ private static List<Column> normalizeColumns(
619
}
620
621
// primary key and auto increment column should not nullable
622
- if ((pkSet.contains(column.getName())
623
- || autoIncrementColumnNames.contains(column.getName()))
624
- && column.getDataType().isNullable()) {
+ if (pkSet.contains(column.getName()) && column.getDataType().isNullable()) {
625
newColumns.add(
626
new Column(
627
column.getName(),
628
- column.getDataType().copy(true),
+ column.getDataType().copy(false),
629
column.getComment().isPresent() ? column.getComment().get() : null,
630
column.getColumnId()));
631
} else {
0 commit comments