You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Yuval Itzchakov <yu...@gmail.com> on 2019/08/27 14:23:21 UTC
Assigning UID to Flink SQL queries
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 (essentially
the entire query plan) shown in the UI / thread names while debugging.
Is there any convenient way to set / override the UID for SQL defined
queries?
--
Best Regards,
Yuval Itzchakov.
Re: Assigning UID to Flink SQL queries
Posted by Dawid Wysakowicz <dw...@apache.org>.
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. As of know it can also change between Flink version if we implement
new optimizations, operators etc. Right now user also does not have
access to the execution graph.
This is though something that we definitely want to address at some point.
Best,
Dawid
On 30/08/2019 12:51, Yuval Itzchakov wrote:
> Anyone?
>
> On Tue, 27 Aug 2019, 17:23 Yuval Itzchakov, <yuvalos@gmail.com
> <ma...@gmail.com>> 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
> queries, this
> doesn't seem the the case which results in very verbose names
> (essentially
> the entire query plan) shown in the UI / thread names while debugging.
>
> Is there any convenient way to set / override the UID for SQL defined
> queries?
>
> --
> Best Regards,
> Yuval Itzchakov.
>
Re: Assigning UID to Flink SQL queries
Posted by Yuval Itzchakov <yu...@gmail.com>.
Anyone?
On Tue, 27 Aug 2019, 17:23 Yuval Itzchakov, <yu...@gmail.com> 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 queries, this
> doesn't seem the the case which results in very verbose names (essentially
> the entire query plan) shown in the UI / thread names while debugging.
>
> Is there any convenient way to set / override the UID for SQL defined
> queries?
>
> --
> Best Regards,
> Yuval Itzchakov.
>