date:20240803

Re: [ANNOUNCE] Apache Flink 1.20.0 released

2024-08-03 Thread Jingsong Li

Congrats! Thanks all

Ferenc Csaky 于2024年8月2日 周五19:43写道：

> Congrats!
>
> Thanks for the effort to the release mgrs and everyone involved!
>
> Best,
> Ferenc
>
>
>
> On Friday, 2 August 2024 at 12:16, Jiadong Lu  wrote:
>
> >
> >
> > Congrats!
> > Best regards,
> > Jiadong Lu
> >
> > On 2024/8/2 18:13, Aleksandr Pilipenko wrote:
> >
> > > Congrats!
> > >
> > > Best,
> > > Aleksandr
> > >
> > > On Fri, 2 Aug 2024 at 11:11, Feng Jin jinfeng1...@gmail.com wrote:
> > >
> > > > Congratulations!
> > > >
> > > > Thanks to release managers and everyone involved!
> > > >
> > > > Best,
> > > > Feng Jin
> > > >
> > > > On Fri, Aug 2, 2024 at 5:45 PM Yubin Li lyb5...@gmail.com wrote:
> > > >
> > > > > Congrats!
> > > > > Thanks to release managers and everyone involved for the excellent
> work !
> > > > >
> > > > > Best,
> > > > > Yubin Li
> > > > >
> > > > > On Fri, Aug 2, 2024 at 5:41 PM Paul Lam paullin3...@gmail.com
> wrote:
> > > > >
> > > > > > Congrats!
> > > > > >
> > > > > > Best,
> > > > > > Paul Lam
> > > > > >
> > > > > > > 2024年8月2日 17:26，Ahmed Hamdy hamdy10...@gmail.com 写道：
> > > > > > >
> > > > > > > Congratulations!
> > > > > > > Thanks Weijie and the release managers for the huge efforts.
> > > > > > > Best Regards
> > > > > > > Ahmed Hamdy
> > > > > > >
> > > > > > > On Fri, 2 Aug 2024 at 10:15, Zakelly Lan zakelly@gmail.com
> > > > > > > wrote:
> > > > > > >
> > > > > > > > Congratulations! Thanks to release managers and everyone
> involved!
> > > > > > > >
> > > > > > > > Best,
> > > > > > > > Zakelly
> > > > > > > >
> > > > > > > > On Fri, Aug 2, 2024 at 5:05 PM weijie guo <
> > > > > > > > guoweijieres...@gmail.com>
> > > > > > > > wrote:
> > > > > > > >
> > > > > > > > > The Apache Flink community is very happy to announce the
> release of
> > > > > > > > > Apache
> > > > > > > > >
> > > > > > > > > Flink 1.20.0, which is the first release for the Apache
> Flink 1.20
> > > > > > > > > series.
> > > > > > > > >
> > > > > > > > > Apache Flink® is an open-source stream processing
> framework for
> > > > > > > > >
> > > > > > > > > distributed, high-performing, always-available, and
> accurate data
> > > > > > > > > streaming
> > > > > > > > >
> > > > > > > > > applications.
> > > > > > > > >
> > > > > > > > > The release is available for download at:
> > > > > > > > >
> > > > > > > > > https://flink.apache.org/downloads.html
> > > > > > > > >
> > > > > > > > > Please check out the release blog post for an overview of
> the
> > > > > > > > > improvements
> > > > > > > > > for this release:
> > > >
> > > >
> https://flink.apache.org/2024/08/02/announcing-the-release-of-apache-flink-1.20/
> > > >
> > > > > > > > > The full release notes are available in Jira:
> > > >
> > > >
> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12354210
> > > >
> > > > > > > > > We would like to thank all contributors of the Apache Flink
> > > > > > > > > community who
> > > > > > > > >
> > > > > > > > > made this release possible!
> > > > > > > > >
> > > > > > > > > Best,
> > > > > > > > >
> > > > > > > > > Robert, Rui, Ufuk, Weijie
>

Re: [ANNOUNCE] Apache Flink 1.20.0 released

2024-08-03 Thread ConradJam

Congratulations!

Jingsong Li  于2024年8月3日周六 15:14写道：

