[jira] [Created] (FLINK-9600) Add DataStream transformation variants that pass timestamp to the user function

2018-06-15 Thread Elias Levy (JIRA)
Elias Levy created FLINK-9600: - Summary: Add DataStream transformation variants that pass timestamp to the user function Key: FLINK-9600 URL: https://issues.apache.org/jira/browse/FLINK-9600 Project:

[jira] [Created] (FLINK-9596) Ability to configure logging using the same log4j file

2018-06-15 Thread Rinat Sharipov (JIRA)
Rinat Sharipov created FLINK-9596: - Summary: Ability to configure logging using the same log4j file Key: FLINK-9596 URL: https://issues.apache.org/jira/browse/FLINK-9596 Project: Flink Issue

Re: [DISCUSS] Flink 1.4 and below STOPS writing to Kinesis after June 12th.

2018-06-15 Thread Thomas Weise
Hi, I can work on a PR to backport the relevant changes, but it may take a few days before I get to it. Thanks, Thomas -- sent from mobile On Mon, Jun 11, 2018, 1:50 PM Tzu-Li (Gordon) Tai wrote: > Thanks for bring this up, Bowen. > > I’m not sure that it’ll be straightforward to just use

Re: [WEBSITE] Proposal to rework the Flink website

2018-06-15 Thread Fabian Hueske
Hi, I'm planning to put the reworked website online next week. You can have a look at PR #109 [1] to check the changes and give feedback. Btw. I've created FLINK-9541 to track the effort of adding a sitemap.xml. Cheers, Fabian [1] https://github.com/apache/flink-web/pull/109 [2]

[jira] [Created] (FLINK-9597) Flink fail to scale!

2018-06-15 Thread swy (JIRA)
swy created FLINK-9597: -- Summary: Flink fail to scale! Key: FLINK-9597 URL: https://issues.apache.org/jira/browse/FLINK-9597 Project: Flink Issue Type: Bug Components: Core Affects

[jira] [Created] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure

2018-06-15 Thread Prem Santosh (JIRA)
Prem Santosh created FLINK-9598: --- Summary: [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure Key: FLINK-9598 URL:

[jira] [Created] (FLINK-9599) Implement generic mechanism to receive files via rest

2018-06-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9599: --- Summary: Implement generic mechanism to receive files via rest Key: FLINK-9599 URL: https://issues.apache.org/jira/browse/FLINK-9599 Project: Flink

[jira] [Created] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE

2018-06-15 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-9593: --- Summary: Unify AfterMatch semantics with SQL MATCH_RECOGNIZE Key: FLINK-9593 URL: https://issues.apache.org/jira/browse/FLINK-9593 Project: Flink

[jira] [Created] (FLINK-9594) Add documentation for e2e test changes introduced with FLINK-9257

2018-06-15 Thread Florian Schmidt (JIRA)
Florian Schmidt created FLINK-9594: -- Summary: Add documentation for e2e test changes introduced with FLINK-9257 Key: FLINK-9594 URL: https://issues.apache.org/jira/browse/FLINK-9594 Project: Flink

[jira] [Created] (FLINK-9595) Add instructions to docs about ceased support of KPL version used in Kinesis connector

2018-06-15 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-9595: -- Summary: Add instructions to docs about ceased support of KPL version used in Kinesis connector Key: FLINK-9595 URL: https://issues.apache.org/jira/browse/FLINK-9595

Re: [DISCUSS] Flink 1.4 and below STOPS writing to Kinesis after June 12th.

2018-06-15 Thread Tzu-Li (Gordon) Tai
Quick bump: It should be possible for users still on 1.4.x to just do `mvn clean install -Daws.kinesis-kpl-version=0.12.6` when building the Kinesis connector, to upgrade the KPL version used. I think we should add this to the documentation. Here’s a JIRA to track that -