将Kafka数据通过FlinkDataStreamAPI写入StarRocks主键模型，会报以下错误：
Could not create a PRIMARY KEY ‘pk’. Column ‘id’ is nullable.
解决null值问题以后，现在有一个新的问题
之前使用FlinkSQL写入主键模型时，可以通过 sink.properties.columns 参数最后添加 "__op"解决，不知道在DataStreamAPI中是如何解决的？
在 id 列设置 DataTypes.BIGINT().notnull
已解决，十分感谢