swapna267 opened a new pull request, #15780:
URL: https://github.com/apache/iceberg/pull/15780
Support following configs to be configurable from SQL for dynamic sink.
Fallback to writeproperties or Flink configuration if following are not set
on DynamicRecord,
writeParallelism(int) → FlinkWriteOptions.WRITE_PARALLELISM
distributionMode -> FlinkWriteOptions.DISTRIBUTION_MODE
toBranch(String) → FlinkWriteOptions.BRANCH
Provide options to configure following behavior of Dynamic Sink in SQl
cacheMaxSize(int)
immediateTableUpdate(boolean)
dropUnusedColumns(boolean)
cacheRefreshMs(long)
inputSchemasPerTableCacheMaxSize(int)
caseSensitive(boolean)
More context here,
https://github.com/apache/iceberg/pull/15471#issuecomment-4114688122
--
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]
