[jira] [Created] (FLINK-21886) Loosen argument of TableEnvironmentInternal#executeInternal from QueryOperation to Operation

2021-03-19 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-21886: - Summary: Loosen argument of TableEnvironmentInternal#executeInternal from QueryOperation to Operation Key: FLINK-21886 URL: https://issues.apache.org/jira/browse/FLINK-21886

[jira] [Created] (FLINK-21885) Minor Typo Fix in JDBC Connector Documentation

2021-03-19 Thread Rion Williams (Jira)
Rion Williams created FLINK-21885: - Summary: Minor Typo Fix in JDBC Connector Documentation Key: FLINK-21885 URL: https://issues.apache.org/jira/browse/FLINK-21885 Project: Flink Issue Type:

Re: Flink job cannot find recover path after using entropy injection for s3 file systems

2021-03-19 Thread Rainie Li
I see, thanks for the info, Till. Appreciated for your help. Best regards Rainie On Thu, Mar 18, 2021 at 2:09 AM Till Rohrmann wrote: > Hi Rainie, > > if I remember correctly (unfortunately I don't have a S3 deployment at hand > to try it out), then in v1.9 you should find the data files for th

[jira] [Created] (FLINK-21884) Reduce TaskManager failure detection time

2021-03-19 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-21884: -- Summary: Reduce TaskManager failure detection time Key: FLINK-21884 URL: https://issues.apache.org/jira/browse/FLINK-21884 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-21883) Introduce cooldown period into adaptive scheduler

2021-03-19 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-21883: -- Summary: Introduce cooldown period into adaptive scheduler Key: FLINK-21883 URL: https://issues.apache.org/jira/browse/FLINK-21883 Project: Flink Issue T

[jira] [Created] (FLINK-21882) Create a Python based greeter example

2021-03-19 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-21882: Summary: Create a Python based greeter example Key: FLINK-21882 URL: https://issues.apache.org/jira/browse/FLINK-21882 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-21881) Support local global optimization for window aggregation

2021-03-19 Thread Jark Wu (Jira)
Jark Wu created FLINK-21881: --- Summary: Support local global optimization for window aggregation Key: FLINK-21881 URL: https://issues.apache.org/jira/browse/FLINK-21881 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-21880) UnalignedCheckpointRescaleITCase fails on azure

2021-03-19 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-21880: Summary: UnalignedCheckpointRescaleITCase fails on azure Key: FLINK-21880 URL: https://issues.apache.org/jira/browse/FLINK-21880 Project: Flink Issue

[jira] [Created] (FLINK-21879) ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime fails on AZP

2021-03-19 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-21879: --- Summary: ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime fails on AZP Key: FLINK-21879 URL: https://issues.apache.org/jira/browse/FLINK-21879

[jira] [Created] (FLINK-21878) JoinJsonPlanITCase#testIsNullInnerJoinWithNullCond fails on azure

2021-03-19 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-21878: Summary: JoinJsonPlanITCase#testIsNullInnerJoinWithNullCond fails on azure Key: FLINK-21878 URL: https://issues.apache.org/jira/browse/FLINK-21878 Project: Fl

[jira] [Created] (FLINK-21877) Add E2E test for upsert-kafka connector

2021-03-19 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-21877: - Summary: Add E2E test for upsert-kafka connector Key: FLINK-21877 URL: https://issues.apache.org/jira/browse/FLINK-21877 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-21876) Provide a way to handle when the returned value of Python UDF doesn't match the defined result type

2021-03-19 Thread Dian Fu (Jira)
Dian Fu created FLINK-21876: --- Summary: Provide a way to handle when the returned value of Python UDF doesn't match the defined result type Key: FLINK-21876 URL: https://issues.apache.org/jira/browse/FLINK-21876

[jira] [Created] (FLINK-21875) GSRKinesisPubsubClient is not compiling in IntelliJ

2021-03-19 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-21875: -- Summary: GSRKinesisPubsubClient is not compiling in IntelliJ Key: FLINK-21875 URL: https://issues.apache.org/jira/browse/FLINK-21875 Project: Flink Issue

[jira] [Created] (FLINK-21874) Check for out-dated slot allocation confirmations is insufficient

2021-03-19 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21874: Summary: Check for out-dated slot allocation confirmations is insufficient Key: FLINK-21874 URL: https://issues.apache.org/jira/browse/FLINK-21874 Project: Fl

[jira] [Created] (FLINK-21873) CoordinatedSourceRescaleITCase.testUpscaling fails on AZP

2021-03-19 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-21873: - Summary: CoordinatedSourceRescaleITCase.testUpscaling fails on AZP Key: FLINK-21873 URL: https://issues.apache.org/jira/browse/FLINK-21873 Project: Flink I

Re: [VOTE] Move Flink ML pipeline API and library code to a separate repository named flink-ml

2021-03-19 Thread Till Rohrmann
+1 Cheers, Till On Fri, Mar 19, 2021 at 9:02 AM Becket Qin wrote: > +1. Thanks for driving the effort, Dong. > > Jiangjie (Becket) Qin > > On Fri, Mar 19, 2021 at 10:07 AM Dong Lin wrote: > > > Hi all, > > > > I would like to start the vote for moving Flink ML pipeline API and > library > > co

Re: [DISCUSS] Split PyFlink packages into two packages: apache-flink and apache-flink-libraries

2021-03-19 Thread Till Rohrmann
I think that we should try to reduce the size of the packages by either splitting them or by having another means to retrieve the Java binaries. Cheers, Till On Fri, Mar 19, 2021 at 2:58 AM Xingbo Huang wrote: > Hi Till, > > The package size of tensorflow[1] is also very big(about 300MB+). Howe

[jira] [Created] (FLINK-21872) Create a utility to create DataStream API's DataType and Schema

2021-03-19 Thread Timo Walther (Jira)
Timo Walther created FLINK-21872: Summary: Create a utility to create DataStream API's DataType and Schema Key: FLINK-21872 URL: https://issues.apache.org/jira/browse/FLINK-21872 Project: Flink

[jira] [Created] (FLINK-21871) Support watermark for Hive and Filesystem streaming source

2021-03-19 Thread Jark Wu (Jira)
Jark Wu created FLINK-21871: --- Summary: Support watermark for Hive and Filesystem streaming source Key: FLINK-21871 URL: https://issues.apache.org/jira/browse/FLINK-21871 Project: Flink Issue Type:

[jira] [Created] (FLINK-21870) RelDataType of TableFunction different in local and CI

2021-03-19 Thread Wenlong Lyu (Jira)
Wenlong Lyu created FLINK-21870: --- Summary: RelDataType of TableFunction different in local and CI Key: FLINK-21870 URL: https://issues.apache.org/jira/browse/FLINK-21870 Project: Flink Issue Ty

[jira] [Created] (FLINK-21869) Support StreamExecTemporalSort json serialization/deserialization

2021-03-19 Thread godfrey he (Jira)
godfrey he created FLINK-21869: -- Summary: Support StreamExecTemporalSort json serialization/deserialization Key: FLINK-21869 URL: https://issues.apache.org/jira/browse/FLINK-21869 Project: Flink

[jira] [Created] (FLINK-21868) Support StreamExecLookupJoin json serialization/deserialization

2021-03-19 Thread Terry Wang (Jira)
Terry Wang created FLINK-21868: -- Summary: Support StreamExecLookupJoin json serialization/deserialization Key: FLINK-21868 URL: https://issues.apache.org/jira/browse/FLINK-21868 Project: Flink

[jira] [Created] (FLINK-21867) Extend UI to expose also concurrent task failures besides the root cause

2021-03-19 Thread Matthias (Jira)
Matthias created FLINK-21867: Summary: Extend UI to expose also concurrent task failures besides the root cause Key: FLINK-21867 URL: https://issues.apache.org/jira/browse/FLINK-21867 Project: Flink

Re: [VOTE] Move Flink ML pipeline API and library code to a separate repository named flink-ml

2021-03-19 Thread Becket Qin
+1. Thanks for driving the effort, Dong. Jiangjie (Becket) Qin On Fri, Mar 19, 2021 at 10:07 AM Dong Lin wrote: > Hi all, > > I would like to start the vote for moving Flink ML pipeline API and library > code to a separate repository named flink-ml. > > The main motivation is to allow us to rem

[jira] [Created] (FLINK-21866) JMXJobManagerMetricTest crashes on azure

2021-03-19 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-21866: Summary: JMXJobManagerMetricTest crashes on azure Key: FLINK-21866 URL: https://issues.apache.org/jira/browse/FLINK-21866 Project: Flink Issue Type: