Exception : Table of atomic type can only have a single field, when transferring DataStream to Table ?

Hi， I‘m confused about a problem, occuring a exception "org.apache.flink.table.api.TableException: Table of atomic type can only have a single field." Both BillCount and Record are class object. Following is code. case class BillCount(logisId: Int, provinceId: Int, ci

RE: Flink kafka consumer that read from two partitions in local mode

Thank you Fabian. Fabian, Gordon, am I missing something in consumer setup? Should I configure consumer in some way to subscribe to two partitions? Thanks and regards, Tovi From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: יום ג 19 ספטמבר 2017 22:58 To: Sofer, Tovi [ICG-IT] Cc: user; Tzu-Li (