[jira] [Resolved] (FLINK-1342) Quickstart's assembly can possibly filter out user's code

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1342. --- Resolution: Fixed Fix Version/s: (was: 0.8.2) Quickstart's assembly can possibly

[jira] [Closed] (FLINK-1708) KafkaSink not working from Usercode classloader

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1708. - Resolution: Invalid I was working on a broken pull request -- closed as invalid. KafkaSink not

[jira] [Commented] (FLINK-1754) Deadlock in job execution

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14369833#comment-14369833 ] Robert Metzger commented on FLINK-1754: --- Ah, thank you for updating the JIRA. The

[jira] [Updated] (FLINK-1753) Add more tests for Kafka Connectors

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1753: -- Description: The current {{KafkaITCase}} is only doing a single test. We need to refactor that

[jira] [Updated] (FLINK-1751) Update CLI documentation page

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1751: -- Priority: Major (was: Trivial) Update CLI documentation page -

[jira] [Created] (FLINK-1752) Add test to Kafka streaming connector

2015-03-19 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1752: - Summary: Add test to Kafka streaming connector Key: FLINK-1752 URL: https://issues.apache.org/jira/browse/FLINK-1752 Project: Flink Issue Type:

[jira] [Updated] (FLINK-1593) Improve exception handling in the Streaming runtime

2015-03-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1593: -- Summary: Improve exception handling in the Streaming runtime (was: Improve exception handling

[jira] [Commented] (FLINK-1593) Improve exception handling int Streaming runtime

2015-03-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14365219#comment-14365219 ] Robert Metzger commented on FLINK-1593: --- Hey, I'm currently testing Flink streaming

[jira] [Commented] (FLINK-1593) Improve exception handling in the Streaming runtime

2015-03-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14365264#comment-14365264 ] Robert Metzger commented on FLINK-1593: --- Sorry, I resolved the issue. The

[jira] [Commented] (FLINK-1663) Add a FIFO job scheduler to the JobManager

2015-03-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353312#comment-14353312 ] Robert Metzger commented on FLINK-1663: --- Yep, users often request this. +1 Add a

[jira] [Commented] (FLINK-1644) WebClient dies when no ExecutionEnvironment in main method

2015-03-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353445#comment-14353445 ] Robert Metzger commented on FLINK-1644: --- Thank you for the bug report. I hope to

[jira] [Commented] (FLINK-1388) POJO support for writeAsCsv

2015-03-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353460#comment-14353460 ] Robert Metzger commented on FLINK-1388: --- Thank you for updating your changes. There

[jira] [Resolved] (FLINK-1637) Flink uberjar does not work with Java 6

2015-03-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1637. --- Resolution: Fixed Fix Version/s: 0.9 Resolved in

[jira] [Commented] (FLINK-1388) POJO support for writeAsCsv

2015-03-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14357170#comment-14357170 ] Robert Metzger commented on FLINK-1388: --- Hi, yes, Tuple types are subclassed. Flink

[jira] [Commented] (FLINK-1671) Add execution modes for programs

2015-03-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14354825#comment-14354825 ] Robert Metzger commented on FLINK-1671: --- That sounds pretty awesome. I agree to make

[jira] [Created] (FLINK-1692) Add option to Flink YARN client to stop a detached YARN session.

2015-03-12 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1692: - Summary: Add option to Flink YARN client to stop a detached YARN session. Key: FLINK-1692 URL: https://issues.apache.org/jira/browse/FLINK-1692 Project: Flink

[jira] [Commented] (FLINK-1679) Document how degree of parallelism / parallelism / slots are connected to each other

2015-03-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14358345#comment-14358345 ] Robert Metzger commented on FLINK-1679: --- I would suggest to remove all occurrences

[jira] [Updated] (FLINK-1525) Provide utils to pass -D parameters to UDFs

2015-03-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1525: -- Assignee: (was: Robert Metzger) Provide utils to pass -D parameters to UDFs

[jira] [Assigned] (FLINK-1525) Provide utils to pass -D parameters to UDFs

2015-03-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1525: - Assignee: Robert Metzger Provide utils to pass -D parameters to UDFs

[jira] [Resolved] (FLINK-1547) Disable automated ApplicationMaster restart

2015-03-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1547. --- Resolution: Fixed Fix Version/s: 0.9 Resolved in

[jira] [Resolved] (FLINK-1629) Add option to start Flink on YARN in a detached mode

2015-03-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1629. --- Resolution: Fixed Fix Version/s: 0.9 Resolved in

[jira] [Resolved] (FLINK-1630) Add option to YARN client to re-allocate failed containers

2015-03-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1630. --- Resolution: Fixed Fix Version/s: 0.9 Resolved in

[jira] [Commented] (FLINK-1629) Add option to start Flink on YARN in a detached mode

2015-03-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14350926#comment-14350926 ] Robert Metzger commented on FLINK-1629: --- For everyone who's ever facing issues

[jira] [Assigned] (FLINK-1547) Disable automated ApplicationMaster restart

2015-03-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1547: - Assignee: Robert Metzger Disable automated ApplicationMaster restart

[jira] [Commented] (FLINK-1537) GSoC project: Machine learning with Apache Flink

2015-03-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14351593#comment-14351593 ] Robert Metzger commented on FLINK-1537: --- No, no problem at all ;) You can find the

[jira] [Commented] (FLINK-1537) GSoC project: Machine learning with Apache Flink

2015-03-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14351589#comment-14351589 ] Robert Metzger commented on FLINK-1537: --- Hi Sachin, thank you for your interest in a

[jira] [Resolved] (FLINK-1356) Add a warning during startup if config files cannot be found

2015-03-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1356. --- Resolution: Fixed Add a warning during startup if config files cannot be found

[jira] [Commented] (FLINK-1356) Add a warning during startup if config files cannot be found

2015-03-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14361879#comment-14361879 ] Robert Metzger commented on FLINK-1356: --- Thank you for reporting the issue. I've

[jira] [Resolved] (FLINK-1567) Add option to switch between Avro and Kryo serialization for GenericTypes

2015-03-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1567. --- Resolution: Fixed Fix Version/s: 0.8.2 0.9 Resolved for 0.8 in

[jira] [Created] (FLINK-1676) enableForceKryo() is not working as expected

2015-03-10 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1676: - Summary: enableForceKryo() is not working as expected Key: FLINK-1676 URL: https://issues.apache.org/jira/browse/FLINK-1676 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-1605) Create a shaded Hadoop fat jar to resolve library version conflicts

2015-03-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1605. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/84e76f4d

[jira] [Created] (FLINK-1685) Document how to read gzip/compressed files with Flink

2015-03-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1685: - Summary: Document how to read gzip/compressed files with Flink Key: FLINK-1685 URL: https://issues.apache.org/jira/browse/FLINK-1685 Project: Flink Issue

[jira] [Commented] (FLINK-1685) Document how to read gzip/compressed files with Flink

2015-03-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14356736#comment-14356736 ] Robert Metzger commented on FLINK-1685: --- the task probably boils down to putting

[jira] [Comment Edited] (FLINK-1525) Provide utils to pass -D parameters to UDFs

2015-03-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14355904#comment-14355904 ] Robert Metzger edited comment on FLINK-1525 at 3/11/15 9:01 AM:

[jira] [Created] (FLINK-1679) Document how degree of parallelism / parallelism / slots are connected to each other

2015-03-10 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1679: - Summary: Document how degree of parallelism / parallelism / slots are connected to each other Key: FLINK-1679 URL: https://issues.apache.org/jira/browse/FLINK-1679

[jira] [Reopened] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

2015-03-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-1650: --- I'm reopening the issue because the exceptions still occur in the current master. The

[jira] [Updated] (FLINK-82) (Hash) Aggregators (fold style)

2015-03-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-82?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-82: Component/s: Local Runtime (Hash) Aggregators (fold style) ---

[jira] [Created] (FLINK-1700) Include Google Analytics in Javadocs

2015-03-13 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1700: - Summary: Include Google Analytics in Javadocs Key: FLINK-1700 URL: https://issues.apache.org/jira/browse/FLINK-1700 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

2015-03-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360287#comment-14360287 ] Robert Metzger commented on FLINK-1650: --- Right now, we only shade away Hadoop's

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

2015-03-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1390. --- Resolution: Invalid Assignee: Robert Metzger The issue wasn't an issue in Flink itself.

[jira] [Commented] (FLINK-1525) Provide utils to pass -D parameters to UDFs

2015-03-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14355904#comment-14355904 ] Robert Metzger commented on FLINK-1525: --- Hi, great. We're always happy about new

[jira] [Commented] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile)

2015-03-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377847#comment-14377847 ] Robert Metzger commented on FLINK-1769: --- I manually deployed to the snapshot

[jira] [Commented] (FLINK-1783) Quickstart shading should not created shaded jar and dependency reduced pom

2015-03-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379859#comment-14379859 ] Robert Metzger commented on FLINK-1783: --- To my understanding the new quickstarts are

[jira] [Assigned] (FLINK-1781) Quickstarts broken due to Scala Version Variables

2015-03-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1781: - Assignee: Robert Metzger Quickstarts broken due to Scala Version Variables

[jira] [Commented] (FLINK-1781) Quickstarts broken due to Scala Version Variables

2015-03-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379866#comment-14379866 ] Robert Metzger commented on FLINK-1781: --- I'll look into this. Quickstarts broken

[jira] [Closed] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls.

2015-03-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1787. - Resolution: Duplicate Remove commons Validate calls with Guava checkArgument() calls.

[jira] [Updated] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls.

2015-03-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1787: -- Issue Type: Task (was: Bug) Remove commons Validate calls with Guava checkArgument() calls.

[jira] [Created] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls.

2015-03-26 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1787: - Summary: Remove commons Validate calls with Guava checkArgument() calls. Key: FLINK-1787 URL: https://issues.apache.org/jira/browse/FLINK-1787 Project: Flink

[jira] [Commented] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls.

2015-03-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14381645#comment-14381645 ] Robert Metzger commented on FLINK-1787: --- oh, you are right. I'll close this one

[jira] [Created] (FLINK-1804) flink-quickstart-scala tests fail on scala-2.11 build profile on travis

2015-03-30 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1804: - Summary: flink-quickstart-scala tests fail on scala-2.11 build profile on travis Key: FLINK-1804 URL: https://issues.apache.org/jira/browse/FLINK-1804 Project:

[jira] [Commented] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

2015-03-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386792#comment-14386792 ] Robert Metzger commented on FLINK-1650: --- I'm going to set the Akka version back to

[jira] [Resolved] (FLINK-1771) Add support for submitting single jobs to a detached YARN session

2015-03-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1771. --- Resolution: Fixed Fix Version/s: 0.9 Implemented in

[jira] [Updated] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface

2015-03-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1052: -- Assignee: (was: Robert Metzger) Access to stdout and log information of Taskmanagers from

[jira] [Updated] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface

2015-03-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1052: -- Component/s: Webfrontend Access to stdout and log information of Taskmanagers from the web

[jira] [Assigned] (FLINK-1800) Add a Beta badge in the documentation to components in flink-staging

2015-04-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1800: - Assignee: Robert Metzger Add a Beta badge in the documentation to components in

[jira] [Updated] (FLINK-1800) Add a Beta badge in the documentation to components in flink-staging

2015-04-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1800: -- Component/s: Documentation Add a Beta badge in the documentation to components in

[jira] [Created] (FLINK-1811) Allow users to pass custom buffer sizes and timeouts to PersistentKafkaSource

2015-04-01 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1811: - Summary: Allow users to pass custom buffer sizes and timeouts to PersistentKafkaSource Key: FLINK-1811 URL: https://issues.apache.org/jira/browse/FLINK-1811

[jira] [Resolved] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface

2015-03-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1501. --- Resolution: Fixed Fix Version/s: (was: pre-apache) 0.9 Resolved

[jira] [Created] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only

2015-03-27 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1792: - Summary: Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792

