[jira] [Updated] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-07 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-4586: Attachment: FLINK4586Test.scala Scala unit test > NumberSequenceIterator and Accumulator threading issue >

[jira] [Updated] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-07 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-4586: Attachment: (was: FLINK4586Test.scala) > NumberSequenceIterator and Accumulator threading issue > --

[jira] [Commented] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-06 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15468729#comment-15468729 ] Johannes commented on FLINK-4586: - The testcase also fails, when just using a plain collec

[jira] [Updated] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-06 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-4586: Description: There is a strange problem when using the NumberSequenceIterator in combination with an Averag

[jira] [Updated] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-06 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-4586: Description: There is a strange problem when using the NumberSequenceIterator in combination with an Averag

[jira] [Updated] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-06 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-4586: Attachment: FLINK4586Test.scala Complete Scala Testcase > NumberSequenceIterator and Accumulator threading

[jira] [Created] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-06 Thread Johannes (JIRA)
Johannes created FLINK-4586: --- Summary: NumberSequenceIterator and Accumulator threading issue Key: FLINK-4586 URL: https://issues.apache.org/jira/browse/FLINK-4586 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-3293) Custom Application Name on YARN is ignored in deploy jobmanager mode

2016-01-28 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes reassigned FLINK-3293: --- Assignee: Johannes > Custom Application Name on YARN is ignored in deploy jobmanager mode > -

[jira] [Created] (FLINK-3293) Custom Application Name on YARN is ignored in deploy jobmanager mode

2016-01-26 Thread Johannes (JIRA)
Johannes created FLINK-3293: --- Summary: Custom Application Name on YARN is ignored in deploy jobmanager mode Key: FLINK-3293 URL: https://issues.apache.org/jira/browse/FLINK-3293 Project: Flink Iss

[jira] [Created] (FLINK-3090) Create a Parcel Distribution for Cloudera Manager

2015-11-28 Thread Johannes (JIRA)
Johannes created FLINK-3090: --- Summary: Create a Parcel Distribution for Cloudera Manager Key: FLINK-3090 URL: https://issues.apache.org/jira/browse/FLINK-3090 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2213) Configure number of vcores

2015-11-09 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14997286#comment-14997286 ] Johannes commented on FLINK-2213: - What happens when the container exceed its resources is

[jira] [Commented] (FLINK-2984) Support lenient parsing of SVMLight input files

2015-11-07 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14995398#comment-14995398 ] Johannes commented on FLINK-2984: - Good question about the widespread mis/use of this chan

[jira] [Commented] (FLINK-2213) Configure number of vcores

2015-11-06 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14994471#comment-14994471 ] Johannes commented on FLINK-2213: - I just ran into this problem on a cluster configured wi

[jira] [Created] (FLINK-2984) Support lenient parsing of SVMLight input files

2015-11-06 Thread Johannes (JIRA)
Johannes created FLINK-2984: --- Summary: Support lenient parsing of SVMLight input files Key: FLINK-2984 URL: https://issues.apache.org/jira/browse/FLINK-2984 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2935) Allow scala shell to read yarn properties

2015-10-28 Thread Johannes (JIRA)
Johannes created FLINK-2935: --- Summary: Allow scala shell to read yarn properties Key: FLINK-2935 URL: https://issues.apache.org/jira/browse/FLINK-2935 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2094) Implement Word2Vec

2015-05-27 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14561006#comment-14561006 ] Johannes commented on FLINK-2094: - Some information below, as I looked into this algorithm

[jira] [Updated] (FLINK-1974) JobExecutionResult NetRuntime - document result type

