This is an automated email from the ASF dual-hosted git repository.
dkuzmenko pushed a change to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/hive.git
from 753136e0364 HIVE-27856: Disable CTE materialization by default
(Seonggon Namgung, reviewed by Denys Kuzmenko)
add 6aeb31d5740 Tez Progress bar is not displayed in Beeline upon setting
session level execution engine to Tez (Shivangi Jha, reviewed by Attila
Turoczy, Vikram Ahuja, Ayush Saxena, Laszlo Bodor)
add bc78d967c6f HIVE-27662: Incorrect parsing of nested complex types
containing map during vectorized text processing (Raghav Aggarwal, Reviewed by
Denys Kuzmenko, Chinna Rao Lalam)
add 733e4900f04 HIVE-27918: Iceberg: Push transforms for clustering during
table writes (#4908) (Sourabh Badhya reviewed by Denys Kuzmenko)
add 4c39bf1805a HIVE-27894: Enhance HMS Handler Logs for all
'get_partition' functions (Shivangi Jha, Reviewed by Chinna Rao Lalam)
add 1b9ca6545ce HIVE-27797: Transactions that got timed out are not
getting logged as 'ABORTED' in NOTIFICATION_LOG (Taraka Rama Rao Lethavadla,
reviewed by Denys Kuzmenko)
add 9bf1ce77572 HIVE-27905: Some GenericUDFs wrongly cast ObjectInspectors
(#4896). (okumin, reviewed by Ayush Saxena, Attila Turoczy)
add 318b149d2f3 HIVE-27935: Add qtest for Avro invalid schema and field
names (#4918) (Akshat Mathur, reviewed by Butao Zhang)
add cb3097b77a8 HIVE-27893: Add a range validator in
hive.metastore.batch.retrieve.max to only have values greater than 0 (Vikram
Ahuja, Reviewed by Attila Turoczy, Zoltan Ratkai, Chinna Rao Lalam)
add 74f37fefaed HIVE-27658: Error resolving join keys during conversion to
dynamic partition hashjoin (Stamatis Zampetakis reviewed by Denys Kuzmenko)
add 109daa75c01 HIVE-27555: Upgrade issues with Kudu table on backend db
(#4872) (Zhihua Deng, reviewed by Attila Turoczy, Denys Kuzmenko)
add 86b3bde1878 HIVE-27936: Disable flaky test
testBootstrapAcidTablesDuringIncrementalWithConcurrentWrites (#4934)(Butao
Zhang, reviewed by Ayush Saxena)
add 8917810787f HIVE-27446: Exception when rebuild materialized view
incrementally in presence of delete operations (Krisztian Kasa, reviewed by
Laszlo Vegh)
add 0047816a1d2 HIVE-27801: Exists subquery rewrite results in a wrong
plan (Denys Kuzmenko, reviewed by Attila Turoczy, Ayush Saxena)
add b13909afc52 HIVE-27943: NPE in
VectorMapJoinCommonOperator.setUpHashTable when running query with join on date
(Stamatis Zampetakis reviewed by Attila Turoczy, Krisztian Kasa)
add 08d2a215210 HIVE-27930: Insert/Load overwrite table partition does not
clean up directory before overwriting (#4915)(Kiran Velumuri, reviewed by
Indhumathi Muthumurugesh, Butao Zhang)
add 75db8590408 HIVE-27892: Hive 'insert overwrite table' for multiple
partition table issue (#4893) (Mayank Kunwar, Reviewed by Sai Hemanth Gantasala)
add 5dab8ac88b6 HIVE-24219: Disable flaky TestStreaming (Stamatis
Zampetakis reviewed by Sourabh Badhya)
add 467005a0ce2 HIVE-27934: Fix incorrect description about the execution
framework in README.md (#4917)(Butao Zhang, reviewed by Stamatis Zampetakis,
Attila Turoczy)
add 27d16b8da75 HIVE-27850: Iceberg: Major QB Compaction (Dmitriy
Fingerman, reviewed by Attila Turoczy, Ayush Saxena, Butao Zhang, Denys
Kuzmenko)
add 7fbaf56e354 HIVE-27824 : Upgrade ivy to 2.5.2 and htmlunit to 2.70.0
(#4939) (Devaspati Krishnatri reviewed by Attila Turoczy, Sourabh Badhya)
add 12ff933e017 HIVE-27690: Handle casting NULL literal to complex type
(Krisztian Kasa, reviewed by Laszlo Vegh)
add 4982ffdc155 HIVE-27481: TxnHandler cleanup (Laszlo Vegh, reviewed by
Denys Kuzmenko, Krisztian Kasa, Zoltan Ratkai, Laszlo Bodor)
add 48c65ee6cda HIVE-27749: SchemaTool initSchema fails on Mariadb 10.2
(Sourabh Badhya, reviewed by Denys Kuzmenko, Zsolt Miskolczi)
add 3ea6b258e38 HIVE-27952: Use SslContextFactory.Server() instead of
SslContextFactory (#4947)
add e6082f5ebe5 HIVE-27876 Incorrect query results on tables with
ClusterBy & SortBy (Ramesh Kumar Thangarajan, reviewed by Krisztian Kasa,
Attila Turoczy)
add d8a66d6393b HIVE-27963: Build failure when license-maven-plugin
downloads bsd-license.php (Akshat Mathur reviewed by Stamatis Zampetakis, Ayush
Saxena)
add 5576cf6585a HIVE-27919: Constant reduction in CBO does not work for
FROM_UNIXTIME, DATE_ADD, DATE_SUB, TO_UNIX_TIMESTAMP (Stamatis Zampetakis
reviewed by Akshat Mathur, Krisztian Kasa)
add 96f135ac5a5 HIVE-27161: MetaException when executing CTAS query in
Druid storage handler (Krisztian Kasa, reviewed by Denys Kuzmenko)
add 351411aac9e HIVE-25803: URL Mapping appends default Fs scheme even for
LOCAL DIRECTORY ops. (#4957). (Ayush Saxena, reviewed by Denys Kuzmenko)
add 90f71845fc9 HIVE-27797: Addendum: Fix flaky test case (Taraka Rama
Rao Lethavadla, reviewed by Denys Kuzmenko)
add 7f869461d9c HIVE-27804: Implement batching in getPartition calls which
returns partition list along with auth info (Vikram Ahuja, Reviewed by Chinna
Rao Lalam)
add 2234e23a745 HIVE-27967: Iceberg: Fix dynamic runtime filtering (Denys
Kuzmenko, reviewed by Attila Turoczy, Butao Zhang)
add 44b122382fc HIVE-27961: Beeline will print duplicate stats info when
hive.tez.exec.print.summary is true (#4960)(Butao Zhang, reviewed by Attila
Turoczy, Sourabh Badhya)
add fb2df26b3aa HIVE-23558: Remove compute_stats UDAF (#4928)(Butao Zhang,
reviewed by Ayush Saxena)
add a95caacbad5 HIVE-27530: Implement direct SQL for alter partitions to
improve performance (Wechar Yu, reviewed by Denys Kuzmenko, Sai Hemanth
Gantasala)
add 0e198fca1e6 HIVE-27966: Disable flaky
testFetchResultsOfLogWithOrientation (#4967). (Wechar, reviewed by Ayush
Saxena, Akshat Mathur)
add 38597490f4b HIVE-27780: Implement direct SQL for get_all_functions -
ADDENDUM (#4971). (zhangbutao, reviewed by Ayush Saxena)
No new revisions were added by this update.
Summary of changes:
README.md | 8 +-
.../java/org/apache/hadoop/hive/conf/HiveConf.java | 17 +-
.../src/java/org/apache/hive/http/HttpServer.java | 2 +-
data/files/datasets/temp_udf/load.hive.sql | 1 +
.../org/apache/hive/hcatalog/templeton/Main.java | 2 +-
.../iceberg/mr/hive/HiveIcebergFilterFactory.java | 3 -
.../iceberg/mr/hive/HiveIcebergMetaHook.java | 3 +-
.../mr/hive/HiveIcebergOutputCommitter.java | 24 +-
.../iceberg/mr/hive/HiveIcebergStorageHandler.java | 47 +-
.../mr/hive/IcebergTransformSortFunctionUtil.java | 158 +
.../hive/compaction/IcebergCompactionService.java | 77 +
.../compaction/IcebergMajorQueryCompactor.java | 64 +
.../mr/hive/{ => udf}/GenericUDFIcebergBucket.java | 2 +-
.../iceberg/mr/hive/udf/GenericUDFIcebergDay.java | 129 +
.../iceberg/mr/hive/udf/GenericUDFIcebergHour.java | 118 +
.../mr/hive/udf/GenericUDFIcebergMonth.java | 129 +
.../GenericUDFIcebergTruncate.java} | 101 +-
.../iceberg/mr/hive/udf/GenericUDFIcebergYear.java | 129 +
.../mr/hive/TestHiveIcebergFilterFactory.java | 84 -
.../queries/positive/dynamic_partition_writes.q | 100 +-
.../iceberg_major_compaction_partition_evolution.q | 65 +
.../iceberg_major_compaction_partitioned.q | 91 +
.../iceberg_major_compaction_schema_evolution.q | 66 +
.../iceberg_major_compaction_unpartitioned.q | 58 +
.../delete_iceberg_copy_on_write_partitioned.q.out | 36 +-
.../positive/dynamic_partition_writes.q.out | 1031 +++
...berg_major_compaction_partition_evolution.q.out | 377 ++
.../iceberg_major_compaction_partitioned.q.out | 655 ++
...iceberg_major_compaction_schema_evolution.q.out | 362 ++
.../iceberg_major_compaction_unpartitioned.q.out | 310 +
.../merge_iceberg_copy_on_write_partitioned.q.out | 24 +-
.../positive/merge_iceberg_partitioned_orc.q.out | 16 +-
.../update_iceberg_copy_on_write_partitioned.q.out | 64 +-
itests/hive-unit/pom.xml | 9 +-
.../parse/TestReplicationScenariosAcidTables.java | 2 +-
...estReplicationScenariosAcidTablesBootstrap.java | 2 +
.../parse/TestTimedOutTxnNotificationLogging.java | 202 +
.../hive/ql/txn/compactor/TestCompactor.java | 5 +-
.../ql/txn/compactor/TestCrudCompactorOnTez.java | 2 +-
.../org/apache/hive/jdbc/TestRestrictedList.java | 1 +
.../operation/TestOperationLoggingAPIWithMr.java | 2 +
.../TestIcebergLlapLocalCompactorCliDriver.java | 83 +
.../test/resources/testconfiguration.properties | 7 +
.../apache/hadoop/hive/cli/control/CliConfigs.java | 24 +
packaging/pom.xml | 4 +
.../hadoop/hive/ql/parse/IdentifiersParser.g | 2 +-
pom.xml | 4 +-
ql/src/java/org/apache/hadoop/hive/ql/Context.java | 17 +
.../compact/AlterTableCompactOperation.java | 2 +-
.../AlterMaterializedViewRebuildAnalyzer.java | 7 +-
.../hadoop/hive/ql/exec/FunctionRegistry.java | 16 +-
.../VectorMapJoinOptimizedCreateHashTable.java | 1 +
.../org/apache/hadoop/hive/ql/io/AcidUtils.java | 2 +-
.../org/apache/hadoop/hive/ql/metadata/Hive.java | 179 +-
.../hive/ql/metadata/HiveStorageHandler.java | 9 +-
.../hadoop/hive/ql/metadata/PartitionIterable.java | 28 +-
.../hadoop/hive/ql/optimizer/MapJoinProcessor.java | 3 +-
.../reloperators/HiveDateAddSqlOperator.java | 15 +-
.../reloperators/HiveDateSubSqlOperator.java | 15 +-
.../reloperators/HiveFromUnixTimeSqlOperator.java | 29 +-
.../HiveToUnixTimestampSqlOperator.java | 12 +-
.../calcite/rules/HiveRelDecorrelator.java | 16 +-
...veJoinInsertDeleteIncrementalRewritingRule.java | 62 +-
.../rules/views/HiveRowIsDeletedPropagator.java | 25 -
.../calcite/rules/views/InputRefShifter.java | 49 +
.../optimizer/calcite/translator/ASTConverter.java | 82 +-
.../calcite/translator/RexNodeConverter.java | 8 +-
.../apache/hadoop/hive/ql/parse/ParseUtils.java | 51 +-
.../hadoop/hive/ql/parse/SemanticAnalyzer.java | 14 +-
.../ql/parse/type/ExprNodeDescExprFactory.java | 108 +-
.../hive/ql/parse/type/TypeCheckProcFactory.java | 11 +-
.../hadoop/hive/ql/plan/ExprNodeConstantDesc.java | 3 +
.../authorization/command/CommandAuthorizerV2.java | 8 +-
.../hadoop/hive/ql/stats/BasicStatsTask.java | 6 +-
.../hadoop/hive/ql/txn/compactor/Cleaner.java | 4 +-
.../txn/compactor/CompactionHeartbeatService.java | 8 +-
.../hive/ql/txn/compactor/CompactorContext.java | 8 +-
.../hive/ql/txn/compactor/CompactorFactory.java | 25 +-
.../hive/ql/txn/compactor/CompactorThread.java | 103 +-
.../hive/ql/txn/compactor/CompactorUtil.java | 109 +-
.../hadoop/hive/ql/txn/compactor/Initiator.java | 8 +-
.../hive/ql/txn/compactor/InitiatorBase.java | 14 +-
.../hadoop/hive/ql/txn/compactor/MRCompactor.java | 2 +-
.../hive/ql/txn/compactor/MergeCompactor.java | 2 +-
.../ql/txn/compactor/MetaStoreCompactorThread.java | 7 +-
.../hive/ql/txn/compactor/QueryCompactor.java | 39 +-
.../ql/txn/compactor/RemoteCompactorThread.java | 26 +-
...mpactorThread.java => RemoteCompactorUtil.java} | 57 +-
.../hadoop/hive/ql/txn/compactor/StatsUpdater.java | 3 +-
.../hadoop/hive/ql/txn/compactor/Worker.java | 400 +-
.../txn/compactor/handler/AbortedTxnCleaner.java | 2 +-
.../txn/compactor/handler/CompactionCleaner.java | 2 +-
.../hive/ql/txn/compactor/handler/TaskHandler.java | 25 +-
.../compactor/service/AcidCompactionService.java | 420 ++
.../service/CompactionExecutorFactory.java | 58 +
.../txn/compactor/service/CompactionService.java | 86 +
.../ql/udf/generic/GenericUDFBaseNwayCompare.java | 1 +
.../udf/generic/GenericUDFEnforceConstraint.java | 5 +
.../hive/ql/udf/generic/GenericUDFEpochMilli.java | 6 +-
.../udf/generic/GenericUDFExceptionInVertex.java | 22 +-
.../hive/ql/udf/generic/GenericUDFGrouping.java | 1 +
.../hive/ql/udf/generic/GenericUDFOPFalse.java | 1 +
.../hive/ql/udf/generic/GenericUDFOPNotFalse.java | 1 +
.../hive/ql/udf/generic/GenericUDFOPNotTrue.java | 1 +
.../hive/ql/udf/generic/GenericUDFOPTrue.java | 1 +
.../ql/udf/generic/GenericUDFSQCountCheck.java | 1 +
.../hive/ql/udf/generic/GenericUDFSplit.java | 1 +
...enericUDFOPTrue.java => GenericUDFToArray.java} | 42 +-
...{GenericUDFOPTrue.java => GenericUDFToMap.java} | 46 +-
...nericUDFOPTrue.java => GenericUDFToStruct.java} | 41 +-
.../hive/ql/udf/generic/GenericUDFTrunc.java | 3 +
.../ql/udf/generic/GenericUDFTumbledWindow.java | 3 +
.../metastore/txn/TestCompactionTxnHandler.java | 7 +-
.../hadoop/hive/metastore/txn/TestTxnHandler.java | 129 +-
.../apache/hadoop/hive/ql/TestTxnCommands3.java | 2 +-
.../hadoop/hive/ql/TxnCommandsBaseForTests.java | 2 +-
.../apache/hadoop/hive/ql/exec/PartitionUtil.java | 28 +
.../ql/exec/TestGetPartitionAuthWithBatches.java | 300 +
.../hive/ql/exec/TestGetPartitionInBatches.java | 74 +-
.../calcite/translator/TestASTConverter.java | 178 +-
.../ql/parse/type/TestExprNodeDescExprFactory.java | 175 +
.../TestHivePrivilegeObjectOwnerNameAndType.java | 33 +
.../hive/ql/txn/compactor/CompactorTest.java | 2 +-
.../hadoop/hive/ql/txn/compactor/TestCleaner.java | 2 +-
.../ql/txn/compactor/TestCompactionMetrics.java | 4 +-
.../TestMRCompactorJobQueueConfiguration.java | 2 +-
.../compactor/handler/TestAbortedTxnCleaner.java | 2 +-
.../clientnegative/avro_duplicate_field_name.q | 25 +
.../clientnegative/avro_invalid_field_name.q | 18 +
.../queries/clientnegative/compute_stats_long.q | 7 -
.../udf_enforce_constraint_wrong_type1.q | 1 +
.../udf_exception_in_vertex_udf_wrong_type1.q | 2 +
.../udf_exception_in_vertex_udf_wrong_type2.q | 2 +
.../udf_exception_in_vertex_udf_wrong_type3.q | 2 +
.../udf_exception_in_vertex_udf_wrong_type4.q | 2 +
.../queries/clientnegative/udf_greatest_error_3.q | 2 +
.../clientnegative/udf_grouping_wrong_type1.q | 1 +
.../clientnegative/udf_isfalse_wrong_type1.q | 1 +
.../clientnegative/udf_isnotfalse_wrong_type1.q | 1 +
.../clientnegative/udf_isnottrue_wrong_type1.q | 1 +
.../clientnegative/udf_istrue_wrong_type1.q | 1 +
.../queries/clientnegative/udf_split_wrong_type1.q | 1 +
.../queries/clientnegative/udf_split_wrong_type2.q | 1 +
.../udf_sq_count_check_wrong_type1.q | 1 +
.../udf_to_epoch_milli_wrong_type1.q | 2 +
.../queries/clientnegative/udf_trunc_wrong_type1.q | 1 +
.../queries/clientnegative/udf_trunc_wrong_type2.q | 1 +
.../udf_tumbling_window_check_wrong_type1.q | 1 +
.../udf_tumbling_window_check_wrong_type2.q | 1 +
.../queries/clientpositive/cast_null_to_complex.q | 13 +
.../queries/clientpositive/cbo_constantfolding.q | 5 +
ql/src/test/queries/clientpositive/char_udf1.q | 1 +
.../test/queries/clientpositive/complex_datatype.q | 232 +
.../queries/clientpositive/compute_stats_binary.q | 9 -
.../queries/clientpositive/compute_stats_boolean.q | 9 -
.../queries/clientpositive/compute_stats_date.q | 28 -
.../queries/clientpositive/compute_stats_decimal.q | 11 -
.../queries/clientpositive/compute_stats_double.q | 9 -
.../clientpositive/compute_stats_empty_table.q | 12 -
.../queries/clientpositive/compute_stats_long.q | 9 -
.../queries/clientpositive/compute_stats_string.q | 9 -
.../queries/clientpositive/empty_result_ctas.q | 12 +
.../queries/clientpositive/groupby_sort_2_23.q | 10 +
.../insert_and_load_overwrite_drop_partition.q | 61 +
ql/src/test/queries/clientpositive/mapjoin_date.q | 8 +
.../materialized_view_join_rebuild.q | 33 +
.../materialized_view_repeated_rebuild.q | 37 +
.../reduceSinkDeDuplication_pRS_key_empty.q | 1 +
.../subquery_complex_correlation_predicates.q | 15 +
.../clientpositive/tez_dynpart_hashjoin_4.q | 24 +
ql/src/test/queries/clientpositive/varchar_udf1.q | 1 +
ql/src/test/queries/clientpositive/vector_udf1.q | 1 +
.../clientnegative/avro_duplicate_field_name.q.out | 27 +
.../clientnegative/avro_invalid_field_name.q.out | 20 +
.../clientnegative/compute_stats_long.q.out | 57 -
.../udf_enforce_constraint_wrong_type1.q.out | 1 +
.../udf_exception_in_vertex_udf_wrong_type1.q.out | 1 +
.../udf_exception_in_vertex_udf_wrong_type2.q.out | 1 +
.../udf_exception_in_vertex_udf_wrong_type3.q.out | 1 +
.../udf_exception_in_vertex_udf_wrong_type4.q.out | 1 +
.../clientnegative/udf_greatest_error_3.q.out | 1 +
.../clientnegative/udf_grouping_wrong_type1.q.out | 1 +
.../clientnegative/udf_isfalse_wrong_type1.q.out | 1 +
.../udf_isnotfalse_wrong_type1.q.out | 1 +
.../clientnegative/udf_isnottrue_wrong_type1.q.out | 1 +
.../clientnegative/udf_istrue_wrong_type1.q.out | 1 +
.../clientnegative/udf_split_wrong_type1.q.out | 1 +
.../clientnegative/udf_split_wrong_type2.q.out | 1 +
.../udf_sq_count_check_wrong_type1.q.out | 1 +
.../udf_to_epoch_milli_wrong_type1.q.out | 1 +
.../clientnegative/udf_trunc_wrong_type1.q.out | 1 +
.../clientnegative/udf_trunc_wrong_type2.q.out | 1 +
.../udf_tumbling_window_check_wrong_type1.q.out | 1 +
.../udf_tumbling_window_check_wrong_type2.q.out | 1 +
.../results/clientpositive/cbo_rp_auto_join1.q.out | 457 +-
.../results/clientpositive/llap/analyze_npe.q.out | 7 +-
.../llap/auto_sortmerge_join_10.q.out | 295 +-
.../clientpositive/llap/bucket_groupby.q.out | 89 +-
.../clientpositive/llap/cast_null_to_complex.q.out | 107 +
.../clientpositive/llap/cbo_constantfolding.q.out | 60 +
.../clientpositive/llap/complex_datatype.q.out | 668 ++
.../clientpositive/llap/compute_stats_binary.q.out | 34 -
.../llap/compute_stats_boolean.q.out | 34 -
.../clientpositive/llap/compute_stats_date.q.out | 176 -
.../llap/compute_stats_decimal.q.out | Bin 1512 -> 0 bytes
.../clientpositive/llap/compute_stats_double.q.out | Bin 1443 -> 0 bytes
.../llap/compute_stats_empty_table.q.out | 62 -
.../clientpositive/llap/compute_stats_long.q.out | Bin 1376 -> 0 bytes
.../clientpositive/llap/compute_stats_string.q.out | Bin 1448 -> 0 bytes
.../llap/constant_prop_coalesce.q.out | 10 +-
.../clientpositive/llap/empty_result_ctas.q.out | 124 +-
.../clientpositive/llap/groupby_sort_2_23.q.out | 180 +
.../insert_and_load_overwrite_drop_partition.q.out | 256 +
.../results/clientpositive/llap/mapjoin_date.q.out | 186 +
.../llap/materialized_view_create_rewrite_5.q.out | 112 +-
.../llap/materialized_view_create_rewrite_8.q.out | 52 +-
.../llap/materialized_view_join_rebuild.q.out | 108 +
.../llap/materialized_view_repeated_rebuild.q.out | 134 +
.../clientpositive/llap/ppd_transform.q.out | 6 +-
.../clientpositive/llap/schemeAuthority.q.out | 2 -
.../clientpositive/llap/schemeAuthority2.q.out | 2 -
.../clientpositive/llap/show_functions.q.out | 9 +-
.../subquery_complex_correlation_predicates.q.out | 66 +
.../llap/tez_dynpart_hashjoin_4.q.out | 209 +
.../lazy/fast/LazySimpleDeserializeRead.java | 14 +-
.../org/apache/hive/service/cli/CLIService.java | 4 +
.../hive/service/cli/thrift/ThriftCLIService.java | 4 +-
.../service/cli/thrift/ThriftHttpCLIService.java | 2 +-
.../src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp | 2560 ++++----
.../gen/thrift/gen-cpp/hive_metastore_types.cpp | 652 +-
.../src/gen/thrift/gen-cpp/hive_metastore_types.h | 10 +-
.../hive/metastore/api/GetOpenTxnsRequest.java | 36 +-
.../api/GetPartitionsPsWithAuthRequest.java | 204 +-
.../api/GetPartitionsPsWithAuthResponse.java | 36 +-
.../hive/metastore/api/ReplicationMetricList.java | 36 +-
.../hive/metastore/api/ThriftHiveMetastore.java | 2780 ++++----
.../gen-php/metastore/GetOpenTxnsRequest.php | 18 +-
.../metastore/GetPartitionsPsWithAuthRequest.php | 52 +-
.../metastore/GetPartitionsPsWithAuthResponse.php | 20 +-
.../gen-php/metastore/ReplicationMetricList.php | 20 +-
.../ThriftHiveMetastore_add_partitions_args.php | 20 +-
...riftHiveMetastore_add_partitions_pspec_args.php | 20 +-
...Metastore_add_write_ids_to_min_history_args.php | 26 +-
.../ThriftHiveMetastore_alter_partitions_args.php | 20 +-
...er_partitions_with_environment_context_args.php | 20 +-
.../ThriftHiveMetastore_append_partition_args.php | 18 +-
...end_partition_with_environment_context_args.php | 18 +-
...etastore_create_table_with_constraints_args.php | 120 +-
.../ThriftHiveMetastore_drop_partition_args.php | 18 +-
...rop_partition_with_environment_context_args.php | 18 +-
...ThriftHiveMetastore_exchange_partition_args.php | 26 +-
...hriftHiveMetastore_exchange_partitions_args.php | 26 +-
...iftHiveMetastore_exchange_partitions_result.php | 20 +-
...iveMetastore_find_columns_with_stats_result.php | 18 +-
...hriftHiveMetastore_get_all_databases_result.php | 18 +-
...erialized_view_objects_for_rewriting_result.php | 20 +-
...ThriftHiveMetastore_get_all_packages_result.php | 18 +-
...eMetastore_get_all_stored_procedures_result.php | 18 +-
.../ThriftHiveMetastore_get_all_tables_result.php | 18 +-
...eMetastore_get_all_token_identifiers_result.php | 18 +-
...veMetastore_get_all_write_event_info_result.php | 20 +-
.../ThriftHiveMetastore_get_databases_result.php | 18 +-
...riftHiveMetastore_get_dataconnectors_result.php | 18 +-
.../ThriftHiveMetastore_get_fields_result.php | 20 +-
..._get_fields_with_environment_context_result.php | 20 +-
.../ThriftHiveMetastore_get_functions_result.php | 18 +-
.../ThriftHiveMetastore_get_master_keys_result.php | 18 +-
...get_materialized_views_for_rewriting_result.php | 18 +-
...veMetastore_get_part_specs_by_filter_result.php | 20 +-
.../ThriftHiveMetastore_get_partition_args.php | 18 +-
...ftHiveMetastore_get_partition_names_ps_args.php | 18 +-
...HiveMetastore_get_partition_names_ps_result.php | 18 +-
...iveMetastore_get_partition_names_req_result.php | 18 +-
...iftHiveMetastore_get_partition_names_result.php | 18 +-
...tHiveMetastore_get_partition_with_auth_args.php | 36 +-
...tastore_get_partitions_by_filter_req_result.php | 20 +-
...veMetastore_get_partitions_by_filter_result.php | 20 +-
...tHiveMetastore_get_partitions_by_names_args.php | 18 +-
...iveMetastore_get_partitions_by_names_result.php | 20 +-
.../ThriftHiveMetastore_get_partitions_ps_args.php | 18 +-
...hriftHiveMetastore_get_partitions_ps_result.php | 20 +-
...eMetastore_get_partitions_ps_with_auth_args.php | 36 +-
...etastore_get_partitions_ps_with_auth_result.php | 20 +-
...ftHiveMetastore_get_partitions_pspec_result.php | 20 +-
.../ThriftHiveMetastore_get_partitions_result.php | 20 +-
...HiveMetastore_get_partitions_with_auth_args.php | 18 +-
...veMetastore_get_partitions_with_auth_result.php | 20 +-
.../ThriftHiveMetastore_get_privilege_set_args.php | 18 +-
.../ThriftHiveMetastore_get_role_names_result.php | 18 +-
...hriftHiveMetastore_get_runtime_stats_result.php | 20 +-
...iveMetastore_get_schema_all_versions_result.php | 20 +-
.../ThriftHiveMetastore_get_schema_result.php | 20 +-
..._get_schema_with_environment_context_result.php | 20 +-
.../ThriftHiveMetastore_get_table_meta_args.php | 18 +-
.../ThriftHiveMetastore_get_table_meta_result.php | 20 +-
...eMetastore_get_table_names_by_filter_result.php | 18 +-
...iveMetastore_get_table_objects_by_name_args.php | 18 +-
...eMetastore_get_table_objects_by_name_result.php | 20 +-
...riftHiveMetastore_get_tables_by_type_result.php | 18 +-
.../ThriftHiveMetastore_get_tables_ext_result.php | 20 +-
.../ThriftHiveMetastore_get_tables_result.php | 18 +-
.../ThriftHiveMetastore_get_type_all_result.php | 28 +-
...iveMetastore_isPartitionMarkedForEvent_args.php | 26 +-
.../ThriftHiveMetastore_list_privileges_result.php | 20 +-
.../ThriftHiveMetastore_list_roles_result.php | 20 +-
...iftHiveMetastore_markPartitionForEvent_args.php | 26 +-
...re_partition_name_has_valid_characters_args.php | 18 +-
...HiveMetastore_partition_name_to_spec_result.php | 26 +-
...HiveMetastore_partition_name_to_vals_result.php | 18 +-
.../ThriftHiveMetastore_rename_partition_args.php | 18 +-
.../metastore/ThriftHiveMetastore_set_ugi_args.php | 18 +-
.../ThriftHiveMetastore_set_ugi_result.php | 18 +-
.../ThriftHiveMetastore_truncate_table_args.php | 18 +-
.../gen-py/hive_metastore/ThriftHiveMetastore.py | 1056 +--
.../src/gen/thrift/gen-py/hive_metastore/ttypes.py | 70 +-
.../src/gen/thrift/gen-rb/hive_metastore_types.rb | 4 +-
.../hadoop/hive/metastore/conf/MetastoreConf.java | 5 +-
.../hadoop/hive/metastore/txn/TxnQueries.java | 88 -
.../src/main/thrift/hive_metastore.thrift | 3 +-
.../apache/hadoop/hive/metastore/Batchable.java | 30 +-
.../hadoop/hive/metastore/DatabaseProduct.java | 41 +-
.../hadoop/hive/metastore/DirectSqlInsertPart.java | 8 +-
.../hadoop/hive/metastore/DirectSqlUpdatePart.java | 1536 +++++
.../hadoop/hive/metastore/DirectSqlUpdateStat.java | 727 ---
.../apache/hadoop/hive/metastore/HMSHandler.java | 112 +-
.../hadoop/hive/metastore/MetaStoreDirectSql.java | 130 +-
.../apache/hadoop/hive/metastore/ObjectStore.java | 166 +-
.../hadoop/hive/metastore/PartitionIterable.java | 3 +
.../metastore/events/CommitCompactionEvent.java | 3 +-
.../hive/metastore/metrics/AcidMetricLogger.java | 10 +-
.../hive/metastore/metrics/AcidMetricService.java | 10 +-
.../txn/CompactionMetricsDataConverter.java | 1 +
.../hive/metastore/txn/CompactionTxnHandler.java | 139 +-
.../hive/metastore/txn/DefaultTxnLockManager.java | 126 +
...xnHandler.java => TransactionalRetryProxy.java} | 91 +-
.../hadoop/hive/metastore/txn/TxnHandler.java | 6704 ++------------------
.../hadoop/hive/metastore/txn/TxnLockManager.java | 85 +
.../apache/hadoop/hive/metastore/txn/TxnStore.java | 116 +-
.../hadoop/hive/metastore/txn/TxnStoreMutex.java | 209 +
.../apache/hadoop/hive/metastore/txn/TxnUtils.java | 128 +-
.../txn/{ => entities}/CompactionInfo.java | 5 +-
.../txn/{ => entities}/CompactionMetricsData.java | 2 +-
.../txn/{ => entities}/CompactionState.java | 22 +-
.../hive/metastore/txn/entities/LockInfo.java | 147 +
.../metastore/txn/{ => entities}/MetricsInfo.java | 2 +-
.../hive/metastore/txn/{ => entities}/OpenTxn.java | 8 +-
.../metastore/txn/{ => entities}/OpenTxnList.java | 11 +-
.../txn/{ => entities}/OperationType.java | 2 +-
.../metastore/txn/{ => entities}/TxnStatus.java | 2 +-
.../metastore/txn/jdbc/ConditionalCommand.java | 43 +
.../metastore/txn/jdbc/InClauseBatchCommand.java | 75 +
.../txn/jdbc/MultiDataSourceJdbcResource.java | 180 +-
.../metastore/txn/jdbc/NoPoolConnectionPool.java | 145 +
.../txn/jdbc/ParameterizedBatchCommand.java | 61 +
.../RollbackException.java} | 34 +-
.../metastore/txn/jdbc/TransactionContext.java | 54 +-
.../txn/jdbc/TransactionContextManager.java | 58 +-
.../metastore/txn/jdbc/TransactionalFunction.java | 8 +-
.../commands/AddWriteIdsToMinHistoryCommand.java | 87 +
.../commands/AddWriteIdsToTxnToWriteIdCommand.java | 67 +
.../commands/DeleteInvalidOpenTxnsCommand.java | 17 +-
.../commands/DeleteReplTxnMapEntryCommand.java} | 35 +-
.../commands}/InsertCompactionInfoCommand.java | 6 +-
.../commands/InsertCompactionRequestCommand.java | 93 +
.../InsertCompletedTxnComponentsCommand.java | 70 +
.../txn/jdbc/commands/InsertHiveLocksCommand.java | 97 +
.../jdbc/commands/InsertTxnComponentsCommand.java | 185 +
.../RemoveCompactionMetricsDataCommand.java | 4 +-
...emoveDuplicateCompleteTxnComponentsCommand.java | 2 +-
.../RemoveTxnsFromMinHistoryLevelCommand.java | 47 +
.../RemoveWriteIdsFromMinHistoryCommand.java | 49 +
.../jdbc/functions/AbortCompactionFunction.java | 188 +
.../txn/jdbc/functions/AbortTxnFunction.java | 105 +
.../txn/jdbc/functions/AbortTxnsFunction.java | 209 +
.../txn/jdbc/functions/AcquireTxnLockFunction.java | 49 +
.../functions/AllocateTableWriteIdsFunction.java | 348 +
.../txn/jdbc/functions/CheckLockFunction.java | 342 +
.../functions}/CleanTxnToWriteIdTableFunction.java | 13 +-
.../txn/jdbc/functions/CleanupRecordsFunction.java | 186 +
.../txn/jdbc/functions/CommitTxnFunction.java | 636 ++
.../txn/jdbc/functions/CompactFunction.java | 123 +
.../txn/jdbc/functions/EnqueueLockFunction.java | 118 +
.../txn/jdbc/functions/EnsureValidTxnFunction.java | 70 +
.../FindPotentialCompactionsFunction.java | 8 +-
.../GenerateCompactionQueueIdFunction.java | 65 +
...GetMaterializationInvalidationInfoFunction.java | 180 +
.../GetValidWriteIdsForTableFunction.java | 155 +
.../jdbc/functions/GetValidWriteIdsFunction.java | 103 +
.../txn/jdbc/functions/HeartbeatLockFunction.java | 61 +
.../txn/jdbc/functions/HeartbeatTxnFunction.java | 73 +
.../jdbc/functions/HeartbeatTxnRangeFunction.java | 104 +
.../LockMaterializationRebuildFunction.java | 92 +
.../functions}/MarkCleanedFunction.java | 34 +-
.../functions/MinOpenTxnIdWaterMarkFunction.java | 67 +
.../functions}/NextCompactionFunction.java | 4 +-
.../txn/jdbc/functions/OnRenameFunction.java | 159 +
.../txn/jdbc/functions/OpenTxnsFunction.java | 233 +
.../jdbc/functions/PerformTimeoutsFunction.java | 203 +
.../functions}/PurgeCompactionHistoryFunction.java | 25 +-
.../ReleaseMaterializationRebuildLocks.java | 78 +
.../functions/ReplTableWriteIdStateFunction.java | 158 +
.../TopCompactionMetricsDataPerTypeFunction.java | 11 +-
.../jdbc/functions/UpdataDatabasePropFunction.java | 72 +
.../UpdateCompactionMetricsDataFunction.java | 6 +-
.../queries/AbortTxnInfoHandler.java} | 16 +-
.../{impl => jdbc/queries}/AbortedTxnHandler.java | 6 +-
.../queries}/CheckFailedCompactionsHandler.java | 4 +-
.../queries}/CompactionCandidateHandler.java | 4 +-
.../queries}/CompactionMetricsDataHandler.java | 4 +-
.../txn/jdbc/queries/CountOpenTxnsHandler.java | 63 +
.../metastore/txn/jdbc/queries/DbTimeHandler.java | 51 +
.../queries}/FindColumnsWithStatsHandler.java | 4 +-
.../txn/jdbc/queries/FindTxnStateHandler.java | 63 +
.../queries}/GetCompactionInfoHandler.java | 8 +-
.../txn/jdbc/queries/GetDatabaseIdHandler.java | 59 +
.../txn/jdbc/queries/GetHighWaterMarkHandler.java | 55 +
.../GetLatestCommittedCompactionInfoHandler.java | 100 +
.../txn/jdbc/queries/GetLocksByLockId.java | 81 +
.../GetMaxAllocatedTableWriteIdHandler.java | 61 +
.../jdbc/queries/GetOpenTxnTypeAndLockHandler.java | 71 +
.../txn/jdbc/queries/GetOpenTxnsListHandler.java | 126 +
.../queries/GetTxnDbsUpdatedHandler.java} | 51 +-
.../txn/jdbc/queries/GetWriteIdsHandler.java | 81 +
.../jdbc/queries/LatestTxnIdInConflictHandler.java | 79 +
.../txn/jdbc/queries/MetricsInfoHandler.java | 93 +
.../queries}/MinUncommittedTxnIdHandler.java | 4 +-
.../OpenTxnTimeoutLowBoundaryTxnIdHandler.java | 64 +
.../queries}/ReadyToCleanAbortHandler.java | 6 +-
.../queries}/ReadyToCleanHandler.java | 15 +-
.../txn/jdbc/queries/ShowCompactHandler.java | 185 +
.../txn/jdbc/queries/ShowLocksHandler.java | 179 +
.../queries/TablesWithAbortedTxnsHandler.java} | 58 +-
.../queries/TargetTxnIdListHandler.java} | 57 +-
.../queries/TxnIdForWriteIdHandler.java} | 55 +-
.../{retryhandling => retry}/RetryPropagation.java | 2 +-
.../txn/{retryhandling => retry}/SqlRetry.java | 2 +-
.../SqlRetryCallProperties.java | 2 +-
.../SqlRetryException.java} | 30 +-
.../{retryhandling => retry}/SqlRetryFunction.java | 5 +-
.../{retryhandling => retry}/SqlRetryHandler.java | 36 +-
.../StackThreadLocal.java} | 53 +-
...upgrade-4.0.0-alpha-2-to-4.0.0-beta-1.derby.sql | 16 +-
...upgrade-4.0.0-alpha-2-to-4.0.0-beta-1.mssql.sql | 16 +-
.../sql/mysql/hive-schema-4.0.0-alpha-2.mysql.sql | 2 +-
.../sql/mysql/hive-schema-4.0.0-beta-1.mysql.sql | 2 +-
...pgrade-4.0.0-alpha-1-to-4.0.0-alpha-2.mysql.sql | 4 +-
...upgrade-4.0.0-alpha-2-to-4.0.0-beta-1.mysql.sql | 16 +-
...pgrade-4.0.0-alpha-2-to-4.0.0-beta-1.oracle.sql | 16 +-
...rade-4.0.0-alpha-2-to-4.0.0-beta-1.postgres.sql | 16 +-
.../hadoop/hive/metastore/DummyCustomRDBMS.java | 2 +-
.../hadoop/hive/metastore/TestObjectStore.java | 2 +-
.../metastore/txn/retry/TestSqlRetryHandler.java | 43 +
.../hadoop/hive/metastore/tools/BenchmarkTool.java | 3 +
.../hadoop/hive/metastore/tools/HMSBenchmarks.java | 30 +
.../org/apache/hive/streaming/TestStreaming.java | 13 +-
455 files changed, 25311 insertions(+), 14409 deletions(-)
create mode 100644 data/files/datasets/temp_udf/load.hive.sql
create mode 100644
iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/IcebergTransformSortFunctionUtil.java
create mode 100644
iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/compaction/IcebergCompactionService.java
create mode 100644
iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/compaction/IcebergMajorQueryCompactor.java
copy iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/{ =>
udf}/GenericUDFIcebergBucket.java (99%)
create mode 100644
iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/udf/GenericUDFIcebergDay.java
create mode 100644
iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/udf/GenericUDFIcebergHour.java
create mode 100644
iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/udf/GenericUDFIcebergMonth.java
rename
iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/{GenericUDFIcebergBucket.java
=> udf/GenericUDFIcebergTruncate.java} (59%)
create mode 100644
iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/udf/GenericUDFIcebergYear.java
create mode 100644
iceberg/iceberg-handler/src/test/queries/positive/iceberg_major_compaction_partition_evolution.q
create mode 100644
iceberg/iceberg-handler/src/test/queries/positive/iceberg_major_compaction_partitioned.q
create mode 100644
iceberg/iceberg-handler/src/test/queries/positive/iceberg_major_compaction_schema_evolution.q
create mode 100644
iceberg/iceberg-handler/src/test/queries/positive/iceberg_major_compaction_unpartitioned.q
create mode 100644
iceberg/iceberg-handler/src/test/results/positive/llap/iceberg_major_compaction_partition_evolution.q.out
create mode 100644
iceberg/iceberg-handler/src/test/results/positive/llap/iceberg_major_compaction_partitioned.q.out
create mode 100644
iceberg/iceberg-handler/src/test/results/positive/llap/iceberg_major_compaction_schema_evolution.q.out
create mode 100644
iceberg/iceberg-handler/src/test/results/positive/llap/iceberg_major_compaction_unpartitioned.q.out
create mode 100644
itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/parse/TestTimedOutTxnNotificationLogging.java
create mode 100644
itests/qtest-iceberg/src/test/java/org/apache/hadoop/hive/cli/TestIcebergLlapLocalCompactorCliDriver.java
create mode 100644
ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/rules/views/InputRefShifter.java
copy
ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/{RemoteCompactorThread.java
=> RemoteCompactorUtil.java} (50%)
create mode 100644
ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/service/AcidCompactionService.java
create mode 100644
ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/service/CompactionExecutorFactory.java
create mode 100644
ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/service/CompactionService.java
copy ql/src/java/org/apache/hadoop/hive/ql/udf/generic/{GenericUDFOPTrue.java
=> GenericUDFToArray.java} (51%)
copy ql/src/java/org/apache/hadoop/hive/ql/udf/generic/{GenericUDFOPTrue.java
=> GenericUDFToMap.java} (51%)
copy ql/src/java/org/apache/hadoop/hive/ql/udf/generic/{GenericUDFOPTrue.java
=> GenericUDFToStruct.java} (51%)
create mode 100644
ql/src/test/org/apache/hadoop/hive/ql/exec/TestGetPartitionAuthWithBatches.java
create mode 100644
ql/src/test/org/apache/hadoop/hive/ql/parse/type/TestExprNodeDescExprFactory.java
create mode 100644
ql/src/test/queries/clientnegative/avro_duplicate_field_name.q
create mode 100644 ql/src/test/queries/clientnegative/avro_invalid_field_name.q
delete mode 100644 ql/src/test/queries/clientnegative/compute_stats_long.q
create mode 100644
ql/src/test/queries/clientnegative/udf_enforce_constraint_wrong_type1.q
create mode 100644
ql/src/test/queries/clientnegative/udf_exception_in_vertex_udf_wrong_type1.q
create mode 100644
ql/src/test/queries/clientnegative/udf_exception_in_vertex_udf_wrong_type2.q
create mode 100644
ql/src/test/queries/clientnegative/udf_exception_in_vertex_udf_wrong_type3.q
create mode 100644
ql/src/test/queries/clientnegative/udf_exception_in_vertex_udf_wrong_type4.q
create mode 100644 ql/src/test/queries/clientnegative/udf_greatest_error_3.q
create mode 100644
ql/src/test/queries/clientnegative/udf_grouping_wrong_type1.q
create mode 100644 ql/src/test/queries/clientnegative/udf_isfalse_wrong_type1.q
create mode 100644
ql/src/test/queries/clientnegative/udf_isnotfalse_wrong_type1.q
create mode 100644
ql/src/test/queries/clientnegative/udf_isnottrue_wrong_type1.q
create mode 100644 ql/src/test/queries/clientnegative/udf_istrue_wrong_type1.q
create mode 100644 ql/src/test/queries/clientnegative/udf_split_wrong_type1.q
create mode 100644 ql/src/test/queries/clientnegative/udf_split_wrong_type2.q
create mode 100644
ql/src/test/queries/clientnegative/udf_sq_count_check_wrong_type1.q
create mode 100644
ql/src/test/queries/clientnegative/udf_to_epoch_milli_wrong_type1.q
create mode 100644 ql/src/test/queries/clientnegative/udf_trunc_wrong_type1.q
create mode 100644 ql/src/test/queries/clientnegative/udf_trunc_wrong_type2.q
create mode 100644
ql/src/test/queries/clientnegative/udf_tumbling_window_check_wrong_type1.q
create mode 100644
ql/src/test/queries/clientnegative/udf_tumbling_window_check_wrong_type2.q
create mode 100644 ql/src/test/queries/clientpositive/cast_null_to_complex.q
create mode 100644 ql/src/test/queries/clientpositive/cbo_constantfolding.q
create mode 100644 ql/src/test/queries/clientpositive/complex_datatype.q
delete mode 100644 ql/src/test/queries/clientpositive/compute_stats_binary.q
delete mode 100644 ql/src/test/queries/clientpositive/compute_stats_boolean.q
delete mode 100644 ql/src/test/queries/clientpositive/compute_stats_date.q
delete mode 100644 ql/src/test/queries/clientpositive/compute_stats_decimal.q
delete mode 100644 ql/src/test/queries/clientpositive/compute_stats_double.q
delete mode 100644
ql/src/test/queries/clientpositive/compute_stats_empty_table.q
delete mode 100644 ql/src/test/queries/clientpositive/compute_stats_long.q
delete mode 100644 ql/src/test/queries/clientpositive/compute_stats_string.q
create mode 100644 ql/src/test/queries/clientpositive/groupby_sort_2_23.q
create mode 100644
ql/src/test/queries/clientpositive/insert_and_load_overwrite_drop_partition.q
create mode 100644 ql/src/test/queries/clientpositive/mapjoin_date.q
create mode 100644
ql/src/test/queries/clientpositive/materialized_view_join_rebuild.q
create mode 100644
ql/src/test/queries/clientpositive/materialized_view_repeated_rebuild.q
create mode 100644 ql/src/test/queries/clientpositive/tez_dynpart_hashjoin_4.q
create mode 100644
ql/src/test/results/clientnegative/avro_duplicate_field_name.q.out
create mode 100644
ql/src/test/results/clientnegative/avro_invalid_field_name.q.out
delete mode 100644 ql/src/test/results/clientnegative/compute_stats_long.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_enforce_constraint_wrong_type1.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_exception_in_vertex_udf_wrong_type1.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_exception_in_vertex_udf_wrong_type2.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_exception_in_vertex_udf_wrong_type3.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_exception_in_vertex_udf_wrong_type4.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_greatest_error_3.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_grouping_wrong_type1.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_isfalse_wrong_type1.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_isnotfalse_wrong_type1.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_isnottrue_wrong_type1.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_istrue_wrong_type1.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_split_wrong_type1.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_split_wrong_type2.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_sq_count_check_wrong_type1.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_to_epoch_milli_wrong_type1.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_trunc_wrong_type1.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_trunc_wrong_type2.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_tumbling_window_check_wrong_type1.q.out
create mode 100644
ql/src/test/results/clientnegative/udf_tumbling_window_check_wrong_type2.q.out
create mode 100644
ql/src/test/results/clientpositive/llap/cast_null_to_complex.q.out
create mode 100644
ql/src/test/results/clientpositive/llap/cbo_constantfolding.q.out
create mode 100644
ql/src/test/results/clientpositive/llap/complex_datatype.q.out
delete mode 100644
ql/src/test/results/clientpositive/llap/compute_stats_binary.q.out
delete mode 100644
ql/src/test/results/clientpositive/llap/compute_stats_boolean.q.out
delete mode 100644
ql/src/test/results/clientpositive/llap/compute_stats_date.q.out
delete mode 100644
ql/src/test/results/clientpositive/llap/compute_stats_decimal.q.out
delete mode 100644
ql/src/test/results/clientpositive/llap/compute_stats_double.q.out
delete mode 100644
ql/src/test/results/clientpositive/llap/compute_stats_empty_table.q.out
delete mode 100644
ql/src/test/results/clientpositive/llap/compute_stats_long.q.out
delete mode 100644
ql/src/test/results/clientpositive/llap/compute_stats_string.q.out
create mode 100644
ql/src/test/results/clientpositive/llap/groupby_sort_2_23.q.out
create mode 100644
ql/src/test/results/clientpositive/llap/insert_and_load_overwrite_drop_partition.q.out
create mode 100644 ql/src/test/results/clientpositive/llap/mapjoin_date.q.out
create mode 100644
ql/src/test/results/clientpositive/llap/materialized_view_join_rebuild.q.out
create mode 100644
ql/src/test/results/clientpositive/llap/materialized_view_repeated_rebuild.q.out
create mode 100644
ql/src/test/results/clientpositive/llap/tez_dynpart_hashjoin_4.q.out
delete mode 100644
standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnQueries.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/DirectSqlUpdatePart.java
delete mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/DirectSqlUpdateStat.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/DefaultTxnLockManager.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{ProxyTxnHandler.java
=> TransactionalRetryProxy.java} (61%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnLockManager.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnStoreMutex.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{
=> entities}/CompactionInfo.java (98%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{
=> entities}/CompactionMetricsData.java (98%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{
=> entities}/CompactionState.java (81%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/entities/LockInfo.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{
=> entities}/MetricsInfo.java (98%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{
=> entities}/OpenTxn.java (84%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{
=> entities}/OpenTxnList.java (89%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{
=> entities}/OperationType.java (97%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{
=> entities}/TxnStatus.java (97%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/ConditionalCommand.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/InClauseBatchCommand.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/NoPoolConnectionPool.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/ParameterizedBatchCommand.java
copy
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{ContextNode.java
=> jdbc/RollbackException.java} (54%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/commands/AddWriteIdsToMinHistoryCommand.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/commands/AddWriteIdsToTxnToWriteIdCommand.java
copy
ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/reloperators/HiveDateAddSqlOperator.java
=>
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/commands/DeleteInvalidOpenTxnsCommand.java
(60%)
copy
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl/RemoveCompactionMetricsDataCommand.java
=> jdbc/commands/DeleteReplTxnMapEntryCommand.java} (56%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/commands}/InsertCompactionInfoCommand.java (96%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/commands/InsertCompactionRequestCommand.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/commands/InsertCompletedTxnComponentsCommand.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/commands/InsertHiveLocksCommand.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/commands/InsertTxnComponentsCommand.java
copy
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/commands}/RemoveCompactionMetricsDataCommand.java (94%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/commands}/RemoveDuplicateCompleteTxnComponentsCommand.java (98%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/commands/RemoveTxnsFromMinHistoryLevelCommand.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/commands/RemoveWriteIdsFromMinHistoryCommand.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/AbortCompactionFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/AbortTxnFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/AbortTxnsFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/AcquireTxnLockFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/AllocateTableWriteIdsFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/CheckLockFunction.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/functions}/CleanTxnToWriteIdTableFunction.java (90%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/CleanupRecordsFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/CommitTxnFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/CompactFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/EnqueueLockFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/EnsureValidTxnFunction.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/functions}/FindPotentialCompactionsFunction.java (87%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/GenerateCompactionQueueIdFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/GetMaterializationInvalidationInfoFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/GetValidWriteIdsForTableFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/GetValidWriteIdsFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/HeartbeatLockFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/HeartbeatTxnFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/HeartbeatTxnRangeFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/LockMaterializationRebuildFunction.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/functions}/MarkCleanedFunction.java (90%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/MinOpenTxnIdWaterMarkFunction.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/functions}/NextCompactionFunction.java (97%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/OnRenameFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/OpenTxnsFunction.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/PerformTimeoutsFunction.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/functions}/PurgeCompactionHistoryFunction.java (93%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/ReleaseMaterializationRebuildLocks.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/ReplTableWriteIdStateFunction.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/functions}/TopCompactionMetricsDataPerTypeFunction.java (87%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/functions/UpdataDatabasePropFunction.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/functions}/UpdateCompactionMetricsDataFunction.java (92%)
copy
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl/ReadyToCleanAbortHandler.java
=> jdbc/queries/AbortTxnInfoHandler.java} (91%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/queries}/AbortedTxnHandler.java (94%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/queries}/CheckFailedCompactionsHandler.java (96%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/queries}/CompactionCandidateHandler.java (96%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/queries}/CompactionMetricsDataHandler.java (95%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/CountOpenTxnsHandler.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/DbTimeHandler.java
copy
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/queries}/FindColumnsWithStatsHandler.java (95%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/FindTxnStateHandler.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/queries}/GetCompactionInfoHandler.java (96%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/GetDatabaseIdHandler.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/GetHighWaterMarkHandler.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/GetLatestCommittedCompactionInfoHandler.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/GetLocksByLockId.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/GetMaxAllocatedTableWriteIdHandler.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/GetOpenTxnTypeAndLockHandler.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/GetOpenTxnsListHandler.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl/FindColumnsWithStatsHandler.java
=> jdbc/queries/GetTxnDbsUpdatedHandler.java} (50%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/GetWriteIdsHandler.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/LatestTxnIdInConflictHandler.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/MetricsInfoHandler.java
copy
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/queries}/MinUncommittedTxnIdHandler.java (96%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/OpenTxnTimeoutLowBoundaryTxnIdHandler.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/queries}/ReadyToCleanAbortHandler.java (97%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl
=> jdbc/queries}/ReadyToCleanHandler.java (92%)
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/ShowCompactHandler.java
create mode 100644
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/ShowLocksHandler.java
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl/MinUncommittedTxnIdHandler.java
=> jdbc/queries/TablesWithAbortedTxnsHandler.java} (50%)
copy
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl/RemoveCompactionMetricsDataCommand.java
=> jdbc/queries/TargetTxnIdListHandler.java} (50%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{impl/RemoveCompactionMetricsDataCommand.java
=> jdbc/queries/TxnIdForWriteIdHandler.java} (52%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{retryhandling
=> retry}/RetryPropagation.java (97%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{retryhandling
=> retry}/SqlRetry.java (96%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{retryhandling
=> retry}/SqlRetryCallProperties.java (98%)
copy
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{ContextNode.java
=> retry/SqlRetryException.java} (58%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{retryhandling
=> retry}/SqlRetryFunction.java (89%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/{retryhandling
=> retry}/SqlRetryHandler.java (91%)
rename
standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/{txn/ContextNode.java
=> utils/StackThreadLocal.java} (50%)
create mode 100644
standalone-metastore/metastore-server/src/test/java/org/apache/hadoop/hive/metastore/txn/retry/TestSqlRetryHandler.java
