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

Hardcoded paths in flink-python/.../PythonPlanBinder.java

    Details

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

      Description

      The PythonPlanBinder.java contains three hardcoded filesystem paths:

      public static final String FLINK_PYTHON_FILE_PATH = System.getProperty("java.io.tmpdir") + File.separator + "flink_plan";
      
      private static String FLINK_HDFS_PATH = "hdfs:/tmp";
      public static final String FLINK_TMP_DATA_DIR = System.getProperty("java.io.tmpdir") + File.separator + "flink_data";
      

      FLINK_PYTHON_FILE_PATH and FLINK_TMP_DATA_DIR are configurable by modifying java.io.tmpdir.
      For FLINK_HDFS_PATH, there is no way of configuring otherwise but modifying the source.

      Is it possible to make all three parameters configurable in the usual flink configuration files (like flink-conf.yaml)?

        Attachments

          Activity

            People

            • Assignee:
              Zentol Chesnay Schepler
              Reporter:
              felxe Felix seibert
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: