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

State backend class cannot be loaded, because fully qualified name converted to lower-case

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: 1.1.2
    • Fix Version/s: 1.2.0, 1.1.3
    • Labels:
      None
    • Environment:

      Debian Linux and Mac OS X

      Description

      The name of the state backend in the configuration file ist converted to lower-case (see https://github.com/eBay/Flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L587).

      Therefore, the class cannot be found, and the state backend (e.g., RocksDB) is not loaded properly (see https://github.com/eBay/Flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L603).

        Activity

        Hide
        StephanEwen Stephan Ewen added a comment -

        Will look into this...

        Show
        StephanEwen Stephan Ewen added a comment - Will look into this...
        Hide
        StephanEwen Stephan Ewen added a comment -

        1.1.3 fix in d619f51ac8f922c0cf1d1e789c5141076128f04e

        Show
        StephanEwen Stephan Ewen added a comment - 1.1.3 fix in d619f51ac8f922c0cf1d1e789c5141076128f04e
        Hide
        florian.koenig Florian Koenig added a comment -
        Show
        florian.koenig Florian Koenig added a comment - Thanks for the quick fix! Sorry about the links to the wrong repository in the original description. For the record, here are the correct links to the mentioned locations in the code (at the time of the submission): https://github.com/apache/flink/blob/0dac7ad00a25c4b038b57009f41f5512f8ce73c3/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L755 https://github.com/apache/flink/blob/0dac7ad00a25c4b038b57009f41f5512f8ce73c3/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L773
        Hide
        StephanEwen Stephan Ewen added a comment -

        Fixed in

        • 1.1.3 via d619f51ac8f922c0cf1d1e789c5141076128f04e
        • 1.2.0 via 9e17cbd6b768f73299a6a344fdf44539802fb76c
        Show
        StephanEwen Stephan Ewen added a comment - Fixed in 1.1.3 via d619f51ac8f922c0cf1d1e789c5141076128f04e 1.2.0 via 9e17cbd6b768f73299a6a344fdf44539802fb76c

          People

          • Assignee:
            StephanEwen Stephan Ewen
            Reporter:
            florian.koenig Florian Koenig
          • Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development