You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by da...@apache.org on 2021/09/11 05:17:30 UTC

[hudi] branch master updated (0624041 -> b30c5bd)

This is an automated email from the ASF dual-hosted git repository.

danny0405 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.


    from 0624041  [HUDI-2354] Fix TimelineServer error because of replacecommit archive (#3536)
     add b30c5bd  [HUDI-2412] Add timestamp based partitioning for flink writer (#3638)

No new revisions were added by this update.

Summary of changes:
 .../apache/hudi/configuration/FlinkOptions.java    |  16 +++-
 .../org/apache/hudi/sink/bulk/RowDataKeyGen.java   |  42 ++++++++-
 .../java/org/apache/hudi/source/FileIndex.java     |  16 +++-
 .../apache/hudi/streamer/FlinkStreamerConfig.java  |   2 +-
 .../org/apache/hudi/table/HoodieTableFactory.java  |  57 +++++++++--
 .../java/org/apache/hudi/util/DataTypeUtils.java   |  61 ++++++++++++
 .../java/org/apache/hudi/util/StreamerUtil.java    |  13 +--
 .../apache/hudi/sink/bulk/TestRowDataKeyGen.java   |  33 +++++++
 .../java/org/apache/hudi/source/TestFileIndex.java |  19 ++++
 .../apache/hudi/table/HoodieDataSourceITCase.java  | 104 +++++++++++++++------
 .../apache/hudi/table/TestHoodieTableFactory.java  |  30 +++++-
 .../org/apache/hudi/utils/TestConfigurations.java  |  25 +++--
 12 files changed, 354 insertions(+), 64 deletions(-)
 create mode 100644 hudi-flink/src/main/java/org/apache/hudi/util/DataTypeUtils.java