[jira] [Created] (FLINK-7674) NullPointerException in ContinuousFileMonitoringFunction close

["Ufuk Celebi (JIRA)" <ji...@apache.org>]

Ufuk Celebi created FLINK-7674:
----------------------------------

             Summary: NullPointerException in ContinuousFileMonitoringFunction close
                 Key: FLINK-7674
                 URL: https://issues.apache.org/jira/browse/FLINK-7674
             Project: Flink
          Issue Type: Bug
          Components: Streaming Connectors
    Affects Versions: 1.4.0
            Reporter: Ufuk Celebi
            Priority: Minor


If the ContinuousFileMonitoringFunction is closed before run is called (because initialization fails), we get a NullPointerException, because checkpointLock has not been set.

{code}
synchronized (checkpointLock) {
  globalModificationTime = Long.MAX_VALUE;
  isRunning = false;
}
{code}

This results in a follow up error log:
{code}
2017-09-23 10:25:04,096 ERROR org.apache.flink.streaming.runtime.tasks.StreamTask           - Error during disposal of stream operator.
java.lang.NullPointerException
	at org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction.close(ContinuousFileMonitoringFunction.java:337)
	at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:43)
	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.dispose(AbstractUdfStreamOperator.java:126)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.disposeAllOperators(StreamTask.java:429)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:334)
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:702)
	at java.lang.Thread.run(Thread.java:748)
{code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)