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

reuse MiniCluster in table integration test class ?

    XMLWordPrintableJSON

Details

    Description

      before 1.11, MiniCluster can be reused in each integration test class. (see TestStreamEnvironment#setAsContext)
      In 1.11, after we correct the execution behavior of TableEnvironment, StreamTableEnvironment and BatchTableEnvironment (see FLINK-16363, FLINK-17126), MiniCluster will be created for each test case even in same test class (see org.apache.flink.client.deployment.executors.LocalExecutor). It's better we can reuse MiniCluster like before. One approach is we provide a new kind of MiniCluster factory (such as: SessionMiniClusterFactory) instead of using PerJobMiniClusterFactory. WDYT ?

      Attachments

        Activity

          People

            Unassigned Unassigned
            godfreyhe godfrey he
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated: