[GitHub] flink pull request #4472: FLINK-7368: MetricStore makes cpu spin at 100%

2017-08-09 Thread asdf2014
Github user asdf2014 commented on a diff in the pull request: https://github.com/apache/flink/pull/4472#discussion_r132358492 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricStore.java --- @@ -24,8 +24,8 @@ import org.slf4j.Logger

[GitHub] flink issue #4474: FLINK-7369: Add more information for `Key group index out...

2017-08-04 Thread asdf2014
Github user asdf2014 commented on the issue: https://github.com/apache/flink/pull/4474 You are so polite that you do not have to be sorry :D --- 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

[GitHub] flink issue #4474: FLINK-7369: Add more information for `Key group index out...

2017-08-04 Thread asdf2014
Github user asdf2014 commented on the issue: https://github.com/apache/flink/pull/4474 Hi, @StefanRRichter . Thank you take the suggestion. I have already seen the improvement [merged](https://github.com/apache/flink/commit/04777538c0a54c113d0f9b49b5922ba47f6e1eb8) into master. :+1

[GitHub] flink pull request #4474: FLINK-7369: Add more information for `Key group in...

2017-08-04 Thread asdf2014
Github user asdf2014 closed the pull request at: https://github.com/apache/flink/pull/4474 --- 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, or if the feature

[GitHub] flink pull request #4474: FLINK-7369: Add more information for `Key group in...

2017-08-04 Thread asdf2014
GitHub user asdf2014 opened a pull request: https://github.com/apache/flink/pull/4474 FLINK-7369: Add more information for `Key group index out of range of key group range` exception When i got the following exception log, it make me confused that the index is more than `32

[GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

2017-06-14 Thread asdf2014
Github user asdf2014 commented on the issue: https://github.com/apache/flink/pull/2487 @rmetzger Alright. Thank you for your asking, but i think our company still plan to use `Flink-CEP` and contributing `Bahir-Siddhi` feature is a huge job, so... I'm so sorry. --- If your project

[GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

2017-06-09 Thread asdf2014
Github user asdf2014 commented on the issue: https://github.com/apache/flink/pull/2487 @dianfu Great! Look forward to. --- 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

[GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

2017-06-09 Thread asdf2014
Github user asdf2014 commented on the issue: https://github.com/apache/flink/pull/2487 Hi, @haoch @rmetzger . Why i cannot find `flink-siddhi` in [bahir](https://github.com/apache/bahir) or [bahir-flink](https://github.com/apache/bahir-flink)? In addition, the [flink-siddhi](https

[GitHub] flink pull request #4087: [FLINK-6868][build] Using `scala.binary.version` f...

2017-06-08 Thread asdf2014
GitHub user asdf2014 opened a pull request: https://github.com/apache/flink/pull/4087 [FLINK-6868][build] Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector` Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector` You can