(DEPRECATED) Apache Flink User Mailing List archive.

GetExecutionPlan fails with IllegalArgumentException in Comparator

classic Classic list List threaded Threaded
♦
♦
 5 messages Options
Bauss, Julian
Reply | Threaded
Open this post in threaded view
♦
♦
|

GetExecutionPlan fails with IllegalArgumentException in Comparator

Bauss, Julian

Hello everybody,

 

we‘re currently encountering an exception while generating an ExecutionGraph JSON in Flink v1.3.2.

Actually executing the job does not cause an exception and everything works as inteded.

 

This happens since we started adding side-outputs to many of our operators.

 

Is this already a known bug?

 

Below is the stacktrace. The problem seems to be a contract violation in the comparator implementation.

 

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.

        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:545)

        at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:419)

        at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:381)

        at org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:838)

        at org.apache.flink.client.CliFrontend.run(CliFrontend.java:259)

        at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1086)

        at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1133)

        at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1130)

        at org.apache.flink.runtime.security.HadoopSecurityContext$1.run(HadoopSecurityContext.java:43)

        at java.security.AccessController.doPrivileged(Native Method)

        at javax.security.auth.Subject.doAs(Subject.java:422)

        at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1656)

        at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:40)

        at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1130)

Caused by: java.lang.RuntimeException: JSON plan creation failed

        at org.apache.flink.streaming.api.graph.StreamGraph.getStreamingPlanAsJSON(StreamGraph.java:668)

        at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getExecutionPlan(StreamExecutionEnvironment.java:1538)

        at com.example.Main.main(Main.java:262)

        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

        at java.lang.reflect.Method.invoke(Method.java:498)

        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:528)

        ... 13 more

Caused by: java.lang.IllegalArgumentException: Comparison method violates its general contract!

        at java.util.TimSort.mergeLo(TimSort.java:777)

        at java.util.TimSort.mergeAt(TimSort.java:514)

        at java.util.TimSort.mergeCollapse(TimSort.java:441)

        at java.util.TimSort.sort(TimSort.java:245)

        at java.util.Arrays.sort(Arrays.java:1512)

        at java.util.ArrayList.sort(ArrayList.java:1454)

        at java.util.Collections.sort(Collections.java:175)

        at org.apache.flink.streaming.api.graph.JSONGenerator.getJSON(JSONGenerator.java:60)

        at org.apache.flink.streaming.api.graph.StreamGraph.getStreamingPlanAsJSON(StreamGraph.java:665)

        ... 21 more

 

Best Regards,

 

Julian



**************************************************************************************************************

bonprix Handelsgesellschaft mbH
Sitz der Gesellschaft: Hamburg

Geschäftsführung:
Markus Fuchshofen
Dr. Richard Gottwald
Dr. Kai Heck
Rien Jansen
Beiratsvorsitzender: Dr. Marcus Ackermann

Handelsregister AG Hamburg HR B 36 455

Adresse:

bonprix Handelsgesellschaft mbH

Haldesdorfer Str. 61
22179 Hamburg

Diese E-Mail enthält vertrauliche und/oder rechtlich geschützte Informationen.
Wenn Sie nicht der richtige Adressat sind oder diese E-Mail irrtümlich erhalten haben,
informieren Sie bitte sofort den Absender und vernichten Sie diese Mail.
Das unerlaubte Kopieren sowie die unbefugte Weitergabe dieser E-Mail ist nicht gestattet.

This e-mail may contain confidential and/or privileged information.
If you are not the intended recipient (or have received the e-mail in error)
please notify the sender immediately and delete this e-mail. Any unauthorized copying,
disclosure or distribution of the material in this e-mail is strictly forbidden.

**************************************************************************************************************

Fabian Hueske-2
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: GetExecutionPlan fails with IllegalArgumentException in Comparator

Fabian Hueske-2
Hi Julian,

I searched for the issue in JIRA [1] but did not find a corresponding issue.
Could you open an issue for this bug?

Thank you,
Fabian

[1] https://issues.apache.org/jira/projects/FLINK/summary

