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

Reply via email to