[jira] [Created] (FLINK-5499) Try to reuse the resource location of previous execution attempt when allocate slot

Zhijiang Wang created FLINK-5499: Summary: Try to reuse the resource location of previous execution attempt when allocate slot Key: FLINK-5499 URL: https://issues.apache.org/jira/browse/FLINK-5499

[jira] [Created] (FLINK-5498) Fix JoinITCase and add support for filter expressions on the On clause in left/right outer joins

lincoln.lee created FLINK-5498: -- Summary: Fix JoinITCase and add support for filter expressions on the On clause in left/right outer joins Key: FLINK-5498 URL: https://issues.apache.org/jira/browse/FLINK-5498

Need guidance for write a client connector for 'Flink'

Hi, we have a data analytics server that has analytics data tables. So I need to write a custom *Java* implementation for read data from that data source and do processing (*batch* processing) using Apache Flink. Basically it's like a new client connector for Flink. So It would be great if you

re: some questions about submit flink job on flink-yarn

Hi Till, Thanks very much ! It's helpful. HuangWHWHW 2017/1/16 -邮件原件- 发件人: Till Rohrmann [mailto:trohrm...@apache.org] 发送时间: 2017年1月15日 20:11 收件人: dev@flink.apache.org 抄送: u...@flink.apache.org 主题: Re: some questions about submit flink job on flink-yarn Hi Huang, the reason why you

Re: Flink CEP development is stalling

Hi Alexey, I agree with you. Most contributors are overloaded, but PRs for other sub-projects are reviewed much faster. In my experience, in most cases, you can get a first review for a PR in less than a week and it's usually merged within a month or less. Flink CEP is a notable exception. I

[jira] [Created] (FLINK-5497) remove duplicated tests

Alexey Diomin created FLINK-5497: Summary: remove duplicated tests Key: FLINK-5497 URL: https://issues.apache.org/jira/browse/FLINK-5497 Project: Flink Issue Type: Improvement

Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate)

I found two problematic issues with Mesos HA mode which breaks it: https://issues.apache.org/jira/browse/FLINK-5495 https://issues.apache.org/jira/browse/FLINK-5496 On Fri, Jan 13, 2017 at 11:29 AM, Fabian Hueske wrote: > I tested the Table API / SQL a bit. > > I implemented

[jira] [Created] (FLINK-5496) ClassCastException when using Mesos HA mode

Till Rohrmann created FLINK-5496: Summary: ClassCastException when using Mesos HA mode Key: FLINK-5496 URL: https://issues.apache.org/jira/browse/FLINK-5496 Project: Flink Issue Type: Bug

Re: Flink CEP development is stalling

Hi Ivan, I think problem not only with CEP project. Main contributors overloaded and simple fixes frequently are staying as PR without merge. You can see how amount of open PR increasing over time. Thanks, Alexey Diomin 2017-01-15 17:18 GMT+04:00 Ivan Mushketyk : >

[jira] [Created] (FLINK-5495) ZooKeeperMesosWorkerStore cannot be instantiated

Till Rohrmann created FLINK-5495: Summary: ZooKeeperMesosWorkerStore cannot be instantiated Key: FLINK-5495 URL: https://issues.apache.org/jira/browse/FLINK-5495 Project: Flink Issue Type:

[jira] [Created] (FLINK-5494) Improve Mesos documentation

Till Rohrmann created FLINK-5494: Summary: Improve Mesos documentation Key: FLINK-5494 URL: https://issues.apache.org/jira/browse/FLINK-5494 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5493) FlinkDistributionOverlay does not properly display missing environment variables

Till Rohrmann created FLINK-5493: Summary: FlinkDistributionOverlay does not properly display missing environment variables Key: FLINK-5493 URL: https://issues.apache.org/jira/browse/FLINK-5493

Re: Flink CEP development is stalling

Hi Dmitry, Your contributions are welcomed, but right now the most critical issue is that CEP project does not have an experienced Flink contributor who can review and approve new pull requests. I hope that Flink community will promptly resolve the issue, so feel free to take select a JIRA issue

Re: some questions about submit flink job on flink-yarn

Hi Huang, the reason why you cannot use the IP address to send messages to your YARN JobManager is that we no longer resolve the hostname into an IP address. Instead we start the ActorSystem with the unresolved hostname. You can see this in the following log line: `Actor system bound to hostname

[jira] [Created] (FLINK-5492) BootstrapTools log wrong address of started ActorSystem

Till Rohrmann created FLINK-5492: Summary: BootstrapTools log wrong address of started ActorSystem Key: FLINK-5492 URL: https://issues.apache.org/jira/browse/FLINK-5492 Project: Flink Issue