[jira] [Created] (FLINK-17257) AbstractYarnClusterTest does not compile with Hadoop 2.10

Xintong Song created FLINK-17257: Summary: AbstractYarnClusterTest does not compile with Hadoop 2.10 Key: FLINK-17257 URL: https://issues.apache.org/jira/browse/FLINK-17257 Project: Flink Iss

[jira] [Created] (FLINK-17258) Enable unaligned checkpoints in tests by default

Arvid Heise created FLINK-17258: --- Summary: Enable unaligned checkpoints in tests by default Key: FLINK-17258 URL: https://issues.apache.org/jira/browse/FLINK-17258 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-17259) Have scala 2.12 support

João Boto created FLINK-17259: - Summary: Have scala 2.12 support Key: FLINK-17259 URL: https://issues.apache.org/jira/browse/FLINK-17259 Project: Flink Issue Type: Improvement Component

[jira] [Created] (FLINK-17260) StreamingKafkaITCase failure on Azure

Roman Khachatryan created FLINK-17260: - Summary: StreamingKafkaITCase failure on Azure Key: FLINK-17260 URL: https://issues.apache.org/jira/browse/FLINK-17260 Project: Flink Issue Type: B

[jira] [Created] (FLINK-17261) Statefun docs broken

Chesnay Schepler created FLINK-17261: Summary: Statefun docs broken Key: FLINK-17261 URL: https://issues.apache.org/jira/browse/FLINK-17261 Project: Flink Issue Type: Bug Compon

[jira] [Created] (FLINK-17262) Statefun snapshot deployments broken

Chesnay Schepler created FLINK-17262: Summary: Statefun snapshot deployments broken Key: FLINK-17262 URL: https://issues.apache.org/jira/browse/FLINK-17262 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations Hequn! Thanks, Zhu Zhu zoudan 于2020年4月20日周一 上午10:34写道： > Congratulations Hequn > > Best, > Dan Zou > > > > 在 2020年4月20日，10:23，Terry Wang 写道： > > > > Congratulations Hequn !!! > > Best, > > Terry Wang > > > > > > > >> 2020年4月20日 10:20，Jingsong Li 写道： > >> > >> Congratulations H

[jira] [Created] (FLINK-17263) Remove RepeatFamilyOperandTypeChecker in blink planner and replace it with calcite's CompositeOperandTypeChecker

Terry Wang created FLINK-17263: -- Summary: Remove RepeatFamilyOperandTypeChecker in blink planner and replace it with calcite's CompositeOperandTypeChecker Key: FLINK-17263 URL: https://issues.apache.org/jira/browse/

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congrats! On Fri, Apr 17, 2020 at 2:44 PM Becket Qin wrote: > Hi all, > > I am glad to announce that Hequn Chen has joined the Flink PMC. > > Hequn has contributed to Flink for years. He has worked on several > components including Table / SQL，PyFlink and Flink ML Pipeline. Besides, > Hequn is a

[jira] [Created] (FLINK-17264) taskmanager.sh could not work on Mac

Yang Wang created FLINK-17264: - Summary: taskmanager.sh could not work on Mac Key: FLINK-17264 URL: https://issues.apache.org/jira/browse/FLINK-17264 Project: Flink Issue Type: Bug Comp

Re: [DISCUSS] Creating a new repo to host Flink benchmarks

Repository has been created: https://github.com/apache/flink-benchmarks On Sat, Apr 18, 2020 at 5:10 PM Tzu-Li (Gordon) Tai wrote: > There doesn't seem to be any objections in not considering the > flink-benchmarks migration as a significant change that requires a vote. > > If no-one objects in

Re: [DISCUSS] Integration of training materials into Apache Flink

The flink-training repository has been created: https://github.com/apache/flink-training On Mon, Apr 20, 2020 at 12:47 AM David Anderson wrote: > How about calling the component "Documentation / Training"? > > > Sounds good. Thanks! > > *David Anderson* | Training Coordinator > > Follow us @Verv

[jira] [Created] (FLINK-17265) uniform time and timeUnit use

Jake.zhang created FLINK-17265: -- Summary: uniform time and timeUnit use Key: FLINK-17265 URL: https://issues.apache.org/jira/browse/FLINK-17265 Project: Flink Issue Type: Wish Componen

[jira] [Created] (FLINK-17266) WorkerResourceSpec is not serializable

