[jira] [Created] (FLINK-21855) Document Metrics Limitations

2021-03-18 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-21855: Summary: Document Metrics Limitations Key: FLINK-21855 URL: https://issues.apache.org/jira/browse/FLINK-21855 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21856) Fix the bug of using Python UDF from sub-query as input param of Python UDTF

2021-03-18 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-21856: Summary: Fix the bug of using Python UDF from sub-query as input param of Python UDTF Key: FLINK-21856 URL: https://issues.apache.org/jira/browse/FLINK-21856 Project:

[jira] [Created] (FLINK-21857) StackOverflow for large parallelism jobs when processing EndOfChannelStateEvent

2021-03-18 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-21857: --- Summary: StackOverflow for large parallelism jobs when processing EndOfChannelStateEvent Key: FLINK-21857 URL: https://issues.apache.org/jira/browse/FLINK-21857 Project

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

2021-03-18 Thread Till Rohrmann
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 the checkpoint under s3a://{bucket name}/dev/checkpoints/_entropy_/{job_id}/chk-2230. A checkpoint consists of these data files and a metadata file

[jira] [Created] (FLINK-21858) TaskMetricGroup taskName is too long, especially in sql tasks.

2021-03-18 Thread Andrew.D.lin (Jira)
Andrew.D.lin created FLINK-21858: Summary: TaskMetricGroup taskName is too long, especially in sql tasks. Key: FLINK-21858 URL: https://issues.apache.org/jira/browse/FLINK-21858 Project: Flink

[jira] [Created] (FLINK-21859) Batch job fails due to "Could not mark slot 61a637e3977c58a0e6b73533c419297d active"

2021-03-18 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-21859: --- Summary: Batch job fails due to "Could not mark slot 61a637e3977c58a0e6b73533c419297d active" Key: FLINK-21859 URL: https://issues.apache.org/jira/browse/FLINK-21859 Pr

[jira] [Created] (FLINK-21860) Support StreamExecExpand json serialization/deserialization

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

[jira] [Created] (FLINK-21861) Support StreamExecIncrementalGroupAggregate json serialization/deserialization

2021-03-18 Thread godfrey he (Jira)
godfrey he created FLINK-21861: -- Summary: Support StreamExecIncrementalGroupAggregate json serialization/deserialization Key: FLINK-21861 URL: https://issues.apache.org/jira/browse/FLINK-21861 Project: F

[jira] [Created] (FLINK-21862) Add a Java SDK showcase tutorial to StateFun playground

2021-03-18 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-21862: --- Summary: Add a Java SDK showcase tutorial to StateFun playground Key: FLINK-21862 URL: https://issues.apache.org/jira/browse/FLINK-21862 Project: Flink

[jira] [Created] (FLINK-21863) SortPartition should allow chaining of KeySelectors to support different sorting orders for the fields

2021-03-18 Thread Etienne Chauchot (Jira)
Etienne Chauchot created FLINK-21863: Summary: SortPartition should allow chaining of KeySelectors to support different sorting orders for the fields Key: FLINK-21863 URL: https://issues.apache.org/jira/browse

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

2021-03-18 Thread Xingbo Huang
Hi Till, The package size of tensorflow[1] is also very big(about 300MB+). However, it does not try to solve the problem, but expands the space limit in PyPI frequently whenever the project space is full. We could also choose this option. According to our current release frequency, we probably nee

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

2021-03-18 Thread Dong Lin
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 remove SQL planner in Flink 1.14 while still allowing ML pipeline API/library development in the coming year, The vote will last

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

2021-03-18 Thread Dong Lin
Thank you Becket and Till for your comments! Since the discussion has been open for about 1 week and there is no concern with this proposal, I have started the voting thread. Please help vote when you get time. Cheers, Dong On Mon, Mar 15, 2021 at 6:00 PM Till Rohrmann wrote: > +1 for moving F

[jira] [Created] (FLINK-21864) Support StreamExecTemporalJoin json serialization/deserialization

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

[jira] [Created] (FLINK-21865) Add a Docker Compose greeter example to StateFun playgrounds

2021-03-18 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-21865: --- Summary: Add a Docker Compose greeter example to StateFun playgrounds Key: FLINK-21865 URL: https://issues.apache.org/jira/browse/FLINK-21865 Project: F