You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by asdf2014 <gi...@git.apache.org> on 2017/08/04 08:02:15 UTC

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

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` or less than `16`. So, we should add more information for it.
    
    ```java
    java.lang.IllegalArgumentException: Key group index out of range of key group range [16, 32).
    	at org.apache.flink.runtime.state.heap.NestedMapsStateTable.setMapForKeyGroup(NestedMapsStateTable.java:104)
    	at org.apache.flink.runtime.state.heap.NestedMapsStateTable.putAndGetOld(NestedMapsStateTable.java:218)
    	at org.apache.flink.runtime.state.heap.NestedMapsStateTable.put(NestedMapsStateTable.java:207)
    	at org.apache.flink.runtime.state.heap.NestedMapsStateTable.put(NestedMapsStateTable.java:145)
    	at org.apache.flink.runtime.state.heap.HeapValueState.update(HeapValueState.java:72)
    	at org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator.updateNFA(AbstractKeyedCEPPatternOperator.java:276)
    	at org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator.processElement(AbstractKeyedCEPPatternOperator.java:171)
    	at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:206)
    	at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:69)
    	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:263)
    	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:702)
    	at java.lang.Thread.run(Thread.java:745)
    ```

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/asdf2014/flink FLINK-7369

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/4474.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #4474
    
----
commit 930e042939a65fb1539aa29f514084e0570ed49d
Author: asdf2014 <15...@qq.com>
Date:   2017-08-04T07:59:48Z

    FLINK-7369: Add more information for `Key group index out of range of key group range` exception

----


---
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 is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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

Posted by StefanRRichter <gi...@git.apache.org>.
Github user StefanRRichter commented on the issue:

    https://github.com/apache/flink/pull/4474
  
    Hi,
    
    sorry that I saw this PR too late because Jira was hanging and I only saw the email of the opened issue. I already merged a fix for this to master and 1.3. I would have also suggested to remove the offset information from the message. From the user, the bounds and the index should be enough information.
    
    Can you please close the PR?


---
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 is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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

Posted by asdf2014 <gi...@git.apache.org>.
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: 


---
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 is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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

Posted by asdf2014 <gi...@git.apache.org>.
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 this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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

Posted by asdf2014 <gi...@git.apache.org>.
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 is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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

Posted by StefanRRichter <gi...@git.apache.org>.
Github user StefanRRichter commented on the issue:

    https://github.com/apache/flink/pull/4474
  
    @asdf2014 Yes, and sorry again that I didn't see the PR fast enough. It was absolutely not my intention to ignore your work. Thanks again for your efforts!


---
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 is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---