[jira] [Created] (FLINK-28986) UNNEST function with nested fails to generate plan

Jane Chan created FLINK-28986: - Summary: UNNEST function with nested fails to generate plan Key: FLINK-28986 URL: https://issues.apache.org/jira/browse/FLINK-28986 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api

This is a good suggestion, we can start this work after we finish the discussion and vote -- Best ConradJam 于2022年8月15日周一 21:01写道： > I've created a new ticket [FLINK-28973] Extending /jars/:jarid/plan API to > support setting Flink configs - ASF JIRA (apache.org)< > https://issues.apache.org/

[jira] [Created] (FLINK-28985) support create table like view

waywtdcc created FLINK-28985: Summary: support create table like view Key: FLINK-28985 URL: https://issues.apache.org/jira/browse/FLINK-28985 Project: Flink Issue Type: Improvement Comp

[jira] [Created] (FLINK-28984) FsCheckpointStateOutputStream is not being released normally

ChangjiGuo created FLINK-28984: -- Summary: FsCheckpointStateOutputStream is not being released normally Key: FLINK-28984 URL: https://issues.apache.org/jira/browse/FLINK-28984 Project: Flink Iss

[jira] [Created] (FLINK-28983) using serviceaccount in FlinkDeployment not works when sink to aws s3

Lichuan Shang created FLINK-28983: - Summary: using serviceaccount in FlinkDeployment not works when sink to aws s3 Key: FLINK-28983 URL: https://issues.apache.org/jira/browse/FLINK-28983 Project: Flin

[jira] [Created] (FLINK-28982) Start TaskInterrupter when task switch from DEPLOYING to CANCELING

LI Mingkun created FLINK-28982: -- Summary: Start TaskInterrupter when task switch from DEPLOYING to CANCELING Key: FLINK-28982 URL: https://issues.apache.org/jira/browse/FLINK-28982 Project: Flink

[jira] [Created] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

Zhu Zhu created FLINK-28981: --- Summary: Release Testing: Verify FLIP-245 sources speculative execution Key: FLINK-28981 URL: https://issues.apache.org/jira/browse/FLINK-28981 Project: Flink Issue T

[jira] [Created] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

Zhu Zhu created FLINK-28980: --- Summary: Release Testing: Verify FLIP-168 speculative execution Key: FLINK-28980 URL: https://issues.apache.org/jira/browse/FLINK-28980 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-28979) Add another owner into the JM deployment's owner references

Xin Hao created FLINK-28979: --- Summary: Add another owner into the JM deployment's owner references Key: FLINK-28979 URL: https://issues.apache.org/jira/browse/FLINK-28979 Project: Flink Issue Type

[jira] [Created] (FLINK-28978) [aws][connectors] Kinesis connector doesn't work for new AWS regions

Hong Liang Teoh created FLINK-28978: --- Summary: [aws][connectors] Kinesis connector doesn't work for new AWS regions Key: FLINK-28978 URL: https://issues.apache.org/jira/browse/FLINK-28978 Project: F

[jira] [Created] (FLINK-28977) NullPointerException in HybridSourceSplitEnumerator.close

Michael created FLINK-28977: --- Summary: NullPointerException in HybridSourceSplitEnumerator.close Key: FLINK-28977 URL: https://issues.apache.org/jira/browse/FLINK-28977 Project: Flink Issue Type: B

[jira] [Created] (FLINK-28976) Changelog 1st materialization delayed unneccesarily

Roman Khachatryan created FLINK-28976: - Summary: Changelog 1st materialization delayed unneccesarily Key: FLINK-28976 URL: https://issues.apache.org/jira/browse/FLINK-28976 Project: Flink

[jira] [Created] (FLINK-28975) withIdleness marks all streams from FLIP-27 sources as idle

David Anderson created FLINK-28975: -- Summary: withIdleness marks all streams from FLIP-27 sources as idle Key: FLINK-28975 URL: https://issues.apache.org/jira/browse/FLINK-28975 Project: Flink

[jira] [Created] (FLINK-28974) Add doc for the API and Option of sql gateway rest endpoint

Wencong Liu created FLINK-28974: --- Summary: Add doc for the API and Option of sql gateway rest endpoint Key: FLINK-28974 URL: https://issues.apache.org/jira/browse/FLINK-28974 Project: Flink Is