Gary Yao created FLINK-17266: Summary: WorkerResourceSpec is not serializable Key: FLINK-17266 URL: https://issues.apache.org/jira/browse/FLINK-17266 Project: Flink Issue Type: Bug Comp

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations Hequn! Bests, Wenlong On Mon, 20 Apr 2020 at 17:56, Yuan Mei wrote: > Congrats! > > On Fri, Apr 17, 2020 at 2:44 PM Becket Qin wrote: > > > Hi all, > > > > I am glad to announce that Hequn Chen has joined the Flink PMC. > > > > Hequn has contributed to Flink for years. He has w

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations Hequn! Regards, Canbin Zheng wenlong.lwl 于2020年4月20日周一 下午8:02写道： > Congratulations Hequn! > > Bests, > Wenlong > > On Mon, 20 Apr 2020 at 17:56, Yuan Mei wrote: > > > Congrats! > > > > On Fri, Apr 17, 2020 at 2:44 PM Becket Qin wrote: > > > > > Hi all, > > > > > > I am glad to

[jira] [Created] (FLINK-17267) supports EXPLAIN statement in TableEnvironment#executeSql and Table#explain api

godfrey he created FLINK-17267: -- Summary: supports EXPLAIN statement in TableEnvironment#executeSql and Table#explain api Key: FLINK-17267 URL: https://issues.apache.org/jira/browse/FLINK-17267 Project:

[jira] [Created] (FLINK-17268) SourceReaderTestBase.testAddSplitToExistingFetcher deadlocks on Travis

Till Rohrmann created FLINK-17268: - Summary: SourceReaderTestBase.testAddSplitToExistingFetcher deadlocks on Travis Key: FLINK-17268 URL: https://issues.apache.org/jira/browse/FLINK-17268 Project: Fli

[jira] [Created] (FLINK-17269) Translate new Tutorials Overview

David Anderson created FLINK-17269: -- Summary: Translate new Tutorials Overview Key: FLINK-17269 URL: https://issues.apache.org/jira/browse/FLINK-17269 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Integration of training materials into Apache Flink

The Jira component has been created! On Mon, Apr 20, 2020 at 12:04 PM Tzu-Li (Gordon) Tai wrote: > The flink-training repository has been created: > https://github.com/apache/flink-training > > On Mon, Apr 20, 2020 at 12:47 AM David Anderson > wrote: > >> How about calling the component "Docum

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations! On Mon, Apr 20, 2020 at 2:05 PM Canbin Zheng wrote: > Congratulations Hequn! > > Regards, > Canbin Zheng > > wenlong.lwl 于2020年4月20日周一 下午8:02写道： > > > Congratulations Hequn! > > > > Bests, > > Wenlong > > > > On Mon, 20 Apr 2020 at 17:56, Yuan Mei wrote: > > > > > Congrats! >

[jira] [Created] (FLINK-17270) param has space in config.sh

Yu Wang created FLINK-17270: --- Summary: param has space in config.sh Key: FLINK-17270 URL: https://issues.apache.org/jira/browse/FLINK-17270 Project: Flink Issue Type: Bug Reporter: Yu W

[GitHub] [flink-web] MarkSfik commented on a change in pull request #328: Add blog post: "Memory Management improvements with Apache Flink 1.10"

MarkSfik commented on a change in pull request #328: URL: https://github.com/apache/flink-web/pull/328#discussion_r411336028 ## File path: _posts/2020-04-17-memory-management-improvements-flink-1.10.md ## @@ -0,0 +1,87 @@ +--- +layout: post +title: "Memory Management improvemen

[GitHub] [flink-web] MarkSfik commented on a change in pull request #328: Add blog post: "Memory Management improvements with Apache Flink 1.10"

MarkSfik commented on a change in pull request #328: URL: https://github.com/apache/flink-web/pull/328#discussion_r411336241 ## File path: _posts/2020-04-17-memory-management-improvements-flink-1.10.md ## @@ -0,0 +1,87 @@ +--- +layout: post +title: "Memory Management improvemen

[GitHub] [flink-web] MarkSfik commented on a change in pull request #328: Add blog post: "Memory Management improvements with Apache Flink 1.10"

