[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-03-31 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15220858#comment-15220858
 ] 

ASF GitHub Bot commented on FLINK-3523:
---

GitHub user mjsax opened a pull request:

https://github.com/apache/flink/pull/1844

[FLINK-3523] [Storm-Compatibility] Added SplitStreamMapper to program…

… to get rid of SplitStreamType wrapper

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

$ git pull https://github.com/mjsax/flink flink-3523-split-example

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

https://github.com/apache/flink/pull/1844.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 #1844


commit 8e518b548909b4604a427c3aca5fb2d33aabbb8f
Author: mjsax 
Date:   2016-03-31T23:23:30Z

[FLINK-3523] [Storm-Compatibility] Added SplitStreamMapper to program to 
get rid of SplitStreamType wrapper




> Storm SpoutSplitExample fails with a ClassCastException
> ---
>
> Key: FLINK-3523
> URL: https://issues.apache.org/jira/browse/FLINK-3523
> Project: Flink
>  Issue Type: Bug
>  Components: Storm Compatibility
>Reporter: Stephan Ewen
>Assignee: Matthias J. Sax
>
> {code}
> Caused by: java.lang.ClassCastException: 
> org.apache.flink.storm.util.SplitStreamType cannot be cast to 
> java.lang.Integer
>   at 
> org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
>   at 
> org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
>   at 
> org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
>   at 
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
>   at 
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
>   at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
>   at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-04 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15224051#comment-15224051
 ] 

ASF GitHub Bot commented on FLINK-3523:
---

Github user mxm commented on the pull request:

https://github.com/apache/flink/pull/1844#issuecomment-205282397
  
LGTM. Perhaps we could add a test case for this example?


> Storm SpoutSplitExample fails with a ClassCastException
> ---
>
> Key: FLINK-3523
> URL: https://issues.apache.org/jira/browse/FLINK-3523
> Project: Flink
>  Issue Type: Bug
>  Components: Storm Compatibility
>Reporter: Stephan Ewen
>Assignee: Matthias J. Sax
>
> {code}
> Caused by: java.lang.ClassCastException: 
> org.apache.flink.storm.util.SplitStreamType cannot be cast to 
> java.lang.Integer
>   at 
> org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
>   at 
> org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
>   at 
> org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
>   at 
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
>   at 
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
>   at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
>   at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-04 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15224055#comment-15224055
 ] 

ASF GitHub Bot commented on FLINK-3523:
---

Github user mjsax commented on the pull request:

https://github.com/apache/flink/pull/1844#issuecomment-205283761
  
This is an additional example that runs forever -- it was never designed 
for getting tested. Furthermore, there are already two test for split-stream 
functionality.


> Storm SpoutSplitExample fails with a ClassCastException
> ---
>
> Key: FLINK-3523
> URL: https://issues.apache.org/jira/browse/FLINK-3523
> Project: Flink
>  Issue Type: Bug
>  Components: Storm Compatibility
>Reporter: Stephan Ewen
>Assignee: Matthias J. Sax
>
> {code}
> Caused by: java.lang.ClassCastException: 
> org.apache.flink.storm.util.SplitStreamType cannot be cast to 
> java.lang.Integer
>   at 
> org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
>   at 
> org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
>   at 
> org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
>   at 
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
>   at 
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
>   at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
>   at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-04 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15224074#comment-15224074
 ] 

ASF GitHub Bot commented on FLINK-3523:
---

Github user mxm commented on the pull request:

https://github.com/apache/flink/pull/1844#issuecomment-205286176
  
IMHO we should have a way to check that examples are working properly. We 
don't have to address this in this PR though.


> Storm SpoutSplitExample fails with a ClassCastException
> ---
>
> Key: FLINK-3523
> URL: https://issues.apache.org/jira/browse/FLINK-3523
> Project: Flink
>  Issue Type: Bug
>  Components: Storm Compatibility
>Reporter: Stephan Ewen
>Assignee: Matthias J. Sax
>
> {code}
> Caused by: java.lang.ClassCastException: 
> org.apache.flink.storm.util.SplitStreamType cannot be cast to 
> java.lang.Integer
>   at 
> org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
>   at 
> org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
>   at 
> org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
>   at 
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
>   at 
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
>   at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
>   at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-04 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15224138#comment-15224138
 ] 

ASF GitHub Bot commented on FLINK-3523:
---

Github user mjsax commented on the pull request:

https://github.com/apache/flink/pull/1844#issuecomment-205299917
  
Change example slightly (make it run finite and added a check for even/odd 
stream) and added IT-Case.


