>>>>> On Tue, Jan 5, 2021 at 1:53 PM Arvid Heise
>>>>>>> wrote:
>>>>>>>
>>>>>>>> Hi Avi,
>>>>>>>>
>>>>>>>> without being a scala-guy, I'm guessing that you are mixing sc
the same scala version
>>>>>> 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).
>>>>>>
>>>&g
Mon, Dec 28, 2020 at 3:54 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])
>>>>>
lements: Iterable[String], out:
>>> Collector[SimpleAggregate]): Unit = {
>>> val es: List[String] = elements.toList
>>> val record = SimpleAggregate(es)
>>> out.collect(record)
>>> }
>>> }
>>>
>>> But I am gettin
ut 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.NoSuchMe
[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
ink.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: f57b682f5867a8bf6ff6e
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)
at
aStream 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
Hi All,
I am just trying to read edges which has the following format in Kafka
1,2
1,3
1,5
using the Table API and then converting to 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
11 matches
Mail list logo