2015-05-05 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-1974: Summary: JobExecutionResult NetRuntime - document result type (was: JobExecutionResult NetRuntime - documen

[jira] [Updated] (FLINK-1974) JobExecutionResult NetRuntime - document the type of the result

2015-05-05 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-1974: Summary: JobExecutionResult NetRuntime - document the type of the result (was: JobExecutionResult NetRuntim

[jira] [Created] (FLINK-1974) JobExecutionResult NetRuntime - document the type or the result

2015-05-05 Thread Johannes (JIRA)
Johannes created FLINK-1974: --- Summary: JobExecutionResult NetRuntime - document the type or the result Key: FLINK-1974 URL: https://issues.apache.org/jira/browse/FLINK-1974 Project: Flink Issue Ty

[jira] [Commented] (FLINK-1596) FileIOChannel introduces space in temp file name

2015-02-22 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14332236#comment-14332236 ] Johannes commented on FLINK-1596: - Hi [~hsaputra], indeed the file not found error seems t

[jira] [Commented] (FLINK-1596) FileIOChannel introduces space in temp file name

2015-02-21 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14330440#comment-14330440 ] Johannes commented on FLINK-1596: - I think I celebrated too early :) While the change fixe

[jira] [Updated] (FLINK-1596) FileIOChannel introduces space in temp file name

2015-02-21 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-1596: Description: FLINK-1483 introduced separate directories for all threads. Unfortunately this seems to not wor

[jira] [Created] (FLINK-1596) FileIOChannel introduces space in temp file name

2015-02-21 Thread Johannes (JIRA)
Johannes created FLINK-1596: --- Summary: FileIOChannel introduces space in temp file name Key: FLINK-1596 URL: https://issues.apache.org/jira/browse/FLINK-1596 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1531) Custom Kryo Serializer fails in itertation scenario

2015-02-14 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321520#comment-14321520 ] Johannes commented on FLINK-1531: - Thanks for the info [~StephanEwen] Makes sense to me an

[jira] [Commented] (FLINK-1531) Custom Kryo Serializer fails in itertation scenario

2015-02-12 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14318779#comment-14318779 ] Johannes commented on FLINK-1531: - Thanks for the quick turnaround Tried it locally and it

[jira] [Commented] (FLINK-1531) Custom Kryo Serializer fails in itertation scenario

2015-02-12 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14318314#comment-14318314 ] Johannes commented on FLINK-1531: - I just had a look again at the logging again Right at

[jira] [Updated] (FLINK-1531) Custom Kryo Serializer fails in itertation scenario

2015-02-12 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-1531: Priority: Minor (was: Major) > Custom Kryo Serializer fails in itertation scenario > --

[jira] [Updated] (FLINK-1531) Custom Kryo Serializer fails in itertation scenario

2015-02-12 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-1531: Assignee: (was: Johannes) > Custom Kryo Serializer fails in itertation scenario > --

[jira] [Commented] (FLINK-1531) Custom Kryo Serializer fails in itertation scenario

2015-02-12 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14318002#comment-14318002 ] Johannes commented on FLINK-1531: - It seems that in the attached test scenario there is a

[jira] [Updated] (FLINK-1531) Custom Kryo Serializer fails in itertation scenario

2015-02-12 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-1531: Attachment: TestKryoIterationSerializer.java JUnit test to reproduce > Custom Kryo Serializer fails in iter

[jira] [Created] (FLINK-1531) Custom Kryo Serializer fails in itertation scenario

2015-02-12 Thread Johannes (JIRA)
Johannes created FLINK-1531: --- Summary: Custom Kryo Serializer fails in itertation scenario Key: FLINK-1531 URL: https://issues.apache.org/jira/browse/FLINK-1531 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-1485) Typo in Documentation - Join with Join-Function

2015-02-05 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-1485: Component/s: Documentation > Typo in Documentation - Join with Join-Function > -

[jira] [Created] (FLINK-1485) Typo in Documentation - Join with Join-Function

2015-02-05 Thread Johannes (JIRA)
Johannes created FLINK-1485: --- Summary: Typo in Documentation - Join with Join-Function Key: FLINK-1485 URL: https://issues.apache.org/jira/browse/FLINK-1485 Project: Flink Issue Type: Bug Affec