[
https://issues.apache.org/jira/browse/FLINK-35533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18041023#comment-18041023
]
Xin Chen commented on FLINK-35533:
----------------------------------
{code:java}
Caused by: java.lang.NullPointerException
at
org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:59)
at
org.apache.flink.runtime.io.network.partition.ResultPartitionFactory.create(ResultPartitionFactory.java:267)
at
org.apache.flink.runtime.io.network.partition.ResultPartitionFactory.create(ResultPartitionFactory.java:137)
at
org.apache.flink.runtime.io.network.NettyShuffleEnvironment.createResultPartitionWriters(NettyShuffleEnvironment.java:235)
at org.apache.flink.runtime.taskmanager.Task.<init>(Task.java:416)
at
org.apache.flink.runtime.taskexecutor.TaskExecutor.submitTask(TaskExecutor.java:863)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRpcInvocation$1(PekkoRpcActor.java:318)
at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcInvocation(PekkoRpcActor.java:316)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:229)
{code}
[~Weijie Guo] Sry，I used “config.setString("execution.batch-shuffle-mode",
"ALL_EXCHANGES_HYBRID_FULL");” or ALL_EXCHANGES_HYBRID_SELECTIVE， but has above
exception， what mistake is it， Please. Flink version is 2.0.0.
> FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn
> -----------------------------------------------------------------------
>
> Key: FLINK-35533
> URL: https://issues.apache.org/jira/browse/FLINK-35533
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Network
> Affects Versions: 1.20.0
> Reporter: Yuxin Tan
> Assignee: Yuxin Tan
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.20.0
>
>
> This is the jira for
> [FLIP-459|https://cwiki.apache.org/confluence/display/FLINK/FLIP-459%3A+Support+Flink+hybrid+shuffle+integration+with+Apache+Celeborn].
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
