[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&focusedCommentId=16889581#comment-16889581 ] Shannon Carey commented on FLINK-12595: --- Created [https://github.com/apache/flink/

[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&focusedCommentId=16889564#comment-16889564 ] Shannon Carey edited comment on FLINK-12595 at 7/20/19 6:49 PM: --

[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&focusedCommentId=16889565#comment-16889565 ] Shannon Carey commented on FLINK-12595: --- Another thing I noticed: FlinkKinesisCons

[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&focusedCommentId=16889565#comment-16889565 ] Shannon Carey edited comment on FLINK-12595 at 7/20/19 6:26 PM: --

[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&focusedCommentId=16889564#comment-16889564 ] Shannon Carey commented on FLINK-12595: --- Sorry about that! Had to draw out a big s

[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&focusedCommentId=16033571#comment-16033571 ] Shannon Carey commented on FLINK-6805: -- A better solution may be to add exclusions fo

[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&focusedCommentId=16001826#comment-16001826 ] Shannon Carey commented on FLINK-5690: -- Regarding the comment: {quote} Mh, that's we

[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&focusedCommentId=15889297#comment-15889297 ] Shannon Carey commented on FLINK-5929: -- [~aljoscha] as far as I am aware, the state d

[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&focusedCommentId=15886419#comment-15886419 ] Shannon Carey commented on FLINK-5929: -- If I understand correctly, I agree this would

[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&focusedCommentId=15886378#comment-15886378 ] Shannon Carey edited comment on FLINK-5929 at 2/27/17 7:40 PM: -

[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&focusedCommentId=15886378#comment-15886378 ] Shannon Carey edited comment on FLINK-5929 at 2/27/17 7:38 PM: -

[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&focusedCommentId=15886378#comment-15886378 ] Shannon Carey commented on FLINK-5929: -- Just to clarify, you're referring to the stat

[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 Comp

[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&focusedCommentId=15810263#comment-15810263 ] Shannon Carey commented on FLINK-5425: -- I am using the statsd reporter and the data t

[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 replace

[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&focusedCommentId=15806496#comment-15806496 ] Shannon Carey edited comment on FLINK-5322 at 1/7/17 2:11 AM: --

[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&focusedCommentId=15806496#comment-15806496 ] Shannon Carey commented on FLINK-5322: -- Another important note: quoting strings doesn

[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&focusedCommentId=15746008#comment-15746008 ] Shannon Carey commented on FLINK-5322: -- Yes, that worked! Thanks! It becomes availabl

[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&focusedCommentId=15634445#comment-15634445 ] Shannon Carey edited comment on FLINK-4091 at 12/12/16 9:44 PM:

[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: test

[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 Is

[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&focusedCommentId=15634445#comment-15634445 ] Shannon Carey commented on FLINK-4091: -- Flink's inclusion of altered Cassandra classe

[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&focusedCommentId=15569025#comment-15569025 ] Shannon Carey commented on FLINK-4803: -- Yes, that's right. cancel() blocks on close()

[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 HadoopOutputF

[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 I

[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&focusedCommentId=15433839#comment-15433839 ] Shannon Carey commented on FLINK-4418: -- Thanks [~rmetzger]. Should I mark the issue a

[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 hostn

[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: https://issues.apache.org/jira/bro

[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 Type:

[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&focusedCommentId=15330837#comment-15330837 ] Shannon Carey commented on FLINK-4069: -- Oh, I'm sorry! I looked for an existing issue

[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 Type

[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&focusedCommentId=15229638#comment-15229638 ] Shannon Carey commented on FLINK-3711: -- I will have a Github PR for you on this momen

[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