[jira] [Comment Edited] (FLINK-2080) Execute Flink with sbt

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573275#comment-14573275 ] Robert Metzger edited comment on FLINK-2080 at 6/4/15 6:05 PM:

[jira] [Updated] (FLINK-1877) Stalled Flink on Tez build

2015-06-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1877: -- Component/s: Flink on Tez Stalled Flink on Tez build --

[jira] [Created] (FLINK-2152) Provide zipWithIndex utility in flink-contrib

2015-06-03 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2152: - Summary: Provide zipWithIndex utility in flink-contrib Key: FLINK-2152 URL: https://issues.apache.org/jira/browse/FLINK-2152 Project: Flink Issue Type:

[jira] [Created] (FLINK-2151) Provide interface to distinguish close() calls in error and regular cases

2015-06-03 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2151: - Summary: Provide interface to distinguish close() calls in error and regular cases Key: FLINK-2151 URL: https://issues.apache.org/jira/browse/FLINK-2151 Project:

[jira] [Updated] (FLINK-1674) Add test with nested avro type

2015-06-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1674: -- Labels: starter (was: ) Add test with nested avro type --

[jira] [Updated] (FLINK-1947) Make Avro and Tachyon test logging less verbose

2015-06-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1947: -- Labels: starter (was: ) Make Avro and Tachyon test logging less verbose

[jira] [Assigned] (FLINK-2095) Screenshots missing in webcient documentation

2015-06-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2095: - Assignee: Robert Metzger Screenshots missing in webcient documentation

[jira] [Commented] (FLINK-2075) Shade akka and protobuf dependencies away

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

[jira] [Updated] (FLINK-2075) Shade akka and protobuf dependencies away

2015-06-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2075: -- Component/s: Build System Shade akka and protobuf dependencies away

[jira] [Resolved] (FLINK-864) Add description of mutable object iterators (GroupReduce, CoGroup) to documentation

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-864. -- Resolution: Invalid The mutable object mode is going to be documented in FLINK-1565 Add

[jira] [Assigned] (FLINK-1061) Describe how to run the examples from the command line

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1061: - Assignee: Robert Metzger Describe how to run the examples from the command line

[jira] [Assigned] (FLINK-1126) Add suggestion for using large TupleX types

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1126: - Assignee: Robert Metzger Add suggestion for using large TupleX types

[jira] [Commented] (FLINK-2123) Fix CLI client logging

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572833#comment-14572833 ] Robert Metzger commented on FLINK-2123: --- How can I reproduce the too much

[jira] [Commented] (FLINK-2123) Fix CLI client logging

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572841#comment-14572841 ] Robert Metzger commented on FLINK-2123: --- Okay .. sorry.. It seems that the too much

[jira] [Created] (FLINK-2158) NullPointerException in DateSerializer.

2015-06-04 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2158: - Summary: NullPointerException in DateSerializer. Key: FLINK-2158 URL: https://issues.apache.org/jira/browse/FLINK-2158 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-2135) Java plan translation fails with ClassCastException (probably in first())

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

[jira] [Updated] (FLINK-2095) Screenshots missing in webcient documentation

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2095: -- Priority: Trivial (was: Major) Assignee: (was: Robert Metzger) Labels: starter

[jira] [Updated] (FLINK-2095) Screenshots missing in webcient documentation

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2095: -- Affects Version/s: (was: 0.9) Screenshots missing in webcient documentation

[jira] [Commented] (FLINK-2095) Screenshots missing in webcient documentation

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572570#comment-14572570 ] Robert Metzger commented on FLINK-2095: --- There were no screenshots in the page.

[jira] [Resolved] (FLINK-1061) Describe how to run the examples from the command line

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

[jira] [Resolved] (FLINK-2164) Document batch and streaming startup modes

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

[jira] [Resolved] (FLINK-2179) when return value from linkedlist or map and use in filter function display error

2015-06-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2179. --- Resolution: Invalid Please write to u...@flink.apache.org or here