> Storm SpoutSplitExample fails with a ClassCastException
> ---
>
> Key: FLINK-3523
> URL: https://issues.apache.org/jira/browse/FLINK-3523
> Project: Flink
>  Issue Type: Bug
>  Components: Storm Compatibility
>Reporter: Stephan Ewen
>Assignee: Matthias J. Sax
>
> {code}
> Caused by: java.lang.ClassCastException: 
> org.apache.flink.storm.util.SplitStreamType cannot be cast to 
> java.lang.Integer
>   at 
> org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
>   at 
> org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
>   at 
> org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
>   at 
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
>   at 
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
>   at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
>   at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-05 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15226034#comment-15226034
 ] 

ASF GitHub Bot commented on FLINK-3523:
---

Github user StephanEwen commented on the pull request:

https://github.com/apache/flink/pull/1844#issuecomment-205744485
  
For the test, two comments:

  - Can you add it to another ITCase (saves bringing an extra mini cluster)
  - Also, it will probably not run on windows. Writing to a temp file and 
deleting that should make this compatible.


> Storm SpoutSplitExample fails with a ClassCastException
> ---
>
> Key: FLINK-3523
> URL: https://issues.apache.org/jira/browse/FLINK-3523
> Project: Flink
>  Issue Type: Bug
>  Components: Storm Compatibility
>Reporter: Stephan Ewen
>Assignee: Matthias J. Sax
>
> {code}
> Caused by: java.lang.ClassCastException: 
> org.apache.flink.storm.util.SplitStreamType cannot be cast to 
> java.lang.Integer
>   at 
> org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
>   at 
> org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
>   at 
> org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
>   at 
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
>   at 
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
>   at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
>   at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-05 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15226109#comment-15226109
 ] 

ASF GitHub Bot commented on FLINK-3523:
---

Github user mjsax commented on the pull request:

https://github.com/apache/flink/pull/1844#issuecomment-205767304
  
Done. I needed to restructure class hierarchy, because 
`StreamingMultipleProgramsTestBase` did not provided methods for tmp-file 
handling...


> Storm SpoutSplitExample fails with a ClassCastException
> ---
>
> Key: FLINK-3523
> URL: https://issues.apache.org/jira/browse/FLINK-3523
> Project: Flink
>  Issue Type: Bug
>  Components: Storm Compatibility
>Reporter: Stephan Ewen
>Assignee: Matthias J. Sax
>
> {code}
> Caused by: java.lang.ClassCastException: 
> org.apache.flink.storm.util.SplitStreamType cannot be cast to 
> java.lang.Integer
>   at 
> org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
>   at 
> org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
>   at 
> org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
>   at 
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
>   at 
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
>   at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
>   at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-06 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227918#comment-15227918
 ] 

ASF GitHub Bot commented on FLINK-3523:
---

Github user mxm commented on a diff in the pull request:

https://github.com/apache/flink/pull/1844#discussion_r58665510
  
--- Diff: 
flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/split/SpoutSplitExample.java
 ---