> Congrats! Thanks all
>
> Ferenc Csaky 于2024年8月2日 周五19:43写道：
>
> > Congrats!
> >
> > Thanks for the effort to the release mgrs and everyone involved!
> >
> > Best,
> > Ferenc
> >
> >
> >
> > On Friday, 2 August 2024 at 12:16, Jiadong Lu 
> wrote:
> >
> > >
> > >
> > > Congrats!
> > > Best regards,
> > > Jiadong Lu
> > >
> > > On 2024/8/2 18:13, Aleksandr Pilipenko wrote:
> > >
> > > > Congrats!
> > > >
> > > > Best,
> > > > Aleksandr
> > > >
> > > > On Fri, 2 Aug 2024 at 11:11, Feng Jin jinfeng1...@gmail.com wrote:
> > > >
> > > > > Congratulations!
> > > > >
> > > > > Thanks to release managers and everyone involved!
> > > > >
> > > > > Best,
> > > > > Feng Jin
> > > > >
> > > > > On Fri, Aug 2, 2024 at 5:45 PM Yubin Li lyb5...@gmail.com wrote:
> > > > >
> > > > > > Congrats!
> > > > > > Thanks to release managers and everyone involved for the
> excellent
> > work !
> > > > > >
> > > > > > Best,
> > > > > > Yubin Li
> > > > > >
> > > > > > On Fri, Aug 2, 2024 at 5:41 PM Paul Lam paullin3...@gmail.com
> > wrote:
> > > > > >
> > > > > > > Congrats!
> > > > > > >
> > > > > > > Best,
> > > > > > > Paul Lam
> > > > > > >
> > > > > > > > 2024年8月2日 17:26，Ahmed Hamdy hamdy10...@gmail.com 写道：
> > > > > > > >
> > > > > > > > Congratulations!
> > > > > > > > Thanks Weijie and the release managers for the huge efforts.
> > > > > > > > Best Regards
> > > > > > > > Ahmed Hamdy
> > > > > > > >
> > > > > > > > On Fri, 2 Aug 2024 at 10:15, Zakelly Lan
> zakelly@gmail.com
> > > > > > > > wrote:
> > > > > > > >
> > > > > > > > > Congratulations! Thanks to release managers and everyone
> > involved!
> > > > > > > > >
> > > > > > > > > Best,
> > > > > > > > > Zakelly
> > > > > > > > >
> > > > > > > > > On Fri, Aug 2, 2024 at 5:05 PM weijie guo <
> > > > > > > > > guoweijieres...@gmail.com>
> > > > > > > > > wrote:
> > > > > > > > >
> > > > > > > > > > The Apache Flink community is very happy to announce the
> > release of
> > > > > > > > > > Apache
> > > > > > > > > >
> > > > > > > > > > Flink 1.20.0, which is the first release for the Apache
> > Flink 1.20
> > > > > > > > > > series.
> > > > > > > > > >
> > > > > > > > > > Apache Flink® is an open-source stream processing
> > framework for
> > > > > > > > > >
> > > > > > > > > > distributed, high-performing, always-available, and
> > accurate data
> > > > > > > > > > streaming
> > > > > > > > > >
> > > > > > > > > > applications.
> > > > > > > > > >
> > > > > > > > > > The release is available for download at:
> > > > > > > > > >
> > > > > > > > > > https://flink.apache.org/downloads.html
> > > > > > > > > >
> > > > > > > > > > Please check out the release blog post for an overview of
> > the
> > > > > > > > > > improvements
> > > > > > > > > > for this release:
> > > > >
> > > > >
> >
> https://flink.apache.org/2024/08/02/announcing-the-release-of-apache-flink-1.20/
> > > > >
> > > > > > > > > > The full release notes are available in Jira:
> > > > >
> > > > >
> >
> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12354210
> > > > >
> > > > > > > > > > We would like to thank all contributors of the Apache
> Flink
> > > > > > > > > > community who
> > > > > > > > > >
> > > > > > > > > > made this release possible!
> > > > > > > > > >
> > > > > > > > > > Best,
> > > > > > > > > >
> > > > > > > > > > Robert, Rui, Ufuk, Weijie
> >
>


-- 
Best

ConradJam

Re: [ANNOUNCE] Apache Flink 1.20.0 released

2024-08-03 Thread Samrat Deb

Congratulations !

Bests,
Samrat

On Sun, 4 Aug 2024 at 7:24 AM, ConradJam  wrote:

> Congratulations!
>
> Jingsong Li  于2024年8月3日周六 15:14写道：
>
> > Congrats! Thanks all
> >
> > Ferenc Csaky 于2024年8月2日 周五19:43写道：
> >
> > > Congrats!
> > >
> > > Thanks for the effort to the release mgrs and everyone involved!
> > >
> > > Best,
> > > Ferenc
> > >
> > >
> > >
> > > On Friday, 2 August 2024 at 12:16, Jiadong Lu 
> > wrote:
> > >
> > > >
> > > >
> > > > Congrats!
> > > > Best regards,
> > > > Jiadong Lu
> > > >
> > > > On 2024/8/2 18:13, Aleksandr Pilipenko wrote:
> > > >
> > > > > Congrats!
> > > > >
> > > > > Best,
> > > > > Aleksandr
> > > > >
> > > > > On Fri, 2 Aug 2024 at 11:11, Feng Jin jinfeng1...@gmail.com wrote:
> > > > >
> > > > > > Congratulations!
> > > > > >
> > > > > > Thanks to release managers and everyone involved!
> > > > > >
> > > > > > Best,
> > > > > > Feng Jin
> > > > > >
> > > > > > On Fri, Aug 2, 2024 at 5:45 PM Yubin Li lyb5...@gmail.com wrote:
> > > > > >
> > > > > > > Congrats!
> > > > > > > Thanks to release managers and everyone involved for the
> > excellent
> > > work !
> > > > > > >
> > > > > > > Best,
> > > > > > > Yubin Li
> > > > > > >
> > > > > > > On Fri, Aug 2, 2024 at 5:41 PM Paul Lam paullin3...@gmail.com
> > > wrote:
> > > > > > >
> > > > > > > > Congrats!
> > > > > > > >
> > > > > > > > Best,
> > > > > > > > Paul Lam
> > > > > > > >
> > > > > > > > > 2024年8月2日 17:26，Ahmed Hamdy hamdy10...@gmail.com 写道：
> > > > > > > > >
> > > > > > > > > Congratulations!
> > > > > > > > > Thanks Weijie and the release managers for the huge
> efforts.
> > > > > > > > > Best Regards
> > > > > > > > > Ahmed Hamdy
> > > > > > > > >
> > > > > > > > > On Fri, 2 Aug 2024 at 10:15, Zakelly Lan
> > zakelly@gmail.com
> > > > > > > > > wrote:
> > > > > > > > >
> > > > > > > > > > Congratulations! Thanks to release managers and everyone
> > > involved!
> > > > > > > > > >
> > > > > > > > > > Best,
> > > > > > > > > > Zakelly
> > > > > > > > > >
> > > > > > > > > > On Fri, Aug 2, 2024 at 5:05 PM weijie guo <
> > > > > > > > > > guoweijieres...@gmail.com>
> > > > > > > > > > wrote:
> > > > > > > > > >
> > > > > > > > > > > The Apache Flink community is very happy to announce
> the
> > > release of
> > > > > > > > > > > Apache
> > > > > > > > > > >
> > > > > > > > > > > Flink 1.20.0, which is the first release for the Apache
> > > Flink 1.20
> > > > > > > > > > > series.
> > > > > > > > > > >
> > > > > > > > > > > Apache Flink® is an open-source stream processing
> > > framework for
> > > > > > > > > > >
> > > > > > > > > > > distributed, high-performing, always-available, and
> > > accurate data
> > > > > > > > > > > streaming
> > > > > > > > > > >
> > > > > > > > > > > applications.
> > > > > > > > > > >
> > > > > > > > > > > The release is available for download at:
> > > > > > > > > > >
> > > > > > > > > > > https://flink.apache.org/downloads.html
> > > > > > > > > > >
> > > > > > > > > > > Please check out the release blog post for an overview
> of
> > > the
> > > > > > > > > > > improvements
> > > > > > > > > > > for this release:
> > > > > >
> > > > > >
> > >
> >
> https://flink.apache.org/2024/08/02/announcing-the-release-of-apache-flink-1.20/
> > > > > >
> > > > > > > > > > > The full release notes are available in Jira:
> > > > > >
> > > > > >
> > >
> >
> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12354210
> > > > > >
> > > > > > > > > > > We would like to thank all contributors of the Apache
> > Flink
> > > > > > > > > > > community who
> > > > > > > > > > >
> > > > > > > > > > > made this release possible!
> > > > > > > > > > >
> > > > > > > > > > > Best,
> > > > > > > > > > >
> > > > > > > > > > > Robert, Rui, Ufuk, Weijie
> > >
> >
>
>
> --
> Best
>
> ConradJam
>

