You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2021/11/19 08:36:04 UTC
[flink] branch master updated (8aa74d5 -> d821e03)

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

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


    from 8aa74d5  [FLINK-24835][table-planner] Fix bug in `RelTimeIndicatorConverter` when materialize time attribute fields of regular join's inputs
     add d821e03  [FLINK-24616][connectors][table] Add metadata from FileStatus in FileSystemTableSource

No new revisions were added by this update.

Summary of changes:
 docs/content/docs/connectors/table/filesystem.md   | 19 ++++-
 .../flink/connector/file/src/FileSourceSplit.java  | 94 ++++++++++++++++++++--
 .../file/src/FileSourceSplitSerializer.java        | 15 +++-
 .../BlockSplittingRecursiveEnumerator.java         | 11 ++-
 .../enumerate/NonSplittingRecursiveEnumerator.java | 10 ++-
 .../file/src/FileSourceHeavyThroughputTest.java    |  3 +-
 .../file/src/FileSourceSplitSerializerTest.java    | 21 ++++-
 .../file/src/FileSourceSplitStateTest.java         |  2 +
 .../connector/file/src/FileSourceSplitTest.java    |  2 +-
 .../src/PendingSplitsCheckpointSerializerTest.java |  6 +-
 .../assigners/LocalityAwareSplitAssignerTest.java  |  2 +-
 .../BlockSplittingRecursiveEnumeratorTest.java     |  9 ++-
 .../NonSplittingRecursiveEnumeratorTest.java       | 17 +++-
 .../connector/file/src/impl/AdapterTestBase.java   | 23 +++++-
 .../impl/ContinuousFileSplitEnumeratorTest.java    |  7 +-
 .../file/src/impl/FileSourceReaderTest.java        |  3 +-
 .../src/impl/StaticFileSplitEnumeratorTest.java    |  7 +-
 .../file/src/impl/StreamFormatAdapterTest.java     |  4 +-
 .../connectors/hive/HiveSourceSplitSerializer.java |  4 +
 .../hive/read/HiveCompactReaderFactory.java        | 14 +++-
 .../connectors/hive/read/HiveSourceSplit.java      | 40 ++++++++-
 .../orc/OrcColumnarRowFileInputFormatTest.java     | 17 +++-
 .../parquet/ParquetColumnarRowInputFormatTest.java | 22 ++++-
 .../filesystem/FileSystemTableSourceTest.java      |  2 +-
 .../table/filesystem/FileSystemTableSourceTest.xml |  4 +-
 .../planner/runtime/FileSystemITCaseBase.scala     | 63 ++++++++++++++-
 .../table/filesystem/FileSystemTableSource.java    | 38 ++++++++-
 .../stream/compact/CompactBulkReader.java          | 11 ++-
 .../filesystem/FileSystemTableFactoryTest.java     | 25 ++++++
 .../table/filesystem/LimitableBulkFormatTest.java  | 17 +++-
 30 files changed, 459 insertions(+), 53 deletions(-)