MarkSfik commented on a change in pull request #328: URL: https://github.com/apache/flink-web/pull/328#discussion_r411336465 ## File path: _posts/2020-04-17-memory-management-improvements-flink-1.10.md ## @@ -0,0 +1,87 @@ +--- +layout: post +title: "Memory Management improvemen

[GitHub] [flink-web] MarkSfik commented on a change in pull request #328: Add blog post: "Memory Management improvements with Apache Flink 1.10"

MarkSfik commented on a change in pull request #328: URL: https://github.com/apache/flink-web/pull/328#discussion_r411336895 ## File path: _posts/2020-04-17-memory-management-improvements-flink-1.10.md ## @@ -0,0 +1,87 @@ +--- +layout: post +title: "Memory Management improvemen

[GitHub] [flink-web] MarkSfik commented on a change in pull request #328: Add blog post: "Memory Management improvements with Apache Flink 1.10"

MarkSfik commented on a change in pull request #328: URL: https://github.com/apache/flink-web/pull/328#discussion_r411337034 ## File path: _posts/2020-04-17-memory-management-improvements-flink-1.10.md ## @@ -0,0 +1,87 @@ +--- +layout: post +title: "Memory Management improvemen

[GitHub] [flink-web] MarkSfik commented on a change in pull request #328: Add blog post: "Memory Management improvements with Apache Flink 1.10"

MarkSfik commented on a change in pull request #328: URL: https://github.com/apache/flink-web/pull/328#discussion_r411337742 ## File path: _posts/2020-04-17-memory-management-improvements-flink-1.10.md ## @@ -0,0 +1,87 @@ +--- +layout: post +title: "Memory Management improvemen

[GitHub] [flink-web] MarkSfik commented on a change in pull request #328: Add blog post: "Memory Management improvements with Apache Flink 1.10"

MarkSfik commented on a change in pull request #328: URL: https://github.com/apache/flink-web/pull/328#discussion_r411337034 ## File path: _posts/2020-04-17-memory-management-improvements-flink-1.10.md ## @@ -0,0 +1,87 @@ +--- +layout: post +title: "Memory Management improvemen

[GitHub] [flink-web] MarkSfik commented on a change in pull request #328: Add blog post: "Memory Management improvements with Apache Flink 1.10"

MarkSfik commented on a change in pull request #328: URL: https://github.com/apache/flink-web/pull/328#discussion_r411339534 ## File path: _posts/2020-04-17-memory-management-improvements-flink-1.10.md ## @@ -0,0 +1,87 @@ +--- +layout: post +title: "Memory Management improvemen

[GitHub] [flink-web] MarkSfik commented on a change in pull request #328: Add blog post: "Memory Management improvements with Apache Flink 1.10"

MarkSfik commented on a change in pull request #328: URL: https://github.com/apache/flink-web/pull/328#discussion_r409549023 ## File path: _posts/2020-04-17-memory-management-improvements-flink-1.10.md ## @@ -0,0 +1,87 @@ +--- +layout: post +title: "Memory Management improvemen

[GitHub] [flink-web] MarkSfik commented on a change in pull request #328: Add blog post: "Memory Management improvements with Apache Flink 1.10"

MarkSfik commented on a change in pull request #328: URL: https://github.com/apache/flink-web/pull/328#discussion_r411340267 ## File path: _posts/2020-04-17-memory-management-improvements-flink-1.10.md ## @@ -0,0 +1,87 @@ +--- +layout: post +title: "Memory Management improvemen

[jira] [Created] (FLINK-17271) Translate new DataStream API tutorial

David Anderson created FLINK-17271: -- Summary: Translate new DataStream API tutorial Key: FLINK-17271 URL: https://issues.apache.org/jira/browse/FLINK-17271 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-17272) param has space in config.sh

Yu Wang created FLINK-17272: --- Summary: param has space in config.sh Key: FLINK-17272 URL: https://issues.apache.org/jira/browse/FLINK-17272 Project: Flink Issue Type: Bug Reporter: Yu W

[jira] [Created] (FLINK-17273) Fix not calling ResourceManager#closeTaskManagerConnection in KubernetesResourceManager in case of registered TaskExecutor failure

Canbin Zheng created FLINK-17273: Summary: Fix not calling ResourceManager#closeTaskManagerConnection in KubernetesResourceManager in case of registered TaskExecutor failure Key: FLINK-17273 URL: https://issues.a

[jira] [Created] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

