[
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]
>
[
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
[
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:
[
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
[
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,
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
[
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
[
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
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
[
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
[
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
[
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.
[
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
[
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
[
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
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
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
[
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
[
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
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
[
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
[
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
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
[
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
[
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
[
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:
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
[
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
[
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
[
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
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
[
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
>
[
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"
[
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
Shannon Carey created FLINK-4418:
Summary: ClusterClient/ConnectionUtils#findConnectingAddress fails
immediately if InetAddress.getLocalHost throws exception
Key: FLINK-4418
URL:
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
[
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
>
[
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
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
[
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
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
41 matches
Mail list logo