Hi Satyam,
I also meet the same issue when I integrate flink with zeppelin. Here's
what I did.
https://github.com/apache/zeppelin/blob/master/flink/src/main/java/org/apache/zeppelin/flink/TableEnvFactory.java#L226
If you are interested in flink on zeppelin, you can refer the following
blogs and
Thanks, Jark & Godfrey.
The workaround was successful.
I have created the following ticket to track the issue -
https://issues.apache.org/jira/browse/FLINK-18095
Regards,
Satyam
On Wed, Jun 3, 2020 at 3:26 AM Jark Wu wrote:
> Hi Satyam,
>
> In the long term, TableEnvironment is the entry
Hi Satyam,
In the long term, TableEnvironment is the entry point for pure Table/SQL
users. So it should have all the ability of StreamExecutionEnvironment.
I think remote execution is a reasonable feature, could you create an JIRA
issue for this?
As a workaround, you can construct
Thanks for the reply, Godfrey.
I would also love to learn the reasoning behind that limitation.
For more context, I am building a Java application that receives some user
input via a GRPC service. The user's input is translated to some SQL that
may be executed in streaming or batch mode based on
Hi Satyam,
for blink batch mode, only TableEnvironment can be used,
and TableEnvironment do not take StreamExecutionEnvironment as argument.
Instead StreamExecutionEnvironment instance is created internally.
back to your requirement, you can build your table program as user jar,
and submit the
Hello,
I am running into a very basic problem while working with Table API. I wish
to create a TableEnvironment connected to a remote environment that uses
Blink planner in batch mode. Examples and documentation I have come across
so far recommend the following pattern to create such an
