This is an automated email from the ASF dual-hosted git repository. tchoi pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/hive.git
from 8ff73bb6e0e HIVE-29038: Make catalog servlet parameters generic (#5893) add 90b48ff2fe6 HIVE-28975: [HiveAcidReplication] Remove dangling txns from Target side post incremental replication (#5874) No new revisions were added by this update. Summary of changes: .../java/org/apache/hadoop/hive/conf/HiveConf.java | 2 + .../hive/ql/parse/TestReplicationScenarios.java | 22 +- .../parse/TestReplicationScenariosAcidTables.java | 206 + .../TestReplicationScenariosAcrossInstances.java | 2 +- .../TestReplicationScenariosExclusiveReplica.java | 2 + ql/if/queryplan.thrift | 3 +- ql/src/gen/thrift/gen-cpp/queryplan_types.cpp | 8 +- ql/src/gen/thrift/gen-cpp/queryplan_types.h | 3 +- .../apache/hadoop/hive/ql/plan/api/StageType.java | 5 +- ql/src/gen/thrift/gen-php/StageType.php | 3 + ql/src/gen/thrift/gen-py/queryplan/ttypes.py | 3 + ql/src/gen/thrift/gen-rb/queryplan_types.rb | 5 +- .../apache/hadoop/hive/ql/exec/TaskFactory.java | 4 + .../hive/ql/exec/repl/ClearDanglingTxnTask.java | 130 + .../repl/ClearDanglingTxnWork.java} | 39 +- .../hadoop/hive/ql/exec/repl/ReplDumpTask.java | 16 + .../hadoop/hive/ql/exec/repl/ReplLoadTask.java | 12 + .../hadoop/hive/ql/exec/repl/util/ReplUtils.java | 3 + .../hadoop/hive/ql/lockmgr/DbTxnManager.java | 9 + .../hadoop/hive/ql/lockmgr/DummyTxnManager.java | 6 + .../hadoop/hive/ql/lockmgr/HiveTxnManager.java | 3 + .../org/apache/hadoop/hive/ql/parse/EximUtil.java | 28 + .../src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp | 2947 +++-- .../src/gen/thrift/gen-cpp/ThriftHiveMetastore.h | 135 + .../ThriftHiveMetastore_server.skeleton.cpp | 5 + .../gen/thrift/gen-cpp/hive_metastore_types.cpp | 12298 ++++++++++--------- .../src/gen/thrift/gen-cpp/hive_metastore_types.h | 44 + .../hive/metastore/api/AbortCompactResponse.java | 48 +- .../hive/metastore/api/AbortCompactionRequest.java | 32 +- .../hive/metastore/api/AbortTxnsRequest.java | 32 +- .../metastore/api/AddCheckConstraintRequest.java | 36 +- .../metastore/api/AddDefaultConstraintRequest.java | 36 +- .../hive/metastore/api/AddDynamicPartitions.java | 32 +- .../hive/metastore/api/AddForeignKeyRequest.java | 36 +- .../metastore/api/AddNotNullConstraintRequest.java | 36 +- .../hive/metastore/api/AddPartitionsRequest.java | 72 +- .../hive/metastore/api/AddPartitionsResult.java | 72 +- .../hive/metastore/api/AddPrimaryKeyRequest.java | 36 +- .../metastore/api/AddUniqueConstraintRequest.java | 36 +- .../hadoop/hive/metastore/api/AggrStats.java | 36 +- .../api/AllocateTableWriteIdsRequest.java | 68 +- .../api/AllocateTableWriteIdsResponse.java | 36 +- .../hive/metastore/api/AlterPartitionsRequest.java | 72 +- .../hive/metastore/api/AlterTableRequest.java | 32 +- .../metastore/api/AppendPartitionsRequest.java | 32 +- .../metastore/api/CheckConstraintsResponse.java | 36 +- .../metastore/api/ClearFileMetadataRequest.java | 32 +- .../hive/metastore/api/ClientCapabilities.java | 36 +- .../hive/metastore/api/ColumnStatistics.java | 36 +- .../hive/metastore/api/CommitTxnRequest.java | 36 +- .../hive/metastore/api/CompactionRequest.java | 44 +- .../hive/metastore/api/CreateDatabaseRequest.java | 44 +- .../hive/metastore/api/CreateTableRequest.java | 248 +- .../hive/metastore/api/CreationMetadata.java | 68 +- .../hadoop/hive/metastore/api/DataConnector.java | 44 +- .../apache/hadoop/hive/metastore/api/Database.java | 44 +- .../metastore/api/DefaultConstraintsResponse.java | 36 +- .../api/DeleteColumnStatisticsRequest.java | 64 +- .../hive/metastore/api/DropPartitionRequest.java | 32 +- .../hive/metastore/api/DropPartitionsResult.java | 36 +- .../hive/metastore/api/ExtendedTableInfo.java | 64 +- .../hadoop/hive/metastore/api/FileMetadata.java | 32 +- .../hive/metastore/api/FindSchemasByColsResp.java | 36 +- .../hive/metastore/api/FireEventRequest.java | 76 +- .../hive/metastore/api/FireEventRequestData.java | 36 +- .../hive/metastore/api/FireEventResponse.java | 32 +- .../hive/metastore/api/ForeignKeysResponse.java | 36 +- .../apache/hadoop/hive/metastore/api/Function.java | 36 +- .../metastore/api/GetAllFunctionsResponse.java | 36 +- .../hive/metastore/api/GetCatalogsResponse.java | 32 +- .../metastore/api/GetDatabaseObjectsResponse.java | 36 +- .../hive/metastore/api/GetDatabaseRequest.java | 32 +- .../hive/metastore/api/GetFieldsResponse.java | 36 +- .../api/GetFileMetadataByExprRequest.java | 32 +- .../metastore/api/GetFileMetadataByExprResult.java | 48 +- .../hive/metastore/api/GetFileMetadataRequest.java | 32 +- .../hive/metastore/api/GetFileMetadataResult.java | 44 +- .../hive/metastore/api/GetFunctionsResponse.java | 68 +- .../GetLatestCommittedCompactionInfoRequest.java | 32 +- .../GetLatestCommittedCompactionInfoResponse.java | 36 +- .../metastore/api/GetOpenTxnsInfoResponse.java | 36 +- .../hive/metastore/api/GetOpenTxnsRequest.java | 36 +- .../hive/metastore/api/GetOpenTxnsResponse.java | 32 +- .../metastore/api/GetPartitionNamesPsRequest.java | 32 +- .../metastore/api/GetPartitionNamesPsResponse.java | 32 +- .../hive/metastore/api/GetPartitionRequest.java | 32 +- .../metastore/api/GetPartitionsByNamesRequest.java | 64 +- .../metastore/api/GetPartitionsByNamesResult.java | 36 +- .../metastore/api/GetPartitionsFilterSpec.java | 32 +- .../api/GetPartitionsPsWithAuthRequest.java | 96 +- .../api/GetPartitionsPsWithAuthResponse.java | 36 +- .../hive/metastore/api/GetPartitionsRequest.java | 64 +- .../hive/metastore/api/GetPartitionsResponse.java | 36 +- .../metastore/api/GetPrincipalsInRoleResponse.java | 36 +- .../hive/metastore/api/GetProjectionsSpec.java | 32 +- .../api/GetRoleGrantsForPrincipalResponse.java | 36 +- .../hive/metastore/api/GetSchemaResponse.java | 36 +- .../hadoop/hive/metastore/api/GetTableRequest.java | 32 +- .../hive/metastore/api/GetTablesExtRequest.java | 32 +- .../hive/metastore/api/GetTablesRequest.java | 64 +- .../hadoop/hive/metastore/api/GetTablesResult.java | 36 +- .../metastore/api/GetValidWriteIdsRequest.java | 32 +- .../metastore/api/GetValidWriteIdsResponse.java | 36 +- .../metastore/api/HeartbeatTxnRangeResponse.java | 64 +- .../hadoop/hive/metastore/api/HiveObjectRef.java | 32 +- .../hive/metastore/api/InsertEventRequestData.java | 128 +- .../hadoop/hive/metastore/api/LockRequest.java | 36 +- .../metastore/api/NotNullConstraintsResponse.java | 36 +- .../metastore/api/NotificationEventRequest.java | 96 +- .../metastore/api/NotificationEventResponse.java | 36 +- .../api/NotificationEventsCountRequest.java | 32 +- .../hive/metastore/api/ObjectDictionary.java | 72 +- .../hadoop/hive/metastore/api/OpenTxnRequest.java | 32 +- .../hive/metastore/api/OpenTxnsResponse.java | 32 +- .../hadoop/hive/metastore/api/Partition.java | 76 +- .../metastore/api/PartitionListComposingSpec.java | 36 +- .../metastore/api/PartitionSpecWithSharedSD.java | 36 +- .../hive/metastore/api/PartitionValuesRequest.java | 72 +- .../metastore/api/PartitionValuesResponse.java | 36 +- .../hive/metastore/api/PartitionValuesRow.java | 32 +- .../hive/metastore/api/PartitionWithoutSD.java | 76 +- .../hive/metastore/api/PartitionsByExprResult.java | 36 +- .../hive/metastore/api/PartitionsResponse.java | 36 +- .../metastore/api/PartitionsSpecByExprResult.java | 36 +- .../hive/metastore/api/PartitionsStatsRequest.java | 64 +- .../hive/metastore/api/PartitionsStatsResult.java | 76 +- .../hive/metastore/api/PrimaryKeysResponse.java | 36 +- .../hive/metastore/api/PrincipalPrivilegeSet.java | 228 +- .../hadoop/hive/metastore/api/PrivilegeBag.java | 36 +- .../hive/metastore/api/PropertyGetRequest.java | 32 +- .../hive/metastore/api/PropertyGetResponse.java | 84 +- .../hive/metastore/api/PropertySetRequest.java | 44 +- .../hive/metastore/api/PutFileMetadataRequest.java | 64 +- .../hive/metastore/api/RenamePartitionRequest.java | 32 +- .../hadoop/hive/metastore/api/ReplLastIdInfo.java | 32 +- .../metastore/api/ReplTblWriteIdStateRequest.java | 32 +- ...ntext.java => ReplayedTxnsForPolicyResult.java} | 216 +- .../hive/metastore/api/ReplicationMetricList.java | 36 +- .../hive/metastore/api/RequestPartsSpec.java | 68 +- .../hive/metastore/api/SQLAllTableConstraints.java | 216 +- .../apache/hadoop/hive/metastore/api/Schema.java | 80 +- .../hadoop/hive/metastore/api/SchemaVersion.java | 36 +- .../hadoop/hive/metastore/api/SerDeInfo.java | 44 +- .../metastore/api/SetPartitionsStatsRequest.java | 36 +- .../hive/metastore/api/ShowCompactResponse.java | 36 +- .../hive/metastore/api/ShowLocksResponse.java | 36 +- .../hadoop/hive/metastore/api/SkewedInfo.java | 164 +- .../hive/metastore/api/StorageDescriptor.java | 148 +- .../apache/hadoop/hive/metastore/api/Table.java | 144 +- .../hive/metastore/api/TableStatsRequest.java | 32 +- .../hive/metastore/api/TableStatsResult.java | 36 +- .../hive/metastore/api/TableValidWriteIds.java | 32 +- .../hive/metastore/api/ThriftHiveMetastore.java | 5941 +++++---- .../hive/metastore/api/TruncateTableRequest.java | 32 +- .../org/apache/hadoop/hive/metastore/api/Type.java | 36 +- .../metastore/api/UniqueConstraintsResponse.java | 36 +- .../hive/metastore/api/WMFullResourcePlan.java | 144 +- .../api/WMGetAllResourcePlanResponse.java | 36 +- .../api/WMGetTriggersForResourePlanResponse.java | 36 +- .../api/WMValidateResourcePlanResponse.java | 64 +- .../api/WriteNotificationLogBatchRequest.java | 36 +- .../metastore/api/WriteNotificationLogRequest.java | 32 +- .../gen-php/metastore/AbortCompactResponse.php | 28 +- .../gen-php/metastore/AbortCompactionRequest.php | 18 +- .../thrift/gen-php/metastore/AbortTxnsRequest.php | 18 +- .../metastore/AddCheckConstraintRequest.php | 20 +- .../metastore/AddDefaultConstraintRequest.php | 20 +- .../gen-php/metastore/AddDynamicPartitions.php | 18 +- .../gen-php/metastore/AddForeignKeyRequest.php | 20 +- .../metastore/AddNotNullConstraintRequest.php | 20 +- .../gen-php/metastore/AddPartitionsRequest.php | 40 +- .../gen-php/metastore/AddPartitionsResult.php | 40 +- .../gen-php/metastore/AddPrimaryKeyRequest.php | 20 +- .../metastore/AddUniqueConstraintRequest.php | 20 +- .../src/gen/thrift/gen-php/metastore/AggrStats.php | 20 +- .../metastore/AllocateTableWriteIdsRequest.php | 38 +- .../metastore/AllocateTableWriteIdsResponse.php | 20 +- .../gen-php/metastore/AlterPartitionsRequest.php | 40 +- .../thrift/gen-php/metastore/AlterTableRequest.php | 18 +- .../gen-php/metastore/AppendPartitionsRequest.php | 18 +- .../gen-php/metastore/CheckConstraintsResponse.php | 20 +- .../gen-php/metastore/ClearFileMetadataRequest.php | 18 +- .../gen-php/metastore/ClientCapabilities.php | 18 +- .../thrift/gen-php/metastore/ColumnStatistics.php | 20 +- .../thrift/gen-php/metastore/CommitTxnRequest.php | 20 +- .../thrift/gen-php/metastore/CompactionRequest.php | 26 +- .../gen-php/metastore/CreateDatabaseRequest.php | 26 +- .../gen-php/metastore/CreateTableRequest.php | 138 +- .../thrift/gen-php/metastore/CreationMetadata.php | 38 +- .../gen/thrift/gen-php/metastore/DataConnector.php | 26 +- .../src/gen/thrift/gen-php/metastore/Database.php | 26 +- .../metastore/DefaultConstraintsResponse.php | 20 +- .../metastore/DeleteColumnStatisticsRequest.php | 36 +- .../gen-php/metastore/DropPartitionRequest.php | 18 +- .../gen-php/metastore/DropPartitionsResult.php | 20 +- .../thrift/gen-php/metastore/ExtendedTableInfo.php | 36 +- .../gen/thrift/gen-php/metastore/FileMetadata.php | 18 +- .../gen-php/metastore/FindSchemasByColsResp.php | 20 +- .../thrift/gen-php/metastore/FireEventRequest.php | 44 +- .../gen-php/metastore/FireEventRequestData.php | 20 +- .../thrift/gen-php/metastore/FireEventResponse.php | 18 +- .../gen-php/metastore/ForeignKeysResponse.php | 20 +- .../src/gen/thrift/gen-php/metastore/Function.php | 20 +- .../gen-php/metastore/GetAllFunctionsResponse.php | 20 +- .../gen-php/metastore/GetCatalogsResponse.php | 18 +- .../metastore/GetDatabaseObjectsResponse.php | 20 +- .../gen-php/metastore/GetDatabaseRequest.php | 18 +- .../thrift/gen-php/metastore/GetFieldsResponse.php | 20 +- .../metastore/GetFileMetadataByExprRequest.php | 18 +- .../metastore/GetFileMetadataByExprResult.php | 28 +- .../gen-php/metastore/GetFileMetadataRequest.php | 18 +- .../gen-php/metastore/GetFileMetadataResult.php | 26 +- .../gen-php/metastore/GetFunctionsResponse.php | 38 +- .../GetLatestCommittedCompactionInfoRequest.php | 18 +- .../GetLatestCommittedCompactionInfoResponse.php | 20 +- .../gen-php/metastore/GetOpenTxnsInfoResponse.php | 20 +- .../gen-php/metastore/GetOpenTxnsRequest.php | 18 +- .../gen-php/metastore/GetOpenTxnsResponse.php | 18 +- .../metastore/GetPartitionNamesPsRequest.php | 18 +- .../metastore/GetPartitionNamesPsResponse.php | 18 +- .../gen-php/metastore/GetPartitionRequest.php | 18 +- .../metastore/GetPartitionsByNamesRequest.php | 36 +- .../metastore/GetPartitionsByNamesResult.php | 20 +- .../gen-php/metastore/GetPartitionsFilterSpec.php | 18 +- .../metastore/GetPartitionsPsWithAuthRequest.php | 54 +- .../metastore/GetPartitionsPsWithAuthResponse.php | 20 +- .../gen-php/metastore/GetPartitionsRequest.php | 36 +- .../gen-php/metastore/GetPartitionsResponse.php | 20 +- .../metastore/GetPrincipalsInRoleResponse.php | 20 +- .../gen-php/metastore/GetProjectionsSpec.php | 18 +- .../GetRoleGrantsForPrincipalResponse.php | 20 +- .../thrift/gen-php/metastore/GetSchemaResponse.php | 20 +- .../thrift/gen-php/metastore/GetTableRequest.php | 18 +- .../gen-php/metastore/GetTablesExtRequest.php | 18 +- .../thrift/gen-php/metastore/GetTablesRequest.php | 36 +- .../thrift/gen-php/metastore/GetTablesResult.php | 20 +- .../gen-php/metastore/GetValidWriteIdsRequest.php | 18 +- .../gen-php/metastore/GetValidWriteIdsResponse.php | 20 +- .../metastore/HeartbeatTxnRangeResponse.php | 36 +- .../gen/thrift/gen-php/metastore/HiveObjectRef.php | 18 +- .../gen-php/metastore/InsertEventRequestData.php | 72 +- .../gen/thrift/gen-php/metastore/LockRequest.php | 20 +- .../metastore/NotNullConstraintsResponse.php | 20 +- .../gen-php/metastore/NotificationEventRequest.php | 54 +- .../metastore/NotificationEventResponse.php | 20 +- .../metastore/NotificationEventsCountRequest.php | 18 +- .../thrift/gen-php/metastore/ObjectDictionary.php | 44 +- .../thrift/gen-php/metastore/OpenTxnRequest.php | 18 +- .../thrift/gen-php/metastore/OpenTxnsResponse.php | 18 +- .../src/gen/thrift/gen-php/metastore/Partition.php | 44 +- .../metastore/PartitionListComposingSpec.php | 20 +- .../metastore/PartitionSpecWithSharedSD.php | 20 +- .../gen-php/metastore/PartitionValuesRequest.php | 40 +- .../gen-php/metastore/PartitionValuesResponse.php | 20 +- .../gen-php/metastore/PartitionValuesRow.php | 18 +- .../gen-php/metastore/PartitionWithoutSD.php | 44 +- .../gen-php/metastore/PartitionsByExprResult.php | 20 +- .../gen-php/metastore/PartitionsResponse.php | 20 +- .../metastore/PartitionsSpecByExprResult.php | 20 +- .../gen-php/metastore/PartitionsStatsRequest.php | 36 +- .../gen-php/metastore/PartitionsStatsResult.php | 46 +- .../gen-php/metastore/PrimaryKeysResponse.php | 20 +- .../gen-php/metastore/PrincipalPrivilegeSet.php | 138 +- .../gen/thrift/gen-php/metastore/PrivilegeBag.php | 20 +- .../gen-php/metastore/PropertyGetRequest.php | 18 +- .../gen-php/metastore/PropertyGetResponse.php | 52 +- .../gen-php/metastore/PropertySetRequest.php | 26 +- .../gen-php/metastore/PutFileMetadataRequest.php | 36 +- .../gen-php/metastore/RenamePartitionRequest.php | 18 +- .../thrift/gen-php/metastore/ReplLastIdInfo.php | 18 +- .../metastore/ReplTblWriteIdStateRequest.php | 18 +- .../metastore/ReplayedTxnsForPolicyResult.php | 42 +- .../gen-php/metastore/ReplicationMetricList.php | 20 +- .../thrift/gen-php/metastore/RequestPartsSpec.php | 38 +- .../gen-php/metastore/SQLAllTableConstraints.php | 120 +- .../src/gen/thrift/gen-php/metastore/Schema.php | 46 +- .../gen/thrift/gen-php/metastore/SchemaVersion.php | 20 +- .../src/gen/thrift/gen-php/metastore/SerDeInfo.php | 26 +- .../metastore/SetPartitionsStatsRequest.php | 20 +- .../gen-php/metastore/ShowCompactResponse.php | 20 +- .../thrift/gen-php/metastore/ShowLocksResponse.php | 20 +- .../gen/thrift/gen-php/metastore/SkewedInfo.php | 98 +- .../thrift/gen-php/metastore/StorageDescriptor.php | 84 +- .../src/gen/thrift/gen-php/metastore/Table.php | 82 +- .../thrift/gen-php/metastore/TableStatsRequest.php | 18 +- .../thrift/gen-php/metastore/TableStatsResult.php | 20 +- .../gen-php/metastore/TableValidWriteIds.php | 18 +- .../metastore/ThriftHiveMetastoreClient.php | 62 + .../gen-php/metastore/ThriftHiveMetastoreIf.php | 6 + .../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 +- ...eMetastore_fetch_partition_names_req_result.php | 18 +- ...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 +- ...etastore_get_replayed_txns_for_policy_args.php} | 22 +- ...astore_get_replayed_txns_for_policy_result.php} | 12 +- .../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 +- ...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-php/metastore/TruncateTableRequest.php | 18 +- .../src/gen/thrift/gen-php/metastore/Type.php | 20 +- .../metastore/UniqueConstraintsResponse.php | 20 +- .../gen-php/metastore/WMFullResourcePlan.php | 80 +- .../metastore/WMGetAllResourcePlanResponse.php | 20 +- .../WMGetTriggersForResourePlanResponse.php | 20 +- .../metastore/WMValidateResourcePlanResponse.php | 36 +- .../metastore/WriteNotificationLogBatchRequest.php | 20 +- .../metastore/WriteNotificationLogRequest.php | 18 +- .../hive_metastore/ThriftHiveMetastore-remote | 7 + .../gen-py/hive_metastore/ThriftHiveMetastore.py | 1247 +- .../src/gen/thrift/gen-py/hive_metastore/ttypes.py | 2660 ++-- .../src/gen/thrift/gen-rb/hive_metastore_types.rb | 18 + .../src/gen/thrift/gen-rb/thrift_hive_metastore.rb | 61 + .../metastore/AbstractThriftHiveMetastore.java | 6 + .../hadoop/hive/metastore/HiveMetaStoreClient.java | 8 + .../hadoop/hive/metastore/IMetaStoreClient.java | 4 + .../src/main/thrift/hive_metastore.thrift | 4 + .../apache/hadoop/hive/metastore/HMSHandler.java | 17 + .../hadoop/hive/metastore/txn/TxnHandler.java | 16 + .../apache/hadoop/hive/metastore/txn/TxnStore.java | 7 + ...r.java => GetReplayedTxnsForPolicyHandler.java} | 28 +- 385 files changed, 20571 insertions(+), 17926 deletions(-) create mode 100644 ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ClearDanglingTxnTask.java copy ql/src/java/org/apache/hadoop/hive/ql/{ddl/database/use/SwitchDatabaseDesc.java => exec/repl/ClearDanglingTxnWork.java} (57%) copy standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/{EnvironmentContext.java => ReplayedTxnsForPolicyResult.java} (56%) copy service-rpc/src/gen/thrift/gen-php/TStructTypeEntry.php => standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/ReplayedTxnsForPolicyResult.php (70%) copy standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/{ThriftHiveMetastore_add_master_key_args.php => ThriftHiveMetastore_get_replayed_txns_for_policy_args.php} (76%) copy standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/{ThriftHiveMetastore_get_principals_in_role_result.php => ThriftHiveMetastore_get_replayed_txns_for_policy_result.php} (89%) copy standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/jdbc/queries/{GetTargetTxnIdListForPolicyHandler.java => GetReplayedTxnsForPolicyHandler.java} (67%)