[ https://issues.apache.org/jira/browse/FLINK-1922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14517389#comment-14517389 ]
ASF GitHub Bot commented on FLINK-1922: --------------------------------------- Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/631#discussion_r29262910 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskInputSplitProviderTest.java --- @@ -0,0 +1,93 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.flink.runtime.taskmanager; + +import akka.actor.ActorRef; +import akka.actor.ActorSystem; +import akka.actor.Props; +import akka.actor.Status; +import akka.actor.UntypedActor; +import akka.testkit.JavaTestKit; +import akka.util.Timeout; +import org.apache.flink.api.common.JobID; +import org.apache.flink.core.io.InputSplit; +import org.apache.flink.runtime.executiongraph.ExecutionAttemptID; +import org.apache.flink.runtime.jobgraph.JobVertexID; +import org.apache.flink.runtime.messages.JobManagerMessages; +import org.apache.flink.runtime.testingUtils.TestingUtils; +import org.junit.AfterClass; +import org.junit.BeforeClass; +import org.junit.Test; + +import static org.junit.Assert.*; + +import java.util.concurrent.TimeUnit; + +public class TaskInputSplitProviderTest { + + private static ActorSystem system; + + @BeforeClass + public static void setup() throws Exception { + system = ActorSystem.create("TestActorSystem", TestingUtils.testConfig()); + } + + @AfterClass + public static void teardown() throws Exception { + JavaTestKit.shutdownActorSystem(system); + system = null; + } + + @Test + public void testRequestNextInputSplitWithInvalidExecutionID() { + + final JobID jobID = new JobID(); + final JobVertexID vertexID = new JobVertexID(); + final ExecutionAttemptID executionID = new ExecutionAttemptID(); + final Timeout timeout = new Timeout(10, TimeUnit.SECONDS); + + final ActorRef jobManagerRef = system.actorOf(Props.create(NullInputSplitJobManager.class)); + + final TaskInputSplitProvider provider = new TaskInputSplitProvider( + jobManagerRef, + jobID, + vertexID, + executionID, + Thread.currentThread().getContextClassLoader(), --- End diff -- This is probably `null`, no? The default classloader can be grabbed either via. `Classloader.getSystemClassloader()` or here via `getClass().getClassloader()`. > Failed task deployment causes NPE on input split assignment > ----------------------------------------------------------- > > Key: FLINK-1922 > URL: https://issues.apache.org/jira/browse/FLINK-1922 > Project: Flink > Issue Type: Bug > Components: JobManager > Affects Versions: 0.9 > Reporter: Robert Metzger > Assignee: Till Rohrmann > > The input split assignment code is returning {null} if the Task has failed, > which is causing a NPE. > We should improve our error handling / reporting in that situation. > {code} > 13:12:31,002 INFO org.apache.flink.yarn.ApplicationMaster$$anonfun$2$$anon$1 > - Status of job c0b47ce41e9a85a628a628a3977705ef (Flink Java Job at Tue > Apr 21 13:10:36 UTC 2015) changed to FAILING Cannot deploy task - TaskManager > not responding.. > .... > 13:12:47,591 ERROR org.apache.flink.runtime.operators.RegularPactTask > - Error in task code: CHAIN DataSource (at userMethod > (org.apache.flink.api.java.io.AvroInputFormat)) -> FlatMap (FlatMap at > main(UserClass.java:111)) (20/50) > java.lang.RuntimeException: Requesting the next InputSplit failed. > at > org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:88) > at > org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:337) > at > org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:136) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:217) > at java.lang.Thread.run(Thread.java:744) > Caused by: java.lang.NullPointerException > at java.io.ByteArrayInputStream.<init>(ByteArrayInputStream.java:106) > at > org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:301) > at > org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:83) > ... 4 more > 13:12:47,595 INFO org.apache.flink.runtime.taskmanager.Task > - CHAIN DataSource (at SomeMethod > (org.apache.flink.api.java.io.AvroInputFormat)) -> FlatMap (FlatMap at > main(SomeClass.java:111)) (20/50) switched to FAILED : > java.lang.RuntimeException: Requesting the next InputSplit failed. > at > org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:88) > at > org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:337) > at > org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:136) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:217) > at java.lang.Thread.run(Thread.java:744) > Caused by: java.lang.NullPointerException > at java.io.ByteArrayInputStream.<init>(ByteArrayInputStream.java:106) > at > org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:301) > at > org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:83) > ... 4 more > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)