2018-01-22 14:11 GMT+01:00 Bauss, Julian <[hidden email]>:

Hello everybody,

 

we‘re currently encountering an exception while generating an ExecutionGraph JSON in Flink v1.3.2.

Actually executing the job does not cause an exception and everything works as inteded.

 

This happens since we started adding side-outputs to many of our operators.

 

Is this already a known bug?

 

Below is the stacktrace. The problem seems to be a contract violation in the comparator implementation.

 

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.

        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:545)

        at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:419)

        at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:381)

        at org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:838)

        at org.apache.flink.client.CliFrontend.run(CliFrontend.java:259)

        at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1086)

        at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1133)

        at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1130)

        at org.apache.flink.runtime.security.HadoopSecurityContext$1.run(HadoopSecurityContext.java:43)

        at java.security.AccessController.doPrivileged(Native Method)

        at javax.security.auth.Subject.doAs(Subject.java:422)

        at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1656)

        at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:40)

        at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1130)

Caused by: java.lang.RuntimeException: JSON plan creation failed

        at org.apache.flink.streaming.api.graph.StreamGraph.getStreamingPlanAsJSON(StreamGraph.java:668)

        at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getExecutionPlan(StreamExecutionEnvironment.java:1538)

        at com.example.Main.main(Main.java:262)

        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

        at java.lang.reflect.Method.invoke(Method.java:498)

        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:528)

        ... 13 more

Caused by: java.lang.IllegalArgumentException: Comparison method violates its general contract!

        at java.util.TimSort.mergeLo(TimSort.java:777)

        at java.util.TimSort.mergeAt(TimSort.java:514)

        at java.util.TimSort.mergeCollapse(TimSort.java:441)

        at java.util.TimSort.sort(TimSort.java:245)

        at java.util.Arrays.sort(Arrays.java:1512)

        at java.util.ArrayList.sort(ArrayList.java:1454)

        at java.util.Collections.sort(Collections.java:175)

        at org.apache.flink.streaming.api.graph.JSONGenerator.getJSON(JSONGenerator.java:60)

        at org.apache.flink.streaming.api.graph.StreamGraph.getStreamingPlanAsJSON(StreamGraph.java:665)

        ... 21 more

 

Best Regards,

 

Julian



**************************************************************************************************************

bonprix Handelsgesellschaft mbH
Sitz der Gesellschaft: Hamburg

Geschäftsführung:
Markus Fuchshofen
Dr. Richard Gottwald
Dr. Kai Heck
Rien Jansen
Beiratsvorsitzender: Dr. Marcus Ackermann

Handelsregister AG Hamburg HR B 36 455

Adresse:

bonprix Handelsgesellschaft mbH

Haldesdorfer Str. 61
22179 Hamburg

Diese E-Mail enthält vertrauliche und/oder rechtlich geschützte Informationen.
Wenn Sie nicht der richtige Adressat sind oder diese E-Mail irrtümlich erhalten haben,
informieren Sie bitte sofort den Absender und vernichten Sie diese Mail.
Das unerlaubte Kopieren sowie die unbefugte Weitergabe dieser E-Mail ist nicht gestattet.

This e-mail may contain confidential and/or privileged information.
If you are not the intended recipient (or have received the e-mail in error)
please notify the sender immediately and delete this e-mail. Any unauthorized copying,
disclosure or distribution of the material in this e-mail is strictly forbidden.

**************************************************************************************************************


Bauss, Julian
Reply | Threaded
Open this post in threaded view
♦
♦
|

AW: GetExecutionPlan fails with IllegalArgumentException in Comparator

Bauss, Julian

Hi Fabian,

 

sure!

 

See: https://issues.apache.org/jira/browse/FLINK-8498

 

Best Regards,

 

Julian

 

Von: Fabian Hueske [mailto:[hidden email]]
Gesendet: Montag, 22. Januar 2018 14:42
An: Bauss, Julian <[hidden email]>
Cc: [hidden email]
Betreff: Re: GetExecutionPlan fails with IllegalArgumentException in Comparator

 

Hi Julian,

I searched for the issue in JIRA [1] but did not find a corresponding issue.

Could you open an issue for this bug?

Thank you,

Fabian

[1] https://issues.apache.org/jira/projects/FLINK/summary

 

2018-01-22 14:11 GMT+01:00 Bauss, Julian <[hidden email]>:

Hello everybody,

 

we‘re currently encountering an exception while generating an ExecutionGraph JSON in Flink v1.3.2.

Actually executing the job does not cause an exception and everything works as inteded.

 

This happens since we started adding side-outputs to many of our operators.

 

Is this already a known bug?

 

Below is the stacktrace. The problem seems to be a contract violation in the comparator implementation.

 

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.

        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:545)

        at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:419)

        at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:381)

        at org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:838)

        at org.apache.flink.client.CliFrontend.run(CliFrontend.java:259)

        at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1086)

        at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1133)

        at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1130)

        at org.apache.flink.runtime.security.HadoopSecurityContext$1.run(HadoopSecurityContext.java:43)

        at java.security.AccessController.doPrivileged(Native Method)

        at javax.security.auth.Subject.doAs(Subject.java:422)

        at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1656)

        at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:40)

        at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1130)

Caused by: java.lang.RuntimeException: JSON plan creation failed

        at org.apache.flink.streaming.api.graph.StreamGraph.getStreamingPlanAsJSON(StreamGraph.java:668)

        at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getExecutionPlan(StreamExecutionEnvironment.java:1538)

        at com.example.Main.main(Main.java:262)

        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

        at java.lang.reflect.Method.invoke(Method.java:498)

        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:528)

        ... 13 more

Caused by: java.lang.IllegalArgumentException: Comparison method violates its general contract!

        at java.util.TimSort.mergeLo(TimSort.java:777)

        at java.util.TimSort.mergeAt(TimSort.java:514)

        at java.util.TimSort.mergeCollapse(TimSort.java:441)

        at java.util.TimSort.sort(TimSort.java:245)

        at java.util.Arrays.sort(Arrays.java:1512)

        at java.util.ArrayList.sort(ArrayList.java:1454)

        at java.util.Collections.sort(Collections.java:175)

        at org.apache.flink.streaming.api.graph.JSONGenerator.getJSON(JSONGenerator.java:60)

        at org.apache.flink.streaming.api.graph.StreamGraph.getStreamingPlanAsJSON(StreamGraph.java:665)

        ... 21 more

 

Best Regards,

 

Julian



**************************************************************************************************************

bonprix Handelsgesellschaft mbH
Sitz der Gesellschaft: Hamburg

Geschäftsführung:
Markus Fuchshofen
Dr. Richard Gottwald
Dr. Kai Heck
Rien Jansen
Beiratsvorsitzender: Dr. Marcus Ackermann

Handelsregister AG Hamburg HR B 36 455

Adresse:

bonprix Handelsgesellschaft mbH

<a href="https://maps.google.com/?q=Haldesdorfer&#43;Str.&#43;61&#43;%0D&#43;22179&#43;Hamburg&amp;entry=gmail&amp;source=g">Haldesdorfer Str. 61
22179 Hamburg

Diese E-Mail enthält vertrauliche und/oder rechtlich geschützte Informationen.
Wenn Sie nicht der richtige Adressat sind oder diese E-Mail irrtümlich erhalten haben,
informieren Sie bitte sofort den Absender und vernichten Sie diese Mail.
Das unerlaubte Kopieren sowie die unbefugte Weitergabe dieser E-Mail ist nicht gestattet.

This e-mail may contain confidential and/or privileged information.
If you are not the intended recipient (or have received the e-mail in error)
please notify the sender immediately and delete this e-mail. Any unauthorized copying,
disclosure or distribution of the material in this e-mail is strictly forbidden.

**************************************************************************************************************

 



**************************************************************************************************************

bonprix Handelsgesellschaft mbH
Sitz der Gesellschaft: Hamburg

