Skip to content

Commit 58b727c

Browse files
committed
avoid deprecated method call
1 parent 15a8eb9 commit 58b727c

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

src/main/java/tech/ydb/spark/connector/YdbAlterTable.java

+5-1
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,11 @@ private void applyProperty(String name, String value, PartitioningSettings ps) {
145145
CompletableFuture<Status> run(Session session) {
146146
final AlterTableSettings settings = new AlterTableSettings();
147147
for (YdbFieldInfo yfi : addColumns.values()) {
148-
settings.addColumn(yfi.getName(), yfi.getType().toSdkType(yfi.isNullable()));
148+
if (yfi.isNullable()) {
149+
settings.addNullableColumn(yfi.getName(), yfi.getType().toSdkType(false));
150+
} else {
151+
settings.addNonnullColumn(yfi.getName(), yfi.getType().toSdkType(false));
152+
}
149153
}
150154
for (String name : removeColumns) {
151155
settings.dropColumn(name);

0 commit comments

Comments
 (0)