[jira] [Commented] (FLINK-12595) KinesisDataFetcherTest.testOriginalExceptionIsPreservedWhenInterruptedDuringShutdown deadlocks

2019-07-20 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889581#comment-16889581 ] Shannon Carey commented on FLINK-12595: --- Created [https://github.com/apache/flink/pull/9187] >

[jira] [Comment Edited] (FLINK-12595) KinesisDataFetcherTest.testOriginalExceptionIsPreservedWhenInterruptedDuringShutdown deadlocks

2019-07-20 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889564#comment-16889564 ] Shannon Carey edited comment on FLINK-12595 at 7/20/19 6:49 PM: Sorry

[jira] [Commented] (FLINK-12595) KinesisDataFetcherTest.testOriginalExceptionIsPreservedWhenInterruptedDuringShutdown deadlocks

2019-07-20 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889565#comment-16889565 ] Shannon Carey commented on FLINK-12595: --- Another thing I noticed:

[jira] [Comment Edited] (FLINK-12595) KinesisDataFetcherTest.testOriginalExceptionIsPreservedWhenInterruptedDuringShutdown deadlocks

2019-07-20 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889565#comment-16889565 ] Shannon Carey edited comment on FLINK-12595 at 7/20/19 6:26 PM: Another

[jira] [Commented] (FLINK-12595) KinesisDataFetcherTest.testOriginalExceptionIsPreservedWhenInterruptedDuringShutdown deadlocks

2019-07-20 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889564#comment-16889564 ] Shannon Carey commented on FLINK-12595: --- Sorry about that! Had to draw out a big sequence diagram,

[jira] [Created] (FLINK-11568) Exception in Kinesis ShardConsumer hidden by InterruptedException

2019-02-08 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-11568: - Summary: Exception in Kinesis ShardConsumer hidden by InterruptedException Key: FLINK-11568 URL: https://issues.apache.org/jira/browse/FLINK-11568 Project: Flink

[jira] [Updated] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