Geschäftsführung:
Markus Fuchshofen
Dr. Richard Gottwald
Dr. Kai Heck
Rien Jansen
Beiratsvorsitzender: Dr. Marcus Ackermann

Handelsregister AG Hamburg HR B 36 455

Adresse:

bonprix Handelsgesellschaft mbH

Haldesdorfer Str. 61
22179 Hamburg

Diese E-Mail enthält vertrauliche und/oder rechtlich geschützte Informationen.
Wenn Sie nicht der richtige Adressat sind oder diese E-Mail irrtümlich erhalten haben,
informieren Sie bitte sofort den Absender und vernichten Sie diese Mail.
Das unerlaubte Kopieren sowie die unbefugte Weitergabe dieser E-Mail ist nicht gestattet.

This e-mail may contain confidential and/or privileged information.
If you are not the intended recipient (or have received the e-mail in error)
please notify the sender immediately and delete this e-mail. Any unauthorized copying,
disclosure or distribution of the material in this e-mail is strictly forbidden.

**************************************************************************************************************

Fabian Hueske-2
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: GetExecutionPlan fails with IllegalArgumentException in Comparator

Fabian Hueske-2
Great! Thank you :-)

2018-01-23 17:58 GMT+01:00 Bauss, Julian <[hidden email]>:

Hi Fabian,

 

sure!

 

See: https://issues.apache.org/jira/browse/FLINK-8498

 

Best Regards,

 

Julian

 

Von: Fabian Hueske [mailto:[hidden email]]
Gesendet: Montag, 22. Januar 2018 14:42
An: Bauss, Julian <[hidden email]>
Cc: [hidden email]
Betreff: Re: GetExecutionPlan fails with IllegalArgumentException in Comparator

 

Hi Julian,

I searched for the issue in JIRA [1] but did not find a corresponding issue.

Could you open an issue for this bug?

Thank you,

Fabian

[1] https://issues.apache.org/jira/projects/FLINK/summary

 

2018-01-22 14:11 GMT+01:00 Bauss, Julian <[hidden email]>:

Hello everybody,

 

we‘re currently encountering an exception while generating an ExecutionGraph JSON in Flink v1.3.2.

Actually executing the job does not cause an exception and everything works as inteded.

 

This happens since we started adding side-outputs to many of our operators.

 

Is this already a known bug?

 

Below is the stacktrace. The problem seems to be a contract violation in the comparator implementation.

 

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.

        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:545)

        at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:419)

        at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:381)

        at org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:838)

        at org.apache.flink.client.CliFrontend.run(CliFrontend.java:259)

        at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1086)

        at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1133)

        at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1130)

        at org.apache.flink.runtime.security.HadoopSecurityContext$1.run(HadoopSecurityContext.java:43)

        at java.security.AccessController.doPrivileged(Native Method)

        at javax.security.auth.Subject.doAs(Subject.java:422)

        at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1656)

        at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:40)

        at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1130)

Caused by: java.lang.RuntimeException: JSON plan creation failed

        at org.apache.flink.streaming.api.graph.StreamGraph.getStreamingPlanAsJSON(StreamGraph.java:668)

        at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getExecutionPlan(StreamExecutionEnvironment.java:1538)

        at com.example.Main.main(Main.java:262)

        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

        at java.lang.reflect.Method.invoke(Method.java:498)

        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:528)

        ... 13 more

Caused by: java.lang.IllegalArgumentException: Comparison method violates its general contract!

        at java.util.TimSort.mergeLo(TimSort.java:777)

        at java.util.TimSort.mergeAt(TimSort.java:514)

        at java.util.TimSort.mergeCollapse(TimSort.java:441)

        at java.util.TimSort.sort(TimSort.java:245)

        at java.util.Arrays.sort(Arrays.java:1512)

        at java.util.ArrayList.sort(ArrayList.java:1454)

        at java.util.Collections.sort(Collections.java:175)

        at org.apache.flink.streaming.api.graph.JSONGenerator.getJSON(JSONGenerator.java:60)

        at org.apache.flink.streaming.api.graph.StreamGraph.getStreamingPlanAsJSON(StreamGraph.java:665)

        ... 21 more

 

