This is an automated email from the ASF dual-hosted git repository.
garyli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from 2a7e1e0 [HUDI-1942] Add Default value for
HIVE_AUTO_CREATE_DATABASE_OPT_KEY in HoodieSparkSqlWriter (#3036)
add 08464a6 [HUDI-1931] BucketAssignFunction use ValueState instead of
MapState (#3026)
No new revisions were added by this update.
Summary of changes:
.../sink/partitioner/BucketAssignFunction.java | 56 +++++++++++----------
.../sink/partitioner/BucketAssignOperator.java | 57 ++++++++++++++++++++++
.../org/apache/hudi/table/HoodieTableSink.java | 3 +-
.../org/apache/hudi/sink/StreamWriteITCase.java | 5 +-
.../hudi/sink/utils/CompactFunctionWrapper.java | 10 ++--
.../hudi/sink/utils/MockOperatorStateStore.java | 6 ++-
.../org/apache/hudi/sink/utils/MockValueState.java | 28 ++++++-----
.../sink/utils/StreamWriteFunctionWrapper.java | 33 ++++++++++++-
8 files changed, 147 insertions(+), 51 deletions(-)
create mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignOperator.java
copy
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/InMemoryMetricsReporter.java
=> hudi-flink/src/test/java/org/apache/hudi/sink/utils/MockValueState.java
(66%)
