[jira] [Created] (FLINK-11794) Allow compression of row format files created by StreamingFileSink

2019-03-01 Thread Elias Levy (JIRA)
Elias Levy created FLINK-11794: -- Summary: Allow compression of row format files created by StreamingFileSink Key: FLINK-11794 URL: https://issues.apache.org/jira/browse/FLINK-11794 Project: Flink

Re: [ANNOUNCE] Update on Flink 1.8 Release Progress

2019-03-01 Thread Thomas Weise
Hi Aljoscha, Thanks for driving the release. I think it is a good idea for others to take a look at the blog post and make sure we capture all goodies worth mentioning. I would also like to ask to cherry pick the following into the release branch:

Re: [DISCUSS] Improve the flinkbot

2019-03-01 Thread Thomas Weise
It would be good to encourage participation of non-committers in the review process, so +1 for allowing everyone to operate the bot. Github approval will show a green checkmark for committer approval (assuming accounts were linked via gitbox) - that should provide sufficient orientation? I just

[jira] [Created] (FLINK-11793) Make KafkaProducer more resilient to Kafka Broker Failures

2019-03-01 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-11793: Summary: Make KafkaProducer more resilient to Kafka Broker Failures Key: FLINK-11793 URL: https://issues.apache.org/jira/browse/FLINK-11793 Project: Flink

[jira] [Created] (FLINK-11792) Make KafkaConsumer more resilient to Kafka Broker Failures

2019-03-01 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-11792: Summary: Make KafkaConsumer more resilient to Kafka Broker Failures Key: FLINK-11792 URL: https://issues.apache.org/jira/browse/FLINK-11792 Project: Flink

Re: [DISCUSS] Improve the flinkbot

2019-03-01 Thread Robert Metzger
I will update labels only based on committer's approvals (for everything), I think that's cleaner. We can always revisit this. On Wed, Feb 27, 2019 at 4:31 PM Chesnay Schepler wrote: > Fore code-quality/description I agree, but consensus and the final > approval should require a committer IMO.

Re: Recommended module for connector ratelimiting?

2019-03-01 Thread Thomas Weise
Lakshmi, I would prefer we move the ratelimiter interface to the appropriate location before we merge the PR. Thanks, Thomas On Thu, Feb 28, 2019 at 5:29 PM Lakshmi Gururaja Rao wrote: > @Thomas Weise that seems reasonable to me. I'll > create a JIRA to track this. > > @Roshan > The idea of

[ANNOUNCE] Update on Flink 1.8 Release Progress

2019-03-01 Thread Aljoscha Krettek
Hi Everyone, We are now about a week after cutting the release-1.8 branch and things are looking quite good! The community has worked hard on fixing bugs and test instabilities. There are now only two issues that are marked as “blocker” in our Jira: [1]. The first of which is about updating

[jira] [Created] (FLINK-11791) Describe how to build Flink with Hadoop in build guide

2019-03-01 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-11791: Summary: Describe how to build Flink with Hadoop in build guide Key: FLINK-11791 URL: https://issues.apache.org/jira/browse/FLINK-11791 Project: Flink

[jira] [Created] (FLINK-11790) Introduce basic Flink RelNode interface

2019-03-01 Thread godfrey he (JIRA)
godfrey he created FLINK-11790: -- Summary: Introduce basic Flink RelNode interface Key: FLINK-11790 URL: https://issues.apache.org/jira/browse/FLINK-11790 Project: Flink Issue Type: New Feature

Refactoring of FlinkKafkaProducer

2019-03-01 Thread Александр
Hello, flink community! I recently joined the community and I'm trying to understand the project module by module. I've noticed that in FlinkKafkaProducer (

[jira] [Created] (FLINK-11789) Checkpoint directories are not cleaned up after job termination

2019-03-01 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11789: - Summary: Checkpoint directories are not cleaned up after job termination Key: FLINK-11789 URL: https://issues.apache.org/jira/browse/FLINK-11789 Project: Flink

Re: [RESULT][VOTE] Clean up and reorganize the JIRA components

2019-03-01 Thread Robert Metzger
@Kurt: Okay. @all: I've now creating the new components, and I've migrated almost all of the old components. We also had 200 tickets which were not assigned to any component. I've assigned them all, and I'll keep an eye on those tickets w/o a component. There's a "*chinese-translation*"

Re: Some dev questions

2019-03-01 Thread Flavio Pompermaier
You're right Chesnay, I did a git fetch and I didn't remember that it doesn't update the tag list.. After a git fetch --tags --all I was able to find the tags. It would be nice to add this info into the "build from source" documentation [1]: the page states "This page covers how to build Flink

Re: Permission to apply for contributor

2019-03-01 Thread Fabian Hueske
Hi, Welcome to the Flink community. I've given you contributor permissions for Jira. Best, Fabian Am Fr., 1. März 2019 um 08:43 Uhr schrieb yelun <986463...@qq.com>: > Hi ,I want to contribute to the Flink Community.My jira id is guanghui. > Thanks > >

Re: Some dev questions

2019-03-01 Thread Chesnay Schepler
Tags still exist for all releases, which ou can easily verify this on GitHub.. My guess is that you didn't fetch them properly. As for the ML tickets, these were specific to the flink-ml module, and for this module it seems unlikely that we will continue improving it as we haven't been

Flink Custom SourceFunction and SinkFunction

2019-03-01 Thread Siew Wai Yow
Hi guys, I have question regarding to the title that need your expertise, 1. I need to build a SFTP SourceFunction, may I know if hadoop SFTPFileSystem suitable? 2. I need to build a SFTP SinkFunction as well, may I know if per-defined HDFS rolling file sink accept SFTP connection since