Hi Marjan,
That's rather weird, because PyFlink uses the same implementation. Could
you file a Jira ticket? If not, let me know and I'll create one for you.
Best regards,
Martijn
On Thu, Dec 22, 2022 at 11:37 AM Marjan Jordanovski
wrote:
> Hello,
>
> I am using custom made connector to create
Hello,
I am using custom made connector to create Source table in this way:
create table Source (
ts TIMESTAMP(3),
instance STRING,
sservice STRING,
logdatetime STRING,
threadid STRING,
level STRING,
log_line STRING
) with (
