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

Chained streaming operators should not throw chained exceptions

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.3.0
    • Component/s: DataStream API
    • Labels:
      None

      Description

      The exceptions that come from chained operators have an non-intuitive chaining structure, that makes the stack traces harder to understand.

      For every chained task, there is a "Failed to forward record" exception, before the actual exception comes as a cause.

      In the Batch API, we use a special "ExceptionInChainedStubException" that is recognized and un-nested to make chained operator exceptions surface as root exceptions.

      We should do the same for the streaming API.

        Activity

        Hide
        StephanEwen Stephan Ewen added a comment -

        Fixed via 6181302f1ab741b86af357e4513f5952a5fc1531

        Show
        StephanEwen Stephan Ewen added a comment - Fixed via 6181302f1ab741b86af357e4513f5952a5fc1531

          People

          • Assignee:
            StephanEwen Stephan Ewen
            Reporter:
            StephanEwen Stephan Ewen
          • Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development