[jira] [Commented] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager

[ https://issues.apache.org/jira/browse/FLINK-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311160#comment-14311160 ] ASF GitHub Bot commented on FLINK-1179: --- GitHub user chiwanpark opened a pull reques

[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 `org.apache.flink.runtime.instance.

[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-tabpanel&focusedCommentId=14311019#comment-14311019 ] Fabian Hueske commented on FLINK-1219: -- Is this a duplicate of FLINK-972? > Add supp

[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] [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 >

[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-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-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-871) Create a documentation distribution together with other release artifacts

[ https://issues.apache.org/jira/browse/FLINK-871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-871: Priority: Minor (was: Major) > Create a documentation distribution together with other release artif

[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 > ---

[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-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-1294) Add Performance and Tuning Guide to documentation

[ https://issues.apache.org/jira/browse/FLINK-1294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1294: - Priority: Minor (was: Major) > Add Performance and Tuning Guide to documentation > --

[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-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-1268) FileOutputFormat with overwrite does not clear local output directories

[ https://issues.apache.org/jira/browse/FLINK-1268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1268: - Priority: Minor (was: Major) > FileOutputFormat with overwrite does not clear local output direct

[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] [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 t

[jira] [Updated] (FLINK-1396) Add hadoop input formats directly to the user API.

[ https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1396: - Priority: Minor (was: Major) > Add hadoop input formats directly to the user API. > -

[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 website

[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] [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-tabpanel&focusedCommentId=14310996#comment-14310996 ] ASF GitHub Bot commented on FLINK-785: -- Github user fhueske commented on the pull requ

[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 ob

[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-tabpanel&focusedCommentId=14310983#comment-14310983 ] ASF GitHub Bot commented on FLINK-1486: --- Github user fhueske commented on the pull r

[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

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

Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/335#issuecomment-73381932 I got the ACK from Apache. My ICLA has been filed :) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as we

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

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

[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-tabpanel&focusedCommentId=14310892#comment-14310892 ] Robert Metzger commented on FLINK-1390: --- I'll ask the user who reported the issue wh

[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-tabpanel&focusedCommentId=14310891#comment-14310891 ] Robert Metzger commented on FLINK-1438: --- We should add this also to release-0.8 in m

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

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

[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 projec

[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-tabpanel&focusedCommentId=14310629#comment-14310629 ] Fabian Hueske commented on FLINK-1390: -- The possibly related issue FLINK-1438 has bee

[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 > --- > >

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

[ https://issues.apache.org/jira/browse/FLINK-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14310626#comment-14310626 ] Fabian Hueske commented on FLINK-1476: -- For a fair comparison, all system should get