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

2015-05-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1676. --- Resolution: Pending Closed Fix Version/s: 0.9 Assignee: Robert Metzger

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

2015-05-13 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2008: - Summary: PersistentKafkaSource is sometimes emitting tuples multiple times Key: FLINK-2008 URL: https://issues.apache.org/jira/browse/FLINK-2008 Project: Flink

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

2015-05-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543647#comment-14543647 ] Robert Metzger commented on FLINK-1731: --- [~aalexandrov]: only users with Contributor

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

2015-05-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545111#comment-14545111 ] Robert Metzger commented on FLINK-2008: --- {{brokerFailureTest()}} has been fixed in

[jira] [Created] (FLINK-2017) Add predefinde required parameters to ParameterTool

2015-05-15 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2017: - Summary: Add predefinde required parameters to ParameterTool Key: FLINK-2017 URL: https://issues.apache.org/jira/browse/FLINK-2017 Project: Flink Issue

[jira] [Created] (FLINK-2018) Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's argument parser

2015-05-15 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2018: - Summary: Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's argument parser Key: FLINK-2018 URL: https://issues.apache.org/jira/browse/FLINK-2018

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

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

[jira] [Created] (FLINK-2019) Grouping by Joda DateTime field fails with Kryo exception

2015-05-15 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2019: - Summary: Grouping by Joda DateTime field fails with Kryo exception Key: FLINK-2019 URL: https://issues.apache.org/jira/browse/FLINK-2019 Project: Flink

[jira] [Resolved] (FLINK-1949) YARNSessionFIFOITCase sometimes fails to detect when the detached session finishes

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

[jira] [Closed] (FLINK-1949) YARNSessionFIFOITCase sometimes fails to detect when the detached session finishes

2015-05-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1949. - YARNSessionFIFOITCase sometimes fails to detect when the detached session finishes

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

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

[jira] [Updated] (FLINK-2017) Add predefined required parameters to ParameterTool

2015-05-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2017: -- Summary: Add predefined required parameters to ParameterTool (was: Add predefinde required

[jira] [Created] (FLINK-2021) Rework examples to use new ParameterTool

2015-05-15 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2021: - Summary: Rework examples to use new ParameterTool Key: FLINK-2021 URL: https://issues.apache.org/jira/browse/FLINK-2021 Project: Flink Issue Type:

[jira] [Created] (FLINK-2022) log4j.properties are not in quickstart projects

2015-05-15 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2022: - Summary: log4j.properties are not in quickstart projects Key: FLINK-2022 URL: https://issues.apache.org/jira/browse/FLINK-2022 Project: Flink Issue Type:

[jira] [Reopened] (FLINK-2006) TaskManagerTest.testRunJobWithForwardChannel:432 expected:FINISHED but was:FAILED

2015-05-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-2006: --- 9da2f1f725473f1242067acb546607888e3a5015 did not resolve the issue. We had another case on

[jira] [Resolved] (FLINK-2019) Grouping by Joda DateTime field fails with Kryo exception

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

[jira] [Assigned] (FLINK-2022) log4j.properties are not in quickstart projects

2015-05-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2022: - Assignee: Robert Metzger log4j.properties are not in quickstart projects

[jira] [Created] (FLINK-2040) TaskTest.testCancelDuringInvoke:434-validateListenerMessage:712 expected:CANCELING but was:CANCELED

2015-05-18 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2040: - Summary: TaskTest.testCancelDuringInvoke:434-validateListenerMessage:712 expected:CANCELING but was:CANCELED Key: FLINK-2040 URL:

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

2015-05-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14548064#comment-14548064 ] Robert Metzger commented on FLINK-2037: --- I'm not sure how to resolve this issue. The

[jira] [Commented] (FLINK-2022) log4j.properties are not in quickstart projects

2015-05-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14548100#comment-14548100 ] Robert Metzger commented on FLINK-2022: --- Fix:

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

2015-05-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14548089#comment-14548089 ] Robert Metzger commented on FLINK-2037: --- The first suggested approach was super

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

2015-05-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2037: - Assignee: Robert Metzger Unable to start Python API using ./bin/pyflink*.sh

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

2015-05-18 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2037: - Summary: Unable to start Python API using ./bin/pyflink*.sh Key: FLINK-2037 URL: https://issues.apache.org/jira/browse/FLINK-2037 Project: Flink Issue

[jira] [Resolved] (FLINK-2022) log4j.properties are not in quickstart projects

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

[jira] [Resolved] (FLINK-1346) Add akka parameters to the configuration

2015-05-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1346. --- Resolution: Fixed Fix Version/s: 0.9 Assignee: Till Rohrmann I think

[jira] [Closed] (FLINK-1872) How can generation dataset in flink automatic depend on number of filed and data type

2015-05-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1872. - Resolution: Not A Problem I'm closing this issue. User questions should be discussed on

[jira] [Updated] (FLINK-1916) EOFException when running delta-iteration job

2015-05-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1916: -- Component/s: Local Runtime EOFException when running delta-iteration job

[jira] [Updated] (FLINK-1916) EOFException when running delta-iteration job

2015-05-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1916: -- Affects Version/s: 0.9 EOFException when running delta-iteration job

[jira] [Commented] (FLINK-2003) Building on some encrypted filesystems leads to File name too long error

2015-05-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14539694#comment-14539694 ] Robert Metzger commented on FLINK-2003: --- I think we also should put an entry to our

[jira] [Commented] (FLINK-2036) StreamExecutionEnvironment usage in KafkaITcase

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550068#comment-14550068 ] Robert Metzger commented on FLINK-2036: --- No, this is still an open issue. I am

[jira] [Updated] (FLINK-2043) Change the KMeansDataGenerator to allow passing a custom path

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2043: -- Component/s: Examples Change the KMeansDataGenerator to allow passing a custom path

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

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2045: -- Issue Type: Bug (was: Improvement) JobManager webinterface is unresponsive with many

[jira] [Commented] (FLINK-1952) Cannot run ConnectedComponents example: Could not allocate a slot on instance

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550215#comment-14550215 ] Robert Metzger commented on FLINK-1952: --- Thank you for looking into the issue. Lets

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

2015-05-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] [Created] (FLINK-2006) TaskManagerTest.testRunJobWithForwardChannel:432 expected:FINISHED but was:FAILED

2015-05-13 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2006: - Summary: TaskManagerTest.testRunJobWithForwardChannel:432 expected:FINISHED but was:FAILED Key: FLINK-2006 URL: https://issues.apache.org/jira/browse/FLINK-2006

[jira] [Resolved] (FLINK-1260) Add custom partitioning to documentation

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

[jira] [Commented] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547107#comment-14547107 ] Robert Metzger commented on FLINK-1985: --- [~mjsax]: The issue is assigned to

[jira] [Commented] (FLINK-2031) Missing images in blog posts

2015-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547110#comment-14547110 ] Robert Metzger commented on FLINK-2031: --- A user also reported numerous broken links

[jira] [Updated] (FLINK-2031) Missing images in blog posts

2015-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2031: -- Labels: starter (was: ) Missing images in blog posts

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

2015-04-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14494246#comment-14494246 ] Robert Metzger commented on FLINK-1753: --- Added a broker failure test in

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

2015-04-14 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-1753) Add more tests for Kafka Connectors

2015-04-14 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] [Assigned] (FLINK-1875) Add figure to documentation describing slots and parallelism

2015-04-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1875: - Assignee: Robert Metzger Add figure to documentation describing slots and parallelism

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

2015-04-16 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] [Commented] (FLINK-1753) Add more tests for Kafka Connectors

2015-04-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14497691#comment-14497691 ] Robert Metzger commented on FLINK-1753: --- Added large record test in

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

2015-04-16 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] [Commented] (FLINK-1818) Provide API to cancel running job

2015-04-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14499391#comment-14499391 ] Robert Metzger commented on FLINK-1818: --- I think a method to cancel only one job is

[jira] [Commented] (FLINK-1902) Web interface reports false (the default) jobmanager.rpc.port on YARN

2015-04-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14499505#comment-14499505 ] Robert Metzger commented on FLINK-1902: --- I've fixed the issue. I'll merge the fix

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

2015-04-17 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] [Created] (FLINK-1905) Add tests for parallelism 1 for Kafka sources

2015-04-17 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1905: - Summary: Add tests for parallelism 1 for Kafka sources Key: FLINK-1905 URL: https://issues.apache.org/jira/browse/FLINK-1905 Project: Flink Issue Type:

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

2015-04-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1753: - Assignee: Robert Metzger (was: Gábor Hermann) Add more tests for Kafka Connectors

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

2015-04-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1905: -- Description: Also, test with multiple partitions Add tests for parallelism 1 for Kafka

[jira] [Commented] (FLINK-1902) Web interface reports false (the default) jobmanager.rpc.port on YARN

2015-04-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14499436#comment-14499436 ] Robert Metzger commented on FLINK-1902: --- Hi, thank you for reporting the issue. I'm

[jira] [Updated] (FLINK-1902) Web interface reports false (the default) jobmanager.rpc.port on YARN

2015-04-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1902: -- Component/s: YARN Client Web interface reports false (the default) jobmanager.rpc.port on YARN

[jira] [Resolved] (FLINK-1902) Web interface reports false (the default) jobmanager.rpc.port on YARN

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

[jira] [Commented] (FLINK-1865) Unstable test KafkaITCase

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492079#comment-14492079 ] Robert Metzger commented on FLINK-1865: --- FLINK-1784 is a similar / same issue.

[jira] [Created] (FLINK-1874) Break up streaming connectors into submodules

2015-04-13 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1874: - Summary: Break up streaming connectors into submodules Key: FLINK-1874 URL: https://issues.apache.org/jira/browse/FLINK-1874 Project: Flink Issue Type:

[jira] [Created] (FLINK-1875) Add figure to documentation describing

2015-04-13 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1875: - Summary: Add figure to documentation describing Key: FLINK-1875 URL: https://issues.apache.org/jira/browse/FLINK-1875 Project: Flink Issue Type:

[jira] [Updated] (FLINK-1873) Distributed matrix implementation

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1873: -- Assignee: liaoyuxi Distributed matrix implementation -

