[jira] [Created] (FLINK-11198) Access to MetricGroup in an AggregateFunction(Non Rich)

Chirag Dewan created FLINK-11198: Summary: Access to MetricGroup in an AggregateFunction(Non Rich) Key: FLINK-11198 URL: https://issues.apache.org/jira/browse/FLINK-11198 Project: Flink

[jira] [Created] (FLINK-11197) Improve migration test comments about how to generate snapshots

Hequn Cheng created FLINK-11197: --- Summary: Improve migration test comments about how to generate snapshots Key: FLINK-11197 URL: https://issues.apache.org/jira/browse/FLINK-11197 Project: Flink

[jira] [Created] (FLINK-11196) Extend S3 EntropyInjector to use key replacement (instead of key removal) when creating checkpoint metadata files

Mark Cho created FLINK-11196: Summary: Extend S3 EntropyInjector to use key replacement (instead of key removal) when creating checkpoint metadata files Key: FLINK-11196 URL:

Re: [DISCUSS] Python (and Non-JVM) Language Support in Flink

Hi Shaoxuan, FWIW, Kenn Knowles (Beam PMC Chair) recently gave a talk at the Bay Area Apache Beam Meetup[1] which included a bit on a vision for how Beam could better leverage runner specific optimizations -- as an example/extension, Beam SQL leveraging Flink specific SQL optimizations (to

[jira] [Created] (FLINK-11195) Extend AbstractS3FileSystemFactory.createHadoopFileSystem to accept URI and Hadoop Configuration

Mark Cho created FLINK-11195: Summary: Extend AbstractS3FileSystemFactory.createHadoopFileSystem to accept URI and Hadoop Configuration Key: FLINK-11195 URL: https://issues.apache.org/jira/browse/FLINK-11195

Re: [DISCUSS] Flink Kerberos Improvement

Hi Shuyi, Yes. I think the impersonation is a very much valid question! This can actually be considered as 2 questions as I stated in the doc. 1. In the doc I stated that impersonation should be implemented on the user-side code and should only invoke the cluster client as the actual user joe'.

[jira] [Created] (FLINK-11192) rockdb customize configuration Covered jobmaster

Fan weiwen created FLINK-11192: -- Summary: rockdb customize configuration Covered jobmaster Key: FLINK-11192 URL: https://issues.apache.org/jira/browse/FLINK-11192 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-11194) missing Scala 2.12 build of HBase connector

Zhenhao Li created FLINK-11194: -- Summary: missing Scala 2.12 build of HBase connector Key: FLINK-11194 URL: https://issues.apache.org/jira/browse/FLINK-11194 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-11193) rockdb customize configuration Covered jobmaster

Fan weiwen created FLINK-11193: -- Summary: rockdb customize configuration Covered jobmaster Key: FLINK-11193 URL: https://issues.apache.org/jira/browse/FLINK-11193 Project: Flink Issue Type: Bug

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

+1 - signing key present in KEYS - signatures ok - src contains no binaries - binary not missing any jars - tag exists - release notes classification/names seem appropriate - maven artifacts not missing any jars On 18.12.2018 06:27, Thomas Weise wrote: Hi everyone, Please review and vote on

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

Done, removed 1.5.6 fix version from open tickets. On Tue, Dec 18, 2018 at 5:35 AM Chesnay Schepler wrote: > The release notes include a number of open issues. These typically have > not been fixed for the release; as such the 1.5.6 fixVersion should be > removed from them. > > On 18.12.2018

[jira] [Created] (FLINK-11191) Exception in code generation when ambiguous columns in MATCH_RECOGNIZE

Dawid Wysakowicz created FLINK-11191: Summary: Exception in code generation when ambiguous columns in MATCH_RECOGNIZE Key: FLINK-11191 URL: https://issues.apache.org/jira/browse/FLINK-11191

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

The release notes include a number of open issues. These typically have not been fixed for the release; as such the 1.5.6 fixVersion should be removed from them. On 18.12.2018 06:27, Thomas Weise wrote: Hi everyone, Please review and vote on the release candidate #1 for the version 1.5.6, as

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

+1 - signatures ok - src contains no binaries - binary not missing any jars - tag exists - release notes classification/names seem appropriate - maven artifacts not missing any jars On 18.12.2018 11:15, Tzu-Li (Gordon) Tai wrote: Hi everyone, Please review and vote on the release candidate #1

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

FLINK-10874 and FLINK-10987 were fixed for 1.7.0 . I will remove FLINK-10543 from the release notes. On 17.12.2018 03:36, Hequn Cheng wrote: Hi Chesnay, Thanks for the vote and great job! I checked the release notes and found the following errors: - Missing bugs: [FLINK-10874] Kafka 2.0

[VOTE] Release 1.6.3, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 1.6.3, 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-11190) Log stack trace on declined checkpoint

Daniel Harper created FLINK-11190: - Summary: Log stack trace on declined checkpoint Key: FLINK-11190 URL: https://issues.apache.org/jira/browse/FLINK-11190 Project: Flink Issue Type:

[jira] [Created] (FLINK-11189) Deprecated documentation for readSequenceFile function

shin chen created FLINK-11189: - Summary: Deprecated documentation for readSequenceFile function Key: FLINK-11189 URL: https://issues.apache.org/jira/browse/FLINK-11189 Project: Flink Issue Type: