Skip to content

Commit 216fac7

Browse files
yingjianwu98Yingjian Wu
andauthored
set cluster info type to Catalog Type (#569)
* set cluster info type to Catalog Type * adjust test --------- Co-authored-by: Yingjian Wu <[email protected]>
1 parent a4cd4a5 commit 216fac7

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

metacat-common-server/src/main/java/com/netflix/metacat/common/server/spi/MetacatCatalogConfig.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ public static MetacatCatalogConfig createFromMapAndRemoveProperties(
109109
final String clusterEnv = properties.get(Keys.CLUSTER_ENV);
110110
final String clusterRegion = properties.get(Keys.CLUSTER_REGION);
111111
final ClusterInfo clusterInfo =
112-
new ClusterInfo(clusterName, type, clusterAccount, clusterAccountId, clusterEnv, clusterRegion);
112+
new ClusterInfo(clusterName, catalogType, clusterAccount, clusterAccountId, clusterEnv, clusterRegion);
113113

114114
return new MetacatCatalogConfig(catalogType, catalogName, clusterInfo, includeViewsWithTables, schemaWhitelist,
115115
schemaBlacklist, thriftPort, cacheEnabled, interceptorEnabled, hasDataExternal);

metacat-main/src/test/groovy/com/netflix/metacat/main/services/impl/TableServiceImplSpec.groovy

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -71,8 +71,8 @@ class TableServiceImplSpec extends Specification {
7171
def usermetadataService = Mock(UserMetadataService)
7272
def eventBus = Mock(MetacatEventBus)
7373
def converterUtil = Mock(ConverterUtil)
74-
def catalogConfig = MetacatCatalogConfig.createFromMapAndRemoveProperties('hive', 'a', ['metacat.interceptor.enabled': 'true', 'metacat.has-data-external':'true'])
75-
def catalogConfigFalse = MetacatCatalogConfig.createFromMapAndRemoveProperties('hive', 'a', ['metacat.interceptor.enabled': 'false', 'metacat.has-data-external':'false'])
74+
def catalogConfig = MetacatCatalogConfig.createFromMapAndRemoveProperties('migration', 'a', ['metacat.interceptor.enabled': 'true', 'metacat.has-data-external':'true', 'metacat.type': 'hive'])
75+
def catalogConfigFalse = MetacatCatalogConfig.createFromMapAndRemoveProperties('migration', 'a', ['metacat.interceptor.enabled': 'false', 'metacat.has-data-external':'false', 'metacat.type': 'hive'])
7676
def registry = new NoopRegistry()
7777
def config = Mock(Config)
7878
def tableDto = DataDtoProvider.getTable('a', 'b', 'c', "amajumdar", "s3:/a/b")

0 commit comments

Comments
 (0)