Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

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

Closed
wants to merge 1 commit into from

Conversation

@asdf2014
Copy link
Member

@asdf2014 asdf2014 commented Aug 4, 2017

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.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)
… key group range` exception
@StefanRRichter
Copy link
Contributor

@StefanRRichter StefanRRichter commented Aug 4, 2017

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?

@asdf2014
Copy link
Member Author

@asdf2014 asdf2014 commented Aug 4, 2017

Hi, @StefanRRichter . Thank you for taking the suggestion. I have already seen the improvement merged into master. 👍

@asdf2014 asdf2014 closed this Aug 4, 2017
@asdf2014 asdf2014 deleted the asdf2014:FLINK-7369 branch Aug 4, 2017
@StefanRRichter
Copy link
Contributor

@StefanRRichter StefanRRichter commented Aug 4, 2017

@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!

@asdf2014
Copy link
Member Author

@asdf2014 asdf2014 commented Aug 4, 2017

You are so polite that you do not have to be sorry :D

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
3 participants