Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-5275

InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 1.1.4, 1.2.0
    • Runtime / Network
    • None

    Description

      Reported by rmetzger. While creating the input channel deployment descriptors for a job that does not allow lazy deployment (all streaming jobs), Robert got an ExecutionGraphException with the message Trying to eagerly schedule a task whose inputs are not ready in the InputChannelDeploymentDescriptor.

      This was not reported as the root cause and is most likely due to a failed producer. For such cases, it makes sense to include the execution state of the producing task so that users see that this is related to the producer.

      Attachments

        Activity

          People

            uce Ufuk Celebi
            uce Ufuk Celebi
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: