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

Executing query in SQL client results in "java.lang.ClassNotFoundException: org.apache.flink.core.execution.RestoreMode"

    XMLWordPrintableJSON

Details

    Description

      Tested with Flink 1.20 RC0

      Reproducer:

      CREATE TABLE `product` (
          id INT,
          brandId INT,
          PRIMARY KEY (id) NOT ENFORCED
      ) WITH (
          'connector' = 'datagen',
          'rows-per-second' = '10',
          'fields.id.kind' = 'random',
          'fields.brandId.min' = '1',
          'fields.brandId.max' = '100'
      );
      

      Followed by:

      SELECT * FROM product
      

      Results in:
      [ERROR] Could not execute SQL statement. Reason:
      java.lang.ClassNotFoundException: org.apache.flink.core.execution.RestoreMode

      Attachments

        Activity

          People

            Unassigned Unassigned
            martijnvisser Martijn Visser
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: