Re:  problem with build from source flink 1.11

2020-07-27 Thread Timo Walther
Great to hear. Thanks for letting us know. Regards, Timo On 27.07.20 17:58, Felipe Lolas wrote: Seems fixed! I was replacing only flink-dist.jar. When replaced all the compiled jar's from flink-1.1.0-bin fixed the issue. Thanks! El 27 de julio de 2020 4:28, Felipe Lolas escribió: Hi!! T

Re: problem with build from source flink 1.11

2020-07-27 Thread Felipe Lolas
Seems fixed! I was replacing only flink-dist.jar. When replaced all the compiled jar's from flink-1.1.0-bin fixed the issue. Thanks! El 27 de julio de 2020 4:28, Felipe Lolas escribió: Hi!! Timo and Chesnay: Thanks for helping!!! Here is the full stack trace: 2020-07-27 05:27:38,661 INFO

Re: problem with build from source flink 1.11

2020-07-27 Thread Felipe Lolas
Hi!! Timo and Chesnay: Thanks for helping!!! Here is the full stack trace: 2020-07-27 05:27:38,661 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job insert-into_default_catalog.default_database.print_table (ca40bd10a729f5cad56a7db6bef17a6f) switched from state FAILIN

Re: problem with build from source flink 1.11

2020-07-27 Thread Chesnay Schepler
@Timo maven 3.2.5 is the recommended Maven version for building Flink. @Felipe Can you provide us the full stacktrace? This could be a library issue in regards to JDK compatibility. On 27/07/2020 15:23, Timo Walther wrote: Hi Felipe, are you sure that Maven and the TaskManagers are using the

Re: problem with build from source flink 1.11

2020-07-27 Thread Timo Walther
Hi Felipe, are you sure that Maven and the TaskManagers are using the JDK version that you mentioned? Usually, a `mvn clean install` in the `.../flink/` directory should succeed without any problems. Also your Maven version seems pretty old. I'm using Apache Maven 3.6.3 for example. The No

problem with build from source flink 1.11

2020-07-27 Thread Felipe Lolas
Hi, Im Felipe, just started learning flink a few weeks ago(moving spark streaming workloads). Now, I currently testing some changes into flink-yarn, but when using my builded flink-dist.jar, the Job in TaskManager fails because of: java.lang.NoSuchMethodError: java.nio.ByteBuffer.position(I)