[jira] [Resolved] (FLINK-2092) Document (new) behavior of print() and execute()

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

[jira] [Commented] (FLINK-1858) Add further checks to QA bot

2015-06-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14576478#comment-14576478 ] Robert Metzger commented on FLINK-1858: --- We could also add a check which ensures

[jira] [Created] (FLINK-2266) Building Flink for a specific HDP version fails

2015-06-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2266: - Summary: Building Flink for a specific HDP version fails Key: FLINK-2266 URL: https://issues.apache.org/jira/browse/FLINK-2266 Project: Flink Issue Type:

[jira] [Updated] (FLINK-2266) Building Flink for a specific HDP version fails

2015-06-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2266: -- Description: I was talking to a user recently, who had issues using Flink's build-in HDFS

[jira] [Commented] (FLINK-2266) Building Flink for a specific HDP version fails

2015-06-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14599190#comment-14599190 ] Robert Metzger commented on FLINK-2266: --- It seems that

[jira] [Updated] (FLINK-2248) Allow disabling of sdtout logging output

2015-06-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2248: -- Labels: starter (was: ) Allow disabling of sdtout logging output

[jira] [Created] (FLINK-2268) Provide Flink binary release without Hadoop

2015-06-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2268: - Summary: Provide Flink binary release without Hadoop Key: FLINK-2268 URL: https://issues.apache.org/jira/browse/FLINK-2268 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

2015-06-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593008#comment-14593008 ] Robert Metzger commented on FLINK-2235: --- If I recall correctly, the community

[jira] [Updated] (FLINK-2237) Add hash-based Aggregation

2015-06-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2237: -- Labels: (was: github-import) Add hash-based Aggregation --

[jira] [Updated] (FLINK-2237) Add hash-based Aggregation

2015-06-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2237: -- Fix Version/s: (was: pre-apache) Add hash-based Aggregation --

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

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

[jira] [Updated] (FLINK-1541) GSoC project: Distributed profiling

2015-06-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1541: -- Assignee: (was: Robert Metzger) GSoC project: Distributed profiling

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

2015-06-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14594897#comment-14594897 ] Robert Metzger commented on FLINK-2167: --- Mh. Are there any error message? Maybe you

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

2015-06-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14594851#comment-14594851 ] Robert Metzger commented on FLINK-2248: --- The execution config has a method to

[jira] [Comment Edited] (FLINK-2235) Local Flink cluster allocates too much memory

2015-06-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14594861#comment-14594861 ] Robert Metzger edited comment on FLINK-2235 at 6/20/15 11:01 PM:

