You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by GitBox <gi...@apache.org> on 2021/08/18 12:58:46 UTC

[GitHub] [hudi] xingbowu opened a new pull request #3495: [HUDI-2229] Refact hoodie stream creator

xingbowu opened a new pull request #3495:
URL: https://github.com/apache/hudi/pull/3495


   ## *Tips*
   - *Thank you very much for contributing to Apache Hudi.*
   - *Please review https://hudi.apache.org/contribute/how-to-contribute before opening a pull request.*
   
   ## What is the purpose of the pull request
   
   *(For example: This pull request adds quick-start document.)*
   
   ## Brief change log
   
   *(for example:)*
     - *Modify AnnotationLocation checkstyle rule in checkstyle.xml*
   
   ## Verify this pull request
   
   *(Please pick either of the following options)*
   
   This pull request is a trivial rework / code cleanup without any test coverage.
   
   *(or)*
   
   This pull request is already covered by existing tests, such as *(please describe tests)*.
   
   (or)
   
   This change added tests and can be verified as follows:
   
   *(example:)*
   
     - *Added integration tests for end-to-end.*
     - *Added HoodieClientWriteTest to verify the change.*
     - *Manually verified the change by running a job locally.*
   
   ## Committer checklist
   
    - [ ] Has a corresponding JIRA in PR title & commit
    
    - [ ] Commit message is descriptive of the change
    
    - [ ] CI is green
   
    - [ ] Necessary doc changes done or have another open PR
          
    - [ ] For large changes, please consider breaking it into sub-tasks under an umbrella JIRA.
   
   Associated with issue #3348 closed by mistake
   


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] xingbowu commented on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
xingbowu commented on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901839035


   resolved conflict with #3494


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902






-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888",
       "triggerID" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1899",
       "triggerID" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * bbe7dd4a418b756da880733278eddd08558a551a Azure: [SUCCESS](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1899) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact HoodieFlinkStreamer to reuse the pipeline of HoodieTableSink

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888",
       "triggerID" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1899",
       "triggerID" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "2c1f5a13558bf406285fac38e73d46bb17bbe11c",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1914",
       "triggerID" : "2c1f5a13558bf406285fac38e73d46bb17bbe11c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4c24abbf9680621ddc3b9bea120ba21c3c687596",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1917",
       "triggerID" : "4c24abbf9680621ddc3b9bea120ba21c3c687596",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 2c1f5a13558bf406285fac38e73d46bb17bbe11c Azure: [SUCCESS](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1914) 
   * 4c24abbf9680621ddc3b9bea120ba21c3c687596 Azure: [PENDING](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1917) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888",
       "triggerID" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1899",
       "triggerID" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "2c1f5a13558bf406285fac38e73d46bb17bbe11c",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1914",
       "triggerID" : "2c1f5a13558bf406285fac38e73d46bb17bbe11c",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * bbe7dd4a418b756da880733278eddd08558a551a Azure: [SUCCESS](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1899) 
   * 2c1f5a13558bf406285fac38e73d46bb17bbe11c Azure: [PENDING](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1914) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888",
       "triggerID" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 9428c4d43d2983bd161b7a538da919ffc369ca89 Azure: [FAILURE](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888) 
   * bbe7dd4a418b756da880733278eddd08558a551a UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot commented on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot commented on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 50883665df09cc6119ce85488935d38a853dd0f1 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] xingbowu commented on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
xingbowu commented on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-905424351


   resolved conflict with #3516 
   


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * bc544d31ed207d0fbcfb632067fddc442deca8c1 Azure: [SUCCESS](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810) 
   * 9428c4d43d2983bd161b7a538da919ffc369ca89 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] danny0405 commented on a change in pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
danny0405 commented on a change in pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#discussion_r696443387



##########
File path: hudi-flink/src/main/java/org/apache/hudi/streamer/HoodieFlinkStreamer.java
##########
@@ -21,30 +21,18 @@
 import org.apache.hudi.common.model.HoodieRecord;
 import org.apache.hudi.common.util.Option;
 import org.apache.hudi.configuration.FlinkOptions;
