Re: Assigning UID to Flink SQL queries

2019-09-02 Thread Dawid Wysakowicz
Hi Yuval, Unfortunately currently you cannot assign UIDs in table programs. The reason is that uid is used for reassigning state upon restart. Table programs are automatically compiled to executable program. This program might change depending on many factors: table statistics, applied rules etc.

Re: Assigning UID to Flink SQL queries

2019-08-30 Thread Yuval Itzchakov
Anyone? On Tue, 27 Aug 2019, 17:23 Yuval Itzchakov, wrote: > Hi, > > We a have a bunch of Flink SQL queries running in our Flink environment. > For > regular Table API interactions, we can override `uid` which also gives us > an > indicative name for the thread/UI to look at. For Flink SQL queri

Assigning UID to Flink SQL queries

2019-08-27 Thread Yuval Itzchakov
Hi, We a have a bunch of Flink SQL queries running in our Flink environment. For regular Table API interactions, we can override `uid` which also gives us an indicative name for the thread/UI to look at. For Flink SQL queries, this doesn't seem the the case which results in very verbose names (ess