Hi,

Using the JDBCInputFormat I loaded a DataSet<Row> type. When I tried to
save it as CSV file it errors:
java.lang.ClassCastException: org.apache.flink.types.Row cannot be cast to
org.apache.flink.api.java.tuple.Tuple

That's while I can save it as a text file. Here is the code.

DataSet<Row> dataset = env.createInput(InputFormat);

dataset.writeAsCsv("table_data");

Is it a bug?

Reply via email to