Hello Aljoscha,
I am using Flink 0.10.1 (see below) and flinkspector (0.1-SNAPSHOT).
-
org.apache.flink
flink-scala
0.10.1
org.apache.flink
flink-streaming-scala
0.10.1
org.apache.flink
flink-clients
0.10.1
Hi,
which version of Flink are you using, by the way? This would help me narrow
down on possible causes of the problem.
Cheers,
Aljoscha
> On 26 Feb 2016, at 10:34, Nirmalya Sengupta
> wrote:
>
> Hello Aljoscha,
>
> I have also tried by using the field's name in the sum("field3") function
>
Hello Aljoscha,
I have also tried by using the field's name in the sum("field3") function
(like you have suggested), but this time the exception is different:
Exception in thread "main" java.lang.ExceptionInInitializerError
at
Hi,
as far as I can see it the problem is in this line:
k.sum(3)
using field indices is only valid for Tuple Types. In your case you should be
able to use this:
k.sum(“field3”)
because this is a field of your Reading type.
Cheers,
Aljoscha
> On 26 Feb 2016, at 02:44, Nirmalya Sengupta
> wrote
Hello Flinksters,
I am trying to use Flinkspector in a Scala code snippet of mine and Flink
is complaining. The code is here:
---
case class Reading(field1:String,field2:String,field3:Int)
