[jira] [Created] (FLINK-7454) update 'Monitoring Current Event Time' section of Flink doc

2017-08-16 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7454: --- Summary: update 'Monitoring Current Event Time' section of Flink doc Key: FLINK-7454 URL: https://issues.apache.org/jira/browse/FLINK-7454 Project: Flink Issue Type:

[jira] [Created] (FLINK-7455) RocksDB TTL support

2017-08-16 Thread Andrey Konyaev (JIRA)
Andrey Konyaev created FLINK-7455: - Summary: RocksDB TTL support Key: FLINK-7455 URL: https://issues.apache.org/jira/browse/FLINK-7455 Project: Flink Issue Type: New Feature Compone

[jira] [Created] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based

2017-08-16 Thread zhijiang (JIRA)
zhijiang created FLINK-7456: --- Summary: Implement Netty sender incoming pipeline for credit-based Key: FLINK-7456 URL: https://issues.apache.org/jira/browse/FLINK-7456 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-7457) Make dispatcher HA

2017-08-16 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7457: Summary: Make dispatcher HA Key: FLINK-7457 URL: https://issues.apache.org/jira/browse/FLINK-7457 Project: Flink Issue Type: Improvement Components

[jira] [Created] (FLINK-7458) Generalize GatewayRetriever for WebRuntimeMonitor

2017-08-16 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7458: Summary: Generalize GatewayRetriever for WebRuntimeMonitor Key: FLINK-7458 URL: https://issues.apache.org/jira/browse/FLINK-7458 Project: Flink Issue Type: I

[jira] [Created] (FLINK-7459) Introduce RedirectHandler for the WebRuntimeMonitor

2017-08-16 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7459: Summary: Introduce RedirectHandler for the WebRuntimeMonitor Key: FLINK-7459 URL: https://issues.apache.org/jira/browse/FLINK-7459 Project: Flink Issue Type:

[jira] [Created] (FLINK-7460) Close all ColumnFamilyHandles when restoring rescaled incremental checkpoints

2017-08-16 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-7460: - Summary: Close all ColumnFamilyHandles when restoring rescaled incremental checkpoints Key: FLINK-7460 URL: https://issues.apache.org/jira/browse/FLINK-7460 Project

[jira] [Created] (FLINK-7461) Remove Backwards compatibility for Flink 1.1 from Flink 1.4

2017-08-16 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-7461: - Summary: Remove Backwards compatibility for Flink 1.1 from Flink 1.4 Key: FLINK-7461 URL: https://issues.apache.org/jira/browse/FLINK-7461 Project: Flink

Re: [POLL] Dropping savepoint format compatibility for 1.1.x in the Flink 1.4.0 release

2017-08-16 Thread Stefan Richter
Hi, after there have been no objections since a long time, I took the next step and created a PR that implements this change in commit 95e44099784c9deaf2ca422b8dfc11c3d67d7f82 of https://github.com/apache/flink/pull/4550 . Announcing this here as a l

[jira] [Created] (FLINK-7462) Add very obvious warning about outdated docs

2017-08-16 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7462: -- Summary: Add very obvious warning about outdated docs Key: FLINK-7462 URL: https://issues.apache.org/jira/browse/FLINK-7462 Project: Flink Issue Type: Improvemen

[DISCUSS] Stop serving docs for Flink version prior to 1.0

2017-08-16 Thread Ufuk Celebi
Hey devs, I would like to stop serving the documentation for all Flink versions prior to 1.0. Do you have any concerns about this? These Flink versions are very old without any upgrade path to newer versions but they still get a lot of traffic and most new users don't realize that they are looki

Re: [DISCUSS] Stop serving docs for Flink version prior to 1.0

2017-08-16 Thread Kostas Kloudas
Hi Ufuk, +1 I think that this is a nice change! Thanks Ufuk for opening the discussion. I think that broken/redirect links are not an issue, as either way the information provided is far outdated (== wrong). As for the warning, we cannot put it in the header instead of the footer? Sth like,

Re: [DISCUSS] Stop serving docs for Flink version prior to 1.0

2017-08-16 Thread Ted Yu
Without any upgrade path, the old versions are not useful. +1 on redirecting doc to stable release(s). On Wed, Aug 16, 2017 at 9:46 AM, Kostas Kloudas wrote: > Hi Ufuk, > > +1 > > I think that this is a nice change! > Thanks Ufuk for opening the discussion. > > I think that broken/redirect link

Re: [DISCUSS] Stop serving docs for Flink version prior to 1.0

2017-08-16 Thread Ufuk Celebi
Thanks for your early feedback Kostas and Ted. @Kostas: I have a proposal for a more obvious warning here: https://github.com/apache/flink/pull/4553 Would appreciate comments in that PR too :-) On Wed, Aug 16, 2017 at 6:56 PM, Ted Yu wrote: > Without any upgrade path, the old versions are not u

Which window function to use to start a window at anytime

2017-08-16 Thread Bowen Li
Hi guys, I sent this email to Flink user email alias but didn't get any feedbacks. I'm sending it here. We are trying use Flink to count millions of keyed items of an hour window hourly as `time(SlidingEventTimeWindows.of(1hour, 1hour))`. According to the sliding window doc

[jira] [Created] (FLINK-7463) Release nascent workers on slot request timeout

2017-08-16 Thread Eron Wright (JIRA)
Eron Wright created FLINK-7463: --- Summary: Release nascent workers on slot request timeout Key: FLINK-7463 URL: https://issues.apache.org/jira/browse/FLINK-7463 Project: Flink Issue Type: Sub-