您遇到了表api的一个当前限制：无法将水印和行时属性与 forValues 方法；你需要一个连接器。有两种解决方法：
1.使用 csv 你和你的 VALUES ，如本例所示。
2.使用内置的datagen连接器。既然您正在为cep准备一个单元测试，我想您需要对生成的数据进行某种程度的控制，所以这可能不是一个可行的选择。我想我还是提一下。
注意：建议使用SQLDDL语法从Flink1.10创建表。这将使您要做的两件事（即定义水印和命名表）更加简单：

tEnv.executeSql("CREATE TABLE table_name (\n" +
                "             event_time TIMESTAMP(3),\n" +
                "             foobar STRING \n" +
                "             WATERMARK FOR event_time AS event_time\n" +
                ") WITH (...)"
);

Table data = tEnv.from("table_name");

水印声明为计算列，并且可以选择使用多种水印策略。有关详细信息，请查看此文档页。