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

+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 Leonard Xu 于2020年5月12日周二 上午11:10写道： > +1 (non-binding) > > - checked/verified signatures and hashes > - checked the release

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

+1 (non-binding) - checked/verified signatures and hashes - checked the release note - checked that there are no missing artifacts in staging area - built from source sing scala 2.11 succeeded - started cluster and run some e2e test succeeded - started a cluster, WebUI was accessible, submitted a

[jira] [Created] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

Jark Wu created FLINK-17625: --- Summary: Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction Key: FLINK-17625 URL: https://issues.apache.org/jira/browse/FLINK-17625 Project: Flink Issue

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

+1(binding) - built from source and run Streaming word count without unexpected information. - check the signatures, looks good! BTW: I've added your PyPI account(carp84) as a maintainer role. Great job Yu! Best, Jincheng Hequn Cheng 于2020年5月12日周二 上午9:49写道： > +1 (binding) > > - Go through

[jira] [Created] (FLINK-17624) "TPC-DS end-to-end test (Blink planner)' is unstable

Yang Wang created FLINK-17624: - Summary: "TPC-DS end-to-end test (Blink planner)' is unstable Key: FLINK-17624 URL: https://issues.apache.org/jira/browse/FLINK-17624 Project: Flink Issue Type:

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

+1 (binding) - Go through all commits from 1.10.0 to 1.10.1 and spot no new license problems. - Built from source archive successfully. - Travis e2e tests have passed. - Signatures and hash are correct. - Run SocketWindowWordCount on the local cluster and check web ui & logs. - Install Python

[jira] [Created] (FLINK-17623) Elasticsearch sink should support user resource cleanup

Yun Wang created FLINK-17623: Summary: Elasticsearch sink should support user resource cleanup Key: FLINK-17623 URL: https://issues.apache.org/jira/browse/FLINK-17623 Project: Flink Issue Type:

[jira] [Created] (FLINK-17622) Remove useless switch for decimal in PostresCatalog

Flavio Pompermaier created FLINK-17622: -- Summary: Remove useless switch for decimal in PostresCatalog Key: FLINK-17622 URL: https://issues.apache.org/jira/browse/FLINK-17622 Project: Flink

Re: [DISCUSS] Add a material web page under "https://flink.apache.org/"

Yep, Marta's concern is definitely a great point in terms of maintenance costs. What I would like to highlight is a place to collect scattered materials `altogether` so that they are easy to search, tag, and update. In that sense, I really like Fabian's idea. It is even better if we could have

Re: [DISCUSS] FLIP-126: Unify (and separate) Watermark Assigners

Thanks for the explanation. I like the fatory pattern to make the member variables immutable and final. So +1 to the proposal. Best, Jark On Mon, 11 May 2020 at 22:01, Stephan Ewen wrote: > I am fine with that. > > Much of the principles seem agreed upon. I understand the need to support >

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

+1 (binding) - checked release notes - verified sums and hashes - reviewed website PR - successfully built an internal Flink distribution based on the 1.10.1-rc3 commit - successfully built internal jobs against the staging repo and deployed those jobs to a 1.10.1 job cluster on Kubernetes and

Re: [PROPOSAL] Google Season of Docs 2020.

Awesome. Great job. On Mon, 11 May 2020 at 7:22 PM, Seth Wiesman wrote: > Thank you for putting this together Marta! > > On Mon, May 11, 2020 at 8:35 AM Fabian Hueske wrote: > > > Thanks Marta and congratulations! > > > > Am Mo., 11. Mai 2020 um 14:55 Uhr schrieb Robert Metzger < > >

[jira] [Created] (FLINK-17621) Use default akka.ask.timeout in TPC-DS e2e test

Gary Yao created FLINK-17621: Summary: Use default akka.ask.timeout in TPC-DS e2e test Key: FLINK-17621 URL: https://issues.apache.org/jira/browse/FLINK-17621 Project: Flink Issue Type: Task

Re: [DISCUSS] FLIP-126: Unify (and separate) Watermark Assigners

I am fine with that. Much of the principles seem agreed upon. I understand the need to support code-generated extractors and we should support most of it already (as Aljoscha mentioned via the factories) can extend this if needed. I think that the factory approach supports code-generated

Re: [PROPOSAL] Google Season of Docs 2020.

Thank you for putting this together Marta! On Mon, May 11, 2020 at 8:35 AM Fabian Hueske wrote: > Thanks Marta and congratulations! > > Am Mo., 11. Mai 2020 um 14:55 Uhr schrieb Robert Metzger < > rmetz...@apache.org>: > > > Awesome :) > > Thanks a lot for driving this Marta! > > > > Nice to

[jira] [Created] (FLINK-17620) Rename StandaloneJobClusterEntryPoint to StandaloneApplicationClusterEntryPoint

Kostas Kloudas created FLINK-17620: -- Summary: Rename StandaloneJobClusterEntryPoint to StandaloneApplicationClusterEntryPoint Key: FLINK-17620 URL: https://issues.apache.org/jira/browse/FLINK-17620

