注册table时catalog无法变更
Posted by
xiyueha@163.com on
Jan 07, 2020; 7:20am
URL: http://apache-flink.370.s1.nabble.com/table-catalog-tp1417.html
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?
[hidden email]