This is an automated email from the ASF dual-hosted git repository.
voonhous pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 2ab2c0a38952 refactor(io): use SLF4J parameterized logging instead of
string concatenation (#19188)
add feea94ba1848 refactor(flink): migrate hand-declared LOG to Lombok
@Slf4j (#19190)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/sink/FlinkCheckpointClient.java | 18 +++++-----
.../AppendWriteFunctionWithContinuousSort.java | 20 +++++------
.../clustering/ClusteringPlanSourceFunction.java | 10 +++---
.../sink/clustering/HoodieFlinkClusteringJob.java | 42 +++++++++++-----------
.../sink/compact/CompactionPlanSourceFunction.java | 10 +++---
.../hudi/sink/compact/HoodieFlinkCompactor.java | 38 ++++++++++----------
.../hudi/sink/muttley/AthenaIngestionGateway.java | 9 +++--
.../hudi/sink/muttley/FlinkHudiMuttleyClient.java | 24 ++++++-------
.../java/org/apache/hudi/source/HoodieSource.java | 10 +++---
.../HoodieContinuousSplitEnumerator.java | 14 ++++----
.../source/reader/HoodieSourceSplitReader.java | 10 +++---
.../source/split/DefaultHoodieSplitDiscover.java | 6 ++--
.../hudi/sink/TestFlinkCheckpointClient.java | 26 +++++++-------
.../apache/hudi/table/ITTestHoodieDataSource.java | 12 +++----
.../cow/vector/reader/AbstractColumnReader.java | 8 ++---
.../vector/reader/NestedPrimitiveColumnReader.java | 16 ++++-----
.../cow/vector/reader/AbstractColumnReader.java | 8 ++---
.../vector/reader/NestedPrimitiveColumnReader.java | 16 ++++-----
.../cow/vector/reader/AbstractColumnReader.java | 8 ++---
.../vector/reader/NestedPrimitiveColumnReader.java | 16 ++++-----
.../cow/vector/reader/AbstractColumnReader.java | 8 ++---
.../vector/reader/NestedPrimitiveColumnReader.java | 16 ++++-----
hudi-flink-datasource/hudi-flink2.1.x/pom.xml | 6 ++++
.../cow/vector/reader/AbstractColumnReader.java | 8 ++---
.../vector/reader/BaseVectorizedColumnReader.java | 16 ++++-----
.../vector/reader/NestedPrimitiveColumnReader.java | 16 ++++-----
26 files changed, 174 insertions(+), 217 deletions(-)
