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

BatchTestBase doesn't actually use MiniClusterExtension

    XMLWordPrintableJSON

Details

    Description

      BatchTestBase sets up a table environment in instance fields, which runs before the BeforeEachCallback from the MiniClusterExtension has time to run.
      As a result the table environment internally creates a local stream environment, due to which all test extending the BatchTestBase are spawning separate mini clusters for every single job.

      I believe this is on reason why we had troubles with enabling fork-reuse in the planner module

      Attachments

        Activity

          People

            chesnay Chesnay Schepler
            chesnay Chesnay Schepler
            Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: