This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
from 43fec308b32 [FLINK-33599] Run restore tests with RocksDB state backend (#23883) add 978bff3bb90 [FLINK-25565][Formats][Parquet] write and read parquet int64 timestamp (#18304) No new revisions were added by this update. Summary of changes: .../docs/connectors/table/formats/parquet.md | 14 ++ .../docs/connectors/table/formats/parquet.md | 14 ++ .../formats/parquet/ParquetFileFormatFactory.java | 15 ++ .../parquet/ParquetVectorizedInputFormat.java | 13 +- .../formats/parquet/row/ParquetRowDataBuilder.java | 13 +- .../formats/parquet/row/ParquetRowDataWriter.java | 67 ++++- .../parquet/utils/ParquetSchemaConverter.java | 50 +++- .../formats/parquet/vector/ParquetDictionary.java | 20 +- .../parquet/vector/ParquetSplitReaderUtil.java | 3 +- .../vector/reader/AbstractColumnReader.java | 2 +- .../vector/reader/TimestampColumnReader.java | 101 +++++++- .../formats/parquet/ParquetTimestampITCase.java | 280 +++++++++++++++++++++ .../parquet/row/ParquetRowDataWriterTest.java | 14 ++ .../vector/ParquetInt64TimestampReaderTest.java | 69 +++++ .../runtime/stream/FsStreamingSinkITCaseBase.scala | 65 +++-- 15 files changed, 683 insertions(+), 57 deletions(-) create mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTimestampITCase.java create mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/vector/ParquetInt64TimestampReaderTest.java