Best Regards,

 

Julian



**************************************************************************************************************

bonprix Handelsgesellschaft mbH
Sitz der Gesellschaft: Hamburg

Geschäftsführung:
Markus Fuchshofen
Dr. Richard Gottwald
Dr. Kai Heck
Rien Jansen
Beiratsvorsitzender: Dr. Marcus Ackermann

Handelsregister AG Hamburg HR B 36 455

Adresse:

bonprix Handelsgesellschaft mbH

Haldesdorfer Str. 61
22179 Hamburg

Diese E-Mail enthält vertrauliche und/oder rechtlich geschützte Informationen.
Wenn Sie nicht der richtige Adressat sind oder diese E-Mail irrtümlich erhalten haben,
informieren Sie bitte sofort den Absender und vernichten Sie diese Mail.
Das unerlaubte Kopieren sowie die unbefugte Weitergabe dieser E-Mail ist nicht gestattet.

This e-mail may contain confidential and/or privileged information.
If you are not the intended recipient (or have received the e-mail in error)
please notify the sender immediately and delete this e-mail. Any unauthorized copying,
disclosure or distribution of the material in this e-mail is strictly forbidden.

**************************************************************************************************************

 



**************************************************************************************************************

bonprix Handelsgesellschaft mbH
Sitz der Gesellschaft: Hamburg

Geschäftsführung:
Markus Fuchshofen
Dr. Richard Gottwald
Dr. Kai Heck
Rien Jansen
Beiratsvorsitzender: Dr. Marcus Ackermann

Handelsregister AG Hamburg HR B 36 455

Adresse:

bonprix Handelsgesellschaft mbH

Haldesdorfer Str. 61
22179 Hamburg

Diese E-Mail enthält vertrauliche und/oder rechtlich geschützte Informationen.
Wenn Sie nicht der richtige Adressat sind oder diese E-Mail irrtümlich erhalten haben,
informieren Sie bitte sofort den Absender und vernichten Sie diese Mail.
Das unerlaubte Kopieren sowie die unbefugte Weitergabe dieser E-Mail ist nicht gestattet.

This e-mail may contain confidential and/or privileged information.
If you are not the intended recipient (or have received the e-mail in error)
please notify the sender immediately and delete this e-mail. Any unauthorized copying,
disclosure or distribution of the material in this e-mail is strictly forbidden.

**************************************************************************************************************


Chesnay Schepler
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: GetExecutionPlan fails with IllegalArgumentException in Comparator

Chesnay Schepler
@Julian Could you provide an example job to reproduce this? (Can also be shared privately)

On 23.01.2018 18:05, Fabian Hueske wrote:
Great! Thank you :-)

2018-01-23 17:58 GMT+01:00 Bauss, Julian <[hidden email]>:

Hi Fabian,

 

sure!

 

See: https://issues.apache.org/jira/browse/FLINK-8498

 

Best Regards,

 

Julian

 

Von: Fabian Hueske [mailto:[hidden email]]
Gesendet: Montag, 22. Januar 2018 14:42
An: Bauss, Julian <[hidden email]>
Cc: [hidden email]
Betreff: Re: GetExecutionPlan fails with IllegalArgumentException in Comparator

 

Hi Julian,

I searched for the issue in JIRA [1] but did not find a corresponding issue.

Could you open an issue for this bug?

Thank you,

Fabian

[1] https://issues.apache.org/jira/projects/FLINK/summary

 

2018-01-22 14:11 GMT+01:00 Bauss, Julian <[hidden email]>:

Hello everybody,

 

we‘re currently encountering an exception while generating an ExecutionGraph JSON in Flink v1.3.2.

Actually executing the job does not cause an exception and everything works as inteded.

 

This happens since we started adding side-outputs to many of our operators.

 

Is this already a known bug?

 

Below is the stacktrace. The problem seems to be a contract violation in the comparator implementation.

 

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.

        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:545)

        at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:419)

        at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:381)

        at org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:838)

        at org.apache.flink.client.CliFrontend.run(CliFrontend.java:259)

        at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1086)

        at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1133)

        at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1130)

        at org.apache.flink.runtime.security.HadoopSecurityContext$1.run(HadoopSecurityContext.java:43)

        at java.security.AccessController.doPrivileged(Native Method)

        at javax.security.auth.Subject.doAs(Subject.java:422)

        at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1656)

        at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:40)

        at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1130)

Caused by: java.lang.RuntimeException: JSON plan creation failed

        at org.apache.flink.streaming.api.graph.StreamGraph.getStreamingPlanAsJSON(StreamGraph.java:668)

        at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getExecutionPlan(StreamExecutionEnvironment.java:1538)

        at com.example.Main.main(Main.java:262)

        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

        at java.lang.reflect.Method.invoke(Method.java:498)

        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:528)

        ... 13 more

Caused by: java.lang.IllegalArgumentException: Comparison method violates its general contract!

        at java.util.TimSort.mergeLo(TimSort.java:777)

        at java.util.TimSort.mergeAt(TimSort.java:514)

        at java.util.TimSort.mergeCollapse(TimSort.java:441)

        at java.util.TimSort.sort(TimSort.java:245)

        at java.util.Arrays.sort(Arrays.java:1512)

        at java.util.ArrayList.sort(ArrayList.java:1454)

        at java.util.Collections.sort(Collections.java:175)

        at org.apache.flink.streaming.api.graph.JSONGenerator.getJSON(JSONGenerator.java:60)

        at org.apache.flink.streaming.api.graph.StreamGraph.getStreamingPlanAsJSON(StreamGraph.java:665)

        ... 21 more

 

Best Regards,

 

Julian



**************************************************************************************************************

bonprix Handelsgesellschaft mbH
Sitz der Gesellschaft: Hamburg

Geschäftsführung:
Markus Fuchshofen
Dr. Richard Gottwald
Dr. Kai Heck
Rien Jansen
Beiratsvorsitzender: Dr. Marcus Ackermann

Handelsregister AG Hamburg HR B 36 455

Adresse:

bonprix Handelsgesellschaft mbH

Haldesdorfer Str. 61
22179 Hamburg

Diese E-Mail enthält vertrauliche und/oder rechtlich geschützte Informationen.
Wenn Sie nicht der richtige Adressat sind oder diese E-Mail irrtümlich erhalten haben,
informieren Sie bitte sofort den Absender und vernichten Sie diese Mail.
Das unerlaubte Kopieren sowie die unbefugte Weitergabe dieser E-Mail ist nicht gestattet.

This e-mail may contain confidential and/or privileged information.
If you are not the intended recipient (or have received the e-mail in error)
please notify the sender immediately and delete this e-mail. Any unauthorized copying,
disclosure or distribution of the material in this e-mail is strictly forbidden.

**************************************************************************************************************

 



**************************************************************************************************************

bonprix Handelsgesellschaft mbH
Sitz der Gesellschaft: Hamburg

Geschäftsführung:
Markus Fuchshofen
Dr. Richard Gottwald
Dr. Kai Heck
Rien Jansen
Beiratsvorsitzender: Dr. Marcus Ackermann

Handelsregister AG Hamburg HR B 36 455

Adresse:

bonprix Handelsgesellschaft mbH

Haldesdorfer Str. 61
22179 Hamburg

Diese E-Mail enthält vertrauliche und/oder rechtlich geschützte Informationen.
Wenn Sie nicht der richtige Adressat sind oder diese E-Mail irrtümlich erhalten haben,
informieren Sie bitte sofort den Absender und vernichten Sie diese Mail.
Das unerlaubte Kopieren sowie die unbefugte Weitergabe dieser E-Mail ist nicht gestattet.

This e-mail may contain confidential and/or privileged information.
If you are not the intended recipient (or have received the e-mail in error)
please notify the sender immediately and delete this e-mail. Any unauthorized copying,
disclosure or distribution of the material in this e-mail is strictly forbidden.

**************************************************************************************************************



Free forum by Nabble Edit this page