2021 at 1:53 PM Arvid Heise
>>>>>>> wrote:
>>>>>>>
>>>>>>>> Hi Avi,
>>>>>>>>
>>>>>>>> without being a scala-guy, I'm guessing that you are mixing scala
>>>>>>>> ver
gt;> as Flink (1.11 or 1.12)? I have also heard of issues with different minor
>>>>>> versions of scala, so make sure to use the exact same version (e.g.
>>>>>> 2.11.12).
>>>>>>
>>>>>> On Mon, Dec 28, 2020 at 3:54
4 PM Avi Levi wrote:
>>>>
>>>>> I am trying to aggregate all records in a time window. This is my
>>>>> ProcessAllWindowFunction :
>>>>>
>>>>> case class SimpleAggregate(elms: List[String])
>>>>>
>>>>> cl
, out:
>>> Collector[SimpleAggregate]): Unit = {
>>> val es: List[String] = elements.toList
>>> val record = SimpleAggregate(es)
>>> out.collect(record)
>>> }
>>> }
>>>
>>> But I am getting this exception why ?
&g
I am getting this exception why ?
>
> Exception in thread "main" java.util.concurrent.ExecutionException:
> scala.tools.reflect.ToolBoxError: reflective compilation has failed: cannot
> initialize the compiler due to java.lang.BootstrapMethodError:
> java.lang.NoSuchMethodE
[String],
out: Collector[SimpleAggregate]): Unit = {
val es: List[String] = elements.toList
val record = SimpleAggregate(es)
out.collect(record)
}
}
But I am getting this exception why ?
Exception in thread "main" java.util.concurrent.ExecutionException:
scala.tools.reflect.To
;>
>> at
>> org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:895)
>>
>> at
>> org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:968)
>>
>> at
>> org.apache.flink.ru
pache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
>
> at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:968)
>
> Caused by: java.util.concurrent.ExecutionException:
> org.apache.flink.client.program.ProgramInvocationException: Job failed
> (JobID: f57b682f5867a
)
at
org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:968)
Caused by: java.util.concurrent.ExecutionException:
org.apache.flink.client.program.ProgramInvocationException: Job failed
(JobID: f57b682f5867a8bf6ff6e1ddce93a1ab
DataStream of Edge Objects and
> printing them. However I am getting
> java.util.concurrent.ExecutionException but not sure why?
>
> Here is the sample code
>
> import org.apache.flink.api.common.typeinfo.TypeHint;
> import org.apache.fli
10 matches
Mail list logo
