回复:Would you please give me the permission as a contributor?

2019-02-15 Thread fei han
Hi,Robert I am contributing to Flink Chinese translation now. Best regards, Fei Han -- 发件人:Robert Metzger 发送时间:2019年2月15日(星期五) 19:17 收件人:dev ; hanfeizi0409 主 题:Re: Would you please give me the permission as a

Re: List of consumed kafka topics should not be restored from state

2019-02-15 Thread Tzu-Li (Gordon) Tai
Hi, I indeed don't have a specific use case in mind that justifies the current behaviour. My only concern is that since this was the default behaviour for a quite a while already, I can't be 100% that there are some user who actually expects the current behaviour. That may be dangerous since we

[jira] [Created] (FLINK-11638) Translate "Savepoints" page into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11638: Summary: Translate "Savepoints" page into Chinese Key: FLINK-11638 URL: https://issues.apache.org/jira/browse/FLINK-11638 Project: Flink Issue Type:

[jira] [Created] (FLINK-11637) Translate "Checkpoints" page into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11637: Summary: Translate "Checkpoints" page into Chinese Key: FLINK-11637 URL: https://issues.apache.org/jira/browse/FLINK-11637 Project: Flink Issue Type:

[jira] [Created] (FLINK-11636) Translate "State Schema Evolution" into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11636: Summary: Translate "State Schema Evolution" into Chinese Key: FLINK-11636 URL: https://issues.apache.org/jira/browse/FLINK-11636 Project: Flink Issue Type:

[jira] [Created] (FLINK-11635) Translate "Checkpointing" page into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11635: Summary: Translate "Checkpointing" page into Chinese Key: FLINK-11635 URL: https://issues.apache.org/jira/browse/FLINK-11635 Project: Flink Issue Type:

[jira] [Created] (FLINK-11634) Translate "State Backends" page into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11634: Summary: Translate "State Backends" page into Chinese Key: FLINK-11634 URL: https://issues.apache.org/jira/browse/FLINK-11634 Project: Flink Issue Type:

[jira] [Created] (FLINK-11633) Translate "Working with State" into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11633: Summary: Translate "Working with State" into Chinese Key: FLINK-11633 URL: https://issues.apache.org/jira/browse/FLINK-11633 Project: Flink Issue Type: New

[jira] [Created] (FLINK-11632) Make TaskManager automatic bind address picking more explicit (by default) and more configurable

2019-02-15 Thread Alex (JIRA)
Alex created FLINK-11632: Summary: Make TaskManager automatic bind address picking more explicit (by default) and more configurable Key: FLINK-11632 URL: https://issues.apache.org/jira/browse/FLINK-11632

[jira] [Created] (FLINK-11631) TaskExecutorITCase#testJobReExecutionAfterTaskExecutorTermination unstable on Travis

2019-02-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11631: - Summary: TaskExecutorITCase#testJobReExecutionAfterTaskExecutorTermination unstable on Travis Key: FLINK-11631 URL: https://issues.apache.org/jira/browse/FLINK-11631

[jira] [Created] (FLINK-11630) TaskExecutor does not wait for Task termination when terminating itself

2019-02-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11630: - Summary: TaskExecutor does not wait for Task termination when terminating itself Key: FLINK-11630 URL: https://issues.apache.org/jira/browse/FLINK-11630 Project:

[VOTE] Release Apache Flink 1.6.4, release candidate #1

2019-02-15 Thread jincheng sun
Hi everyone, Please review and vote on the release candidate #1 for the version 1.6.4, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1],

[jira] [Created] (FLINK-11629) Stop AkkaRpcActor immediately after onStop has finished

2019-02-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11629: - Summary: Stop AkkaRpcActor immediately after onStop has finished Key: FLINK-11629 URL: https://issues.apache.org/jira/browse/FLINK-11629 Project: Flink

Re: List of consumed kafka topics should not be restored from state

