Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-7420

Including the Flink runner causes exceptions unless running in a flink environment

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • None
    • 2.16.0
    • runner-flink
    • None

    Description

      The FlinkPipelineOptions imports various Flink enums which make it impossible to e.g. run the direct runner with the same classpath but without the flink runtime. The fix is potentially easy - make the arguments strings and convert them to enums at the callsites.

      Attachments

        Issue Links

          relates to

          Improvement - An improvement or enhancement to an existing feature or task. BEAM-7544 [workaround available] Please provide a build against scala 2.12 for Flink runner

          • P3 - Non-urgent bugs, features, and improvements
          • Resolved
          links to

          Web Link GitHub Pull Request #8894

          Activity

            People

              mxm Maximilian Michels
              mikekap Mike Kaplinskiy
              Votes:
              0 Vote for this issue
              Watchers:
              2 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 - 2.5h
                  2.5h