[jira] [Updated] (FLINK-1781) Quickstarts broken due to Scala Version Variables

2015-03-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1781: -- Assignee: Stephan Ewen (was: Robert Metzger) Quickstarts broken due to Scala Version

[jira] [Updated] (FLINK-1771) Add support for submitting single jobs to a detached YARN session

2015-03-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1771: -- Summary: Add support for submitting single jobs to a detached YARN session (was: Add support

[jira] [Commented] (FLINK-1744) Change the reference of slaves to workers to match the description of the system

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14376033#comment-14376033 ] Robert Metzger commented on FLINK-1744: --- Oh ... sorry. I didn't want to ask you to

[jira] [Created] (FLINK-1771) Add tests for setting the processing slots for the YARN client

2015-03-23 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1771: - Summary: Add tests for setting the processing slots for the YARN client Key: FLINK-1771 URL: https://issues.apache.org/jira/browse/FLINK-1771 Project: Flink

[jira] [Updated] (FLINK-1771) Add tests for setting the processing slots for the YARN client

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1771: -- Affects Version/s: 0.9 Add tests for setting the processing slots for the YARN client

[jira] [Commented] (FLINK-1577) Misleading error messages when cancelling tasks

2015-03-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345300#comment-14345300 ] Robert Metzger commented on FLINK-1577: --- Thank you! Misleading error messages when

[jira] [Resolved] (FLINK-1555) Add utility to log the serializers of composite types

2015-03-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1555. --- Resolution: Fixed Fix Version/s: 0.9 This has been resolved in

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

2015-03-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14343545#comment-14343545 ] Robert Metzger commented on FLINK-1414: --- I've started working on this by committing

[jira] [Commented] (FLINK-1613) Cannost submit to remote ExecutionEnvironment from IDE

2015-02-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14339918#comment-14339918 ] Robert Metzger commented on FLINK-1613: --- How about removing the

[jira] [Updated] (FLINK-1637) Flink uberjar does not work with Java 6

2015-03-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1637: -- Component/s: Build System Flink uberjar does not work with Java 6

[jira] [Closed] (FLINK-1162) Cannot serialize Scala classes with Avro serializer

2015-03-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1162. - Resolution: Fixed Fix Version/s: 0.9 Fixed with Kryo. I suspect there is no test for it.

[jira] [Created] (FLINK-1646) Add name of required configuration value into the Insufficient number of network buffers exception

2015-03-04 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1646: - Summary: Add name of required configuration value into the Insufficient number of network buffers exception Key: FLINK-1646 URL:

[jira] [Commented] (FLINK-1370) Build website automatically

2015-03-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14342290#comment-14342290 ] Robert Metzger commented on FLINK-1370: --- Great! Thank you for implementing this.

[jira] [Created] (FLINK-1614) JM Webfrontend doesn't always show the correct state of Tasks

2015-02-27 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1614: - Summary: JM Webfrontend doesn't always show the correct state of Tasks Key: FLINK-1614 URL: https://issues.apache.org/jira/browse/FLINK-1614 Project: Flink

[jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests

2015-03-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14348585#comment-14348585 ] Robert Metzger commented on FLINK-1166: --- TODO: add a check which checks out a

[jira] [Commented] (FLINK-1572) Output directories are created before input paths are checked

2015-03-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14348807#comment-14348807 ] Robert Metzger commented on FLINK-1572: --- How about removing the files of a failed

[jira] [Resolved] (FLINK-1642) Flakey YARNSessionCapacitySchedulerITCase

2015-03-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1642. --- Resolution: Invalid Flakey YARNSessionCapacitySchedulerITCase

[jira] [Commented] (FLINK-1642) Flakey YARNSessionCapacitySchedulerITCase

2015-03-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14348714#comment-14348714 ] Robert Metzger commented on FLINK-1642: --- As per offline discussion with

[jira] [Commented] (FLINK-1601) Sometimes the YARNSessionFIFOITCase fails on Travis

2015-03-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14348707#comment-14348707 ] Robert Metzger commented on FLINK-1601: --- The errors reported by Till in the

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

2015-03-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14348723#comment-14348723 ] Robert Metzger commented on FLINK-1414: --- I think the best approach here is to lazily

[jira] [Created] (FLINK-1637) Flink uberjar does not work with Java 6

2015-03-03 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1637: - Summary: Flink uberjar does not work with Java 6 Key: FLINK-1637 URL: https://issues.apache.org/jira/browse/FLINK-1637 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1637) Flink uberjar does not work with Java 6

2015-03-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14344918#comment-14344918 ] Robert Metzger commented on FLINK-1637: --- The issue is that Java 6 can not load jar

[jira] [Commented] (FLINK-1577) Misleading error messages when cancelling tasks

2015-03-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345169#comment-14345169 ] Robert Metzger commented on FLINK-1577: --- Another user was affected by this. Would be

[jira] [Assigned] (FLINK-1342) Quickstart's assembly can possibly filter out user's code

2015-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1342: - Assignee: Robert Metzger Quickstart's assembly can possibly filter out user's code

[jira] [Resolved] (FLINK-1308) Flink logo in documentation does not link to website home

2015-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1308. --- Resolution: Fixed The issue has been resolved in

[jira] [Updated] (FLINK-1590) Log environment information also in YARN mode

2015-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1590: -- Component/s: YARN Client Log environment information also in YARN mode

[jira] [Updated] (FLINK-1590) Log environment information also in YARN mode

2015-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1590: -- Affects Version/s: 0.9 Log environment information also in YARN mode

[jira] [Updated] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag

2015-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1521: -- Priority: Minor (was: Major) Some Chained Drivers do not respect object-reuse/non-reuse flag

[jira] [Resolved] (FLINK-1289) Broken links to k-means examples in website

2015-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1289. --- Resolution: Fixed Fix Version/s: 0.8.1 The links are working in the current

[jira] [Assigned] (FLINK-1590) Log environment information also in YARN mode

2015-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1590: - Assignee: Robert Metzger Log environment information also in YARN mode

[jira] [Commented] (FLINK-1582) SocketStream gets stuck when socket closes

2015-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14333096#comment-14333096 ] Robert Metzger commented on FLINK-1582: --- I've assigned [~qmlmoon] to the issue,

[jira] [Updated] (FLINK-1582) SocketStream gets stuck when socket closes

2015-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1582: -- Assignee: Mingliang Qi SocketStream gets stuck when socket closes

[jira] [Commented] (FLINK-1162) Cannot serialize Scala classes with Avro serializer

2015-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14333101#comment-14333101 ] Robert Metzger commented on FLINK-1162: --- I guess we can close this issue because we

[jira] [Closed] (FLINK-567) Yarn Application Master throws no exception when it has no write permission to HDFS

2015-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-567. Resolution: Invalid The issue is very old. The current YARN client is reporting that the YARN

[jira] [Commented] (FLINK-1602) Remove 0.6-incubating from Flink website SVN

2015-02-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14334690#comment-14334690 ] Robert Metzger commented on FLINK-1602: --- How about removing the links to the

[jira] [Commented] (FLINK-1602) Remove 0.6-incubating from Flink website SVN

2015-02-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14334722#comment-14334722 ] Robert Metzger commented on FLINK-1602: --- Yes, I think its a good idea to link the

[jira] [Created] (FLINK-1605) Create a shaded Hadoop fat jar to resolve library version conflicts

2015-02-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1605: - Summary: Create a shaded Hadoop fat jar to resolve library version conflicts Key: FLINK-1605 URL: https://issues.apache.org/jira/browse/FLINK-1605 Project: Flink

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

2015-02-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1596: -- Fix Version/s: 0.9 FileIOChannel introduces space in temp file name

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

2015-02-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14338383#comment-14338383 ] Robert Metzger commented on FLINK-1596: --- Fixed in 0.8 in

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

2015-02-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1596: -- Fix Version/s: 0.8.2 FileIOChannel introduces space in temp file name

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

2015-02-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1596: -- Affects Version/s: (was: 0.8) 0.8.1 FileIOChannel introduces space

<    1   2   3   4   5   6   7   8   9   10   >