You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@paimon.apache.org by "zhangjun0x01 (via GitHub)" <gi...@apache.org> on 2023/11/02 10:43:06 UTC

[I] [Bug] flink can streaming read the deleted data [incubator-paimon]

zhangjun0x01 opened a new issue, #2246:
URL: https://github.com/apache/incubator-paimon/issues/2246

   ### Search before asking
   
   - [X] I searched in the [issues](https://github.com/apache/incubator-paimon/issues) and found nothing similar.
   
   
   ### Paimon version
   
   master
   
   ### Compute Engine
   
   flink
   
   ### Minimal reproduce step
   
   1. `CREATE TABLE t1 (id INT PRIMARY KEY NOT ENFORCED, name STRING)`
   2. start a new flink client to streaming the table `t1`
   3. in the previous flink client, `INSERT INTO t1 SELECT 1,'aa'` , `DELETE FROM t1`
   4. the flink streaming job , it can read the INSERT data . can not read the DELETE data
   
   ### What doesn't meet your expectations?
   
   flink streaming job can read the delete data
   
   ### Anything else?
   
   _No response_
   
   ### Are you willing to submit a PR?
   
   - [X] I'm willing to submit a PR!


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@paimon.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [I] [Bug] flink can not streaming read the deleted data [incubator-paimon]

Posted by "labixiaoxiaopang (via GitHub)" <gi...@apache.org>.
labixiaoxiaopang commented on issue #2246:
URL: https://github.com/apache/incubator-paimon/issues/2246#issuecomment-1803063654

   1:check  this configuration changelog-producer
   2:check  this configuration changelog-producer.row-deduplicate


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@paimon.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [I] [Bug] flink can not streaming read the deleted data [incubator-paimon]

Posted by "zhangjun0x01 (via GitHub)" <gi...@apache.org>.
zhangjun0x01 closed issue #2246: [Bug] flink can not streaming read the deleted data
URL: https://github.com/apache/incubator-paimon/issues/2246


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@paimon.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org