Re: [ANNOUNCE] Apache Flink 1.20.0 released

2024-08-03 Thread Yuan Mei

Congratulations! Thanks for the efforts to accomplish the great work!

Best
Yuan

On Sun, Aug 4, 2024 at 9:56 AM Samrat Deb  wrote:

> Congratulations !
>
> Bests,
> Samrat
>
> On Sun, 4 Aug 2024 at 7:24 AM, ConradJam  wrote:
>
> > Congratulations!
> >
> > Jingsong Li  于2024年8月3日周六 15:14写道：
> >
> > > Congrats! Thanks all
> > >
> > > Ferenc Csaky 于2024年8月2日 周五19:43写道：
> > >
> > > > Congrats!
> > > >
> > > > Thanks for the effort to the release mgrs and everyone involved!
> > > >
> > > > Best,
> > > > Ferenc
> > > >
> > > >
> > > >
> > > > On Friday, 2 August 2024 at 12:16, Jiadong Lu 
> > > wrote:
> > > >
> > > > >
> > > > >
> > > > > Congrats!
> > > > > Best regards,
> > > > > Jiadong Lu
> > > > >
> > > > > On 2024/8/2 18:13, Aleksandr Pilipenko wrote:
> > > > >
> > > > > > Congrats!
> > > > > >
> > > > > > Best,
> > > > > > Aleksandr
> > > > > >
> > > > > > On Fri, 2 Aug 2024 at 11:11, Feng Jin jinfeng1...@gmail.com
> wrote:
> > > > > >
> > > > > > > Congratulations!
> > > > > > >
> > > > > > > Thanks to release managers and everyone involved!
> > > > > > >
> > > > > > > Best,
> > > > > > > Feng Jin
> > > > > > >
> > > > > > > On Fri, Aug 2, 2024 at 5:45 PM Yubin Li lyb5...@gmail.com
> wrote:
> > > > > > >
> > > > > > > > Congrats!
> > > > > > > > Thanks to release managers and everyone involved for the
> > > excellent
> > > > work !
> > > > > > > >
> > > > > > > > Best,
> > > > > > > > Yubin Li
> > > > > > > >
> > > > > > > > On Fri, Aug 2, 2024 at 5:41 PM Paul Lam
> paullin3...@gmail.com
> > > > wrote:
> > > > > > > >
> > > > > > > > > Congrats!
> > > > > > > > >
> > > > > > > > > Best,
> > > > > > > > > Paul Lam
> > > > > > > > >
> > > > > > > > > > 2024年8月2日 17:26，Ahmed Hamdy hamdy10...@gmail.com 写道：
> > > > > > > > > >
> > > > > > > > > > Congratulations!
> > > > > > > > > > Thanks Weijie and the release managers for the huge
> > efforts.
> > > > > > > > > > Best Regards
> > > > > > > > > > Ahmed Hamdy
> > > > > > > > > >
> > > > > > > > > > On Fri, 2 Aug 2024 at 10:15, Zakelly Lan
> > > zakelly@gmail.com
> > > > > > > > > > wrote:
> > > > > > > > > >
> > > > > > > > > > > Congratulations! Thanks to release managers and
> everyone
> > > > involved!
> > > > > > > > > > >
> > > > > > > > > > > Best,
> > > > > > > > > > > Zakelly
> > > > > > > > > > >
> > > > > > > > > > > On Fri, Aug 2, 2024 at 5:05 PM weijie guo <
> > > > > > > > > > > guoweijieres...@gmail.com>
> > > > > > > > > > > wrote:
> > > > > > > > > > >
> > > > > > > > > > > > The Apache Flink community is very happy to announce
> > the
> > > > release of
> > > > > > > > > > > > Apache
> > > > > > > > > > > >
> > > > > > > > > > > > Flink 1.20.0, which is the first release for the
> Apache
> > > > Flink 1.20
> > > > > > > > > > > > series.
> > > > > > > > > > > >
> > > > > > > > > > > > Apache Flink® is an open-source stream processing
> > > > framework for
> > > > > > > > > > > >
> > > > > > > > > > > > distributed, high-performing, always-available, and
> > > > accurate data
> > > > > > > > > > > > streaming
> > > > > > > > > > > >
> > > > > > > > > > > > applications.
> > > > > > > > > > > >
> > > > > > > > > > > > The release is available for download at:
> > > > > > > > > > > >
> > > > > > > > > > > > https://flink.apache.org/downloads.html
> > > > > > > > > > > >
> > > > > > > > > > > > Please check out the release blog post for an
> overview
> > of
> > > > the
> > > > > > > > > > > > improvements
> > > > > > > > > > > > for this release:
> > > > > > >
> > > > > > >
> > > >
> > >
> >
> https://flink.apache.org/2024/08/02/announcing-the-release-of-apache-flink-1.20/
> > > > > > >
> > > > > > > > > > > > The full release notes are available in Jira:
> > > > > > >
> > > > > > >
> > > >
> > >
> >
> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12354210
> > > > > > >
> > > > > > > > > > > > We would like to thank all contributors of the Apache
> > > Flink
> > > > > > > > > > > > community who
> > > > > > > > > > > >
> > > > > > > > > > > > made this release possible!
> > > > > > > > > > > >
> > > > > > > > > > > > Best,
> > > > > > > > > > > >
> > > > > > > > > > > > Robert, Rui, Ufuk, Weijie
> > > >
> > >
> >
> >
> > --
> > Best
> >
> > ConradJam
> >
>

