Re: Flink cannot recognized catalog set by registerCatalog.

2019-08-12 Thread Xuefu Z
nStreamingMode() > .withBuiltInCatalogName("ca1") > .withBuiltInDatabaseName("db1") > .build()); > > > As Dawid said, if I want to store in my custom catalog, I can call > catalog.createTable or using DDL. > > Thanks, > SImon > > On

Re: Flink cannot recognized catalog set by registerCatalog.

2019-08-12 Thread Xuefu Z
Hi Simon, Thanks for reporting the problem. There is some rough edges around catalog API and table environments, and we are improving post 1.9 release. Nevertheless, tableEnv.registerCatalog() is just to put a new catalog in Flink's CatalogManager, It doens't change the default catalog/database a

Re: [ANNOUNCE] Rong Rong becomes a Flink committer

2019-07-11 Thread Xuefu Z
Congratulations, Rong! On Thu, Jul 11, 2019 at 10:59 AM Bowen Li wrote: > Congrats, Rong! > > > On Thu, Jul 11, 2019 at 10:48 AM Oytun Tez wrote: > > > Congratulations Rong! > > > > --- > > Oytun Tez > > > > *M O T A W O R D* > > The World's Fastest Human Translation Platform. > > oy...@motawor