You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2021/07/19 09:05:51 UTC

[GitHub] [rocketmq-externals] chenliuyang1989 opened a new issue #748: rocketmq-flink- the checkPointLock should use the context checkpointLock，No need to define separately and should not

chenliuyang1989 opened a new issue #748:
URL: https://github.com/apache/rocketmq-externals/issues/748


   First：
   For the message get from Rocketmq，
   we should use the context checkpoint  to insure the checkpointing and the emission of elements must never occur at the same time。
   If we use a seperate lock，it will not work。
   ![image](https://user-images.githubusercontent.com/4150132/126133890-21ec07ee-1cbb-48c8-8004-f55737b5f4f6.png)
   
   Second,we should keep the Atomic operation for the operation of emission of elements  and the operation of update the
   offset of rocketmq topic.
   
   ![image](https://user-images.githubusercontent.com/4150132/126134059-26128eb6-b033-40bc-b8eb-182e58895fbb.png)
   
   
   
   
   


-- 
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: dev-unsubscribe@rocketmq.apache.org

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

[GitHub] [rocketmq-externals] vongosling closed issue #748: rocketmq-flink- the checkPointLock should use the context checkpointLock，No need to define separately and should not

Posted by GitBox <gi...@apache.org>.
vongosling closed issue #748:
URL: https://github.com/apache/rocketmq-externals/issues/748


   


-- 
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: dev-unsubscribe@rocketmq.apache.org

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

[GitHub] [rocketmq-externals] vongosling closed issue #748: rocketmq-flink- the checkPointLock should use the context checkpointLock，No need to define separately and should not

Posted by GitBox <gi...@apache.org>.
vongosling closed issue #748:
URL: https://github.com/apache/rocketmq-externals/issues/748


   


-- 
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: dev-unsubscribe@rocketmq.apache.org

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

[GitHub] [rocketmq-externals] chenliuyang1989 commented on issue #748: rocketmq-flink- the checkPointLock should use the context checkpointLock，No need to define separately and should not

Posted by GitBox <gi...@apache.org>.
chenliuyang1989 commented on issue #748:
URL: https://github.com/apache/rocketmq-externals/issues/748#issuecomment-882381076


   should not define a seperate lock。
   ![image](https://user-images.githubusercontent.com/4150132/126134253-4557e0df-f6f1-4c45-ac66-c3088eaa51d6.png)
   


-- 
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: dev-unsubscribe@rocketmq.apache.org

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

[GitHub] [rocketmq-externals] chenliuyang1989 commented on issue #748: rocketmq-flink- the checkPointLock should use the context checkpointLock，No need to define separately and should not

Posted by GitBox <gi...@apache.org>.
chenliuyang1989 commented on issue #748:
URL: https://github.com/apache/rocketmq-externals/issues/748#issuecomment-882381076


   should not define a seperate lock。
   ![image](https://user-images.githubusercontent.com/4150132/126134253-4557e0df-f6f1-4c45-ac66-c3088eaa51d6.png)
   


-- 
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: dev-unsubscribe@rocketmq.apache.org

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

[GitHub] [rocketmq-externals] vongosling commented on issue #748: rocketmq-flink- the checkPointLock should use the context checkpointLock，No need to define separately and should not

Posted by GitBox <gi...@apache.org>.
vongosling commented on issue #748:
URL: https://github.com/apache/rocketmq-externals/issues/748#issuecomment-883284583


   @duhenglucky 


-- 
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: dev-unsubscribe@rocketmq.apache.org

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

[GitHub] [rocketmq-externals] vongosling closed issue #748: rocketmq-flink- the checkPointLock should use the context checkpointLock，No need to define separately and should not

Posted by GitBox <gi...@apache.org>.
vongosling closed issue #748:
URL: https://github.com/apache/rocketmq-externals/issues/748


   


-- 
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: dev-unsubscribe@rocketmq.apache.org

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

[GitHub] [rocketmq-externals] chenliuyang1989 commented on issue #748: rocketmq-flink- the checkPointLock should use the context checkpointLock，No need to define separately and should not

Posted by GitBox <gi...@apache.org>.
chenliuyang1989 commented on issue #748:
URL: https://github.com/apache/rocketmq-externals/issues/748#issuecomment-905278067


   any updates？


-- 
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: dev-unsubscribe@rocketmq.apache.org

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

[GitHub] [rocketmq-externals] vongosling commented on issue #748: rocketmq-flink- the checkPointLock should use the context checkpointLock，No need to define separately and should not

Posted by GitBox <gi...@apache.org>.
vongosling commented on issue #748:
URL: https://github.com/apache/rocketmq-externals/issues/748#issuecomment-883284583


   @duhenglucky 


-- 
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: dev-unsubscribe@rocketmq.apache.org

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