Ah, I found an old jar in my classpath, thanks for the hint!
On 10.02.2015 12:12, Stephan Ewen wrote:
This sounds very much like a version mixup. Can you check that you
reference the same version for core, clients, runtime, ...?
The exception is from the 0.8 RPC service. Are you using 0.8 every
This sounds very much like a version mixup. Can you check that you
reference the same version for core, clients, runtime, ...?
The exception is from the 0.8 RPC service. Are you using 0.8 everywhere?
On Tue, Feb 10, 2015 at 12:09 PM, Sebastian wrote:
> I'm running it from within my IDE...
>
> O
I'm running it from within my IDE...
On 10.02.2015 11:17, Robert Metzger wrote:
Hi,
the NoSuchMethodError exception indicates that there is a mixup of Flink
versions.
Are you running the job from within your IDE or are you submitting it to
a cluster? Maybe the cluster has a different Flink versi
Hi,
the NoSuchMethodError exception indicates that there is a mixup of Flink
versions.
Are you running the job from within your IDE or are you submitting it to a
cluster? Maybe the cluster has a different Flink version?
On Tue, Feb 10, 2015 at 10:51 AM, Sebastian wrote:
> Yes, the import was mis
Yes, the import was missing thank you for the hint!
Now I'm getting the following error:
java.io.IOException: java.lang.NoSuchMethodError:
org.apache.flink.util.ClassUtils.isPrimitiveOrBoxedOrString(Ljava/lang/Class;)Z
at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:428)
Hi,
do you have this import?
import org.apache.flink.api.scala._
You could also just import
org.apache.flink.api.scala.createTypeInformation but most of the other
stuff in the package is required anyways.
Cheers,
Aljoscha
On Tue, Feb 10, 2015 at 10:05 AM, Sebastian wrote:
> Hi,
>
> I'm trying
Hi,
I'm trying to write a simple join in flink-scala but for some reasons
flink fails to compile my code. I've tried several reformulations but
can't get rid of the error. Can you tell me how to fix this piece of
code? I'm using flink 0.8.0.
Sebastian
---
