[RESULT][VOTE] Release 1.11.1, release candidate #1

2020-07-20 Thread Dian Fu
Hi everyone, I'm happy to announce that we have unanimously approved this release. There are 9 approving votes, 4 of which are binding: * Jark (binding) * Yu (binding) * Zhijiang (binding) * Jincheng (binding) * Leonard * Rui * Congxian * Dian * Zhuzhu There are no disapproving votes. Thanks

Re: [VOTE] Release 1.11.1, release candidate #1

2020-07-20 Thread Dian Fu
Hi all, Thanks a lot for checking and voting for this release! I’ll summarize the result in another email. Thanks, Dian > 在 2020年7月21日,下午12:06,jincheng sun 写道: > > +1(binding) > > Checks: > > - checked the signature and checksum > - test the built from the wheel package > - check

[jira] [Created] (FLINK-18655) Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin in module flink-runtime

2020-07-20 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-18655: --- Summary: Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin in module flink-runtime Key: FLINK-18655 URL: https://issues.apache.org/jira/browse/FLINK-18655

Re: [VOTE] Release 1.11.1, release candidate #1

2020-07-20 Thread jincheng sun
+1(binding) Checks: - checked the signature and checksum - test the built from the wheel package - check wheel package consistency - pip installed the Python package and run a word count example successfully Best, Jincheng Zhu Zhu 于2020年7月21日周二 上午11:25写道: > +1 (non-binding) > >

[jira] [Created] (FLINK-18654) Correct missleading documentation in "Partitioned Scan" section of JDBC connector

2020-07-20 Thread Jark Wu (Jira)
Jark Wu created FLINK-18654: --- Summary: Correct missleading documentation in "Partitioned Scan" section of JDBC connector Key: FLINK-18654 URL: https://issues.apache.org/jira/browse/FLINK-18654 Project:

[jira] [Created] (FLINK-18653) flink-storm中可以根据TopologyBuilder转换成DataStream,但是,在现实使用的时候,我们只能从Storm jar中获得StormTopolgoy。

2020-07-20 Thread Jira
陈磊 created FLINK-18653: -- Summary: flink-storm中可以根据TopologyBuilder转换成DataStream,但是,在现实使用的时候,我们只能从Storm jar中获得StormTopolgoy。 Key: FLINK-18653 URL: https://issues.apache.org/jira/browse/FLINK-18653 Project: Flink

Re: [VOTE] Release 1.11.1, release candidate #1

2020-07-20 Thread Zhu Zhu
+1 (non-binding) - checked release notes - checked signatures - built from source - submitted an example job on yarn cluster - WebUI and logs look good Thanks, Zhu Zhu Zhijiang 于2020年7月21日周二 上午11:06写道: > +1 (binding) > > - Checked checksums and GPG files matching: OK > - Verified that the

Re: thrift support

2020-07-20 Thread Jark Wu
Hi Chen, Your listed items sound great to me. I think we can start from the thrift format, could you open an issue for it? The community also planned to support PB format in the next version, maybe can work together. Deriving table schema out of thrift struct is also an interesting topic, and is

Re: [VOTE] Release 1.11.1, release candidate #1

2020-07-20 Thread Zhijiang
+1 (binding) - Checked checksums and GPG files matching: OK - Verified that the source does not contain any binaries: OK - Checked that all the POMs point to the same version: OK - Build the source with Maven: OK - Review the Web PR: OK - Checked the artifacts in repo: OK - Execute the WordCount

Re: thrift support

2020-07-20 Thread Benchao Li
Hi Chen, - adding support in flink-format (e.g flink-thrift) Sure. We should have a flink-thrift format to do the (de)ser work. - evaluate if TBaseSeralizaer (Kryo) need extra work I don't known if I understand it correctly, I think we don't need to transfer thrift data inside Flink, we just

[jira] [Created] (FLINK-18652) JDBCAppendTableSink to ClickHouse (data always repeating)

2020-07-20 Thread mzz (Jira)
mzz created FLINK-18652: --- Summary: JDBCAppendTableSink to ClickHouse (data always repeating) Key: FLINK-18652 URL: https://issues.apache.org/jira/browse/FLINK-18652 Project: Flink Issue Type:

[jira] [Created] (FLINK-18651) implicitly cast the time attribute to regular TIMESTAMP type in regular join

2020-07-20 Thread godfrey he (Jira)
godfrey he created FLINK-18651: -- Summary: implicitly cast the time attribute to regular TIMESTAMP type in regular join Key: FLINK-18651 URL: https://issues.apache.org/jira/browse/FLINK-18651 Project:

[jira] [Created] (FLINK-18650) The description of dispatcher in Flink Architecture document is not accurate

2020-07-20 Thread Peng (Jira)
Peng created FLINK-18650: Summary: The description of dispatcher in Flink Architecture document is not accurate Key: FLINK-18650 URL: https://issues.apache.org/jira/browse/FLINK-18650 Project: Flink

How does TaskManager announce JobManager about available ResultPartitions?

2020-07-20 Thread Fork Joseph
Hi, According to description in https://cwiki.apache.org/confluence/display/FLINK/Data+exchange+between+tasks, TaskManager announces (tells) JobManager about available ResultSubpartitions (RSs) to let another TM to initiate the transfer. However, I can’t find where in the codebase TM actually

Re: thrift support

