You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by Emma Li <em...@gmail.com> on 2022/08/29 19:29:15 UTC
Flink Table Task question
Hello,
We are calling flink table apis and are wondering is it possible to have a
better naming of such operators to show on ui?
E.g how do we renaming the following when the code is trying to make a
sqlQuery()
call
SourceConversion(table=[default_catalog.default_database.mytable],
fields=[data1, data2, data3, data4, data5, data6, data7, data8, data9,
data10]) -> Calc(select=[data1, data2, data3, data4, data5, data6, data7,
data8, data9, data10], where=[(data1.field=
_UTF-16LE'0000000000000000':VARCHAR(2147483647) CHARACTER SET "UTF-16LE")])
Regards,
Emma
Re: Flink Table Task question
Posted by Lijie Wang <wa...@gmail.com>.
Hi Emma,
As Sergey said, the improvement of naming (FLIP-195) is ready in Flink
1.15. Maybe you can upgrade Flink to 1.15.x.
Best,
Lijie
Sergey Nuyanzin <sn...@gmail.com> 于2022年9月1日周四 15:33写道：
> Hi Emma,
>
> not sure if I fully understand your question/case
> however there is a FLIP-195 [1] about improvement of naming
> I think you might be interested in taking a look at it
>
> [1]
>
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-195%3A+Improve+the+name+and+structure+of+vertex+and+operator+name+for+job
>
> On Tue, Aug 30, 2022 at 1:22 AM Emma Li <em...@gmail.com> wrote:
>
> > Hello,
> >
> > We are calling flink table apis and are wondering is it possible to have
> a
> > better naming of such operators to show on ui?
> > E.g how do we renaming the following when the code is trying to make a
> > sqlQuery()
> > call
> >
> > SourceConversion(table=[default_catalog.default_database.mytable],
> > fields=[data1, data2, data3, data4, data5, data6, data7, data8, data9,
> > data10]) -> Calc(select=[data1, data2, data3, data4, data5, data6, data7,
> > data8, data9, data10], where=[(data1.field=
> > _UTF-16LE'0000000000000000':VARCHAR(2147483647) CHARACTER SET
> "UTF-16LE")])
> >
> > Regards,
> > Emma
> >
>
>
> --
> Best regards,
> Sergey
>
Re: Flink Table Task question
Posted by Sergey Nuyanzin <sn...@gmail.com>.
Hi Emma,
not sure if I fully understand your question/case
however there is a FLIP-195 [1] about improvement of naming
I think you might be interested in taking a look at it
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-195%3A+Improve+the+name+and+structure+of+vertex+and+operator+name+for+job
On Tue, Aug 30, 2022 at 1:22 AM Emma Li <em...@gmail.com> wrote:
> Hello,
>
> We are calling flink table apis and are wondering is it possible to have a
> better naming of such operators to show on ui?
> E.g how do we renaming the following when the code is trying to make a
> sqlQuery()
> call
>
> SourceConversion(table=[default_catalog.default_database.mytable],
> fields=[data1, data2, data3, data4, data5, data6, data7, data8, data9,
> data10]) -> Calc(select=[data1, data2, data3, data4, data5, data6, data7,
> data8, data9, data10], where=[(data1.field=
> _UTF-16LE'0000000000000000':VARCHAR(2147483647) CHARACTER SET "UTF-16LE")])
>
> Regards,
> Emma
>
--
Best regards,
Sergey