yanqinghe commented on issue #2958:
URL: https://github.com/apache/iceberg/issues/2958#issuecomment-898849650
如果你使用的是Spark Structured Streaming的话，可以在写入的时候指定配置：
``` scala
.writeStream
.format("iceberg")
.options(Map(
"fanout-enabled" -> "true"
))
.outputMode(OutputMode.Append())
.trigger(Trigger.ProcessingTime(5, TimeUnit.MINUTES))
.start()
.awaitTermination()
```
> > @zephaniah-wzf 可以发一下具体的堆栈吗
>
> [报错信息.txt](https://github.com/apache/iceberg/files/6980457/default.txt)
> 还是会报那样的错误，有点不合理啊
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