2020-07-20 Thread Chen Qin
Jeff A sample would be you have a Kafka topic stores record in thrift format, - Flink SQL will not work because it doesn't support thrift format out of the box, - table schema can't be inferred so the user might end up handcrafting field by field mapping - thrift object serialization fall back to

[jira] [Created] (FLINK-18649) MongoDB Exactly-Once Semantics - recommended approach

2020-07-20 Thread Eric Holsinger (Jira)
Eric Holsinger created FLINK-18649: -- Summary: MongoDB Exactly-Once Semantics - recommended approach Key: FLINK-18649 URL: https://issues.apache.org/jira/browse/FLINK-18649 Project: Flink

[jira] [Created] (FLINK-18648) KafkaITCase.testStartFromGroupOffsets times out on azure

2020-07-20 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-18648: Summary: KafkaITCase.testStartFromGroupOffsets times out on azure Key: FLINK-18648 URL: https://issues.apache.org/jira/browse/FLINK-18648 Project: Flink

[jira] [Created] (FLINK-18647) How to handle processing time timers with bounded input

2020-07-20 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-18647: -- Summary: How to handle processing time timers with bounded input Key: FLINK-18647 URL: https://issues.apache.org/jira/browse/FLINK-18647 Project: Flink

Re: [REMINDER] Use 'starter' labels for Jira issues where it makes sense

2020-07-20 Thread Aljoscha Krettek
Yes, thanks Andrey! That's a good reminder for everyone. :-) On 20.07.20 16:02, Andrey Zagrebin wrote: Hi Flink Devs, I would like to remind you that we have a 'starter' label [1] to annotate Jira issues which need a contribution and which are not very complicated for the new contributors. The

Re: Flink Jobs are failing for running testcases when trying to build in Jenkins server

2020-07-20 Thread Piotr Nowojski
Hi, It looks like Flink mini (test) cluster has troubles starting up on your Jenkins machine. Frankly, it's hard for me to guess what could be the issue here. 1. Are you following this guideline? [1] 2. Maybe there are some other error messages somewhere else in the logs/stderr/stdout? This 100s

[REMINDER] Use 'starter' labels for Jira issues where it makes sense

2020-07-20 Thread Andrey Zagrebin
Hi Flink Devs, I would like to remind you that we have a 'starter' label [1] to annotate Jira issues which need a contribution and which are not very complicated for the new contributors. The starter issues can be a good opportunity for the new contributors who want to learn about Flink but do

[jira] [Created] (FLINK-18646) Managed memory released check can block RPC thread

2020-07-20 Thread Andrey Zagrebin (Jira)
Andrey Zagrebin created FLINK-18646: --- Summary: Managed memory released check can block RPC thread Key: FLINK-18646 URL: https://issues.apache.org/jira/browse/FLINK-18646 Project: Flink

Re: [VOTE] Release 1.11.1, release candidate #1

2020-07-20 Thread Yu Li
+1 (binding) - Checked diff to last RC: OK ( https://github.com/apache/flink/compare/release-1.11.0...release-1.11.1-rc1) - All dependency related changes are properly documented - Checked release notes: OK - Minor: there're 2 open issues left, please remember to scope them out if this vote

[jira] [Created] (FLINK-18645) Add community driven SDKs to StateFun documentations.

2020-07-20 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-18645: Summary: Add community driven SDKs to StateFun documentations. Key: FLINK-18645 URL: https://issues.apache.org/jira/browse/FLINK-18645 Project: Flink Issue

Re: [VOTE] Release 1.11.1, release candidate #1

2020-07-20 Thread Jark Wu
Thanks Dian for kicking off the RC. +1 from my side: I heavily tested CDC use cases end-to-end and it works well. - checked/verified signatures and hashes - manually verified the diff pom and NOTICE files between 1.11.0 and 1.11.1 to check dependencies, looks good - no missing artifacts in

[jira] [Created] (FLINK-18644) Remove scala-shell doc for hive connector

2020-07-20 Thread Rui Li (Jira)
Rui Li created FLINK-18644: -- Summary: Remove scala-shell doc for hive connector Key: FLINK-18644 URL: https://issues.apache.org/jira/browse/FLINK-18644 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-18643) Migrate Jenkins jobs to ci-builds.apache.org

2020-07-20 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-18643: Summary: Migrate Jenkins jobs to ci-builds.apache.org Key: FLINK-18643 URL: https://issues.apache.org/jira/browse/FLINK-18643 Project: Flink Issue

[jira] [Created] (FLINK-18642) flink sql cep

2020-07-20 Thread franklin DREW (Jira)
franklin DREW created FLINK-18642: - Summary: flink sql cep Key: FLINK-18642 URL: https://issues.apache.org/jira/browse/FLINK-18642 Project: Flink Issue Type: Test Components:

[jira] [Created] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

2020-07-20 Thread Brian Zhou (Jira)
Brian Zhou created FLINK-18641: -- Summary: "Failure to finalize checkpoint" error in MasterTriggerRestoreHook Key: FLINK-18641 URL: https://issues.apache.org/jira/browse/FLINK-18641 Project: Flink

[jira] [Created] (FLINK-18640) Flink jdbc not support postgresql with schema

2020-07-20 Thread Jira
毛宗良 created FLINK-18640: --- Summary: Flink jdbc not support postgresql with schema Key: FLINK-18640 URL: https://issues.apache.org/jira/browse/FLINK-18640 Project: Flink Issue Type: Bug