[
https://issues.apache.org/jira/browse/FLINK-35067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849161#comment-17849161
]
Hongshun Wang commented on FLINK-35067:
---
[~walls.flink.m], I hope you’re doing well. I’ve been
[
https://issues.apache.org/jira/browse/FLINK-35385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848438#comment-17848438
]
Hongshun Wang commented on FLINK-35385:
---
We can ensure multi-version compatibility for the
Hongshun Wang created FLINK-35387:
-
Summary: PG CDC source support heart beat
Key: FLINK-35387
URL: https://issues.apache.org/jira/browse/FLINK-35387
Project: Flink
Issue Type: Bug
Hongshun Wang created FLINK-35385:
-
Summary: upgrader flink dependency version to 1.19
Key: FLINK-35385
URL: https://issues.apache.org/jira/browse/FLINK-35385
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-35349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846183#comment-17846183
]
Hongshun Wang commented on FLINK-35349:
---
I'd like to do it.
> Use connection in
Hongshun Wang created FLINK-35349:
-
Summary: Use connection in openJdbcConnection of
SqlServerDialect/Db2Dialect/OracleDialect
Key: FLINK-35349
URL: https://issues.apache.org/jira/browse/FLINK-35349
[
https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846167#comment-17846167
]
Hongshun Wang commented on FLINK-35344:
---
I'd like to do it.
> Move same code from multiple
Hongshun Wang created FLINK-35344:
-
Summary: Move same code from multiple subclasses to
JdbcSourceChunkSplitter
Key: FLINK-35344
URL: https://issues.apache.org/jira/browse/FLINK-35344
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35327:
--
Issue Type: Improvement (was: Bug)
> SQL Explain show push down condition
>
[
https://issues.apache.org/jira/browse/FLINK-35327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845186#comment-17845186
]
Hongshun Wang commented on FLINK-35327:
---
[~lincoln] , CC
> SQL Explain show push down condition
Hongshun Wang created FLINK-35327:
-
Summary: SQL Explain show push down condition
Key: FLINK-35327
URL: https://issues.apache.org/jira/browse/FLINK-35327
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-35313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844872#comment-17844872
]
Hongshun Wang commented on FLINK-35313:
---
I don't understand whether we need to do it in sql? As
[
https://issues.apache.org/jira/browse/FLINK-35143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35143:
--
Fix Version/s: cdc-3.2.0
Affects Version/s: cdc-3.1.0
> Expose newly added tables
[
https://issues.apache.org/jira/browse/FLINK-35129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35129:
--
Fix Version/s: cdc-3.2.0
Affects Version/s: cdc-3.1.0
> Postgres source commits the
[
https://issues.apache.org/jira/browse/FLINK-35067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35067:
--
Fix Version/s: cdc-3.2.0
> Support metadata 'op_type' virtual column for Postgres CDC
[
https://issues.apache.org/jira/browse/FLINK-34688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34688:
--
Fix Version/s: cdc-3.2.0
(was: cdc-3.1.0)
Affects
[
https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35093:
--
Affects Version/s: cdc-3.1.0
> Postgres source connector support SPECIFIC_OFFSETS start up
[
https://issues.apache.org/jira/browse/FLINK-35067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35067:
--
Affects Version/s: cdc-3.1.0
> Support metadata 'op_type' virtual column for Postgres CDC
[
https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35121:
--
Fix Version/s: cdc-3.2.0
> CDC pipeline connector should verify requiredOptions and
[
https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35121:
--
Affects Version/s: cdc-3.1.0
> CDC pipeline connector should verify requiredOptions and
[
https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35093:
--
Fix Version/s: cdc-3.2.0
> Postgres source connector support SPECIFIC_OFFSETS start up mode
[
https://issues.apache.org/jira/browse/FLINK-34666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844495#comment-17844495
]
Hongshun Wang commented on FLINK-34666:
---
Have done it in FLINK-34634, please close it. [~renqs]
Hongshun Wang created FLINK-35281:
-
Summary: FlinkEnvironmentUtils#addJar add each jar only once
Key: FLINK-35281
URL: https://issues.apache.org/jira/browse/FLINK-35281
Project: Flink
Issue
Hongshun Wang created FLINK-35234:
-
Summary: Fix NullPointerException of
org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString
Key: FLINK-35234
URL:
[
https://issues.apache.org/jira/browse/FLINK-35220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840656#comment-17840656
]
Hongshun Wang commented on FLINK-35220:
---
See
[
https://issues.apache.org/jira/browse/FLINK-34869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840280#comment-17840280
]
Hongshun Wang commented on FLINK-34869:
---
It seems I haven't fixed it [~jmahonin]
> [Bug][mysql]
[
https://issues.apache.org/jira/browse/FLINK-35143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838428#comment-17838428
]
Hongshun Wang commented on FLINK-35143:
---
I'd like to do it
> Expose newly added tables capture in
Hongshun Wang created FLINK-35149:
-
Summary: Fix DataSinkTranslator#sinkTo ignoring pre-write topology
if not TwoPhaseCommittingSink
Key: FLINK-35149
URL: https://issues.apache.org/jira/browse/FLINK-35149
[
https://issues.apache.org/jira/browse/FLINK-35144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838422#comment-17838422
]
Hongshun Wang commented on FLINK-35144:
---
You mean that sync multiple sources to same sink?
>
Hongshun Wang created FLINK-35143:
-
Summary: Expose newly added tables capture in mysql pipeline
connector
Key: FLINK-35143
URL: https://issues.apache.org/jira/browse/FLINK-35143
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837942#comment-17837942
]
Hongshun Wang commented on FLINK-35129:
---
[~m.orazow] , would you like to take it?
> Postgres
Hongshun Wang created FLINK-35129:
-
Summary: Postgres source commits the offset after every multiple
checkpoint cycles.
Key: FLINK-35129
URL: https://issues.apache.org/jira/browse/FLINK-35129
[
https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35128:
--
Description:
In mysql cdc, re-calculate the starting binlog offset after the new table added
[
https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35128:
--
Summary: Re-calculate the starting change log offset after the new table
added (was:
Hongshun Wang created FLINK-35128:
-
Summary: Re-calculate the starting binlog offset after the new
table added
Key: FLINK-35128
URL: https://issues.apache.org/jira/browse/FLINK-35128
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837552#comment-17837552
]
Hongshun Wang commented on FLINK-35121:
---
[~renqs] , CC
> CDC pipeline connector should verify
Hongshun Wang created FLINK-35121:
-
Summary: CDC pipeline connector should verify requiredOptions and
optionalOptions
Key: FLINK-35121
URL: https://issues.apache.org/jira/browse/FLINK-35121
Project:
[
https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35093:
--
Description:
Current, Postgres source connector only support INITIAL and LATEST mode.
[
https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836403#comment-17836403
]
Hongshun Wang commented on FLINK-35093:
---
I'd like to do it
> Postgres source connector support
Hongshun Wang created FLINK-35093:
-
Summary: Postgres source connector support SPECIFIC_OFFSETS start
up mode from an existed replication slot.
Key: FLINK-35093
URL:
[
https://issues.apache.org/jira/browse/FLINK-35071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35071:
--
Component/s: Flink CDC
> Remove dependency on flink-shaded from cdc source connector
>
[
https://issues.apache.org/jira/browse/FLINK-35071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35071:
--
Fix Version/s: 3.1.0
> Remove dependency on flink-shaded from cdc source connector
>
[
https://issues.apache.org/jira/browse/FLINK-35071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35071:
--
Affects Version/s: (was: cdc-3.1.0)
> Remove dependency on flink-shaded from cdc source
[
https://issues.apache.org/jira/browse/FLINK-35071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35071:
--
Affects Version/s: cdc-3.1.0
> Remove dependency on flink-shaded from cdc source connector
>
[
https://issues.apache.org/jira/browse/FLINK-35071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35071:
--
Description:
Like what flink-connector-aws does in FLINK-32208, the flink cdc source
[
https://issues.apache.org/jira/browse/FLINK-35071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35071:
--
Description:
The flink cdc source connectors depend on flink-shaded-guava. With the
[
https://issues.apache.org/jira/browse/FLINK-35071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835612#comment-17835612
]
Hongshun Wang commented on FLINK-35071:
---
[~renqs] I would like to do it.
> Remove dependency on
Hongshun Wang created FLINK-35071:
-
Summary: Remove dependency on flink-shaded from cdc source
connector
Key: FLINK-35071
URL: https://issues.apache.org/jira/browse/FLINK-35071
Project: Flink
Hongshun Wang created FLINK-35067:
-
Summary: Support metadata 'op_type' virtual column for Postgres
CDC Connector.
Key: FLINK-35067
URL: https://issues.apache.org/jira/browse/FLINK-35067
Project:
[
https://issues.apache.org/jira/browse/FLINK-34952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34952:
--
Summary: Flink CDC pipeline supports SinkFunction (was: Flink CDC
pipeline supports
[
https://issues.apache.org/jira/browse/FLINK-34690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34690:
--
Description:
h3. What's the problem
Flink only have bigint type, if mysql data is unsigned
[
https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831301#comment-17831301
]
Hongshun Wang commented on FLINK-34948:
---
Can you provide a case or other more detailed
[
https://issues.apache.org/jira/browse/FLINK-34952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34952:
--
Description:
Though current Flink CDC pipeline define
Hongshun Wang created FLINK-34952:
-
Summary: Flink CDC pipeline supports SourceFunction
Key: FLINK-34952
URL: https://issues.apache.org/jira/browse/FLINK-34952
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830759#comment-17830759
]
Hongshun Wang commented on FLINK-34925:
---
[~gongzhongqiang] , CC, I am not familiar with Sqlserver.
[
https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830464#comment-17830464
]
Hongshun Wang commented on FLINK-34925:
---
This
[
https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830310#comment-17830310
]
Hongshun Wang commented on FLINK-34925:
---
Debezium 2.0 is a major version upgrade which does not
[
https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829715#comment-17829715
]
Hongshun Wang commented on FLINK-34903:
---
[~fffy] , Please change PR titile by
[
https://issues.apache.org/jira/browse/FLINK-34739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828664#comment-17828664
]
Hongshun Wang commented on FLINK-34739:
---
I am willing to do it
> "Connectors" Page for Flink CDC
[
https://issues.apache.org/jira/browse/FLINK-34750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828658#comment-17828658
]
Hongshun Wang commented on FLINK-34750:
---
I am willing to do this.
> "legacy-flink-cdc-sources"
[ https://issues.apache.org/jira/browse/FLINK-34740 ]
Hongshun Wang deleted comment on FLINK-34740:
---
was (Author: JIRAUSER298968):
I am willing to do this.
> "legacy-flink-cdc-sources" Pages for Flink CDC Chinese Documentation
>
[
https://issues.apache.org/jira/browse/FLINK-34740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828570#comment-17828570
]
Hongshun Wang commented on FLINK-34740:
---
I am willing to do this.
> "legacy-flink-cdc-sources"
[
https://issues.apache.org/jira/browse/FLINK-34741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828569#comment-17828569
]
Hongshun Wang commented on FLINK-34741:
---
I am willing to do this.
> "get-started" Page for Flink
[
https://issues.apache.org/jira/browse/FLINK-34742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828568#comment-17828568
]
Hongshun Wang commented on FLINK-34742:
---
I am willing to do this.
> Translate "FAQ" Page for
Hongshun Wang created FLINK-34724:
-
Summary: Fix broken web link in document of legacy Flink CDC
Sources
Key: FLINK-34724
URL: https://issues.apache.org/jira/browse/FLINK-34724
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827775#comment-17827775
]
Hongshun Wang commented on FLINK-34685:
---
It seem this should wait for
[
https://issues.apache.org/jira/browse/FLINK-34685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827438#comment-17827438
]
Hongshun Wang commented on FLINK-34685:
---
I am willing to take this.
> "Deployment - Kubernetes"
[
https://issues.apache.org/jira/browse/FLINK-34690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34690:
--
Description:
h3. What's the problem
Flink only have bigint type, if mysql data is unsigned
[
https://issues.apache.org/jira/browse/FLINK-34690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827404#comment-17827404
]
Hongshun Wang commented on FLINK-34690:
---
[~renqs] ,[~Leonard] , [~Lv Yanquan] , [~banmoy] , CC
>
[
https://issues.apache.org/jira/browse/FLINK-34690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34690:
--
Description:
Flink only have bigint type, if mysql data is unsigned bigint , maybe out of
Hongshun Wang created FLINK-34690:
-
Summary: If data from upstream is decimal and primary key ,
starrocks sink will not support.
Key: FLINK-34690
URL: https://issues.apache.org/jira/browse/FLINK-34690
[
https://issues.apache.org/jira/browse/FLINK-34688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827335#comment-17827335
]
Hongshun Wang commented on FLINK-34688:
---
Please assign it to me.
> CDC framework split snapshot
[
https://issues.apache.org/jira/browse/FLINK-34666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827333#comment-17827333
]
Hongshun Wang commented on FLINK-34666:
---
Please assign it to me.
> Keep assigned splits in order
[
https://issues.apache.org/jira/browse/FLINK-34634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827334#comment-17827334
]
Hongshun Wang commented on FLINK-34634:
---
Please assign it to me.
> Restarting the job will not
Hongshun Wang created FLINK-34688:
-
Summary: CDC framework split snapshot chunks asynchronously
Key: FLINK-34688
URL: https://issues.apache.org/jira/browse/FLINK-34688
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-34666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34666:
--
Description:
h3. Reason
When added newly tables, and then restart job,
[
https://issues.apache.org/jira/browse/FLINK-34666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34666:
--
Description:
## Reason
When added newly tables, and then restart job,
[
https://issues.apache.org/jira/browse/FLINK-34666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34666:
--
Fix Version/s: cdc-3.1.0
> Keep assigned splits in order to fix wrong meta group calculation
[
https://issues.apache.org/jira/browse/FLINK-34666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34666:
--
Issue Type: Bug (was: Improvement)
> Keep assigned splits in order to fix wrong meta group
[
https://issues.apache.org/jira/browse/FLINK-34666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34666:
--
Component/s: Flink CDC
> Keep assigned splits in order to fix wrong meta group calculation
>
Hongshun Wang created FLINK-34666:
-
Summary: Keep assigned splits in order to fix wrong meta group
calculation
Key: FLINK-34666
URL: https://issues.apache.org/jira/browse/FLINK-34666
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825490#comment-17825490
]
Hongshun Wang edited comment on FLINK-34648 at 3/12/24 2:11 AM:
During
[
https://issues.apache.org/jira/browse/FLINK-34648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825490#comment-17825490
]
Hongshun Wang commented on FLINK-34648:
---
During the process of task recovery, will the enumerator
[
https://issues.apache.org/jira/browse/FLINK-34634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825132#comment-17825132
]
Hongshun Wang commented on FLINK-34634:
---
[~ruanhang1993] , [~renqs] , [~Leonard] , CC
>
[
https://issues.apache.org/jira/browse/FLINK-34634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34634:
--
Description:
h3. What's the problem
Once, I removed a table from the option and then
[
https://issues.apache.org/jira/browse/FLINK-34634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34634:
--
Issue Type: Bug (was: Improvement)
> Restarting the job will not read the changelog anymore
[
https://issues.apache.org/jira/browse/FLINK-34634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34634:
--
Description:
Once, I removed a table from the option and then restarted the job from the
Hongshun Wang created FLINK-34634:
-
Summary: Restarting the job will not read the changelog anymore if
it stops before the synchronization of meta information is complete and some
table is removed
Key: FLINK-34634
[
https://issues.apache.org/jira/browse/FLINK-34196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34196:
--
Description:
This improvement implements
[
https://issues.apache.org/jira/browse/FLINK-34196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809400#comment-17809400
]
Hongshun Wang commented on FLINK-34196:
---
[~renqs] , [~Leonard] , CC, WDYT?
> FLIP-389 Annotate
Hongshun Wang created FLINK-34196:
-
Summary: FLIP-389 Annotate SingleThreadFetcherManager as
PublicEvolving.
Key: FLINK-34196
URL: https://issues.apache.org/jira/browse/FLINK-34196
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17808018#comment-17808018
]
Hongshun Wang commented on FLINK-34129:
---
[~fsk119] ,[~lsy] , [~andrewlinc...@gmail.com] , CC
>
[
https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34129:
--
Description:
Take sum for example:
When state is expired, then an update operation from
[
https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34129:
--
Description:
Take sum for example:
When state is expired, then an update operation from
[
https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34129:
--
Issue Type: Bug (was: Improvement)
> MiniBatchGlobalGroupAggFunction will make -D as +I then
[
https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34129:
--
Summary: MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as
-U when state
Hongshun Wang created FLINK-34129:
-
Summary: correct writing: MiniBatchGlobalGroupAggFunction will
make -D as +I then make +I as -U when state expired
Key: FLINK-34129
URL:
[
https://issues.apache.org/jira/browse/FLINK-33465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-33465:
--
Description:
As discussed in FLINK-31324, though the {{SingleThreadFetcherManager}} is
[
https://issues.apache.org/jira/browse/FLINK-33465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-33465:
--
Description:
As discussed in FLINK-31324, though the {{SingleThreadFetcherManager}} is
[
https://issues.apache.org/jira/browse/FLINK-33465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-33465:
--
Description:
As discussed in FLINK-31324, though the {{SingleThreadFetcherManager}} is
1 - 100 of 154 matches
Mail list logo
