You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by le...@apache.org on 2022/01/07 03:53:52 UTC
[flink] branch master updated (137b65c -> c66720a)
This is an automated email from the ASF dual-hosted git repository.
leonard pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 137b65c [FLINK-25487][core][table-planner-loader] Improve verbosity of classloading errors
add c66720a [FLINK-24758][filesystem] Introduce 'partitiontime-extractor.formatter-pattern' to format extracted partition time
No new revisions were added by this update.
Summary of changes:
.../content.zh/docs/connectors/table/filesystem.md | 7 +
docs/content/docs/connectors/table/filesystem.md | 10 +-
.../file/table/DefaultPartTimeExtractor.java | 40 +++--
.../file/table/FileSystemConnectorOptions.java | 26 ++-
.../file/table/FileSystemTableFactory.java | 1 +
.../file/table/PartitionTimeExtractor.java | 5 +-
.../table/stream/PartitionTimeCommitPredicate.java | 4 +-
.../file/table/stream/StreamingFileWriterTest.java | 2 +
.../flink/connectors/hive/HiveTableSource.java | 18 +-
.../hive/read/HivePartitionFetcherContextBase.java | 5 +-
.../runtime/stream/FsStreamingSinkITCaseBase.scala | 184 ++++++++++++++-------
11 files changed, 225 insertions(+), 77 deletions(-)