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/ >