Thank you Xingbo, this will certainly help!
On Wed, Jul 15, 2020 at 7:39 AM Xingbo Huang wrote:
> Hi Manas,
>
> I have created a issue[1] to add related doc
>
> [1] https://issues.apache.org/jira/browse/FLINK-18598
>
> Best,
> Xingbo
>
> Manas Kale 于2020年7月14日周二 下午4:15写道：
>
>> Thank you for the
Hi Manas,
I have created a issue[1] to add related doc
[1] https://issues.apache.org/jira/browse/FLINK-18598
Best,
Xingbo
Manas Kale 于2020年7月14日周二 下午4:15写道：
> Thank you for the quick reply Xingbo!
> Is there some documented webpage example that I can refer to in the
> future for the latest p
Thank you for the quick reply Xingbo!
Is there some documented webpage example that I can refer to in the future
for the latest pyFlink 1.11 API? I couldn't find anything related to
awaiting asynchronous results.
Thanks,
Manas
On Tue, Jul 14, 2020 at 1:29 PM Xingbo Huang wrote:
> Hi Manas,
>
>
Hi Manas,
I tested your code, but there are no errors. Because execute_sql is an
asynchronous method, you need to await through TableResult, you can try the
following code:
from pyflink.datastream import StreamExecutionEnvironment,
TimeCharacteristic
from pyflink.table import StreamTableEnviron
