diff --git a/cpp/velox/compute/WholeStageResultIterator.cc b/cpp/velox/compute/WholeStageResultIterator.cc index f645661b7fbb..9c4367b721e0 100644 --- a/cpp/velox/compute/WholeStageResultIterator.cc +++ b/cpp/velox/compute/WholeStageResultIterator.cc @@ -555,7 +555,7 @@ std::shared_ptr WholeStageResultIterator::createConnectorConfig() configs[velox::connector::hive::HiveConfig::kFileColumnNamesReadAsLowerCaseSession] = !veloxCfg_->get(kCaseSensitive, false) ? "true" : "false"; configs[velox::connector::hive::HiveConfig::kPartitionPathAsLowerCaseSession] = "false"; - configs[velox::connector::hive::HiveConfig::kArrowBridgeTimestampUnit] = "6"; + configs[velox::connector::hive::HiveConfig::kParquetWriteTimestampUnit] = "6"; configs[velox::connector::hive::HiveConfig::kMaxPartitionsPerWritersSession] = std::to_string(veloxCfg_->get(kMaxPartitions, 10000)); configs[velox::connector::hive::HiveConfig::kIgnoreMissingFilesSession] = diff --git a/cpp/velox/operators/writer/VeloxParquetDatasource.cc b/cpp/velox/operators/writer/VeloxParquetDatasource.cc index 26c420316fd6..c45b9cb145d0 100644 --- a/cpp/velox/operators/writer/VeloxParquetDatasource.cc +++ b/cpp/velox/operators/writer/VeloxParquetDatasource.cc @@ -96,6 +96,7 @@ void VeloxParquetDatasource::init(const std::unordered_map(stoi(sparkConfs.find(kParquetBlockRows)->second)); } velox::parquet::WriterOptions writeOption; + writeOption.parquetWriteTimestampUnit = 6 /*micro*/; auto compressionCodec = CompressionKind::CompressionKind_SNAPPY; if (sparkConfs.find(kParquetCompressionCodec) != sparkConfs.end()) { auto compressionCodecStr = sparkConfs.find(kParquetCompressionCodec)->second; diff --git a/ep/build-velox/src/get_velox.sh b/ep/build-velox/src/get_velox.sh index 588acfa21620..f9f6385743fd 100755 --- a/ep/build-velox/src/get_velox.sh +++ b/ep/build-velox/src/get_velox.sh @@ -17,7 +17,7 @@ set -exu VELOX_REPO=https://github.com/oap-project/velox.git -VELOX_BRANCH=2024_03_19 +VELOX_BRANCH=2024_03_20 VELOX_HOME="" #Set on run gluten on HDFS