Hi Jingsong, Thanks for the information. Not sure if I'm missing anything but I have been reusing table env and didn't see anything wrong, I'm worried if I'm missed to note anything?
My use case: I created a class level StreamTableEnvironment and used it throughout my code for creating multiple tables and running multiple SQL queries. private static StreamTableEnvironment bsTableEnv = StreamTableEnvironment.create(bsEnv, bsSettings); bsTableEnv.registerDataStream(...) Table latestTbl1 = bsTableEnv.sqlQuery(...) bsTableEnv.registerDataStream(...) Table latestTbl2 = bsTableEnv.sqlQuery(...) and so on.. Could you please let me know if anything specific I need to look at? I would like to understand what was wrong before changing the code. Thanks, RK On Thu, Jan 23, 2020 at 11:48 PM Jingsong Li <jingsongl...@gmail.com> wrote: > Hi RKandoji, > > IMO, yes, you can not reuse table env, you should create a new tEnv after > executing, 1.9.1 still has this problem. > Related issue is [1], fixed in 1.9.2 and 1.10. > > [1] https://issues.apache.org/jira/browse/FLINK-13708 > > Best, > Jingsong Lee > > On Fri, Jan 24, 2020 at 11:14 AM RKandoji <rkand...@gmail.com> wrote: > >> Hi Team, >> >> I've been using Blink Planner and just came across this page >> https://ci.apache.org/projects/flink/flink-docs-stable/release-notes/flink-1.9.html#known-shortcomings-or-limitations-for-new-features >> and >> saw below limitation: >> >> Due to a bug with how transformations are not being cleared on execution, >>> TableEnvironment instances should not be reused across multiple SQL >>> statements when using the Blink planner. >> >> >> In my code I've created a StreamTableEnvironment (like shown below) and >> reusing this instance everywhere for registering data streams, registering >> tables and performing multiple SQL queries. So I'm a bit concerned if I >> need to change anything? Would above limitation affect StreamTableEnvironment >> as well? >> >> private static StreamTableEnvironment bsTableEnv = StreamTableEnvironment >> .create(bsEnv, bsSettings); >> >> Could someone please clarify and provide more details about the >> implications. >> >> >> Thanks, >> RKandoji >> > > > -- > Best, Jingsong Lee >
