strange Flink SQL parser error

[Francis Conroy <fr...@switchdin.com>]

I've been using flink 1.13.5 with the Flink CDC (2.1.1) postgres connector
and I'm having some trouble with my data formats. For some reason the
parser seems to be expecting TIMESTAMP WITH LOCAL TIME ZONE. Have I done
this correctly? I'll try to create a table with just a UTC timestamp from
literals and see if that works.
[image: image.png]
Same result for the basic case..
[image: image.png]
Is this expected? The documentation seems fairly clear that this should
work.

Thanks,
Francis

-- 
This email and any attachments are proprietary and confidential and are 
intended solely for the use of the individual to whom it is addressed. Any 
views or opinions expressed are solely those of the author and do not 
necessarily reflect or represent those of SwitchDin Pty Ltd. If you have 
received this email in error, please let us know immediately by reply email 
and delete it from your system. You may not use, disseminate, distribute or 
copy this message nor disclose its contents to anyone. 
SwitchDin Pty Ltd 
(ABN 29 154893857) PO Box 1165, Newcastle NSW 2300 Australia

Re: strange Flink SQL parser error

[Jingsong Li <ji...@gmail.com>]

I think you can just use TIMESTAMP. TIMESTAMP type is a timestamp without
timezone, it is something similar to UTC.

[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#timestamp

On Wed, Jan 19, 2022 at 10:21 AM Jingsong Li <ji...@gmail.com> wrote:

> Hi,
>
> Currently flink-sql does not support this type, the document and the error
> message can be improved.
>
> Best,
> Jingsong
>
> On Wed, Jan 19, 2022 at 8:05 AM Francis Conroy <
> francis.conroy@switchdin.com> wrote:
>
>> I've been using flink 1.13.5 with the Flink CDC (2.1.1) postgres
>> connector and I'm having some trouble with my data formats. For some reason
>> the parser seems to be expecting TIMESTAMP WITH LOCAL TIME ZONE. Have I
>> done this correctly? I'll try to create a table with just a UTC timestamp
>> from literals and see if that works.
>> [image: image.png]
>> Same result for the basic case..
>> [image: image.png]
>> Is this expected? The documentation seems fairly clear that this should
>> work.
>>
>> Thanks,
>> Francis
>>
>>
>> This email and any attachments are proprietary and confidential and are
>> intended solely for the use of the individual to whom it is addressed. Any
>> views or opinions expressed are solely those of the author and do not
>> necessarily reflect or represent those of SwitchDin Pty Ltd. If you have
>> received this email in error, please let us know immediately by reply email
>> and delete it from your system. You may not use, disseminate, distribute or
>> copy this message nor disclose its contents to anyone.
>> SwitchDin Pty Ltd (ABN 29 154893857) PO Box 1165, Newcastle NSW 2300
>> Australia
>>
>

Re: strange Flink SQL parser error

[Jingsong Li <ji...@gmail.com>]

Hi,

Currently flink-sql does not support this type, the document and the error
message can be improved.

Best,
Jingsong

On Wed, Jan 19, 2022 at 8:05 AM Francis Conroy <fr...@switchdin.com>
wrote:

> I've been using flink 1.13.5 with the Flink CDC (2.1.1) postgres connector
> and I'm having some trouble with my data formats. For some reason the
> parser seems to be expecting TIMESTAMP WITH LOCAL TIME ZONE. Have I done
> this correctly? I'll try to create a table with just a UTC timestamp from
> literals and see if that works.
> [image: image.png]
> Same result for the basic case..
> [image: image.png]
> Is this expected? The documentation seems fairly clear that this should
> work.
>
> Thanks,
> Francis
>
>
> This email and any attachments are proprietary and confidential and are
> intended solely for the use of the individual to whom it is addressed. Any
> views or opinions expressed are solely those of the author and do not
> necessarily reflect or represent those of SwitchDin Pty Ltd. If you have
> received this email in error, please let us know immediately by reply email
> and delete it from your system. You may not use, disseminate, distribute or
> copy this message nor disclose its contents to anyone.
> SwitchDin Pty Ltd (ABN 29 154893857) PO Box 1165, Newcastle NSW 2300
> Australia
>