[jira] [Commented] (FLINK-2982) CLI info option throws ClassCastException for streaming jobs

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14993297#comment-14993297 ] ASF GitHub Bot commented on FLINK-2982: --- GitHub user sachingoel0101 opened a pull re

[GitHub] flink pull request: [FLINK-2982][cli] Fix to show streaming plans ...

2015-11-05 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/1334 [FLINK-2982][cli] Fix to show streaming plans via info option. You can merge this pull request into a Git repository by running: $ git pull https://github.com/sachingoel0101/flink plan_

[jira] [Resolved] (FLINK-2951) Add Union operator to Table API.

2015-11-05 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-2951. - Resolution: Fixed Fix Version/s: 1.0 > Add Union operator to Table API. > -

[jira] [Commented] (FLINK-2951) Add Union operator to Table API.

2015-11-05 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14993292#comment-14993292 ] Timo Walther commented on FLINK-2951: - Fixed via b80d89a6496060e18257e2c3a69536046e9da

[jira] [Commented] (FLINK-2951) Add Union operator to Table API.

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14993285#comment-14993285 ] ASF GitHub Bot commented on FLINK-2951: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-2951] [Table API] add union operator to...

2015-11-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1315 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Created] (FLINK-2982) CLI info option throws ClassCastException for streaming jobs

2015-11-05 Thread Sachin Goel (JIRA)
Sachin Goel created FLINK-2982: -- Summary: CLI info option throws ClassCastException for streaming jobs Key: FLINK-2982 URL: https://issues.apache.org/jira/browse/FLINK-2982 Project: Flink Issue

[jira] [Created] (FLINK-2981) Update README for building docs

2015-11-05 Thread Martin Junghanns (JIRA)
Martin Junghanns created FLINK-2981: --- Summary: Update README for building docs Key: FLINK-2981 URL: https://issues.apache.org/jira/browse/FLINK-2981 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API.

2015-11-05 Thread Chengxiang Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-2980: - Attachment: Cube-Rollup-GroupSet design doc in Flink.pdf > Add CUBE/ROLLUP/GROUPING SETS operator

[jira] [Created] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API.

2015-11-05 Thread Chengxiang Li (JIRA)
Chengxiang Li created FLINK-2980: Summary: Add CUBE/ROLLUP/GROUPING SETS operator in Table API. Key: FLINK-2980 URL: https://issues.apache.org/jira/browse/FLINK-2980 Project: Flink Issue Type

[jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable

2015-11-05 Thread Nick Dimiduk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992544#comment-14992544 ] Nick Dimiduk commented on FLINK-2124: - Adding {{implements Serializable}} to my POJO a

[GitHub] flink pull request: [doc] fix spelling mistakes in the transformat...

2015-11-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1333 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[GitHub] flink pull request: [doc] fix spelling mistakes in the transformat...

2015-11-05 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1333#issuecomment-154169421 Thank you @rmetzger. I'll merge :) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[jira] [Commented] (FLINK-1728) Add random forest ensemble method to machine learning library

2015-11-05 Thread Devang Bacharwar (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992298#comment-14992298 ] Devang Bacharwar commented on FLINK-1728: - Hello, I would like to work on this. Ca

[jira] [Commented] (FLINK-2966) Improve the way job duration is reported on web frontend.

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992287#comment-14992287 ] ASF GitHub Bot commented on FLINK-2966: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2966][web-dashboard] Improve the way jo...

2015-11-05 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1327#issuecomment-154159578 Rebased to current master. Should be good to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well

[jira] [Updated] (FLINK-2938) Streaming docs not in sync with latest state changes

2015-11-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2938: Fix Version/s: 1.0 > Streaming docs not in sync with latest state changes >

[jira] [Updated] (FLINK-2938) Streaming docs not in sync with latest state changes

2015-11-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2938: Fix Version/s: (was: 0.10) 0.10.1 > Streaming docs not in sync with latest st

[jira] [Closed] (FLINK-2938) Streaming docs not in sync with latest state changes

2015-11-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2938. --- > Streaming docs not in sync with latest state changes > -

[jira] [Resolved] (FLINK-2938) Streaming docs not in sync with latest state changes

2015-11-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2938. - Resolution: Fixed Fixed - master in b32c97a9ce2f4067daf309c1412ba1d33c907709 - 0.10 in 63d92c7

[jira] [Commented] (FLINK-2797) CLI: Missing option to submit jobs in detached mode

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992231#comment-14992231 ] ASF GitHub Bot commented on FLINK-2797: --- Github user sachingoel0101 commented on a d

[GitHub] flink pull request: [FLINK-2797][cli] Add support for running jobs...

2015-11-05 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r44051406 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamContextEnvironment.java --- @@ -81,13 +60,15 @@ public J

[jira] [Commented] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided

2015-11-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992216#comment-14992216 ] Stephan Ewen commented on FLINK-2963: - I would like to avoid it as well. We have our o

[jira] [Commented] (FLINK-2959) Remove number of execution retries configuration from Environment

2015-11-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992211#comment-14992211 ] Stephan Ewen commented on FLINK-2959: - Bear in mind that the ExecutionConfig is shared

[jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable

2015-11-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992176#comment-14992176 ] Maximilian Michels commented on FLINK-2124: --- I just tried the following: {code:

[jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable

2015-11-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992150#comment-14992150 ] Maximilian Michels commented on FLINK-2124: --- Flink 0.9.1 has a custom serializat

[jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable

2015-11-05 Thread Nick Dimiduk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992128#comment-14992128 ] Nick Dimiduk commented on FLINK-2124: - I'm also confused. Further debugging, and I tri

[jira] [Commented] (FLINK-2797) CLI: Missing option to submit jobs in detached mode

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992114#comment-14992114 ] ASF GitHub Bot commented on FLINK-2797: --- Github user sachingoel0101 commented on a d

[GitHub] flink pull request: [FLINK-2797][cli] Add support for running jobs...

2015-11-05 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r44044799 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamContextEnvironment.java --- @@ -81,13 +60,15 @@ public J

[jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable

2015-11-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992106#comment-14992106 ] Maximilian Michels commented on FLINK-2124: --- Sorry, just had a second look. This

[jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable

2015-11-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992103#comment-14992103 ] Maximilian Michels commented on FLINK-2124: --- Just looked into this. The problem

[jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable

2015-11-05 Thread Nick Dimiduk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992066#comment-14992066 ] Nick Dimiduk commented on FLINK-2124: - Debugging, it looks like the source exception i

[jira] [Closed] (FLINK-2957) Make cancel button look less like a label

2015-11-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-2957. - Resolution: Fixed > Make cancel button look less like a label > --

[jira] [Commented] (FLINK-2957) Make cancel button look less like a label

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992054#comment-14992054 ] ASF GitHub Bot commented on FLINK-2957: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-2957][web-dashboard] Improve the appear...

2015-11-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1319 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-2797) CLI: Missing option to submit jobs in detached mode

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992051#comment-14992051 ] ASF GitHub Bot commented on FLINK-2797: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2797][cli] Add support for running jobs...

2015-11-05 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r44040745 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamContextEnvironment.java --- @@ -81,13 +60,15 @@ public JobExecution

[jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable

2015-11-05 Thread Nick Dimiduk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992044#comment-14992044 ] Nick Dimiduk commented on FLINK-2124: - Sure. The code looks like {code} DataStream so

[jira] [Commented] (FLINK-2938) Streaming docs not in sync with latest state changes

2015-11-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992016#comment-14992016 ] Stephan Ewen commented on FLINK-2938: - Will fix this... > Streaming docs not in sync

[GitHub] flink pull request: [FLINK-2966][web-dashboard] Improve the way jo...

2015-11-05 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1327#issuecomment-154123489 Thanks. Looks good! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this featur

[jira] [Commented] (FLINK-2966) Improve the way job duration is reported on web frontend.

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991994#comment-14991994 ] ASF GitHub Bot commented on FLINK-2966: --- Github user mxm commented on the pull reque

[jira] [Assigned] (FLINK-2938) Streaming docs not in sync with latest state changes

2015-11-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-2938: --- Assignee: Stephan Ewen > Streaming docs not in sync with latest state changes > -

[jira] [Commented] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991962#comment-14991962 ] ASF GitHub Bot commented on FLINK-2752: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-2752] [Documentation] Documentation is ...

2015-11-05 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1320#issuecomment-154120354 I'm not too fond of "Home Docu". Can you reduce the size of the search box? That should do it. --- If your project is set up for it, you can reply to this email and have yo

[jira] [Commented] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991945#comment-14991945 ] ASF GitHub Bot commented on FLINK-2752: --- Github user mjsax commented on the pull req

[GitHub] flink pull request: [FLINK-2752] [Documentation] Documentation is ...

2015-11-05 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1320#issuecomment-154116728 Changing "Overview" to "Documenation" breaks the layout for me (using Firefox). What about using "Home Docu 1.0" instead? ![screenshot](https://cloud.githubuserco

[jira] [Commented] (FLINK-2951) Add Union operator to Table API.

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991867#comment-14991867 ] ASF GitHub Bot commented on FLINK-2951: --- Github user twalthr commented on a diff in

[GitHub] flink pull request: [FLINK-2951] [Table API] add union operator to...

2015-11-05 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1315#discussion_r44028753 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/Table.scala --- @@ -243,5 +243,29 @@ case class Table(private[flink] val operat

[jira] [Updated] (FLINK-2977) Cannot access HBase in a Kerberos secured Yarn cluster

2015-11-05 Thread Niels Basjes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Niels Basjes updated FLINK-2977: Attachment: FLINK-2977-20151005-untested.patch First attempt, untested. Essentially copied from htt

[jira] [Closed] (FLINK-2598) NPE when arguments are missing for a "-m yarn-cluster" job

2015-11-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-2598. - Resolution: Won't Fix Fix Version/s: (was: 0.9.2) > NPE when arguments are missing for

[jira] [Commented] (FLINK-2944) Collect, expose and display operator-specific stats

2015-11-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991757#comment-14991757 ] Robert Metzger commented on FLINK-2944: --- Big +1 for this one! > Collect, expose and

[jira] [Commented] (FLINK-2598) NPE when arguments are missing for a "-m yarn-cluster" job

2015-11-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991767#comment-14991767 ] Robert Metzger commented on FLINK-2598: --- Yeah we can close it. It doesn't seem we're

[jira] [Commented] (FLINK-2973) Remove OpenJDK JMH dependency from flink-benchmark

2015-11-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991768#comment-14991768 ] Maximilian Michels commented on FLINK-2973: --- The benchmark module has been remov

[jira] [Commented] (FLINK-2045) JobManager webinterface is unresponsive with many TaskManagers

2015-11-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991765#comment-14991765 ] Robert Metzger commented on FLINK-2045: --- I'll close this issue. It's been created fo

[jira] [Closed] (FLINK-2045) JobManager webinterface is unresponsive with many TaskManagers

2015-11-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-2045. - Resolution: Invalid > JobManager webinterface is unresponsive with many TaskManagers > ---

[GitHub] flink pull request: [doc] fix spelling mistakes in the transformat...

2015-11-05 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1333#issuecomment-154083197 +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature e

[jira] [Assigned] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1

2015-11-05 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2979: --- Assignee: Aljoscha Krettek > RollingSink does not work with Hadoop 2.7.1 > --

[jira] [Comment Edited] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1

2015-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991725#comment-14991725 ] Till Rohrmann edited comment on FLINK-2979 at 11/5/15 2:29 PM: -

[jira] [Commented] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1

2015-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991725#comment-14991725 ] Till Rohrmann commented on FLINK-2979: -- The failure might be caused by {code} java.

[jira] [Commented] (FLINK-2967) TM address detection might not always detect the right interface on slow networks / overloaded JMs

2015-11-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991699#comment-14991699 ] Maximilian Michels commented on FLINK-2967: --- Yes, increasing the timeout will so

[jira] [Commented] (FLINK-2967) TM address detection might not always detect the right interface on slow networks / overloaded JMs

2015-11-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991682#comment-14991682 ] Robert Metzger commented on FLINK-2967: --- The problem is caused by a too short initia

[jira] [Created] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1

2015-11-05 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2979: Summary: RollingSink does not work with Hadoop 2.7.1 Key: FLINK-2979 URL: https://issues.apache.org/jira/browse/FLINK-2979 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991672#comment-14991672 ] ASF GitHub Bot commented on FLINK-2752: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-2752] [Documentation] Documentation is ...

2015-11-05 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1320#issuecomment-154062218 I'm with you that the design could be improved but I rather have some small changes such that we have an improvement over the current situation. So let's merge with "Overvie

[jira] [Commented] (FLINK-2967) TM address detection might not always detect the right interface on slow networks / overloaded JMs

2015-11-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991668#comment-14991668 ] Maximilian Michels commented on FLINK-2967: --- I think the issue is that a task ma

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991665#comment-14991665 ] ASF GitHub Bot commented on FLINK-2905: --- Github user s1ck commented on the pull requ

[GitHub] flink pull request: [FLINK-2905] [gelly] Add Graph Intersection me...

2015-11-05 Thread s1ck
Github user s1ck commented on the pull request: https://github.com/apache/flink/pull/1329#issuecomment-154061114 yeah, that's fine with me. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have thi

[jira] [Created] (FLINK-2978) Integrate web submission interface into the new dashboard

2015-11-05 Thread Sachin Goel (JIRA)
Sachin Goel created FLINK-2978: -- Summary: Integrate web submission interface into the new dashboard Key: FLINK-2978 URL: https://issues.apache.org/jira/browse/FLINK-2978 Project: Flink Issue Typ

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991656#comment-14991656 ] ASF GitHub Bot commented on FLINK-2905: --- Github user vasia commented on the pull req

[GitHub] flink pull request: [FLINK-2905] [gelly] Add Graph Intersection me...

2015-11-05 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1329#issuecomment-154060039 hmm I see. It's not very nice to have 2 different ways of doing the same thing imo. Could we just keep the second one maybe? --- If your project is set up for it, you can

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991644#comment-14991644 ] ASF GitHub Bot commented on FLINK-2905: --- Github user s1ck commented on the pull requ

[GitHub] flink pull request: [FLINK-2905] [gelly] Add Graph Intersection me...

2015-11-05 Thread s1ck
Github user s1ck commented on the pull request: https://github.com/apache/flink/pull/1329#issuecomment-154057136 Hey! you're welcome :) I will fix the comments later today. There is no difference, `graph1.intersect(graph2)` is just a convenience method if the user wants the defaul

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991639#comment-14991639 ] ASF GitHub Bot commented on FLINK-2905: --- Github user vasia commented on the pull req

[GitHub] flink pull request: [FLINK-2905] [gelly] Add Graph Intersection me...

2015-11-05 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1329#issuecomment-154055282 Hey @s1ck, thanks a lot for the PR! I left a few minor comments on the docs. One thing that confuses me is what is the difference between 'graph1.intersect(gra

[jira] [Assigned] (FLINK-2977) Cannot access HBase in a Kerberos secured Yarn cluster

2015-11-05 Thread Niels Basjes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Niels Basjes reassigned FLINK-2977: --- Assignee: Niels Basjes > Cannot access HBase in a Kerberos secured Yarn cluster > ---

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991629#comment-14991629 ] ASF GitHub Bot commented on FLINK-2905: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991633#comment-14991633 ] ASF GitHub Bot commented on FLINK-2905: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-2905] [gelly] Add Graph Intersection me...

2015-11-05 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1329#discussion_r44008216 --- Diff: flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala --- @@ -968,6 +968,46 @@ TypeInformation : ClassTag](jgraph

[GitHub] flink pull request: [FLINK-2905] [gelly] Add Graph Intersection me...

2015-11-05 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1329#discussion_r44008153 --- Diff: flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala --- @@ -968,6 +968,46 @@ TypeInformation : ClassTag](jgraph

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991628#comment-14991628 ] ASF GitHub Bot commented on FLINK-2905: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-2905] [gelly] Add Graph Intersection me...

2015-11-05 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1329#discussion_r44008073 --- Diff: docs/libs/gelly_guide.md --- @@ -485,13 +485,15 @@ val networkWithWeights = network.joinWithEdgesOnSource(vertexOutDegrees, (v1: Do * Undir

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991627#comment-14991627 ] ASF GitHub Bot commented on FLINK-2905: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-2905] [gelly] Add Graph Intersection me...

2015-11-05 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1329#discussion_r44008025 --- Diff: docs/libs/gelly_guide.md --- @@ -485,13 +485,15 @@ val networkWithWeights = network.joinWithEdgesOnSource(vertexOutDegrees, (v1: Do * Undir

[jira] [Commented] (FLINK-2976) Save and load checkpoints manually

2015-11-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991623#comment-14991623 ] Stephan Ewen commented on FLINK-2976: - Yes, what we need for job version upgrades are

[jira] [Commented] (FLINK-2976) Save and load checkpoints manually

2015-11-05 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991622#comment-14991622 ] Gyula Fora commented on FLINK-2976: --- Yes, you are right, this becomes a very tricky ques

[jira] [Commented] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991614#comment-14991614 ] ASF GitHub Bot commented on FLINK-2752: --- Github user mjsax commented on the pull req

[GitHub] flink pull request: [FLINK-2752] [Documentation] Documentation is ...

2015-11-05 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1320#issuecomment-154049603 I agree that changing the colors is a tricky issues. Does anybody have good design skills? From my point of view, a clear visual difference is the only way to get a clear

[jira] [Commented] (FLINK-2976) Save and load checkpoints manually

2015-11-05 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991613#comment-14991613 ] Aljoscha Krettek commented on FLINK-2976: - Yes, it is definitely required. Althoug

[GitHub] flink pull request: [doc] fix spelling mistakes in the transformat...

2015-11-05 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1333 [doc] fix spelling mistakes in the transformations guide You can merge this pull request into a Git repository by running: $ git pull https://github.com/vasia/flink transformations-doc Alternat

[jira] [Commented] (FLINK-2967) TM address detection might not always detect the right interface on slow networks / overloaded JMs

2015-11-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991612#comment-14991612 ] Stephan Ewen commented on FLINK-2967: - Is the problem caused by the too short initial

[jira] [Commented] (FLINK-2977) Cannot access HBase in a Kerberos secured Yarn cluster

2015-11-05 Thread Niels Basjes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991608#comment-14991608 ] Niels Basjes commented on FLINK-2977: - In the mailing list [~rmetzger] responded: {quo

[jira] [Created] (FLINK-2977) Cannot access HBase in a Kerberos secured Yarn cluster

2015-11-05 Thread Niels Basjes (JIRA)
Niels Basjes created FLINK-2977: --- Summary: Cannot access HBase in a Kerberos secured Yarn cluster Key: FLINK-2977 URL: https://issues.apache.org/jira/browse/FLINK-2977 Project: Flink Issue Type

[jira] [Commented] (FLINK-2975) Exclude logging dependencies from shaded Hadoop jar.

2015-11-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991588#comment-14991588 ] Robert Metzger commented on FLINK-2975: --- I've closed the issue as a duplicate. > Ex

[jira] [Resolved] (FLINK-2975) Exclude logging dependencies from shaded Hadoop jar.

2015-11-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2975. --- Resolution: Duplicate > Exclude logging dependencies from shaded Hadoop jar. > ---

[jira] [Commented] (FLINK-2976) Save and load checkpoints manually

2015-11-05 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991570#comment-14991570 ] Gyula Fora commented on FLINK-2976: --- Thanks Ufuk! This is a critical feature for almost

[jira] [Commented] (FLINK-2975) Exclude logging dependencies from shaded Hadoop jar.

2015-11-05 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991556#comment-14991556 ] Jan Thomä commented on FLINK-2975: -- Thank you very much, seems to be indeed a duplicate o

[jira] [Created] (FLINK-2976) Save and load checkpoints manually

2015-11-05 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2976: -- Summary: Save and load checkpoints manually Key: FLINK-2976 URL: https://issues.apache.org/jira/browse/FLINK-2976 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991552#comment-14991552 ] ASF GitHub Bot commented on FLINK-2752: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-2752] [Documentation] Documentation is ...

2015-11-05 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1320#issuecomment-154035246 Thanks for clarifying your approach on the issue. I believe that you are taking concerns seriously but I also think that merging when there are clear open concerns is not an

[jira] [Commented] (FLINK-2957) Make cancel button look less like a label

2015-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991543#comment-14991543 ] ASF GitHub Bot commented on FLINK-2957: --- Github user sachingoel0101 commented on the

  1   2   >