2017-06-01 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shannon Carey updated FLINK-6805: - Description: The Flink Cassandra connector has a dependency on Netty libraries (via promotion of

[jira] [Commented] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

2017-06-01 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16033571#comment-16033571 ] Shannon Carey commented on FLINK-6805: -- A better solution may be to add exclusions for the Netty

[jira] [Created] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

2017-06-01 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-6805: Summary: Flink Cassandra connector dependency on Netty disagrees with Flink Key: FLINK-6805 URL: https://issues.apache.org/jira/browse/FLINK-6805 Project: Flink

[jira] [Commented] (FLINK-5690) protobuf is not shaded properly

2017-05-08 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001826#comment-16001826 ] Shannon Carey commented on FLINK-5690: -- Regarding the comment: {quote} Mh, that's weird. According

[jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction

2017-02-28 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15889297#comment-15889297 ] Shannon Carey commented on FLINK-5929: -- [~aljoscha] as far as I am aware, the state does get cleared

[jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction

2017-02-27 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886419#comment-15886419 ] Shannon Carey commented on FLINK-5929: -- If I understand correctly, I agree this would be useful.

[jira] [Comment Edited] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction

2017-02-27 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886378#comment-15886378 ] Shannon Carey edited comment on FLINK-5929 at 2/27/17 7:40 PM: --- Just to

[jira] [Comment Edited] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction

2017-02-27 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886378#comment-15886378 ] Shannon Carey edited comment on FLINK-5929 at 2/27/17 7:38 PM: --- Just to

[jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction

2017-02-27 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886378#comment-15886378 ] Shannon Carey commented on FLINK-5929: -- Just to clarify, you're referring to the state from

[jira] [Created] (FLINK-5608) Cancel button not always visible

2017-01-22 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-5608: Summary: Cancel button not always visible Key: FLINK-5608 URL: https://issues.apache.org/jira/browse/FLINK-5608 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5542) YARN client incorrectly uses local YARN config to check vcore capacity

2017-01-17 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-5542: Summary: YARN client incorrectly uses local YARN config to check vcore capacity Key: FLINK-5542 URL: https://issues.apache.org/jira/browse/FLINK-5542 Project: Flink

[jira] [Commented] (FLINK-5425) JobManager replaced by IP in metrics

2017-01-08 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15810263#comment-15810263 ] Shannon Carey commented on FLINK-5425: -- I am using the statsd reporter and the data thereby flows to

[jira] [Updated] (FLINK-5425) JobManager replaced by IP in metrics

2017-01-06 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shannon Carey updated FLINK-5425: - Description: In metrics at the jobmanager level and below, the "" scope variable is being

[jira] [Created] (FLINK-5425) JobManager replaced by IP in metrics

2017-01-06 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-5425: Summary: JobManager replaced by IP in metrics Key: FLINK-5425 URL: https://issues.apache.org/jira/browse/FLINK-5425 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-5322) Clean up yarn configuration documentation

2017-01-06 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15806496#comment-15806496 ] Shannon Carey edited comment on FLINK-5322 at 1/7/17 2:11 AM: -- Another

[jira] [Commented] (FLINK-5322) Clean up yarn configuration documentation

2017-01-06 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15806496#comment-15806496 ] Shannon Carey commented on FLINK-5322: -- Another important note: quoting strings doesn't work the way

[jira] [Created] (FLINK-5424) Improve Restart Strategy Logging

2017-01-06 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-5424: Summary: Improve Restart Strategy Logging Key: FLINK-5424 URL: https://issues.apache.org/jira/browse/FLINK-5424 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-5322) yarn.taskmanager.env value does not appear in System.getenv

2016-12-13 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746008#comment-15746008 ] Shannon Carey commented on FLINK-5322: -- Yes, that worked! Thanks! It becomes available from within

[jira] [Comment Edited] (FLINK-4091) flink-connector-cassandra has conflicting guava version

2016-12-12 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15634445#comment-15634445 ] Shannon Carey edited comment on FLINK-4091 at 12/12/16 9:44 PM: Flink's

[jira] [Updated] (FLINK-5322) yarn.taskmanager.env value does not appear in System.getenv

2016-12-12 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shannon Carey updated FLINK-5322: - Description: The value I specified in flink-conf.yaml {code} yarn.taskmanager.env: MY_ENV:

[jira] [Created] (FLINK-5322) yarn.taskmanager.env value does not appear in System.getenv

2016-12-12 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-5322: Summary: yarn.taskmanager.env value does not appear in System.getenv Key: FLINK-5322 URL: https://issues.apache.org/jira/browse/FLINK-5322 Project: Flink

[jira] [Commented] (FLINK-4091) flink-connector-cassandra has conflicting guava version

2016-11-03 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15634445#comment-15634445 ] Shannon Carey commented on FLINK-4091: -- Flink's inclusion of altered Cassandra classes (though

[jira] [Commented] (FLINK-4803) Job Cancel can hang forever waiting for OutputFormat.close()

2016-10-12 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569025#comment-15569025 ] Shannon Carey commented on FLINK-4803: -- Yes, that's right. cancel() blocks on close(), and therefore

[jira] [Updated] (FLINK-4803) Job Cancel can hang forever waiting for OutputFormat.close()

2016-10-11 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shannon Carey updated FLINK-4803: - Description: If the Flink job uses a badly-behaved OutputFormat (in this example, a

[jira] [Created] (FLINK-4803) Job Cancel can hang forever waiting for OutputFormat.close()

2016-10-11 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-4803: Summary: Job Cancel can hang forever waiting for OutputFormat.close() Key: FLINK-4803 URL: https://issues.apache.org/jira/browse/FLINK-4803 Project: Flink

[jira] [Updated] (FLINK-3190) Retry rate limits for DataStream API

2016-08-31 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shannon Carey updated FLINK-3190: - Fix Version/s: 1.1.0 > Retry rate limits for DataStream API >

[jira] [Commented] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception

2016-08-23 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15433839#comment-15433839 ] Shannon Carey commented on FLINK-4418: -- Thanks [~rmetzger]. Should I mark the issue as "resolved"

[jira] [Updated] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception

2016-08-17 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shannon Carey updated FLINK-4418: - Description: When attempting to connect to a cluster with a ClusterClient, if the machine's

[jira] [Created] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception

2016-08-17 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-4418: Summary: ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception Key: FLINK-4418 URL:

[jira] [Created] (FLINK-4334) Shaded Hadoop1 jar not fully excluded in Quickstart

2016-08-08 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-4334: Summary: Shaded Hadoop1 jar not fully excluded in Quickstart Key: FLINK-4334 URL: https://issues.apache.org/jira/browse/FLINK-4334 Project: Flink Issue

[jira] [Closed] (FLINK-4069) Kafka Consumer should not initialize on construction

2016-06-14 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shannon Carey closed FLINK-4069. Resolution: Duplicate > Kafka Consumer should not initialize on construction >

[jira] [Commented] (FLINK-4069) Kafka Consumer should not initialize on construction

2016-06-14 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15330837#comment-15330837 ] Shannon Carey commented on FLINK-4069: -- Oh, I'm sorry! I looked for an existing issue but didn't

[jira] [Created] (FLINK-4069) Kafka Consumer should not initialize on construction

2016-06-13 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-4069: Summary: Kafka Consumer should not initialize on construction Key: FLINK-4069 URL: https://issues.apache.org/jira/browse/FLINK-4069 Project: Flink Issue

[jira] [Commented] (FLINK-3711) Scala fold() example syntax incorrect

2016-04-06 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15229638#comment-15229638 ] Shannon Carey commented on FLINK-3711: -- I will have a Github PR for you on this momentarily. > Scala

[jira] [Created] (FLINK-3711) Scala fold() example syntax incorrect

2016-04-06 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-3711: Summary: Scala fold() example syntax incorrect Key: FLINK-3711 URL: https://issues.apache.org/jira/browse/FLINK-3711 Project: Flink Issue Type: Bug