官方文档:
Real Time Reporting with the Table API #
问题处理:
单机Flink TaskExecutor no more allocated slots 问题解决
Kafka + Flink 出现异常 java.lang.NoClassDefFoundError: org/apache/flink/streaming/util/serialization/DeserializationSchema