Thanks a lot.
On Thu, May 2, 2019, 9:59 AM David Anderson wrote:
> There are some step-by-step instructions for setting up the sql client in
> https://training.ververica.com/setup/sqlClient.html, plus some examples.
>
gt; * @param jsonSchema The schema of the JSON messages to decode from
> Kafka.
> */
>
> Also, your type definition: TypeInformation
>
> typeInfo2 = Types.ROW(...
> arguments seem to have different length for schema names and types.
>
> Thanks,
> Rong
>
>
gt; * @param jsonSchema The schema of the JSON messages to decode from
> Kafka.
> */
>
> Also, your type definition: TypeInformation
>
> typeInfo2 = Types.ROW(...
> arguments seem to have different length for schema names and types.
>
> Thanks,
> Rong
>
>
Hi,
Could anyone help me to solve this problem
/Exception in thread "main" java.lang.Error: Unresolved compilation problem:
The constructor Kafka09JsonTableSource(String, Properties,
TypeInformation) is undefined
/
*--This is the code *
public class FlinkKafkaSQL {
public
1.4.0
org.apache.flink
flink-streaming-scala_2.11
1.4.0
Regards.
Radhya Sahal
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