Re:[DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api

+1 Thanks for driving this,It makes the REST API that runs the job more powerful and complete Best JasonLee Replied Message | From | zhengyu chen | | Date | 08/15/2022 18:06 | | To | | | Subject | [DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api | Hi all, We w

Re: [DISCUSS] Releasing Flink 1.15.2

Thanks Danny. I will merge FLINK-28861 in couple of minutes to master. I will open a PR for 1.15 shortly. This issue is pretty tricky, we should add a warning to 1.15.0 and 1.15.1 releases as it won't be easy to perform stateful upgrades in between 1.15.x patch versions for pipelines that use

Re: [DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api

I've created a new ticket [FLINK-28973] Extending /jars/:jarid/plan API to support setting Flink configs - ASF JIRA (apache.org). for the job plan API. Maybe we can create a new umbrella ticket for FLIP-256 and put FLINK-27060 & FLINK-28973 as

[jira] [Created] (FLINK-28973) Extending /jars/:jarid/plan API to support setting Flink configs

Zhanghao Chen created FLINK-28973: - Summary: Extending /jars/:jarid/plan API to support setting Flink configs Key: FLINK-28973 URL: https://issues.apache.org/jira/browse/FLINK-28973 Project: Flink

Re: [DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api

+1. Thanks for the effort. I think we should also extend the jarid-plan API [1] in a similar way, as some configurations might affect the jog graph as well. [1] https://nightlies.apache.org/flink/flink-docs-master/docs/ops/rest_api/#jars-jarid-plan Best, Zhanghao Chen _

Re: [DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api

+1, I think this is a very useful proposal, especially for session mode. And for simplicity, maybe we can treat the job-level configurations and cluster-level configurations identically, as your mentioned, the cluster-level configurations will be ignored. Best, Yanfei zhengyu chen 于2022年8月15日周一 1

[jira] [Created] (FLINK-28972) Add methods of StartCursor and StopCursor to align the Java

Luning Wang created FLINK-28972: --- Summary: Add methods of StartCursor and StopCursor to align the Java Key: FLINK-28972 URL: https://issues.apache.org/jira/browse/FLINK-28972 Project: Flink Is

[DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api

Hi all, We would like to start a discussion thread on FLIP-256 Support Job Dynamic Parameter With Flink Rest Api [1] After the user submits the jar package, running a job through restap

[jira] [Created] (FLINK-28971) Adds user documentation for the new LOOKUP hint

lincoln lee created FLINK-28971: --- Summary: Adds user documentation for the new LOOKUP hint Key: FLINK-28971 URL: https://issues.apache.org/jira/browse/FLINK-28971 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-28970) Add the doc how to use Cython to optimize Python function

Huang Xingbo created FLINK-28970: Summary: Add the doc how to use Cython to optimize Python function Key: FLINK-28970 URL: https://issues.apache.org/jira/browse/FLINK-28970 Project: Flink Iss

[jira] [Created] (FLINK-28969) Release Testing: Verify FLIP-229 Join Hints for Flink SQL Batch

xuyang created FLINK-28969: -- Summary: Release Testing: Verify FLIP-229 Join Hints for Flink SQL Batch Key: FLINK-28969 URL: https://issues.apache.org/jira/browse/FLINK-28969 Project: Flink Issue Ty

Re: [DISCUSS] Releasing Flink 1.15.2

Thanks all. I can see the final issue has an approved PR now, awaiting merge, thanks Timo and Chesnay. In the meantime I will get setup ready to start the release process. Thanks, On Fri, Aug 12, 2022 at 10:47 PM Jing Ge wrote: > Thanks Danny! Strong +1 and looking forward to the 1.15.2 asap.

[jira] [Created] (FLINK-28968) Release Testing: Verify FLIP-234 LOOKUP Hint

lincoln lee created FLINK-28968: --- Summary: Release Testing: Verify FLIP-234 LOOKUP Hint Key: FLINK-28968 URL: https://issues.apache.org/jira/browse/FLINK-28968 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-28967) Fix Hive multi-version support for Table Store

Caizhi Weng created FLINK-28967: --- Summary: Fix Hive multi-version support for Table Store Key: FLINK-28967 URL: https://issues.apache.org/jira/browse/FLINK-28967 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28966) Check backward compatibility against both 1.1.0 and 1.0.0 (all released versions)

Gyula Fora created FLINK-28966: -- Summary: Check backward compatibility against both 1.1.0 and 1.0.0 (all released versions) Key: FLINK-28966 URL: https://issues.apache.org/jira/browse/FLINK-28966 Project