@@ -84,16 +86,27 @@ public static void main(final String[] args) throws 
Exception {
/**
 * Same as {@link VerifyAndEnrichBolt}.
 */
-   private final static class Enrich implements MapFunction> {
+   public final static class Enrich implements MapFunction> {
private static final long serialVersionUID = 
5213888269197438892L;
private final Tuple2 out;
+   private final boolean evenOrOdd; // true: even -- false: odd
--- End diff --

How about `isEven` as name here?


> Storm SpoutSplitExample fails with a ClassCastException
> ---
>
> Key: FLINK-3523
> URL: https://issues.apache.org/jira/browse/FLINK-3523
> Project: Flink
>  Issue Type: Bug
>  Components: Storm Compatibility
>Reporter: Stephan Ewen
>Assignee: Matthias J. Sax
>
> {code}
> Caused by: java.lang.ClassCastException: 
> org.apache.flink.storm.util.SplitStreamType cannot be cast to 
> java.lang.Integer
>   at 
> org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
>   at 
> org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
>   at 
> org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
>   at 
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
>   at 
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
>   at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
>   at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-06 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227939#comment-15227939
 ] 

ASF GitHub Bot commented on FLINK-3523:
---

Github user mjsax commented on the pull request:

https://github.com/apache/flink/pull/1844#issuecomment-206214664
  
Test fail on Java8 module... Can I merge this @StephanEwen ?


> Storm SpoutSplitExample fails with a ClassCastException
> ---
>
> Key: FLINK-3523
> URL: https://issues.apache.org/jira/browse/FLINK-3523
> Project: Flink
>  Issue Type: Bug
>  Components: Storm Compatibility
>Reporter: Stephan Ewen
>Assignee: Matthias J. Sax
>
> {code}
> Caused by: java.lang.ClassCastException: 
> org.apache.flink.storm.util.SplitStreamType cannot be cast to 
> java.lang.Integer
>   at 
> org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
>   at 
> org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
>   at 
> org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
>   at 
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
>   at 
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
>   at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
>   at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-06 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227940#comment-15227940
 ] 

ASF GitHub Bot commented on FLINK-3523:
---

Github user mjsax commented on a diff in the pull request:

https://github.com/apache/flink/pull/1844#discussion_r58668244
  
--- Diff: 
flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/split/SpoutSplitExample.java
 ---
@@ -84,16 +86,27 @@ public static void main(final String[] args) throws 
Exception {
/**
 * Same as {@link VerifyAndEnrichBolt}.
 */
-   private final static class Enrich implements MapFunction> {
+   public final static class Enrich implements MapFunction> {
private static final long serialVersionUID = 
5213888269197438892L;
private final Tuple2 out;
+   private final boolean evenOrOdd; // true: even -- false: odd
--- End diff --

Sure. Can change it.


> Storm SpoutSplitExample fails with a ClassCastException
> ---
>
> Key: FLINK-3523
> URL: https://issues.apache.org/jira/browse/FLINK-3523
> Project: Flink
>  Issue Type: Bug
>  Components: Storm Compatibility
>Reporter: Stephan Ewen
>Assignee: Matthias J. Sax
>
> {code}
> Caused by: java.lang.ClassCastException: 
> org.apache.flink.storm.util.SplitStreamType cannot be cast to 
> java.lang.Integer
>   at 
> org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
>   at 
> org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
>   at 
> org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
>   at 
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
>   at 
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
>   at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
>   at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-06 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15228170#comment-15228170
 ] 

ASF GitHub Bot commented on FLINK-3523:
---

Github user mxm commented on the pull request:

https://github.com/apache/flink/pull/1844#issuecomment-206344827
  
+1 to merge


> Storm SpoutSplitExample fails with a ClassCastException
> ---
>
> Key: FLINK-3523
> URL: https://issues.apache.org/jira/browse/FLINK-3523
> Project: Flink
>  Issue Type: Bug
>  Components: Storm Compatibility
>Reporter: Stephan Ewen
>Assignee: Matthias J. Sax
>
> {code}
> Caused by: java.lang.ClassCastException: 
> org.apache.flink.storm.util.SplitStreamType cannot be cast to 
> java.lang.Integer
>   at 
> org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
>   at 
> org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
>   at 
> org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
>   at 
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
>   at 
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
>   at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
>   at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-06 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15228379#comment-15228379
 ] 

ASF GitHub Bot commented on FLINK-3523:
---

Github user asfgit closed the pull request at:

https://github.com/apache/flink/pull/1844


> Storm SpoutSplitExample fails with a ClassCastException
> ---
>
> Key: FLINK-3523
> URL: https://issues.apache.org/jira/browse/FLINK-3523
> Project: Flink
>  Issue Type: Bug
>  Components: Storm Compatibility
>Reporter: Stephan Ewen
>Assignee: Matthias J. Sax
>
> {code}
> Caused by: java.lang.ClassCastException: 
> org.apache.flink.storm.util.SplitStreamType cannot be cast to 
> java.lang.Integer
>   at 
> org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
>   at 
> org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
>   at 
> org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
>   at 
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
>   at 
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
>   at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
>   at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-06 Thread Matthias J. Sax (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15228381#comment-15228381
 ] 

Matthias J. Sax commented on FLINK-3523:


fixed via 02ef68fb4adbd413fa159c35980412f280179cbf

> Storm SpoutSplitExample fails with a ClassCastException
> ---
>
> Key: FLINK-3523
> URL: https://issues.apache.org/jira/browse/FLINK-3523
> Project: Flink
>  Issue Type: Bug
>  Components: Storm Compatibility
>Reporter: Stephan Ewen
>Assignee: Matthias J. Sax
>
> {code}
> Caused by: java.lang.ClassCastException: 
> org.apache.flink.storm.util.SplitStreamType cannot be cast to 
> java.lang.Integer
>   at 
> org.apache.flink.storm.wrappers.StormTuple.getInteger(StormTuple.java:152)
>   at 
> org.apache.flink.storm.split.operators.VerifyAndEnrichBolt.execute(VerifyAndEnrichBolt.java:52)
>   at 
> org.apache.flink.storm.wrappers.BoltWrapper.processElement(BoltWrapper.java:313)
>   at 
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168)
>   at 
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
>   at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
>   at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)