Re: Flink 1.1.0 : Hadoop 1/2 compatibility mismatch

Works for me, thanks! -Shannon

Re: [DISCUSS] Proposal for Asynchronous I/O in FLINK

David, I just wanted to say "thanks" for making this proposal! I'm also interested in performing nonblocking I/O (multiplexing threads/reactive programming) within Flink operators so that we can, for example, communicate with external web services with Netty/RxNetty without blocking an entire

Re: [DISCUSS] Proposal for Asynchronous I/O in FLINK

plicitly, Flink does the same with broadcast >> variables. >> >> On Wed, Sep 21, 2016 at 5:04 PM, Shannon Carey <sca...@expedia.com> wrote: >> >> > David, >> > >> > I just wanted to say "thanks" for making this proposal! I'm also

Re: Flink survey by data Artisans

There's a newline that disrupts the URL. http://www.surveygizmo.com/s3/3166399/181bdb611f22 Not: http://www.surveygizmo.com/s3/ 3166399/181bdb611f22

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

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

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

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] [Created] (FLINK-5608) Cancel button not always visible

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

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] [Created] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception

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

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

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] [Created] (FLINK-5322) yarn.taskmanager.env value does not appear in System.getenv

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] [Created] (FLINK-5424) Improve Restart Strategy Logging

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] [Created] (FLINK-5425) JobManager replaced by IP in metrics

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] [Created] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

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] [Created] (FLINK-11568) Exception in Kinesis ShardConsumer hidden by InterruptedException

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