[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

2015-06-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14594861#comment-14594861 ] Robert Metzger commented on FLINK-2235: --- I agree. Lets fix this one for OracleJDK 6.

[jira] [Commented] (FLINK-2220) Join on Pojo without hashCode() silently fails

2015-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14588860#comment-14588860 ] Robert Metzger commented on FLINK-2220: --- I would actually do this in the

[jira] [Commented] (FLINK-1877) Stalled Flink on Tez build

2015-06-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14584249#comment-14584249 ] Robert Metzger commented on FLINK-1877: --- Cool, thank you for the pointer. I'll keep

[jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

2015-06-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14584318#comment-14584318 ] Robert Metzger commented on FLINK-2200: --- This issue has been discussed on the user@

[jira] [Commented] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

2015-06-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14584277#comment-14584277 ] Robert Metzger commented on FLINK-2209: --- I also vote to keep them out of flink-dist.

[jira] [Updated] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

2015-06-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2200: -- Component/s: Build System Flink API with Scala 2.11 - Maven Repository

[jira] [Commented] (FLINK-2227) .yarn-properties file is not cleaned up

2015-06-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14586274#comment-14586274 ] Robert Metzger commented on FLINK-2227: --- It is a bug, but I would not block the

[jira] [Created] (FLINK-2126) Scala shell tests sporadically fail on travis

2015-06-01 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2126: - Summary: Scala shell tests sporadically fail on travis Key: FLINK-2126 URL: https://issues.apache.org/jira/browse/FLINK-2126 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-2037) Unable to start Python API using ./bin/pyflink*.sh

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

[jira] [Commented] (FLINK-2101) Scheme Inference doesn't work for Tuple5

2015-06-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567813#comment-14567813 ] Robert Metzger commented on FLINK-2101: --- Yes, will do. Scheme Inference doesn't

[jira] [Resolved] (FLINK-1905) Add tests for parallelism 1 for Kafka sources

2015-05-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1905. --- Resolution: Fixed Resolved with the recently added tests. Add tests for parallelism 1 for

[jira] [Commented] (FLINK-2101) Scheme Inference doesn't work for Tuple5

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

[jira] [Commented] (FLINK-2081) Change order of restore state and open for Streaming Operators

2015-05-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561084#comment-14561084 ] Robert Metzger commented on FLINK-2081: --- Can we come to an agreement here? I think

[jira] [Commented] (FLINK-2101) Scheme Inference doesn't work for Tuple5

2015-05-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561072#comment-14561072 ] Robert Metzger commented on FLINK-2101: --- The {{KafkaITCase}} is the only code which

[jira] [Commented] (FLINK-2101) Scheme Inference doesn't work for Tuple5

2015-05-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561128#comment-14561128 ] Robert Metzger commented on FLINK-2101: --- I think this constructor is public? {code}

[jira] [Assigned] (FLINK-2101) Scheme Inference doesn't work for Tuple5

2015-05-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2101: - Assignee: Robert Metzger Scheme Inference doesn't work for Tuple5

[jira] [Commented] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements

2015-06-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569132#comment-14569132 ] Robert Metzger commented on FLINK-2130: --- I would let the source fail. All the other

[jira] [Updated] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements

2015-06-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2130: -- Component/s: Streaming Connectors Streaming RabbitMQ source does not fail

[jira] [Created] (FLINK-2135) Java plan translation fails with ClassCastException (probably in first())

2015-06-02 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2135: - Summary: Java plan translation fails with ClassCastException (probably in first()) Key: FLINK-2135 URL: https://issues.apache.org/jira/browse/FLINK-2135 Project:

[jira] [Commented] (FLINK-2008) PersistentKafkaSource is sometimes emitting tuples multiple times

2015-05-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14560554#comment-14560554 ] Robert Metzger commented on FLINK-2008: --- Another case:

[jira] [Resolved] (FLINK-2079) Add watcher to YARN TM containers to detect stopped actor system

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

[jira] [Updated] (FLINK-2096) Remove implicit conversions in Streaming Scala API

2015-05-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2096: -- Assignee: Aljoscha Krettek Remove implicit conversions in Streaming Scala API

[jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

2015-07-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14609733#comment-14609733 ] Robert Metzger commented on FLINK-2200: --- Thank you for looking into this. I wrote to

[jira] [Commented] (FLINK-2176) Add support for ProgramDesctiption interface in clients

2015-07-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14610143#comment-14610143 ] Robert Metzger commented on FLINK-2176: --- Thx for closing. I forgot that because I

[jira] [Resolved] (FLINK-2298) Allow setting custom YARN application names through the CLI

2015-07-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2298. --- Resolution: Fixed Fix Version/s: 0.9.1 0.10 Fixed for 0.10 in

[jira] [Created] (FLINK-2307) Drop Java 6 support

2015-07-01 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2307: - Summary: Drop Java 6 support Key: FLINK-2307 URL: https://issues.apache.org/jira/browse/FLINK-2307 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2311) Set flink-* dependencies in flink-contrib as provided

2015-07-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14611601#comment-14611601 ] Robert Metzger commented on FLINK-2311: --- Hi. I don't understand why you want to set

[jira] [Commented] (FLINK-2307) Drop Java 6 support

2015-07-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14611596#comment-14611596 ] Robert Metzger commented on FLINK-2307: --- Hi Matthias, I don't think we have to

[jira] [Commented] (FLINK-2313) Change Streaming Driver Execution Model

2015-07-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14611730#comment-14611730 ] Robert Metzger commented on FLINK-2313: --- +1 I can actually imagine more possible

[jira] [Commented] (FLINK-2008) PersistentKafkaSource is sometimes emitting tuples multiple times

2015-06-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605544#comment-14605544 ] Robert Metzger commented on FLINK-2008: --- I'm looking into these issues now ...

[jira] [Closed] (FLINK-2311) Set flink-* dependencies in flink-contrib as provided

2015-07-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-2311. - Resolution: Won't Fix Fix Version/s: (was: 0.9.1) (was: 0.10)

[jira] [Commented] (FLINK-2294) Keyed State does not work with DOP=1

2015-06-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14608236#comment-14608236 ] Robert Metzger commented on FLINK-2294: --- It would have been nice if you waited until

[jira] [Created] (FLINK-2296) Checkpoint committing broken

2015-06-30 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2296: - Summary: Checkpoint committing broken Key: FLINK-2296 URL: https://issues.apache.org/jira/browse/FLINK-2296 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-2296) Checkpoint committing broken

2015-06-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2296: - Assignee: Robert Metzger Checkpoint committing broken

[jira] [Updated] (FLINK-2296) Checkpoint committing broken

2015-06-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2296: -- Description: While working on fixing the failing {{PersistentKafkaSource}} test, I realized

[jira] [Created] (FLINK-2298) Allow setting custom YARN application names through the CLI

2015-06-30 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2298: - Summary: Allow setting custom YARN application names through the CLI Key: FLINK-2298 URL: https://issues.apache.org/jira/browse/FLINK-2298 Project: Flink

[jira] [Commented] (FLINK-2299) The slot on which the task maanger was scheduled was killed

2015-06-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14608296#comment-14608296 ] Robert Metzger commented on FLINK-2299: --- Looks like wally025 broke up with the

[jira] [Created] (FLINK-2087) Add streaming mode to YARN as well

2015-05-25 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2087: - Summary: Add streaming mode to YARN as well Key: FLINK-2087 URL: https://issues.apache.org/jira/browse/FLINK-2087 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-2080) Execute Flink with sbt

2015-05-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14558394#comment-14558394 ] Robert Metzger commented on FLINK-2080: --- Thank you for exploring how to run Flink

[jira] [Created] (FLINK-2092) Document (new) behavior of print() and execute()

2015-05-26 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2092: - Summary: Document (new) behavior of print() and execute() Key: FLINK-2092 URL: https://issues.apache.org/jira/browse/FLINK-2092 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-1920) Passing -D akka.ask.timeout=5 min to yarn client does not work

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

[jira] [Commented] (FLINK-2081) Change order of restore state and open for Streaming Operators

2015-05-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14556034#comment-14556034 ] Robert Metzger commented on FLINK-2081: --- You can always work around that by leaving

[jira] [Created] (FLINK-2079) Add watcher to YARN TM containers to detect stopped actor system

2015-05-22 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2079: - Summary: Add watcher to YARN TM containers to detect stopped actor system Key: FLINK-2079 URL: https://issues.apache.org/jira/browse/FLINK-2079 Project: Flink

[jira] [Created] (FLINK-2064) Set Tez version to 0.6.1

2015-05-20 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2064: - Summary: Set Tez version to 0.6.1 Key: FLINK-2064 URL: https://issues.apache.org/jira/browse/FLINK-2064 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases

2015-08-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699315#comment-14699315 ] Robert Metzger commented on FLINK-2491: --- I quickly talked with [~StephanEwen] about

[jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases

2015-08-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699292#comment-14699292 ] Robert Metzger commented on FLINK-2491: --- I suspect FLINK-2519 resolves this bug.

[jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases

2015-08-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699299#comment-14699299 ] Robert Metzger commented on FLINK-2491: --- The issue still persists {code} 1750

[jira] [Updated] (FLINK-2517) Wrong KafkaSink arguments in streaming guide

2015-08-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2517: -- Assignee: Nezih Yigitbasi Wrong KafkaSink arguments in streaming guide

[jira] [Created] (FLINK-2543) State handling does not support deserializing classes through the UserCodeClassloader

2015-08-18 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2543: - Summary: State handling does not support deserializing classes through the UserCodeClassloader Key: FLINK-2543 URL: https://issues.apache.org/jira/browse/FLINK-2543

[jira] [Assigned] (FLINK-2543) State handling does not support deserializing classes through the UserCodeClassloader

2015-08-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2543: - Assignee: Robert Metzger State handling does not support deserializing classes through

[jira] [Updated] (FLINK-2541) TypeComparator creation fails for T2T1byte[], byte[]

2015-08-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2541: -- Component/s: Java API TypeComparator creation fails for T2T1byte[], byte[]

[jira] [Commented] (FLINK-2541) TypeComparator creation fails for T2T1byte[], byte[]

2015-08-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704470#comment-14704470 ] Robert Metzger commented on FLINK-2541: --- Mh, But if the PrimitiveArrayTypeInfo is

[jira] [Updated] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey

2015-08-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2315: -- Fix Version/s: (was: 0.9.1) Hadoop Writables cannot exploit implementing NormalizableKey

[jira] [Updated] (FLINK-2568) Flink fat jar is missing org.w3c.dom.ElementTraversal in some environments.

2015-08-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2568: -- Description: Error while writing into HDFS reported by a user. The user is using a Hadoop

[jira] [Created] (FLINK-2568) Flink fat jar is missing org.w3c.dom.ElementTraversal in some environments.

2015-08-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2568: - Summary: Flink fat jar is missing org.w3c.dom.ElementTraversal in some environments. Key: FLINK-2568 URL: https://issues.apache.org/jira/browse/FLINK-2568 Project:

[jira] [Commented] (FLINK-2543) State handling does not support deserializing classes through the UserCodeClassloader

2015-08-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704577#comment-14704577 ] Robert Metzger commented on FLINK-2543: --- Just a quick update on this: I have a fix

[jira] [Created] (FLINK-2552) Sporadic failure of PartialConsumePipelinedResultTest

2015-08-20 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2552: - Summary: Sporadic failure of PartialConsumePipelinedResultTest Key: FLINK-2552 URL: https://issues.apache.org/jira/browse/FLINK-2552 Project: Flink Issue

[jira] [Updated] (FLINK-2552) Sporadic failure of PartialConsumePipelinedResultTest

2015-08-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2552: -- Priority: Minor (was: Major) Sporadic failure of PartialConsumePipelinedResultTest

[jira] [Updated] (FLINK-2552) Sporadic failure of PartialConsumePipelinedResultTest

2015-08-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2552: -- Description: This test https://travis-ci.org/apache/flink/jobs/76305055 failed with: {code}

[jira] [Closed] (FLINK-2552) Sporadic failure of PartialConsumePipelinedResultTest

2015-08-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-2552. - Resolution: Invalid Okay, I'm closing it for now. Sporadic failure of

[jira] [Created] (FLINK-2555) Hadoop Input/Output Formats are unable to access secured HDFS clusters

2015-08-20 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2555: - Summary: Hadoop Input/Output Formats are unable to access secured HDFS clusters Key: FLINK-2555 URL: https://issues.apache.org/jira/browse/FLINK-2555 Project:

[jira] [Commented] (FLINK-2296) Checkpoint committing broken

2015-06-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14608360#comment-14608360 ] Robert Metzger commented on FLINK-2296: --- +1 for renaming the method to

[jira] [Created] (FLINK-2300) Links on FAQ page not rendered correctly

2015-06-30 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2300: - Summary: Links on FAQ page not rendered correctly Key: FLINK-2300 URL: https://issues.apache.org/jira/browse/FLINK-2300 Project: Flink Issue Type: Bug

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