This is an automated email from the ASF dual-hosted git repository.
danny0405 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 56086d6e99c [MINOR] Fix checkstyle + removed unnecessary index in #add
(#8883)
56086d6e99c is described below
commit 56086d6e99cfd864cffc91440eac1e2b817eb8d1
Author: voonhous <[email protected]>
AuthorDate: Mon Jun 5 17:23:44 2023 +0800
[MINOR] Fix checkstyle + removed unnecessary index in #add (#8883)
---
.../hudi/sink/bucket/ITTestBucketStreamWrite.java | 19 ++++++++-----------
.../hudi/table/format/cow/ParquetSplitReaderUtil.java | 2 +-
.../hudi/table/format/cow/ParquetSplitReaderUtil.java | 2 +-
.../hudi/table/format/cow/ParquetSplitReaderUtil.java | 2 +-
.../hudi/table/format/cow/ParquetSplitReaderUtil.java | 2 +-
.../hudi/table/format/cow/ParquetSplitReaderUtil.java | 2 +-
6 files changed, 13 insertions(+), 16 deletions(-)
diff --git
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/bucket/ITTestBucketStreamWrite.java
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/bucket/ITTestBucketStreamWrite.java
index cc1394cacac..fbe16e3e52f 100644
---
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/bucket/ITTestBucketStreamWrite.java
+++
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/bucket/ITTestBucketStreamWrite.java
@@ -18,17 +18,6 @@
package org.apache.hudi.sink.bucket;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-import org.apache.flink.configuration.Configuration;
-import org.apache.flink.table.api.EnvironmentSettings;
-import org.apache.flink.table.api.TableEnvironment;
-import org.apache.flink.table.api.internal.TableEnvironmentImpl;
-
-import org.apache.hadoop.fs.FileSystem;
-import org.apache.hadoop.fs.Path;
-
import org.apache.hudi.common.fs.FSUtils;
import org.apache.hudi.common.model.HoodieCommitMetadata;
import org.apache.hudi.common.model.IOType;
@@ -46,6 +35,12 @@ import org.apache.hudi.utils.TestConfigurations;
import org.apache.hudi.utils.TestData;
import org.apache.hudi.utils.TestSQL;
+import org.apache.flink.configuration.Configuration;
+import org.apache.flink.table.api.EnvironmentSettings;
+import org.apache.flink.table.api.TableEnvironment;
+import org.apache.flink.table.api.internal.TableEnvironmentImpl;
+import org.apache.hadoop.fs.FileSystem;
+import org.apache.hadoop.fs.Path;
import org.junit.jupiter.api.extension.ExtendWith;
import org.junit.jupiter.api.io.TempDir;
import org.junit.jupiter.params.ParameterizedTest;
@@ -60,6 +55,8 @@ import java.util.concurrent.TimeUnit;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
/**
* Integration test cases for {@link BucketStreamWriteFunction}.
*/
diff --git
a/hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
b/hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
index 52d381a2187..85687a80c10 100644
---
a/hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
+++
b/hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
@@ -393,7 +393,7 @@ public class ParquetSplitReaderUtil {
if (fieldIndex < 0) {
fieldReaders.add(new EmptyColumnReader());
} else {
- fieldReaders.add(i,
+ fieldReaders.add(
createColumnReader(
utcTimestamp,
rowType.getTypeAt(i),
diff --git
a/hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
b/hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
index 1f2a2f453b9..ea47453d64a 100644
---
a/hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
+++
b/hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
@@ -393,7 +393,7 @@ public class ParquetSplitReaderUtil {
if (fieldIndex < 0) {
fieldReaders.add(new EmptyColumnReader());
} else {
- fieldReaders.add(i,
+ fieldReaders.add(
createColumnReader(
utcTimestamp,
rowType.getTypeAt(i),
diff --git
a/hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
b/hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
index d38af61420d..1e142c8fee4 100644
---
a/hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
+++
b/hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
@@ -393,7 +393,7 @@ public class ParquetSplitReaderUtil {
if (fieldIndex < 0) {
fieldReaders.add(new EmptyColumnReader());
} else {
- fieldReaders.add(i,
+ fieldReaders.add(
createColumnReader(
utcTimestamp,
rowType.getTypeAt(i),
diff --git
a/hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
b/hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
index d38af61420d..1e142c8fee4 100644
---
a/hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
+++
b/hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
@@ -393,7 +393,7 @@ public class ParquetSplitReaderUtil {
if (fieldIndex < 0) {
fieldReaders.add(new EmptyColumnReader());
} else {
- fieldReaders.add(i,
+ fieldReaders.add(
createColumnReader(
utcTimestamp,
rowType.getTypeAt(i),
diff --git
a/hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
b/hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
index d38af61420d..1e142c8fee4 100644
---
a/hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
+++
b/hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
@@ -393,7 +393,7 @@ public class ParquetSplitReaderUtil {
if (fieldIndex < 0) {
fieldReaders.add(new EmptyColumnReader());
} else {
- fieldReaders.add(i,
+ fieldReaders.add(
createColumnReader(
utcTimestamp,
rowType.getTypeAt(i),