2019-02-15 Thread Feng LI
Hello Gordon, Thanks for adding the contributor permission. :) Agree with Gyula, I would vote +1 for changing this behavior unless we have use cases for maintaining it. I consider it more like a bug other than expected behavior. We had one counter example in production when migrating from one

Re: List of consumed kafka topics should not be restored from state

2019-02-15 Thread Gyula Fóra
Gordon, Do you have an example where the current default behaviour makes sense and it doesnt cause unexpected problems? Or an example where someone might reasonably expect the current behaviour instead of the newly suggested one. If we have such cases I would agree lets keep it as is. If we cant

Re: List of consumed kafka topics should not be restored from state

2019-02-15 Thread Tzu-Li (Gordon) Tai
Hi Feng, Thanks for working on a fix for this. I gave you contributor permission on JIRA. Before you jump right onto the code: do we have an agreement already on whether we change the default behaviour directly, or add a configuration option (e.g. add a `filterRestoredPartitionOffsetState()`

Re: List of consumed kafka topics should not be restored from state

2019-02-15 Thread Feng LI
Hello Aljoscha, Thanks for sharing the ticket, I think it makes sense to reopen the ticket. (I can work on the fix for this, should be a small patch, just add a filter when restoring Kafka partitions with those discovered partitions). (btw. Can I have a contributor access for jira, my username

Re: [VOTE] Release Apache Flink 1.7.2, release candidate #1

2019-02-15 Thread Tzu-Li (Gordon) Tai
Hi everyone, I’m happy to announce that we have unanimously approved this release candidate to be the 1.7.2 release. There are 6 approving votes, 4 of which are binding: * Chesnay (binding) * Jincheng (non-binding) * Aljoscha (binding) * Averell (non-binding) * Robert (binding) * Gordon

Re: [VOTE] Release Apache Flink 1.7.2, release candidate #1

2019-02-15 Thread Tzu-Li (Gordon) Tai
+1 - checked signatures and hashes - no missing artifacts in release staging area - built from source, without Hadoop and using Scala 2.12 - ran end-to-end tests locally and succeeded - manually tested that a job using Avro as state type can be restored from 1.6.3 with the 1.7.2 RC - a user

Re: [VOTE] Release Apache Flink 1.7.2, release candidate #1

2019-02-15 Thread Robert Metzger
+1 - started flink on yarn on google cloud dataproc (hadoop 2.9.2) - the files in the staging repo look correct (right version in the pom.xml, also for the quickstarts) On Fri, Feb 15, 2019 at 1:05 PM Averell wrote: > +1 > > * Compiled from source > * Downloaded jars from repository > *

Re: [VOTE] Release Apache Flink 1.7.2, release candidate #1

2019-02-15 Thread Averell
+1 * Compiled from source * Downloaded jars from repository * Started cluster * Restored job from savepoint made in the previous version (1.7.1) * Restored job from savepoint made in the current version (1.7.2) Thanks to Gordon for preparing the RC1 -- Sent from:

Re: [DISCUSS] Improve the flinkbot

2019-02-15 Thread Chesnay Schepler
The bot could check that the PR title to starts with [FLINK-X] or [hotfix]. On 13.02.2019 10:29, Robert Metzger wrote: Hey all, the flinkbot has been active for a week now, and I hope the initial hiccups have been resolved :) I wanted to start this as a permanent thread to discuss problems

Re: Would you please give me the permission as a contributor?

2019-02-15 Thread Robert Metzger
Hey, I just granted you the permissions. I'm curious to learn in which part of Flink you'd like to contribute. Best regards, Robert On Fri, Feb 15, 2019 at 9:33 AM hanfeizi0409 wrote: > Hi Guys, > > I want to contribute to Apache Flink. > Would you please give me the permission as a

[jira] [Created] (FLINK-11628) Cache maven on travis

2019-02-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11628: Summary: Cache maven on travis Key: FLINK-11628 URL: https://issues.apache.org/jira/browse/FLINK-11628 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-11627) Translate the "JobManager High Availability (HA)" page into Chinese

2019-02-15 Thread Hui Zhao (JIRA)
Hui Zhao created FLINK-11627: Summary: Translate the "JobManager High Availability (HA)" page into Chinese Key: FLINK-11627 URL: https://issues.apache.org/jira/browse/FLINK-11627 Project: Flink

[jira] [Created] (FLINK-11626) Bump flink-shaded version to 6.0

2019-02-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11626: Summary: Bump flink-shaded version to 6.0 Key: FLINK-11626 URL: https://issues.apache.org/jira/browse/FLINK-11626 Project: Flink Issue Type:

Re: [DISCUSS] Enhance Operator API to Support Dynamically Selective Reading and EndOfInput Event

2019-02-15 Thread Guowei Ma
I agree with you. In the long run, we should clearly define which parts should be exposed to users. At present, AbstractStreamOperator exposes a lot of concrete implementations, such as the details of the asynchronous Checkpoint "OperatorSnapshotFutures", and how to release some resource that is

[jira] [Created] (FLINK-11625) Bump flink-shaded version to 6.0

2019-02-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11625: Summary: Bump flink-shaded version to 6.0 Key: FLINK-11625 URL: https://issues.apache.org/jira/browse/FLINK-11625 Project: Flink Issue Type:

[jira] [Created] (FLINK-11623) Translate the "Configuration" page into Chinese

2019-02-15 Thread Hui Zhao (JIRA)
Hui Zhao created FLINK-11623: Summary: Translate the "Configuration" page into Chinese Key: FLINK-11623 URL: https://issues.apache.org/jira/browse/FLINK-11623 Project: Flink Issue Type: Sub-task

Re: [VOTE] Release Apache Flink 1.7.2, release candidate #1

2019-02-15 Thread Aljoscha Krettek
+1 - verified signatures and hashes - started cluster for both Scala 2.11 and 2.12, ran examples, verified web ui and log output (there is an exception in the log when running without Hadoop, should fix that but not a blocker) - manually verified the diff pom files between 1.7.1 and 1.7.2 to

[jira] [Created] (FLINK-11624) Translate the "File Systems" page into Chinese

2019-02-15 Thread Hui Zhao (JIRA)
Hui Zhao created FLINK-11624: Summary: Translate the "File Systems" page into Chinese Key: FLINK-11624 URL: https://issues.apache.org/jira/browse/FLINK-11624 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11622) Translate the "Command-Line Interface" page into Chinese

2019-02-15 Thread Hui Zhao (JIRA)
Hui Zhao created FLINK-11622: Summary: Translate the "Command-Line Interface" page into Chinese Key: FLINK-11622 URL: https://issues.apache.org/jira/browse/FLINK-11622 Project: Flink Issue Type:

Would you please give me the permission as a contributor?

2019-02-15 Thread hanfeizi0409
Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is hanfeio.

[jira] [Created] (FLINK-11621) Your project apache/flink is using buggy third-party libraries [WARNING]

2019-02-15 Thread Kaifeng Huang (JIRA)
Kaifeng Huang created FLINK-11621: - Summary: Your project apache/flink is using buggy third-party libraries [WARNING] Key: FLINK-11621 URL: https://issues.apache.org/jira/browse/FLINK-11621 Project:

[jira] [Created] (FLINK-11620) table example add kafka

2019-02-15 Thread lining (JIRA)
lining created FLINK-11620: -- Summary: table example add kafka Key: FLINK-11620 URL: https://issues.apache.org/jira/browse/FLINK-11620 Project: Flink Issue Type: Improvement Components:

Re: [DISCUSS] Contributing Chinese website and docs to Apache Flink

2019-02-15 Thread Jark Wu
Hi Fabian, Yes, I think so. We can find a way to move the translated content to crowdin to reuse the translation effort if we want to migrate to Docusaurus in the future. Regards, Jark On Fri, 15 Feb 2019 at 15:19, Fabian Hueske wrote: > Hi Jark, > > Thanks so much for evaluating Docusaurus