[jira] [Created] (FLINK-35971) Lose precision in PostgresParallelSource

2024-08-03 Thread wuzhenhua (Jira)

wuzhenhua created FLINK-35971:
-

 Summary: Lose precision in PostgresParallelSource
 Key: FLINK-35971
 URL: https://issues.apache.org/jira/browse/FLINK-35971
 Project: Flink
  Issue Type: Bug
  Components: Flink CDC
 Environment: Flink version
1.14.0
 

Flink CDC version
2.4.1
 

Database and its version
PostgreSQL 10.23

Reporter: wuzhenhua


Reproduce step:

{code:java}
CREATE TABLE IF NOT EXISTS s1.t1
(
id bigint NOT NULL,
tm time without time zone,
CONSTRAINT t1_pkey PRIMARY KEY (id)
)
{code}

{code:java}
INSERT INTO s1.t1 VALUES(1, '10:33:23.660863')
{code}

{code:java}
val prop = new Properties()

val pgSource = PostgresSourceBuilder.PostgresIncrementalSource.builder[String]
.hostname("localhost")
.port(5432)
.database("cdc_test")
.schemaList("s1")
.tableList("s1.t1")
.username("postgres")
.password("postgres")
.deserializer(new JsonDebeziumDeserializationSchema)
.slotName("aaa")
.decodingPluginName("pgoutput")
.debeziumProperties(prop)
.build()

env.enableCheckpointing(3000)
env.fromSource(pgSource, WatermarkStrategy.noWatermarks[String](), 
"PostgresParallelSource").print()
env.execute("Print Postgres Snapshot + WAL")
{code}

expect to see:
{code:java}
"after":{"id":1,"tm":38003660863}
{code}

i see instead:
{code:java}
"after":{"id":1,"tm":3800366}
{code}

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Re: [ANNOUNCE] Apache Flink 1.20.0 released

Re: [ANNOUNCE] Apache Flink 1.20.0 released

Re: [ANNOUNCE] Apache Flink 1.20.0 released

Re: [ANNOUNCE] Apache Flink 1.20.0 released

[jira] [Created] (FLINK-35971) Lose precision in PostgresParallelSource

5 matches

Site Navigation

Mail list logo

Footer information