[GitHub] flink issue #3758: [FLINK-5855][Streaming Connectors] Unprotected access to ...

2017-04-25 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3758 @zhangminglei Perfect! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so,

[GitHub] flink issue #3758: [FLINK-5855][Streaming Connectors] Unprotected access to ...

2017-04-25 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/3758 @kl0u Yep. I reopened this PR again for waiting you message me. Haha ~ Okay, Now, I will close it and then create another jira and cc you. --- If your project is set up for it, you can reply

[GitHub] flink issue #3758: [FLINK-5855][Streaming Connectors] Unprotected access to ...

2017-04-25 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3758 Yes. This sounds good, but you reopened this pull request right? Shouldn't this be closed? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink issue #3758: [FLINK-5855][Streaming Connectors] Unprotected access to ...

2017-04-24 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/3758 @kl0u Thanks for review , very appreciate it. Yep, BTW, I would like to work on what you will thorough the code in the following days and keep watching this class ```synchronized()```. Hopes

[GitHub] flink issue #3758: [FLINK-5855][Streaming Connectors] Unprotected access to ...

2017-04-24 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3758 Hi @zhangminglei, thanks for looking into this! I tend to agree with @tillrohrmann that there is not need for locking there, as there is no sharing of the data-structure between different threads. The

[GitHub] flink issue #3758: [FLINK-5855][Streaming Connectors] Unprotected access to ...

2017-04-24 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3758 Not sure why we're synchronizing on the `pendingFilesPerCheckpoint` field at all, because it is only the restored state object. Maybe @kl0u can shed some light on that. --- If your project is

[GitHub] flink issue #3758: [FLINK-5855][Streaming Connectors] Unprotected access to ...

2017-04-23 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/3758 cc @tillrohrmann --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes