/"TableResult result1 = stmtSet.execute();
result1.print();"/
I tried this, and the result is following :
Job has been submitted with JobID 4803aa5edc31b3ddc884f922008c5c03
+++
| default_catalog.default_databas
Hi tbud,
you still have two executes; it should only be one. Can you try the
following instead of using outputTable1?
TableResult result1 = stmtSet.execute();
result1.print();
On Sun, Apr 18, 2021 at 12:05 AM tbud wrote:
> I have tried that too For example :
>
> /tableEnv.createTemporaryView("
I have tried that too For example :
/tableEnv.createTemporaryView("CreditDetails", creditStream);
tableEnv.executeSql(
"CREATE TABLE output(loanId VARCHAR) with ('connector.type' = 'filesystem',"
+ "'connector.path' = 'file:///path/Downloads/1',"
+ "'format.type' = 'csv')");
Table creditD
Yes. Instead of calling execute on each table, create a StatementSet using
your StreamTableEnvironment (tableEnv.createStatementSet) and use addInsert
and finally .execute when you want to run the job.
On Sat, Apr 17, 2021, 03:20 tbud wrote:
> If I want to run two different select queries on
