Re: Getting JSON kafka source parsing error with DDL

2022-05-11 Thread Shubham Bansal
Never mind. Figured out. Wrong connector arguments. On Tue, May 10, 2022 at 11:19 PM Shubham Bansal < shubham.bansal2...@gmail.com> wrote: > Hi Everyone, > > I am trying to fix the flink-playground for version 1.14.4 and was working > on fixing pyflink-walkthrough and I getting following error >

Getting JSON kafka source parsing error with DDL

2022-05-10 Thread Shubham Bansal
Hi Everyone, I am trying to fix the flink-playground for version 1.14.4 and was working on fixing pyflink-walkthrough and I getting following error Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.