Re: Broadcasted Variable not updated in a Iterative Data Set

Happy to hear that it works! On Wed, May 13, 2015 at 12:42 AM, Ventura Del Monte < venturadelmo...@gmail.com> wrote: > Thank you for your clarification. At the end I figured out, it was a silly > programming error, now it just works fine. Thank you again for your > explanation. > > > 2015-05-11 2

Re: Broadcasted Variable not updated in a Iterative Data Set

Thank you for your clarification. At the end I figured out, it was a silly programming error, now it just works fine. Thank you again for your explanation. 2015-05-11 22:31 GMT+02:00 Stephan Ewen : > Can you share the respective part of the code, then we can have a look? > > In general, a DataSe

Re: I want writ output dataset in one file not mult file

Thank you very much -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/I-want-writ-output-dataset-in-one-file-not-mult-file-tp1227p1229.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: I want writ output dataset in one file not mult file

Hi, for writing the output to one file, you have to set the parallelism of the output operator to 1. So for example .writeToFile(...).setParallelism(1); On Tue, May 12, 2015 at 1:17 PM, hagersaleh wrote: > I want writ output dataset in one file not mult file > > > > -- > View this message in co

I want writ output dataset in one file not mult file

I want writ output dataset in one file not mult file -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/I-want-writ-output-dataset-in-one-file-not-mult-file-tp1227.html Sent from the Apache Flink User Mailing List archive. mailing list archive a

Re: want write Specified field from dataset to output file

I solve error when use import org.apache.flink.api.java.io.TextOutputFormat.TextFormatter; very thanks -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/want-write-Specified-field-from-dataset-to-output-file-tp1223p1226.html Sent from the Apach

Re: want write Specified field from dataset to output file

when use the solve display error message cannot find symbol new TextFormatter() { symbol: class TextFormatter location: class TPCHQuery3 Note: /home/hadoop/Desktop/sub_query/src/org/apache/flink/examples/java/relational/TPCHQuery3.java uses unchecked or unsafe operations. Note: Recompile with -Xl

Re: want write Specified field from dataset to output file

Hi, please have a look at the programming guide on how to write results to an output file: http://ci.apache.org/projects/flink/flink-docs-master/apis/programming_guide.html#data-sinks In your case, I would recommend: customers.writeAsFormattedText("file:///path/to/the/result/file", new TextF

want write Specified field from dataset to output file

I want write Specified field from dataset to output file I want write field 2 to output file example DataSet customers=env.readCsvFile("/home/hadoop/Desktop/Dataset/customer.csv") .fieldDelimiter('|') .includeFields(1110).ignoreFirstLine()