-import org.apache.hudi.sink.CleanFunction;
-import org.apache.hudi.sink.StreamWriteOperatorFactory;
-import org.apache.hudi.sink.bootstrap.BootstrapOperator;
-import org.apache.hudi.sink.compact.CompactFunction;
-import org.apache.hudi.sink.compact.CompactionCommitEvent;
-import org.apache.hudi.sink.compact.CompactionCommitSink;
-import org.apache.hudi.sink.compact.CompactionPlanEvent;
-import org.apache.hudi.sink.compact.CompactionPlanOperator;
-import org.apache.hudi.sink.partitioner.BucketAssignFunction;
-import org.apache.hudi.sink.partitioner.BucketAssignOperator;
-import org.apache.hudi.sink.transform.RowDataToHoodieFunctions;

Review comment:
       Can we use the `org.apache.hudi.sink.utils.Pipelines` to refactor the `HoodieFlinkStreamer` ?




-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] danny0405 commented on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
danny0405 commented on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-906367638


   Looks good, can we squash the two commits into one and change the title and commit message to
   "[HUDI-2229] Refact HoodieFlinkStreamer to reuse the pipeline of HoodieTableSink"


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] xingbowu commented on pull request #3495: [HUDI-2229] Refact HoodieFlinkStreamer to reuse the pipeline of HoodieTableSink

Posted by GitBox <gi...@apache.org>.
xingbowu commented on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-906412780


   > Looks good, can we squash the two commits into one and change the title and commit message to
   > "[HUDI-2229] Refact HoodieFlinkStreamer to reuse the pipeline of HoodieTableSink"
   
   done. thanks a lot for your reminder!


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot commented on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot commented on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 50883665df09cc6119ce85488935d38a853dd0f1 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] danny0405 merged pull request #3495: [HUDI-2229] Refact HoodieFlinkStreamer to reuse the pipeline of HoodieTableSink

Posted by GitBox <gi...@apache.org>.
danny0405 merged pull request #3495:
URL: https://github.com/apache/hudi/pull/3495


   


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 50883665df09cc6119ce85488935d38a853dd0f1 Azure: [FAILURE](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800) 
   * bc544d31ed207d0fbcfb632067fddc442deca8c1 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] xingbowu commented on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
xingbowu commented on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-905424971


   @danny0405 could you have a look?


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888",
       "triggerID" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1899",
       "triggerID" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "2c1f5a13558bf406285fac38e73d46bb17bbe11c",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "2c1f5a13558bf406285fac38e73d46bb17bbe11c",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * bbe7dd4a418b756da880733278eddd08558a551a Azure: [SUCCESS](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1899) 
   * 2c1f5a13558bf406285fac38e73d46bb17bbe11c UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact HoodieFlinkStreamer to reuse the pipeline of HoodieTableSink

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888",
       "triggerID" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1899",
       "triggerID" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "2c1f5a13558bf406285fac38e73d46bb17bbe11c",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1914",
       "triggerID" : "2c1f5a13558bf406285fac38e73d46bb17bbe11c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4c24abbf9680621ddc3b9bea120ba21c3c687596",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "4c24abbf9680621ddc3b9bea120ba21c3c687596",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 2c1f5a13558bf406285fac38e73d46bb17bbe11c Azure: [SUCCESS](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1914) 
   * 4c24abbf9680621ddc3b9bea120ba21c3c687596 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888",
       "triggerID" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * bc544d31ed207d0fbcfb632067fddc442deca8c1 Azure: [SUCCESS](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810) 
   * 9428c4d43d2983bd161b7a538da919ffc369ca89 Azure: [PENDING](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] danny0405 commented on a change in pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
danny0405 commented on a change in pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#discussion_r696444008



##########
File path: hudi-flink/src/main/java/org/apache/hudi/streamer/HoodieFlinkStreamer.java
##########
@@ -21,30 +21,18 @@
 import org.apache.hudi.common.model.HoodieRecord;
 import org.apache.hudi.common.util.Option;
 import org.apache.hudi.configuration.FlinkOptions;
-import org.apache.hudi.sink.CleanFunction;
-import org.apache.hudi.sink.StreamWriteOperatorFactory;
-import org.apache.hudi.sink.bootstrap.BootstrapOperator;
-import org.apache.hudi.sink.compact.CompactFunction;
-import org.apache.hudi.sink.compact.CompactionCommitEvent;
-import org.apache.hudi.sink.compact.CompactionCommitSink;
-import org.apache.hudi.sink.compact.CompactionPlanEvent;
-import org.apache.hudi.sink.compact.CompactionPlanOperator;
-import org.apache.hudi.sink.partitioner.BucketAssignFunction;
-import org.apache.hudi.sink.partitioner.BucketAssignOperator;
-import org.apache.hudi.sink.transform.RowDataToHoodieFunctions;

Review comment:
       Also the config options of the `HoodieFlinkStreamer` is out of sync with `FlinkOptions`, we can promote that in another PR i guess.




-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 50883665df09cc6119ce85488935d38a853dd0f1 Azure: [FAILURE](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 50883665df09cc6119ce85488935d38a853dd0f1 Azure: [PENDING](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] xingbowu commented on a change in pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
xingbowu commented on a change in pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#discussion_r696518446



##########
File path: hudi-flink/src/main/java/org/apache/hudi/streamer/HoodieFlinkStreamer.java
##########
@@ -21,30 +21,18 @@
 import org.apache.hudi.common.model.HoodieRecord;
 import org.apache.hudi.common.util.Option;
 import org.apache.hudi.configuration.FlinkOptions;
-import org.apache.hudi.sink.CleanFunction;
-import org.apache.hudi.sink.StreamWriteOperatorFactory;
-import org.apache.hudi.sink.bootstrap.BootstrapOperator;
-import org.apache.hudi.sink.compact.CompactFunction;
-import org.apache.hudi.sink.compact.CompactionCommitEvent;
-import org.apache.hudi.sink.compact.CompactionCommitSink;
-import org.apache.hudi.sink.compact.CompactionPlanEvent;
-import org.apache.hudi.sink.compact.CompactionPlanOperator;
-import org.apache.hudi.sink.partitioner.BucketAssignFunction;
-import org.apache.hudi.sink.partitioner.BucketAssignOperator;
-import org.apache.hudi.sink.transform.RowDataToHoodieFunctions;

Review comment:
       > Can we use the `org.apache.hudi.sink.utils.Pipelines` to refactor the `HoodieFlinkStreamer` ?
   
   done, removed other builder.




-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888",
       "triggerID" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1899",
       "triggerID" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 9428c4d43d2983bd161b7a538da919ffc369ca89 Azure: [FAILURE](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888) 
   * bbe7dd4a418b756da880733278eddd08558a551a Azure: [PENDING](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1899) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888",
       "triggerID" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 9428c4d43d2983bd161b7a538da919ffc369ca89 Azure: [FAILURE](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 50883665df09cc6119ce85488935d38a853dd0f1 Azure: [FAILURE](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800) 
   * bc544d31ed207d0fbcfb632067fddc442deca8c1 Azure: [PENDING](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * bc544d31ed207d0fbcfb632067fddc442deca8c1 Azure: [SUCCESS](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact HoodieFlinkStreamer to reuse the pipeline of HoodieTableSink

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888",
       "triggerID" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1899",
       "triggerID" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "2c1f5a13558bf406285fac38e73d46bb17bbe11c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1914",
       "triggerID" : "2c1f5a13558bf406285fac38e73d46bb17bbe11c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4c24abbf9680621ddc3b9bea120ba21c3c687596",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1917",
       "triggerID" : "4c24abbf9680621ddc3b9bea120ba21c3c687596",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 4c24abbf9680621ddc3b9bea120ba21c3c687596 Azure: [SUCCESS](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1917) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [hudi] hudi-bot edited a comment on pull request #3495: [HUDI-2229] Refact hoodie stream creator

Posted by GitBox <gi...@apache.org>.
hudi-bot edited a comment on pull request #3495:
URL: https://github.com/apache/hudi/pull/3495#issuecomment-901095902


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1800",
       "triggerID" : "50883665df09cc6119ce85488935d38a853dd0f1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1810",
       "triggerID" : "bc544d31ed207d0fbcfb632067fddc442deca8c1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1888",
       "triggerID" : "9428c4d43d2983bd161b7a538da919ffc369ca89",
       "triggerType" : "PUSH"
     }, {
       "hash" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1899",
       "triggerID" : "bbe7dd4a418b756da880733278eddd08558a551a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "2c1f5a13558bf406285fac38e73d46bb17bbe11c",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1914",
       "triggerID" : "2c1f5a13558bf406285fac38e73d46bb17bbe11c",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 2c1f5a13558bf406285fac38e73d46bb17bbe11c Azure: [SUCCESS](https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_build/results?buildId=1914) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run travis` re-run the last Travis build
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org