[jira] [Commented] (FLINK-1390) java.lang.ClassCastException: X cannot be cast to X

[ https://issues.apache.org/jira/browse/FLINK-1390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14310629#comment-14310629 ] Fabian Hueske commented on FLINK-1390: -- The possibly related issue FLINK-1438 has

[jira] [Updated] (FLINK-1476) Flink VS Spark on loop test

[ https://issues.apache.org/jira/browse/FLINK-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1476: - Priority: Minor (was: Critical) Flink VS Spark on loop test ---

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons (...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/335#issuecomment-73366441 I'm really sorry that I've messed up this pull request by renaming flink-addons to flink-staging :( I was doing it in a rush Really sorry. --- If your project

[jira] [Commented] (FLINK-1201) Graph API for Flink

[ https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14310746#comment-14310746 ] ASF GitHub Bot commented on FLINK-1201: --- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-1438) ClassCastException for Custom InputSplit in local mode and invalid type code in distributed mode

[ https://issues.apache.org/jira/browse/FLINK-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14310891#comment-14310891 ] Robert Metzger commented on FLINK-1438: --- We should add this also to release-0.8 in

[jira] [Commented] (FLINK-1390) java.lang.ClassCastException: X cannot be cast to X

[ https://issues.apache.org/jira/browse/FLINK-1390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14310892#comment-14310892 ] Robert Metzger commented on FLINK-1390: --- I'll ask the user who reported the issue

[jira] [Commented] (FLINK-1201) Graph API for Flink

[ https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14310922#comment-14310922 ] ASF GitHub Bot commented on FLINK-1201: --- Github user andralungu commented on the

[jira] [Updated] (FLINK-100) Pact API Proposal: Add keyless CoGroup (send all to a single group)

[ https://issues.apache.org/jira/browse/FLINK-100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-100: Priority: Minor (was: Major) Pact API Proposal: Add keyless CoGroup (send all to a single group)

[jira] [Commented] (FLINK-1219) Add support for Apache Tez as execution engine

[ https://issues.apache.org/jira/browse/FLINK-1219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14311019#comment-14311019 ] Fabian Hueske commented on FLINK-1219: -- Is this a duplicate of FLINK-972? Add

[jira] [Commented] (FLINK-1486) Add a string to the print method to identify output

[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14310983#comment-14310983 ] ASF GitHub Bot commented on FLINK-1486: --- Github user fhueske commented on the pull

[GitHub] flink pull request: [FLINK-1486] add print method for prefixing a ...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/372#issuecomment-73387496 I think it would be nice to have some kind of hierarchical structure of the output such as: `$sinkName:$taskId $outputValue` That would give the name of the sink

[jira] [Updated] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout

[ https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1418: - Priority: Minor (was: Major) Make 'print()' output on the client command line, rather than on

[jira] [Updated] (FLINK-1414) Remove quickstart-*.sh from git source and put them to the website's svn

[ https://issues.apache.org/jira/browse/FLINK-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1414: - Priority: Minor (was: Major) Remove quickstart-*.sh from git source and put them to the

[jira] [Updated] (FLINK-1321) New web interface, contains parts from WebInfoServer and WebClient

[ https://issues.apache.org/jira/browse/FLINK-1321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1321: - Priority: Minor (was: Major) New web interface, contains parts from WebInfoServer and WebClient

[jira] [Updated] (FLINK-1340) Project restructure

[ https://issues.apache.org/jira/browse/FLINK-1340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1340: - Priority: Minor (was: Major) Project restructure --- Key:

[jira] [Commented] (FLINK-785) Add Chained operators for AllReduce and AllGroupReduce

[ https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14310996#comment-14310996 ] ASF GitHub Bot commented on FLINK-785: -- Github user fhueske commented on the pull

[jira] [Closed] (FLINK-98) Temp Files are not removed if job fails

[ https://issues.apache.org/jira/browse/FLINK-98?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-98. -- Resolution: Duplicate Duplicate of FLINK-1483 Temp Files are not removed if job fails

[jira] [Updated] (FLINK-1256) Use Kryo for user code object serialization

[ https://issues.apache.org/jira/browse/FLINK-1256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1256: - Priority: Minor (was: Major) Use Kryo for user code object serialization

[jira] [Updated] (FLINK-1278) Remove the Record special code paths

[ https://issues.apache.org/jira/browse/FLINK-1278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1278: - Priority: Minor (was: Major) Remove the Record special code paths

[jira] [Updated] (FLINK-1180) Add support for Hadoop MapReduce.* API Mappers and Reducers

[ https://issues.apache.org/jira/browse/FLINK-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1180: - Priority: Minor (was: Major) Add support for Hadoop MapReduce.* API Mappers and Reducers

[jira] [Updated] (FLINK-1309) Upload Flink logo with Flink name

[ https://issues.apache.org/jira/browse/FLINK-1309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1309: - Priority: Minor (was: Major) Upload Flink logo with Flink name

[jira] [Updated] (FLINK-1116) Packaged Scala Examples do not work due to missing test data

[ https://issues.apache.org/jira/browse/FLINK-1116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1116: - Priority: Minor (was: Major) Packaged Scala Examples do not work due to missing test data

[GitHub] flink pull request: [FLINK-1179] Add button to JobManager web inte...

GitHub user chiwanpark opened a pull request: https://github.com/apache/flink/pull/374 [FLINK-1179] Add button to JobManager web interface to request stack trace of a TaskManager This PR contains following changes: * Add public constructors of

[GitHub] flink pull request: [FLINK-785] Chained AllReduce

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/370#issuecomment-73388209 Looks good in general. You need to make sure though, that you obey the execution object re-usage settings. That basically means you need to pay attention to the

[jira] [Updated] (FLINK-685) Add support for semi-joins

[ https://issues.apache.org/jira/browse/FLINK-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-685: Priority: Minor (was: Major) Add support for semi-joins --

[jira] [Updated] (FLINK-687) Add support for outer-joins

[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-687: Priority: Minor (was: Major) Add support for outer-joins ---

[jira] [Updated] (FLINK-603) Add Spargel GAS pattern

[ https://issues.apache.org/jira/browse/FLINK-603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-603: Priority: Minor (was: Major) Add Spargel GAS pattern ---

[jira] [Updated] (FLINK-788) Enable combiner for Reduce with Broadcast Variable

[ https://issues.apache.org/jira/browse/FLINK-788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-788: Priority: Minor (was: Major) Enable combiner for Reduce with Broadcast Variable