Re: Backpressure rationale

You can find longer explanations for backpressure on teh Interwebs, but briefly, 1. Buffers are never infinite. Even if you're willing to write and maintain a nontrivial scheme for flushing to disk, you might still have a major failure scenario where the consumer is gone forever. Depending on volu

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

I'm wondering whether we should not depend the webserver encryption on the global encryption activation and activating it instead per default. On Thu, Jan 12, 2017 at 4:54 PM, Chesnay Schepler wrote: > FLINK-5470 is a duplicate of FLINK-5298 for which there is also an open PR. > > FLINK-5472 is

Backpressure rationale

Hello, I would like to ask about the rationale behind the backpressure mechanism in Flink. As I understand it, backpressure is for handling the problem of one operator (or source) producing records faster then the next operator can consume them. However, an alternative solution would be to have a

[jira] [Created] (FLINK-5476) Fail fast if trying to submit a job to a non-existing Flink cluster

Till Rohrmann created FLINK-5476: Summary: Fail fast if trying to submit a job to a non-existing Flink cluster Key: FLINK-5476 URL: https://issues.apache.org/jira/browse/FLINK-5476 Project: Flink

[jira] [Created] (FLINK-5475) Extend DC/OS documentation

Till Rohrmann created FLINK-5475: Summary: Extend DC/OS documentation Key: FLINK-5475 URL: https://issues.apache.org/jira/browse/FLINK-5475 Project: Flink Issue Type: Sub-task Compo

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

I also found an issue: https://issues.apache.org/jira/browse/FLINK-5470 I also noticed that Flink's webserver does not support https requests. It might be worthwhile to add it, though. https://issues.apache.org/jira/browse/FLINK-5472 On Thu, Jan 12, 2017 at 11:24 AM, Robert Metzger wrote: > I

[jira] [Created] (FLINK-5474) Extend DC/OS documentation

Till Rohrmann created FLINK-5474: Summary: Extend DC/OS documentation Key: FLINK-5474 URL: https://issues.apache.org/jira/browse/FLINK-5474 Project: Flink Issue Type: Sub-task Compo

[jira] [Created] (FLINK-5473) setMaxParallelism() higher than 1 is possible on non-parallel operators

Robert Metzger created FLINK-5473: - Summary: setMaxParallelism() higher than 1 is possible on non-parallel operators Key: FLINK-5473 URL: https://issues.apache.org/jira/browse/FLINK-5473 Project: Flin

[jira] [Created] (FLINK-5472) Flink's web server does not support https requests

Till Rohrmann created FLINK-5472: Summary: Flink's web server does not support https requests Key: FLINK-5472 URL: https://issues.apache.org/jira/browse/FLINK-5472 Project: Flink Issue Type:

[jira] [Created] (FLINK-5471) Properly inform JobClientActor about terminated Mesos framework

Till Rohrmann created FLINK-5471: Summary: Properly inform JobClientActor about terminated Mesos framework Key: FLINK-5471 URL: https://issues.apache.org/jira/browse/FLINK-5471 Project: Flink

[jira] [Created] (FLINK-5470) Requesting non-existing log/stdout file from TM crashes the it

Till Rohrmann created FLINK-5470: Summary: Requesting non-existing log/stdout file from TM crashes the it Key: FLINK-5470 URL: https://issues.apache.org/jira/browse/FLINK-5470 Project: Flink

[jira] [Created] (FLINK-5469) build_docs.sh -p fails on Windows Subsystem for Linux

Chesnay Schepler created FLINK-5469: --- Summary: build_docs.sh -p fails on Windows Subsystem for Linux Key: FLINK-5469 URL: https://issues.apache.org/jira/browse/FLINK-5469 Project: Flink Iss

FOSDEM 2017 Open Source Conference - Brussels

Hello Everyone This email is to tell you about ASF participation at FOSDEM. The event will be held in Brussels on 4^th & 5^th February 2017 and we are hoping that many people from our ASF projects will be there. https://fosdem.org/2017/ Attending FOSDEM is completely free and the ASF will ag

[jira] [Created] (FLINK-5468) Restoring from a semi async rocksdb statebackend (1.1) to 1.2 fails with ClassNotFoundException

Robert Metzger created FLINK-5468: - Summary: Restoring from a semi async rocksdb statebackend (1.1) to 1.2 fails with ClassNotFoundException Key: FLINK-5468 URL: https://issues.apache.org/jira/browse/FLINK-5468

[jira] [Created] (FLINK-5467) Stateless chained tasks set legacy operator state

Ufuk Celebi created FLINK-5467: -- Summary: Stateless chained tasks set legacy operator state Key: FLINK-5467 URL: https://issues.apache.org/jira/browse/FLINK-5467 Project: Flink Issue Type: Bug

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

I also found a bunch of issues https://issues.apache.org/jira/browse/FLINK-5465 https://issues.apache.org/jira/browse/FLINK-5462 https://issues.apache.org/jira/browse/FLINK-5464 https://issues.apache.org/jira/browse/FLINK-5463 On Thu, Jan 12, 2017 at 9:56 AM, Fabian Hueske wrote: > I have anot

[jira] [Created] (FLINK-5466) Make production environment default in gulpfile

Ufuk Celebi created FLINK-5466: -- Summary: Make production environment default in gulpfile Key: FLINK-5466 URL: https://issues.apache.org/jira/browse/FLINK-5466 Project: Flink Issue Type: Improve

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

I have another bugfix for 1.2.: https://issues.apache.org/jira/browse/FLINK-2662 (pending PR) 2017-01-10 15:16 GMT+01:00 Robert Metzger : > Hi, > > this depends a lot on the number of issues we find during the testing. > > > These are the issues I found so far: > > https://issues.apache.org/jira

Re: Flink CEP development is stalling

+1 I have some clientes interested in CEP features El 11/1/17 16:23, "Ivan Mushketyk" escribió: Hi Flink devs, Roughly half a year ago I implemented several PRs for Flink-CEP[1][2][3] but since then there were no progress with the reviews. What is frustrating about this situati