Robert Metzger created FLINK-17274: -- Summary: Maven: Premature end of Content-Length delimited message body Key: FLINK-17274 URL: https://issues.apache.org/jira/browse/FLINK-17274 Project: Flink

[jira] [Created] (FLINK-17275) Add core training exercises

Nico Kruber created FLINK-17275: --- Summary: Add core training exercises Key: FLINK-17275 URL: https://issues.apache.org/jira/browse/FLINK-17275 Project: Flink Issue Type: New Feature C

[jira] [Created] (FLINK-17276) Add checkstyle to training exercises

Nico Kruber created FLINK-17276: --- Summary: Add checkstyle to training exercises Key: FLINK-17276 URL: https://issues.apache.org/jira/browse/FLINK-17276 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-17277) Apply IntelliJ recommendations to training exercises

Nico Kruber created FLINK-17277: --- Summary: Apply IntelliJ recommendations to training exercises Key: FLINK-17277 URL: https://issues.apache.org/jira/browse/FLINK-17277 Project: Flink Issue Type

[jira] [Created] (FLINK-17278) Add Travis to the training exercises

Nico Kruber created FLINK-17278: --- Summary: Add Travis to the training exercises Key: FLINK-17278 URL: https://issues.apache.org/jira/browse/FLINK-17278 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-17279) Use gradle build scans

Nico Kruber created FLINK-17279: --- Summary: Use gradle build scans Key: FLINK-17279 URL: https://issues.apache.org/jira/browse/FLINK-17279 Project: Flink Issue Type: Improvement Compon

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

Hi Everyone! We would like to start a discussion on "FLIP-126: Unify (and separate) Watermark Assigners" [1]. This work was started by Stephan in an experimental branch. I expanded on that work to provide a PoC for the changes proposed in this FLIP: [2]. Currently, we have two different flav

[jira] [Created] (FLINK-17280) Migrate existing flink-benchmarks under apache project

Yun Tang created FLINK-17280: Summary: Migrate existing flink-benchmarks under apache project Key: FLINK-17280 URL: https://issues.apache.org/jira/browse/FLINK-17280 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-17281) Add existing flink-benchmarks code

Yun Tang created FLINK-17281: Summary: Add existing flink-benchmarks code Key: FLINK-17281 URL: https://issues.apache.org/jira/browse/FLINK-17281 Project: Flink Issue Type: Sub-task R

[jira] [Created] (FLINK-17282) Add CI build for new flink-benchmarks repo

Yun Tang created FLINK-17282: Summary: Add CI build for new flink-benchmarks repo Key: FLINK-17282 URL: https://issues.apache.org/jira/browse/FLINK-17282 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Creating a new repo to host Flink benchmarks

Thanks for Gordon's help! We will move on and create FLINK-17280 [1] to track the progress. [1] https://issues.apache.org/jira/browse/FLINK-17280 Best Yun Tang From: Tzu-Li (Gordon) Tai Sent: Monday, April 20

[jira] [Created] (FLINK-17283) Improve and explain the solution to Long Rides training exercise

David Anderson created FLINK-17283: -- Summary: Improve and explain the solution to Long Rides training exercise Key: FLINK-17283 URL: https://issues.apache.org/jira/browse/FLINK-17283 Project: Flink

[jira] [Created] (FLINK-17284) Support serial field type in PostgresCatalog

Flavio Pompermaier created FLINK-17284: -- Summary: Support serial field type in PostgresCatalog Key: FLINK-17284 URL: https://issues.apache.org/jira/browse/FLINK-17284 Project: Flink Issu

[jira] [Created] (FLINK-17285) Add Chinese translation to Python Table API Documentations

Zixuan Rao created FLINK-17285: -- Summary: Add Chinese translation to Python Table API Documentations Key: FLINK-17285 URL: https://issues.apache.org/jira/browse/FLINK-17285 Project: Flink Issue

[jira] [Created] (FLINK-17286) Integrate json to file system connector

Jingsong Lee created FLINK-17286: Summary: Integrate json to file system connector Key: FLINK-17286 URL: https://issues.apache.org/jira/browse/FLINK-17286 Project: Flink Issue Type: Sub-task

Apply to contribute to Flink

Hi Guys, I want to contribute to Apache Flink.Would you please give me the permission as a contributor?My JIRA ID is lyee.