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

LocalEnvironment is not initializing plugins

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.10.0
    • Fix Version/s: None
    • Component/s: Runtime / Task
    • Labels:
      None

      Description

      Currently, plugins cannot be used in `LocalEnvironment` as `FileSystem`s are only initialized without `PluginManager`. In all other environments, the plugin manager is initialized in `TaskManagerRunner`.

       

      That means unless a user manually adds

         final Configuration configuration = new Configuration();
         FileSystem.initialize(configuration, PluginUtils.createPluginManagerFromRootFolder(configuration));
      

      to his entry point, he cannot use plugins, which means no s3 filesystems after FLINK-11956.

      We should add the proper initialization to the LocalExecutionEnvironment (at LocalExecutor?), so that the user does not have to it manually.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              arvid heise Arvid Heise
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: