This is an automated email from the ASF dual-hosted git repository.
codope pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 6cc39bfe649 [MINOR] Removing unnecessary guards to row writer (#10004)
6cc39bfe649 is described below
commit 6cc39bfe6492bfce789c6998fdb85ff1b9b24e59
Author: Sivabalan Narayanan <[email protected]>
AuthorDate: Thu Nov 16 06:00:54 2023 -0500
[MINOR] Removing unnecessary guards to row writer (#10004)
---
.../src/main/java/org/apache/hudi/utilities/streamer/StreamSync.java | 3 ---
1 file changed, 3 deletions(-)
diff --git
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamSync.java
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamSync.java
index 362bbb72f9e..6626084aa2b 100644
---
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamSync.java
+++
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamSync.java
@@ -579,9 +579,6 @@ public class StreamSync implements Serializable, Closeable {
checkpointStr = dataAndCheckpoint.getCheckpointForNextBatch();
if (this.userProvidedSchemaProvider != null &&
this.userProvidedSchemaProvider.getTargetSchema() != null) {
if (useRowWriter) {
- if (errorTableWriter.isPresent()) {
- throw new HoodieException("Error table is not yet supported with
row writer");
- }
inputBatchForWriter = new InputBatch(transformed, checkpointStr,
this.userProvidedSchemaProvider);
} else {
// non row writer path