Re: Program crashes trying to read JSON file

2014-11-26 Thread Stephan Ewen
functions on hardcore string > operations to do the same. > That would be like reinventing the wheel ... :-(( > > Any advice in this regard will be highly appreciated. > > Thanks in advance to all, > Anirvan > > ------ > > *From: *"Stefano Bortoli

Re: Program crashes trying to read JSON file

2014-11-26 Thread Felix Neutatz
ring is written! > > > > > Something as : > > > > > org.apache.flink.api.java.operators.DataSource@6bd8b476 > > > > > > Worse still ! this string value sometimes remains the same over > multiple > > > runs > > > of the programme &g

Re: Program crashes trying to read JSON file

2014-11-26 Thread Anirvan BASU
a 2-level hierarchy for one field: > > > [JSON] > > > {timestamp: 1397731764 payload: {product: Younited uuid: > > 754726549cec3968a60a2f8ccdc1da27e57a01af4bb2b11841803a25eadd platform: > > native version: 6aa54aca95fb1b8ef2290136ab12df2e4b011241 type: can-usage-v1

Re: Program crashes trying to read JSON file

2014-11-25 Thread Anirvan BASU
e confused if we are doing it correctly :-(( Thanks in advance for helping us to understand where we are going wrong. Anirvan - Original Message - > From: "Stefano Bortoli" > To: "user" > Cc: dev@flink.incubator.apache.org > Sent: Tuesday, November 25,

Re: Program crashes trying to read JSON file

2014-11-25 Thread Stefano Bortoli
Very quickly, it seems you are trying to sum on Strings Caused by: org.apache.flink.api.java. aggregation.UnsupportedAggregationTypeException: The type java.lang.String has currently not supported for built-in sum aggregations. Check your tuple types and be sure that you are not summing on string

Program crashes trying to read JSON file

2014-11-25 Thread Anirvan BASU
Hello all, We are using Flink 0.7 and trying to read a large JSON file, reading some fields into a flink (3-tuple based) dataset, then performing some operations. We encountered the following runtime error: [QUOTE] Error: The main method caused an error. org.apache.flink.client.program.Pro