Re: [DISCUSS] FLIP-126: Unify (and separate) Watermark Assigners

We're slightly running out of time. I would propose we vote on the basic principle and remain open to later additions. This feature is quite important to make the new Kafka Source that is developed as part of FLIP-27 useful. Otherwise we would have to use the legacy interfaces in the newly

Re: [PROPOSAL] Google Season of Docs 2020.

Thanks Marta and congratulations! Am Mo., 11. Mai 2020 um 14:55 Uhr schrieb Robert Metzger < rmetz...@apache.org>: > Awesome :) > Thanks a lot for driving this Marta! > > Nice to see Flink (by virtue of having Apache as part of the name) so high > on the list, with other good open source

Re: [PROPOSAL] Google Season of Docs 2020.

Awesome :) Thanks a lot for driving this Marta! Nice to see Flink (by virtue of having Apache as part of the name) so high on the list, with other good open source projects :) On Mon, May 11, 2020 at 2:18 PM Marta Paes Moreira wrote: > I'm happy to announce that we were *accepted* into this

[Season of Docs] Acceptance into Season of Docs 2020

Congratulations! Your organization’s application for Season of Docs has been accepted. We’ll publish the list of accepted organizations on the Season of Docs website on May 11. From that date, technical writers can explore the list

[jira] [Created] (FLINK-17619) Only set offset commit if group id is configured for Kafka Table source

Gyula Fora created FLINK-17619: -- Summary: Only set offset commit if group id is configured for Kafka Table source Key: FLINK-17619 URL: https://issues.apache.org/jira/browse/FLINK-17619 Project: Flink

[jira] [Created] (FLINK-17618) Update the outdated comments in the log4j properties files

Yang Wang created FLINK-17618: - Summary: Update the outdated comments in the log4j properties files Key: FLINK-17618 URL: https://issues.apache.org/jira/browse/FLINK-17618 Project: Flink Issue

Re: [PROPOSAL] Google Season of Docs 2020.

I'm happy to announce that we were *accepted* into this year's Google Season of Docs! The list of projects was published today [1]. The next step is for technical writers to reach out (May 11th-June 8th) and apply (June 9th-July 9th). Thanks again to everyone involved! I'm really looking forward

Re: [DISCUSS] FLIP-126: Unify (and separate) Watermark Assigners

Ah, I meant to write this in my previous email, sorry about that. The WatermarkStrategy, which is basically a factory for a WatermarkGenerator is the replacement for the open() method. This is the same strategy that was followed for StreamOperatorFactory, which was introduced to allow code

Re: [DISCUSS] Add a material web page under "https://flink.apache.org/"

Fabian's idea is definitely nice, if we find somebody who wants to develop such a site :) Marta has raised valid concerns. Maybe we could start by creating a Wiki page, that nicely categorizes the different items. I'm happy to prominently link the Wiki page from the "Powered By" and Starting

[jira] [Created] (FLINK-17617) Flink SQL CLI Autocomplete does not return correct hints

Gyula Fora created FLINK-17617: -- Summary: Flink SQL CLI Autocomplete does not return correct hints Key: FLINK-17617 URL: https://issues.apache.org/jira/browse/FLINK-17617 Project: Flink Issue

[jira] [Created] (FLINK-17616) Temporarily increase akka.ask.timeout in TPC-DS e2e test

Gary Yao created FLINK-17616: Summary: Temporarily increase akka.ask.timeout in TPC-DS e2e test Key: FLINK-17616 URL: https://issues.apache.org/jira/browse/FLINK-17616 Project: Flink Issue Type:

[jira] [Created] (FLINK-17615) flink batch job name doesn't show as defined in program

akisaya created FLINK-17615: --- Summary: flink batch job name doesn't show as defined in program Key: FLINK-17615 URL: https://issues.apache.org/jira/browse/FLINK-17615 Project: Flink Issue Type:

[jira] [Created] (FLINK-17614) Add project ITCase for partition table in filesystem connector

Leonard Xu created FLINK-17614: -- Summary: Add project ITCase for partition table in filesystem connector Key: FLINK-17614 URL: https://issues.apache.org/jira/browse/FLINK-17614 Project: Flink

Re: [DISCUSS] Releasing "fat" and "slim" Flink distributions

One downside would be that we're shipping more stuff when running on YARN for example, since the entire plugins directory is shiped by default. On 17/04/2020 16:38, Stephan Ewen wrote: @Aljoscha I think that is an interesting line of thinking. the swift-fs may be rarely enough used to move it

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

+1 (binding) Legal checks: - checksum & gpg OK - changes to Kinesis connector NOTICE files looks good - built from source Downstream checks in flink-statefun: - Built StateFun with Flink 1.10.1 + e2e tests enabled (mvn clean install -Prun-e2e-tests), builds and passes - Previous issue preventing

[jira] [Created] (FLINK-17613) Run K8s related e2e tests with multiple K8s versions

Yang Wang created FLINK-17613: - Summary: Run K8s related e2e tests with multiple K8s versions Key: FLINK-17613 URL: https://issues.apache.org/jira/browse/FLINK-17613 Project: Flink Issue Type:

