FlinkFlink 流API 和 Table 以及 SQL API是否可以共存

Posted 2021-09-10 九师兄

1.概述

因为项目需要，所以想测试如何在两种API混用

/**
     * 测试点：测试同时跑2个pipline 一个是SQL的 一个是dataStream的能不能共存，以及其中一个报错会怎么样
     *
     * 测试结果：
     *   2种流结果是可以共存的
     *
     * @throws Exception
     */
    @Test
    public void sqlAndStram() throws Exception {