[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-18 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r559543409 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -102,65 +109,79 @@ public void open() throws Exception

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-18 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r559543672 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -102,65 +106,76 @@ public void open() throws Exception

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-15 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r558324652 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -102,65 +105,76 @@ public void open() throws Exception

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-14 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r557821706 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -71,16 +73,18 @@ private String latestInstant = "";

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-14 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r557820490 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -102,65 +105,76 @@ public void open() throws Exception

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-14 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r557818230 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -222,4 +234,59 @@ public void close() throws Exception

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-12 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r556286285 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -71,22 +72,25 @@ private String latestInstant = "";

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-12 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r556285084 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -222,4 +234,59 @@ public void close() throws Exception

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-12 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r556284970 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -102,65 +106,73 @@ public void open() throws Exception

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-12 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r556284611 ## File path: hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableMetaClient.java ## @@ -202,7 +203,7 @@ public String getTempFolderPath() {

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-12 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r555808717 ## File path: hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableMetaClient.java ## @@ -272,7 +273,7 @@ public HoodieWrapperFileSystem getF

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-12 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r555808215 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -63,104 +63,159 @@ private static final Logger LOG

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-12 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r555808114 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -63,104 +63,159 @@ private static final Logger LOG

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-12 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r555807220 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -63,104 +63,159 @@ private static final Logger LOG

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-12 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r555807899 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -63,104 +63,159 @@ private static final Logger LOG

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-12 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r555806718 ## File path: hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java ## @@ -18,6 +18,18 @@ package org.apache.hudi.operator;

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-12 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r555798148 ## File path: hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableMetaClient.java ## @@ -202,7 +203,7 @@ public String getTempFolderPath() {

[GitHub] [hudi] loukey-lj commented on a change in pull request #2434: [HUDI-1511] InstantGenerateOperator support multiple parallelism

2021-01-12 Thread GitBox
loukey-lj commented on a change in pull request #2434: URL: https://github.com/apache/hudi/pull/2434#discussion_r555797905 ## File path: hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableMetaClient.java ## @@ -71,6 +71,7 @@ private static final long serial