[jira] [Updated] (FLINK-1875) Add figure to documentation describing slots and parallelism

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1875: -- Summary: Add figure to documentation describing slots and parallelism (was: Add figure to

[jira] [Updated] (FLINK-1865) Unstable test KafkaITCase

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1865: -- Component/s: Streaming Affects Version/s: 0.9 Unstable test KafkaITCase

[jira] [Commented] (FLINK-1865) Unstable test KafkaITCase

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492044#comment-14492044 ] Robert Metzger commented on FLINK-1865: --- [~gaborhermann] do you have time to look

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492009#comment-14492009 ] Robert Metzger commented on FLINK-1873: --- I gave you Contributor permission in our

[jira] [Updated] (FLINK-1865) Unstable test KafkaITCase

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1865: -- Component/s: Tests Unstable test KafkaITCase - Key:

[jira] [Updated] (FLINK-1868) EnvironmentInformationTest.testJavaMemory fails on Travis

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1868: -- Component/s: Tests EnvironmentInformationTest.testJavaMemory fails on Travis

[jira] [Updated] (FLINK-1864) Investigate Travis build success when locally not building

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1864: -- Component/s: Tests Investigate Travis build success when locally not building

[jira] [Updated] (FLINK-1867) TaskManagerFailureRecoveryITCase causes stalled travis builds

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1867: -- Component/s: Tests TaskManagerFailureRecoveryITCase causes stalled travis builds

[jira] [Updated] (FLINK-1863) RemoteInputChannelTest.testConcurrentOnBufferAndRelease fails on travis

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1863: -- Component/s: Tests RemoteInputChannelTest.testConcurrentOnBufferAndRelease fails on travis

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

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492345#comment-14492345 ] Robert Metzger commented on FLINK-1877: --- Another instance of the issue:

[jira] [Closed] (FLINK-1881) want link explain Table API Java in flink and what is important

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1881. - Resolution: Invalid The Table API is documented here:

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

2015-04-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14500372#comment-14500372 ] Robert Metzger commented on FLINK-1907: --- Hey [~nikst], I gave you Contributor

[jira] [Updated] (FLINK-1907) Scala Interactive Shell

2015-04-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1907: -- Assignee: Nikolaas Steenbergen Scala Interactive Shell ---

[jira] [Created] (FLINK-1856) Add required imports to Scala API examples

2015-04-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1856: - Summary: Add required imports to Scala API examples Key: FLINK-1856 URL: https://issues.apache.org/jira/browse/FLINK-1856 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-1856) Add required imports to Scala API examples

2015-04-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1856: -- Labels: starter (was: ) Add required imports to Scala API examples

[jira] [Updated] (FLINK-1856) Add required imports to Scala API examples

2015-04-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1856: -- Component/s: Scala API Add required imports to Scala API examples

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

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

[jira] [Created] (FLINK-1818) Provide API to cancel running job

2015-04-02 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1818: - Summary: Provide API to cancel running job Key: FLINK-1818 URL: https://issues.apache.org/jira/browse/FLINK-1818 Project: Flink Issue Type: Improvement

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

2015-04-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1219: -- Component/s: Flink on Tez Add support for Apache Tez as execution engine

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

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

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

2015-04-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1219: -- Component/s: New Components Add support for Apache Tez as execution engine

[jira] [Commented] (FLINK-2048) Enhance Twitter Stream support

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550446#comment-14550446 ] Robert Metzger commented on FLINK-2048: --- Hi [~HilmiYildirim], I gave you Contributor

[jira] [Updated] (FLINK-2046) Quickstarts are missing on the new Website

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2046: -- Component/s: Quickstarts Quickstarts are missing on the new Website

[jira] [Updated] (FLINK-2048) Enhance Twitter Stream support

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2048: -- Assignee: Hilmi Yildirim Enhance Twitter Stream support --

[jira] [Created] (FLINK-2049) KafkaSink sporadically fails to send message

2015-05-19 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2049: - Summary: KafkaSink sporadically fails to send message Key: FLINK-2049 URL: https://issues.apache.org/jira/browse/FLINK-2049 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2055) Implement Streaming HBaseSink

2015-05-20 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2055: - Summary: Implement Streaming HBaseSink Key: FLINK-2055 URL: https://issues.apache.org/jira/browse/FLINK-2055 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-1874) Break up streaming connectors into submodules

2015-05-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552036#comment-14552036 ] Robert Metzger commented on FLINK-1874: --- The blocker for this issue has been

[jira] [Created] (FLINK-2060) Let maven fail on travis when modules reference to outdated internal dependency

2015-05-20 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2060: - Summary: Let maven fail on travis when modules reference to outdated internal dependency Key: FLINK-2060 URL: https://issues.apache.org/jira/browse/FLINK-2060

[jira] [Created] (FLINK-2065) Cancelled jobs finish with final state FAILED

2015-05-20 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2065: - Summary: Cancelled jobs finish with final state FAILED Key: FLINK-2065 URL: https://issues.apache.org/jira/browse/FLINK-2065 Project: Flink Issue Type:

[jira] [Updated] (FLINK-2065) Cancelled jobs finish with final state FAILED

2015-05-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2065: -- Attachment: failed.tgz I've attached the full yarn log of all the machines. Please note that

[jira] [Updated] (FLINK-2065) Cancelled jobs finish with final state FAILED

2015-05-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2065: -- Description: While running some experiments, I've noticed that jobs sometimes finish in

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

2015-06-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2080: -- Component/s: Documentation Execute Flink with sbt --

[jira] [Updated] (FLINK-1884) Outdated Spargel docs

2015-06-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1884: -- Component/s: Documentation Outdated Spargel docs - Key:

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

2015-06-05 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2164: - Summary: Document batch and streaming startup modes Key: FLINK-2164 URL: https://issues.apache.org/jira/browse/FLINK-2164 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1892) Local job execution does not exit.

2015-06-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14574222#comment-14574222 ] Robert Metzger commented on FLINK-1892: --- [~ktzoumas], I'll take over the issue, ok?

[jira] [Assigned] (FLINK-1892) Local job execution does not exit.

2015-06-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1892: - Assignee: Robert Metzger (was: Kostas Tzoumas) Local job execution does not exit.

[jira] [Resolved] (FLINK-1422) Missing usage example for withParameters

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

[jira] [Assigned] (FLINK-1565) Document object reuse behavior

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1565: - Assignee: Robert Metzger Document object reuse behavior --

[jira] [Commented] (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 commented on FLINK-2080: --- Thank you. Can you give me your email

[jira] [Updated] (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:all-tabpanel ] Robert Metzger updated FLINK-2080: -- Assignee: Christian Wuertz Execute Flink with sbt --

[jira] [Commented] (FLINK-1229) Synchronize WebClient arguments with command line arguments

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573297#comment-14573297 ] Robert Metzger commented on FLINK-1229: --- Updated documentation for this in

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