Skip to content

Commit

Permalink
Parameter rename
Browse files Browse the repository at this point in the history
  • Loading branch information
hubgeter committed Aug 22, 2024
1 parent 2a5dfac commit b428fa7
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,6 @@ public class HMSProperties {
// required
public static final String HIVE_METASTORE_URIS = "hive.metastore.uris";
public static final List<String> REQUIRED_FIELDS = Collections.singletonList(HMSProperties.HIVE_METASTORE_URIS);
public static final String ENABLE_HMS_EVENTS_INCREMENTAL_SYNC = "enable_hms_events_incremental_sync";
public static final String HMS_EVENTIS_BATCH_SIZE_PER_RPC = "hms_events_batch_size_per_rpc";
public static final String ENABLE_HMS_EVENTS_INCREMENTAL_SYNC = "hive.enable_hms_events_incremental_sync";
public static final String HMS_EVENTIS_BATCH_SIZE_PER_RPC = "hive.hms_events_batch_size_per_rpc";
}
Original file line number Diff line number Diff line change
Expand Up @@ -39,15 +39,15 @@ suite("test_hms_event_notification", "p0,external,hive,external_docker,external_
"type"="hms",
'hive.metastore.uris' = 'thrift://${externalEnvIp}:${hms_port}',
"use_meta_cache" = "${useMetaCache}",
"enable_hms_events_incremental_sync" ="true",
"hms_events_batch_size_per_rpc" = "1000"
"hive.enable_hms_events_incremental_sync" ="true",
"hive.hms_events_batch_size_per_rpc" = "1000"
);"""

sql """create catalog if not exists ${catalog_name_2} properties (
"type"="hms",
'hive.metastore.uris' = 'thrift://${externalEnvIp}:${hms_port}',
"use_meta_cache" = "${useMetaCache}",
"enable_hms_events_incremental_sync" ="true"
"hive.enable_hms_events_incremental_sync" ="true"
);"""

sleep(wait_time);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,17 +41,17 @@ suite("test_hms_event_notification_multi_catalog", "p0,external,hive,external_do
"type"="hms",
'hive.metastore.uris' = 'thrift://${externalEnvIp}:${hms_port}',
"use_meta_cache" = "${useMetaCache}",
"enable_hms_events_incremental_sync" ="true",
"hms_events_batch_size_per_rpc" = "10000"
"hive.enable_hms_events_incremental_sync" ="true",
"hive.hms_events_batch_size_per_rpc" = "10000"
);"""

sql """drop catalog if exists ${catalog_name_2}"""
sql """create catalog if not exists ${catalog_name_2} properties (
"type"="hms",
'hive.metastore.uris' = 'thrift://${externalEnvIp}:${hms_port}',
"use_meta_cache" = "${useMetaCache}",
"enable_hms_events_incremental_sync" ="true",
"hms_events_batch_size_per_rpc" = "100000"
"hive.enable_hms_events_incremental_sync" ="true",
"hive.hms_events_batch_size_per_rpc" = "100000"
);"""
sleep(wait_time);

Expand Down

0 comments on commit b428fa7

Please sign in to comment.