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(-)