已经创建issue: https://issues.apache.org/jira/browse/FLINK-15563
Kurt Young 于2020年1月8日周三 下午5:33写道：
> 如果是优化器一直卡住不能退出，那基本肯定是BUG了。请开一个issue把这些信息上传上去吧，我们会调查一下是什么问题导致的。
>
> Best,
> Kurt
>
>
> On Wed, Jan 8, 2020 at 5:12 PM jun su wrote:
>
> > 添加代码文字:
> >
> > def main(args: Array[String]): Unit = {
> >
如果是优化器一直卡住不能退出，那基本肯定是BUG了。请开一个issue把这些信息上传上去吧，我们会调查一下是什么问题导致的。
Best,
Kurt
On Wed, Jan 8, 2020 at 5:12 PM jun su wrote:
> 添加代码文字:
>
> def main(args: Array[String]): Unit = {
>
> val env = StreamExecutionEnvironment.getExecutionEnvironment
>
添加代码文字:
def main(args: Array[String]): Unit = {
val env = StreamExecutionEnvironment.getExecutionEnvironment
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
val tableEnv = StreamTableEnvironment.create(env)
val schema =
