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

Distributed caches are not registered in Yarn Per Job Cluster Mode

    XMLWordPrintableJSON

    Details

      Description

      CacheFiles in StreamExecutionEnvironment is not used in Job Submission in the Yarn per job cluster mode. Compare to the job submission in session cluster mode that will upload distributed cache files onto http server in application master, we should get the cache files in job graph and register them into blob store in YarnJobClusterEntrypoint.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                ZhenqiuHuang Zhenqiu Huang
                Reporter:
                ZhenqiuHuang Zhenqiu Huang
              • Votes:
                0 Vote for this issue
                Watchers:
                7 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m