Re: Consuming data from dynamoDB streams to flink

Thanks Fabian and Thomas. Please assign FLINK-4582 to the following username: *yxu-apache * If needed I can get a ICLA or CCLA whichever is proper. *Ying Xu* Software Engineer 510.368.1252 <+15103681252> [image: Lyft]

Re: Consuming data from dynamoDB streams to flink

The user is yxu-lyft, Ying had commented on that JIRA as well. https://issues.apache.org/jira/browse/FLINK-4582 On Mon, Jul 30, 2018 at 1:25 AM Fabian Hueske wrote: > Hi Ying, > > Thanks for considering to contribute the connector! > > In general, you don't need special permissions to contribu

[jira] [Created] (FLINK-9998) FlinkKafkaConsumer produces lag -Inf when the pipeline lags

Julio Biason created FLINK-9998: --- Summary: FlinkKafkaConsumer produces lag -Inf when the pipeline lags Key: FLINK-9998 URL: https://issues.apache.org/jira/browse/FLINK-9998 Project: Flink Issu

Re: [VOTE] Release 1.5.2, release candidate #2

+1 (binding) - build Flink from source release with Hadoop 2.8 - verified that job submissions (client + web) works with ssl enabled - e2e tests passed without a problem - Jepsen test suite passed without a problem Cheers, Till On Mon, Jul 30, 2018 at 9:14 AM Timo Walther wrote: > +1 > > - ru

Re: Release roadmap

Thank you guys, Your reply was very helpful . On 30 July 2018 at 15:46, Chesnay Schepler wrote: > There was an issue with the snapshot releases that should've been fixed by > now. > > > On 30.07.2018 14:37, vino yang wrote: > >> Hi Artsem, >> >> As far as I know, Flink's official documentation d

Re: Release roadmap

There was an issue with the snapshot releases that should've been fixed by now. On 30.07.2018 14:37, vino yang wrote: Hi Artsem, As far as I know, Flink's official documentation does not have a clear Roadmap for the release version. According to the previous plan of the Flink community, a majo

[jira] [Created] (FLINK-9997) Improve ExpressionReduce

Ruidong Li created FLINK-9997: - Summary: Improve ExpressionReduce Key: FLINK-9997 URL: https://issues.apache.org/jira/browse/FLINK-9997 Project: Flink Issue Type: Improvement Components

Re: Release roadmap

Hi Artsem, As far as I know, Flink's official documentation does not have a clear Roadmap for the release version. According to the previous plan of the Flink community, a major version was released in almost two months, but this time range is not fixed. For example, the 1.5 version takes longer.

Release roadmap

Hi guys! I try to figure out when are you going to release 1.6 version of Flink , but I can't find any roadmap . May be you could give me some insides or provide some link where discribed your roadmap or something like this. Also I would like to inform you that your 1.6 version in SNAPSHOT reposi

Questions about join and exactly-once

Hi, I would like to ask 2 questions. 1. Currently, what is the problem of flink join ? And what is the essential difference between batch join and stream join ? 2. What are the shortcomings of current exactly-once ? Thanks minglei.

[jira] [Created] (FLINK-9996) PrestoS3FileSystemITCase#testConfigKeysForwarding fails on travis

Chesnay Schepler created FLINK-9996: --- Summary: PrestoS3FileSystemITCase#testConfigKeysForwarding fails on travis Key: FLINK-9996 URL: https://issues.apache.org/jira/browse/FLINK-9996 Project: Flink

[jira] [Created] (FLINK-9995) Jepsen: Clean up Mesos Logs and Working Directory

Gary Yao created FLINK-9995: --- Summary: Jepsen: Clean up Mesos Logs and Working Directory Key: FLINK-9995 URL: https://issues.apache.org/jira/browse/FLINK-9995 Project: Flink Issue Type: Bug

Re: Consuming data from dynamoDB streams to flink

Hi Ying, Thanks for considering to contribute the connector! In general, you don't need special permissions to contribute to Flink. Anybody can open Jiras and PRs. You only need to be assigned to the Contributor role in Jira to be able to assign an issue to you. I can give you these permissions i

Re: Consuming data from dynamoDB streams to flink

Hello Flink dev: We have implemented the prototype design and the initial PoC worked pretty well. Currently, we plan to move ahead with this design in our internal production system. We are thinking of contributing this connector back to the flink community sometime soon. May I request to be gr

Re: [VOTE] Release 1.5.2, release candidate #2

+1 - run a couple of programs from the Web UI - run SQL Client table programs (failing and non-failing) - run a couple end-to-end tests on my local machine Caveat: The test_streaming_classloader.sh does not work on releases. But this is a bug in the test, not in the release (see FLINK-9987).