Exception in thread "main" org.apache.flink.compiler.CompilerException: The
given program contains multiple disconnected data flows
example
DataSet<Customer3>
customers=env.readCsvFile("/home/hadoop/Desktop/Dataset/customer.csv")
.fieldDelimiter('|')
.includeFields(11000010).ignoreFirstLine()
.tupleType(Customer3.class);
customers = customers.filter(new
FilterFunction<Customer3>()
{
@Override
public boolean filter(Customer3 c) {
c.getField(2).toString().equals("AUTOMOBILE");
}
return true;
}
});
customers.print();
customers.writeAsCsv("/home/hadoop/Desktop/Dataset/out2.csv", "\n", "|");
}
DataSet<Customer2>
customers1=env.readCsvFile("/home/hadoop/Desktop/Dataset/customer.csv")
.fieldDelimiter('|')
.includeFields("10000010").ignoreFirstLine()
.tupleType(Customer2.class);
customers = customers.filter(new
FilterFunction<Customer2>()
{
@Override
public boolean filter(Customer2 c) {
c.getField(1).toString().equals("MACHINERY");
}
});
customers1.print();
customers1.writeAsCsv("/home/hadoop/Desktop/Dataset/out1.csv", "\n", "|");
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Error-when-use-tow-datasink-tp1205.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
