你好,为什么我这边把你的代码复制过来报错呢?麻烦帮忙看看,包和依赖都导入了
你的包是不是导错了。删除你导入的包,把下面的包复制放你程序中。
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.streaming.api.TimeCharacteristic;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.kafka.Kafka09TableSource;
import org.apache.flink.streaming.util.serialization.*;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableEnvironment;
import org.apache.flink.table.api.Types;
import org.apache.flink.table.api.java.StreamTableEnvironment;
import org.apache.flink.table.sources.TableSource;
import org.apache.flink.types.Row;
import java.util.Properties;
你的能启动嘛?我的怎么报错了