注册table时catalog无法变更

Mon, 06 Jan 2020 23:20:35 -0800 

hi，各位：
我在开发过程中，通过下面方式注册table时，默认使用的catalog是EnvironmentSettings.DEFAULT_BUILTIN_CATALOG
    streamTableEnvironment.registerDataStream(tableName, dataStream, 
fields);尝试通过下面方式解决,但是注册的table仍然在EnvironmentSettings.DEFAULT_BUILTIN_CATALOG中    
streamTableEnvironment.registerCatalog(catalogName, new 
InMemoryExternalCatalog(catalogName));    
streamTableEnvironment.useCatalog(catalogName);请问，我如何将table注册到指定的catalog?


xiyu...@163.com

回复