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
&
e 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,RongOn Fri, Jun 1, 2018 at 9:09 AM, Radhya
> Sahal <
> radhya.sahal@
> > wrote:> Hi,
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
>
> On
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 stat
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/
