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
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
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
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 = "";
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
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
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 = "";
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
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
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() {
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
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
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
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
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
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;
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() {
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
18 matches
Mail list logo