Re: [VOTE] Release 1.13.2, release candidate #3

+1 (non-binding) - Verified checksums and signatures - Verified Python wheel package contents - Pip install apache-flink-libraries source package and apache-flink wheel package in Mac - Write and Run a Simple Python UDF job in Python REPL Best, Xingbo Yu Li 于2021年7月30日周五 下午2:33写道： > +1 (bindin

Re: [VOTE] Release 1.13.2, release candidate #3

+1 (binding) - Checked the diff between 1.13.1 and 1.13.2-rc3: OK ( https://github.com/apache/flink/compare/release-1.13.1...release-1.13.2-rc3) - commons-io version has been bumped to 2.8.0 through FLINK-22747 and all NOTICE files updated correctly - guava version has been bumped to 29.0 for

[jira] [Created] (FLINK-23555) Improve common subexpression elimination by using local references

weibowen created FLINK-23555: Summary: Improve common subexpression elimination by using local references Key: FLINK-23555 URL: https://issues.apache.org/jira/browse/FLINK-23555 Project: Flink I

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

Thanks @godfrey for driving this. +1 (non-binding) 1. built from source code flink-1.11.4-src.tgz succeeded 2. Started a local Flink cluster, ran the WordCount example, WebUI looks good, no suspicious output/lo

[jira] [Created] (FLINK-23554) SqlCli throws an exception and hang

JING ZHANG created FLINK-23554: -- Summary: SqlCli throws an exception and hang Key: FLINK-23554 URL: https://issues.apache.org/jira/browse/FLINK-23554 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-23553) Trigger global failover for a synchronous savepoint failure

Dawid Wysakowicz created FLINK-23553: Summary: Trigger global failover for a synchronous savepoint failure Key: FLINK-23553 URL: https://issues.apache.org/jira/browse/FLINK-23553 Project: Flink

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

+1 (non-binding) - Verified checksums and signatures - Verified local cluster - Verified sql-client and run a job Best, Jingsong On Thu, Jul 29, 2021 at 9:26 PM Robert Metzger wrote: > Thanks a lot for creating the release candidate! > > +1 (binding) > > Checks: > - manually checked the diff [

Re: [VOTE] Release 1.13.2, release candidate #3

+1 (non-binding) - Check if checksums and GPG files match the corresponding release files - staging repository looks fine - Start a local cluster (start-cluster.sh), logs fine - Run sql-client and run a job, looks fine I found an unexpected log in sql-client: "Searching for '/Users/lijingsong/Dow

[jira] [Created] (FLINK-23552) Remove yaml not found log in sql-client

Jingsong Lee created FLINK-23552: Summary: Remove yaml not found log in sql-client Key: FLINK-23552 URL: https://issues.apache.org/jira/browse/FLINK-23552 Project: Flink Issue Type: Bug

Re: [VOTE] Release 1.12.5, release candidate #3

Hi everyone, Thanks Robert, I created a new one. all artifacts to be deployed to the Maven Central Repository [4], [4] https://repository.apache.org/content/repositories/orgapacheflink-1444/ Best, Jingsong On Thu, Jul 29, 2021 at 9:50 PM Robert Metzger wrote: > The difference is that the 144

[jira] [Created] (FLINK-23551) Bump ORC to 1.6.9

Dongjoon Hyun created FLINK-23551: - Summary: Bump ORC to 1.6.9 Key: FLINK-23551 URL: https://issues.apache.org/jira/browse/FLINK-23551 Project: Flink Issue Type: Improvement Compone

Re: [DISCUSS] FLIP-177: Extend Sink API

Hi, Arvid & Piotr Sorry for the late reply. 1. Thank you all very much for your patience and explanation. Recently, I have also studied the related code of 'MailBox', which may not be as serious as I thought, after all, it is very similar to Java's `Executor`; 2. Whether to use AsyncIO or MailBox t

[jira] [Created] (FLINK-23550) Supports brotli compression algorithm

rufei xing created FLINK-23550: -- Summary: Supports brotli compression algorithm Key: FLINK-23550 URL: https://issues.apache.org/jira/browse/FLINK-23550 Project: Flink Issue Type: Improvement

Re: [VOTE] FLIP-150: Introduce Hybrid Source

Thanks Thomas. Looks great. That really helps to clarify the design :) On Thu, Jul 29, 2021 at 11:47 AM Thomas Weise wrote: > Thanks Becket. > > I added the interface and also clarified the switching modes under "Basic > Idea" based on your feedback on the PR. > > On Wed, Jul 28, 2021 at 5:56 PM

[jira] [Created] (FLINK-23549) Kafka table connector create table example in docs has syntax error

Mans Singh created FLINK-23549: -- Summary: Kafka table connector create table example in docs has syntax error Key: FLINK-23549 URL: https://issues.apache.org/jira/browse/FLINK-23549 Project: Flink

[jira] [Created] (FLINK-23548) Flink Session Cluster (Standalone) in Kubernetes: Exception occurred in REST handler: Could not execute application.

adis cesir created FLINK-23548: -- Summary: Flink Session Cluster (Standalone) in Kubernetes: Exception occurred in REST handler: Could not execute application. Key: FLINK-23548 URL: https://issues.apache.org/jira/brow

[jira] [Created] (FLINK-23547) StateFun does not execute integration tests

Seth Wiesman created FLINK-23547: Summary: StateFun does not execute integration tests Key: FLINK-23547 URL: https://issues.apache.org/jira/browse/FLINK-23547 Project: Flink Issue Type: Bug

Re: [VOTE] Release 1.13.2, release candidate #3

Thanks a lot for creating this release candidate +1 (binding) - staging repository looks fine - Diff to 1.13.1 looks fine wrt to dependency changes: https://github.com/apache/flink/compare/release-1.13.1...release-1.13.2-rc3 - standalone mode works locally - I found this issue, which is not sp

[jira] [Created] (FLINK-23546) stop-cluster.sh produces warning on macOS 11.4

Robert Metzger created FLINK-23546: -- Summary: stop-cluster.sh produces warning on macOS 11.4 Key: FLINK-23546 URL: https://issues.apache.org/jira/browse/FLINK-23546 Project: Flink Issue Type

Re: [VOTE] Release 1.12.5, release candidate #3

The difference is that the 1440 staging repository contains the Scala _2.11 files, the 1441 repo contains scala_2.12. I'm not sure if this works, because things like "flink-core:1.11.5" will be released twice? I would prefer to have a single staging repository containing all binaries we intend to r

Re: [VOTE] Release 1.12.5, release candidate #3

Thanks a lot for creating a release candidate! What is the difference between the two maven staging repos? https://repository.apache.org/content/repositories/orgapacheflink-1440/ and https://repository.apache.org/content/repositories/orgapacheflink-1441/ ? On Thu, Jul 29, 2021 at 1:52 PM Xingbo H

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

Thanks a lot for creating the release candidate! +1 (binding) Checks: - manually checked the diff [1]. License documentation seems to be properly maintained in all changes (mostly a jackson version dump, and some ES + Kinesis bumps) - checked standalone mode, job submission, logs locally. - check

[jira] [Created] (FLINK-23545) Use new schema in SqlCreateTableConverter

jinfeng created FLINK-23545: --- Summary: Use new schema in SqlCreateTableConverter Key: FLINK-23545 URL: https://issues.apache.org/jira/browse/FLINK-23545 Project: Flink Issue Type: Improvement

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

+1 (non-binding) - Verified checksums and signatures - Verified Python wheel package contents - Pip install Python wheel package in Mac - Run Simple Python UDF job in Python REPL Best, Xingbo Yun Tang 于2021年7月29日周四 下午3:57写道： > > +1 (non-binding) > > Checked the jars with signature of > 4A97887

Re: [VOTE] Release 1.12.5, release candidate #3

+1 (non-binding) - Verified checksums and signatures - Built from sources - Verified Python wheel package contents - Pip install Python wheel package in Mac - Run Python UDF job in Python REPL Best, Xingbo Zakelly Lan 于2021年7月29日周四 下午5:57写道： > +1 (non-binding) > > * Built from source. > * Run

[jira] [Created] (FLINK-23544) Window TVF Supports session window

JING ZHANG created FLINK-23544: -- Summary: Window TVF Supports session window Key: FLINK-23544 URL: https://issues.apache.org/jira/browse/FLINK-23544 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23543) Window TVF Supports session window

JING ZHANG created FLINK-23543: -- Summary: Window TVF Supports session window Key: FLINK-23543 URL: https://issues.apache.org/jira/browse/FLINK-23543 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-23542) Upgrade Checkstyle to at least 8.29

Martijn Visser created FLINK-23542: -- Summary: Upgrade Checkstyle to at least 8.29 Key: FLINK-23542 URL: https://issues.apache.org/jira/browse/FLINK-23542 Project: Flink Issue Type: Technical

Re: [VOTE] Release 1.12.5, release candidate #3

+1 (non-binding) * Built from source. * Run wordcount datastream job on yarn * Web UI and checkpoint seem good. * Kill a container to make job failover, everything is good. * Try run job from checkpoint, everything is good. On Thu, Jul 29, 2021 at 2:34 PM Yun Tang wrote: > +1 (non-binding) > >

Re: [DISCUSS] Change Default Jira Priority from "Major" to "Minor"

It's not unthinkable for infra to provide us with completely custom workflow. But if we can get by with replacing minor with normal without that, then I'd go with that. On 29/07/2021 07:49, Konstantin Knauf wrote: Thanks, Martijn. I was not aware of the definition in Jira. I don't think we

Re: [DISCUSS] Change Default Jira Priority from "Major" to "Minor"

Thanks, Martijn. I was not aware of the definition in Jira. I don't think we can actually change those, because they are shared by many projects. It's not ideal though. For the same reason, we can probably not *rename* Minor to Normal. It would also affect a lot of other projects. What we would ha

Re: Looking for Maintainers for Flink on YARN

Hi Konstantin, Thank you for raising this topic, our development team at Cloudera would be happy to step up to address this responsibility. Best, Marton On Thu, Jul 29, 2021 at 10:15 AM Konstantin Knauf wrote: > Dear community, > > We are looking for community members, who would like to mainta

Looking for Maintainers for Flink on YARN

Dear community, We are looking for community members, who would like to maintain Flink's YARN support going forward. So far, this has been handled by teams at Ververica & Alibaba. The focus of these teams has shifted over the past months so that we only have little time left for this topic. Still,

[jira] [Created] (FLINK-23541) Call StreamOperator#finish on EndOfData

Dawid Wysakowicz created FLINK-23541: Summary: Call StreamOperator#finish on EndOfData Key: FLINK-23541 URL: https://issues.apache.org/jira/browse/FLINK-23541 Project: Flink Issue Type: S

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

+1 (non-binding) Checked the jars with signature of 4A978875E56AA2100EB0CF12A244D52CF0A40279. Reviewed the PR of release notes. Download the pre-built package to run a standalone application mode job successfully. Best Yun Tang On 2021/07/26 15:25:27, godfrey he wrote: > Hi everyone,> > Plea

[jira] [Created] (FLINK-23540) Cannot build succesfully flink runtime project

tim yu created FLINK-23540: -- Summary: Cannot build succesfully flink runtime project Key: FLINK-23540 URL: https://issues.apache.org/jira/browse/FLINK-23540 Project: Flink Issue Type: Bug

Re: [VOTE] Release 1.13.2, release candidate #3

+1 (non-binding) * Built from source. * Run wordcount datastream job on yarn * Web UI and checkpoint seem good. * Kill a container to make job failover, everything is good. * Try run job from checkpoint, everything is good. On Fri, Jul 23, 2021 at 10:04 PM Yun Tang wrote: > Hi everyone, > Pleas