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 <tejasub1...@gmail.com> wrote:
> 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 creditDetailsTable =
> tableEnv.sqlQuery("SELECT id FROM CreditDetails where loanStatus = 'Charged
> Off'");
> Table creditDetailsTable2 =
> tableEnv.sqlQuery("SELECT id FROM CreditDetails where creditScore < 700");
>
> StatementSet stmtSet = tableEnv.createStatementSet();
> stmtSet.addInsert("output", creditDetailsTable);
> stmtSet.addInsert("output", creditDetailsTable2);
> stmtSet.execute();
>
> Table outputTable1 = tableEnv.from("output");
> Table resultsTable1 = outputTable1.select($("*"));
> TableResult result1 = resultsTable1.execute();
> result1.print();/
>
> But this prints result as 0 rows. What am I doing wrong ?
> Also the execution graph shows two different jobs getting created :
> collect,
> and insert. Can you help understand what's going on ?
>
>
>
> --
> Sent from:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
>