[jira] [Created] (FLINK-17612) The Python command line options are ignored by the CliOptionsParser in SQL Client

Wei Zhong created FLINK-17612: - Summary: The Python command line options are ignored by the CliOptionsParser in SQL Client Key: FLINK-17612 URL: https://issues.apache.org/jira/browse/FLINK-17612 Project:

[jira] [Created] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

Francesco Guardiani created FLINK-17611: --- Summary: Support unix domain sockets for sidecar communication in Stateful Functions Key: FLINK-17611 URL: https://issues.apache.org/jira/browse/FLINK-17611

Re: [DISCUSS] Align the behavior of internal return result of MapState#entries, keys, values and iterator.

Hi Tang Yun, I have already created new issue for FLINK-17610 to align the behavior of result of internal map state to return empty iterator. Please check this issue, if you have any question for it, please let me know about this. Thanks, Nicholas Jiang -- Sent from:

Re: [DISCUSS] Align the behavior of internal return result of MapState#entries, keys, values and iterator.

Thanks for everyone's positive response. FLINK-17610 [1] have been created to track this problem. [1] https://issues.apache.org/jira/browse/FLINK-17610 Best Yun Tang From: Congxian Qiu Sent: Monday, May 11, 2020 13:42 To: dev@flink.apache.org Subject: Re:

[jira] [Created] (FLINK-17610) Align the behavior of result of internal map state to return empty iterator

Nicholas Jiang created FLINK-17610: -- Summary: Align the behavior of result of internal map state to return empty iterator Key: FLINK-17610 URL: https://issues.apache.org/jira/browse/FLINK-17610

Re: [DISCUSS] Add a material web page under "https://flink.apache.org/"

Hi everyone, I like the idea of having a place to collect material (blogs, talk recordings, slides) on Flink. As Robert said, we had this before and dropped it at some point because the content became stale. Also I feel we would need something more dynamic than a static website (like

[jira] [Created] (FLINK-17609) Execute the script directly when user specified the entry script with "-py" rather than run as module.

shuiqiangchen created FLINK-17609: - Summary: Execute the script directly when user specified the entry script with "-py" rather than run as module. Key: FLINK-17609 URL:

[jira] [Created] (FLINK-17608) Add TM log and stdout page back

Yadong Xie created FLINK-17608: -- Summary: Add TM log and stdout page back Key: FLINK-17608 URL: https://issues.apache.org/jira/browse/FLINK-17608 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Add a material web page under "https://flink.apache.org/"

Hi, Yuan! Thanks for starting this discussion! It would be really good to make those resources more prominent in the Flink website somehow. You can find an example close to the idea you're bringing up in [1]. My concern is that placing all resources in a page can be hard to maintain and a bit

Re: [DISCUSS] Update our Roadmap

+1 for making the release manager responsible for the roadmap update to happen! On Wed, May 6, 2020 at 11:31 AM Till Rohrmann wrote: > Maybe we could say that the new release manager will do this (or at least > make sure that updating the roadmap will happen). The community usually > tries to

Re: [DISCUSS] Add a material web page under "https://flink.apache.org/"

Thanks Robert! I totally agree. There is a team specifically running to promote Flink community in China, hence the concern of "up to date" won't be a problem. Flink's public WeChat account is maintained by the team, so can the webpage. They make sure the web page is in-sync. Best Yuan On Mon,

Re: [DISCUSS] Add a material web page under "https://flink.apache.org/"

Hey Yuan, I like this idea lot! As long as the material is non-commercial, and really for the purpose of sharing knowledge and promoting Flink, it should be suitable for the Flink website. If we add such a page to Flink, it is important to keep it up to date. If I remember correctly, we used to

[DISCUSS] Add a material web page under "https://flink.apache.org/"

Hey folks, I am looking for a home to put and organize materials (mostly in Chinese) altogether for easier reference or search in the future. Those materials mainly include: - video records for live broadcasting of Flink related content. For example, the set of selected Flink Forward talks

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

+1 (no-binding) - checksum & gpg ok - build from source OK - all pom files points to the same version OK - LICENSE OK - run demos OK Best, Congxian Dian Fu 于2020年5月10日周日 下午10:14写道： > +1 (non-binding) > > - checked the dependency changes since 1.10.0 > 1) kafka was bumped from 0.10.2.1 to

[jira] [Created] (FLINK-17607) TableEnvironmentITCase.testStatementSet fails on azure

Piotr Nowojski created FLINK-17607: -- Summary: TableEnvironmentITCase.testStatementSet fails on azure Key: FLINK-17607 URL: https://issues.apache.org/jira/browse/FLINK-17607 Project: Flink

[jira] [Created] (FLINK-17606) Introduce DataGen connector in table

Jingsong Lee created FLINK-17606: Summary: Introduce DataGen connector in table Key: FLINK-17606 URL: https://issues.apache.org/jira/browse/FLINK-17606 Project: Flink Issue Type: Sub-task