[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:

[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

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

[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

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

[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:

[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-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:

[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

[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

[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

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

[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

[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

[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-21854) WebUI show incorrect value

2021-03-18 Thread junbiao chen (Jira)
junbiao chen created FLINK-21854: Summary: WebUI show incorrect value Key: FLINK-21854 URL: https://issues.apache.org/jira/browse/FLINK-21854 Project: Flink Issue Type: Bug