Danny Chan

Thanks, i will take a look this week, and before that, please do not merge.

@sekaiga thanks for the contribution, can we write a test case here if it is possible ?

Not enough details here, can you try 0.12.1 and see if the duplicates happen ? Would close the issue here first.

Try the option `hoodie.filesystem.view.remote.retry.enable` which is introduced in 0.12.1, it expects to solve the problem. Feel free to reopen it if the problem still exists.

[4373.patch.zip](https://github.com/apache/hudi/files/9782092/4373.patch.zip) Thank, i have reviewed and applied a patch, let's move the clustering update strategy logic into sub-clazzs of `StreamWriteFunction` first.

Nice feature, can we log an JIRA issue and change the commit title to "[HUDI-${JIRA_ID}] ${your title}"

> @danny0405 > > One example I found for varargs use case is when I tried to built ZetaSQL on top of Calcite. ZetaSQL has a `concat` function definition that...

> and this is the code of build writeConfig of writeClient. enableEmbeddedTimelineService is false `public static HoodieWriteConfig getHoodieClientConfig( Configuration conf, boolean enableEmbeddedTimelineService, boolean loadFsViewStorageConfig) { ... .withEmbeddedTimelineServerEnabled(enableEmbeddedTimelineService) .withEmbeddedTimelineServerReuseEnabled(true) // make...

> > > and this is the code of build writeConfig of writeClient. enableEmbeddedTimelineService is false `public static HoodieWriteConfig getHoodieClientConfig( Configuration conf, boolean enableEmbeddedTimelineService, boolean loadFsViewStorageConfig) { ... .withEmbeddedTimelineServerEnabled(enableEmbeddedTimelineService) .withEmbeddedTimelineServerReuseEnabled(true)...

@yanghua Do not merge before i check it.