[jira] [Created] (FLINK-28825) [1] Support specify K8S pod scheduler

bo zhao created FLINK-28825: --- Summary: [1] Support specify K8S pod scheduler Key: FLINK-28825 URL: https://issues.apache.org/jira/browse/FLINK-28825 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-28826) Avoid notifying too frequently when recycling buffers for BatchShuffleReadBufferPool

Yuxin Tan created FLINK-28826: - Summary: Avoid notifying too frequently when recycling buffers for BatchShuffleReadBufferPool Key: FLINK-28826 URL: https://issues.apache.org/jira/browse/FLINK-28826 Projec

[jira] [Created] (FLINK-28827) Complete DataType support in DataStream API for PyFlink

Juntao Hu created FLINK-28827: - Summary: Complete DataType support in DataStream API for PyFlink Key: FLINK-28827 URL: https://issues.apache.org/jira/browse/FLINK-28827 Project: Flink Issue Type:

[jira] [Created] (FLINK-28828) Sorting all unfinished readers in batches at one time in SortMergeResultPartitionReadScheduler

Yuxin Tan created FLINK-28828: - Summary: Sorting all unfinished readers in batches at one time in SortMergeResultPartitionReadScheduler Key: FLINK-28828 URL: https://issues.apache.org/jira/browse/FLINK-28828

回复: [GitHub] [flink] deadwind4 commented on pull request #18469: [FLINK-25485][connector/jdbc] Append default JDBC URL option of batch writing in MySQL.

从 Windows 版邮件发送 发件人: GitBox 发送时间: 2022年8月4日 9:44 收件人: iss...@flink.apache.org 主题: [GitHub] [flink] deadwind4 commented on pull request #18469: [FLINK-25485][connector/jdbc] Append default JDBC URL option of batch writing in MySQL. deadwind4 commented on PR #18469: URL: https://github.com/apa

回复: [GitHub] [flink] hehuiyuan commented on pull request #20425: [FLINK-28750][Hive]Add field comment parse for hive ddl

从 Windows 版邮件发送 发件人: GitBox 发送时间: 2022年8月4日 13:04 收件人: iss...@flink.apache.org 主题: [GitHub] [flink] hehuiyuan commented on pull request #20425: [FLINK-28750][Hive]Add field comment parse for hive ddl hehuiyuan commented on PR #20425: URL: https://github.com/apache/flink/pull/20425#issuecommen

回复: [jira] [Updated] (FLINK-28796) Add Statement Completement API forsql gateway rest endpoint

从 Windows 版邮件发送 发件人: Wencong Liu (Jira) 发送时间: 2022年8月4日 13:47 收件人: iss...@flink.apache.org 主题: [jira] [Updated] (FLINK-28796) Add Statement Completement API forsql gateway rest endpoint [ https://issues.apache.org/jira/browse/FLINK-28796?page=com.atlassian.jira.plugin.system.issuetabpan

[jira] [Created] (FLINK-28829) [2] Need the ability of preparing K8S resource before JobManager creation

bo zhao created FLINK-28829: --- Summary: [2] Need the ability of preparing K8S resource before JobManager creation Key: FLINK-28829 URL: https://issues.apache.org/jira/browse/FLINK-28829 Project: Flink

[jira] [Created] (FLINK-28830) new stack udtf doesn't support atomic type

jackylau created FLINK-28830: Summary: new stack udtf doesn't support atomic type Key: FLINK-28830 URL: https://issues.apache.org/jira/browse/FLINK-28830 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28831) [3] Support pluginable decorators mechanism

bo zhao created FLINK-28831: --- Summary: [3] Support pluginable decorators mechanism Key: FLINK-28831 URL: https://issues.apache.org/jira/browse/FLINK-28831 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28832) [4] Upgrade Fabric8 to the latest version

bo zhao created FLINK-28832: --- Summary: [4] Upgrade Fabric8 to the latest version Key: FLINK-28832 URL: https://issues.apache.org/jira/browse/FLINK-28832 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28833) [5] Support customized scheduler options as a hashmap for each scheduler.

bo zhao created FLINK-28833: --- Summary: [5] Support customized scheduler options as a hashmap for each scheduler. Key: FLINK-28833 URL: https://issues.apache.org/jira/browse/FLINK-28833 Project: Flink

[jira] [Created] (FLINK-28834) Add TemporalJoin example and ITCase

Jun Qin created FLINK-28834: --- Summary: Add TemporalJoin example and ITCase Key: FLINK-28834 URL: https://issues.apache.org/jira/browse/FLINK-28834 Project: Flink Issue Type: Improvement

Re: Reworking use of TableEnvironment due to API change in 1.15

Hi, one correction on the above, both cases when I mentioned tableEnv.executeAsync I was referring to StreamExecutionEnvironment's executeAsync, sorry for the typo. Any thoughts on the issue? Thanks Tamas On Thu, Aug 4, 2022 at 3:44 PM Tamas Kiss wrote: > Hi Experts, > > We are trying to upgr

[jira] [Created] (FLINK-28835) Savepoint and checkpoint capabilities and limitations table is incorrect

Piotr Nowojski created FLINK-28835: -- Summary: Savepoint and checkpoint capabilities and limitations table is incorrect Key: FLINK-28835 URL: https://issues.apache.org/jira/browse/FLINK-28835 Project:

[jira] [Created] (FLINK-28837) Translate "Hybrid Source" page of "DataStream Connectors" into Chinese

JasonLee created FLINK-28837: Summary: Translate "Hybrid Source" page of "DataStream Connectors" into Chinese Key: FLINK-28837 URL: https://issues.apache.org/jira/browse/FLINK-28837 Project: Flink

[jira] [Created] (FLINK-28836) Support broadcast in Thread Mode

Huang Xingbo created FLINK-28836: Summary: Support broadcast in Thread Mode Key: FLINK-28836 URL: https://issues.apache.org/jira/browse/FLINK-28836 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28838) Avoid to notify the elementQueue consumer when the fetch result is empty

Aitozi created FLINK-28838: -- Summary: Avoid to notify the elementQueue consumer when the fetch result is empty Key: FLINK-28838 URL: https://issues.apache.org/jira/browse/FLINK-28838 Project: Flink

flink-on-yarn Out Of Memory exception

hello, My task has an "Out Of Memory" exception error after running for 3 hours. The version of my cluster is 1.14.2, the memory allocation of TaskManager is 2g, and the attachment is the log file of jvm's heap memory analysis, which involves the flink framework. So asking for help, thanks! 从

Re:flink-on-yarn Out Of Memory exception

hello,supplement Task Manager's Log     -- Original -- From:  "张洋"

[jira] [Created] (FLINK-28839) Incorrect english sentence in docs/content/docs/dev/dataset/iterations.md

Bisvarup Mukherjee created FLINK-28839: -- Summary: Incorrect english sentence in docs/content/docs/dev/dataset/iterations.md Key: FLINK-28839 URL: https://issues.apache.org/jira/browse/FLINK-28839

[jira] [Created] (FLINK-28840) Introduce Roadmap document of Flink Table Store

Nicholas Jiang created FLINK-28840: -- Summary: Introduce Roadmap document of Flink Table Store Key: FLINK-28840 URL: https://issues.apache.org/jira/browse/FLINK-28840 Project: Flink Issue Typ

[jira] [Created] (FLINK-28841) Document dynamic property support for startup scripts

Chesnay Schepler created FLINK-28841: Summary: Document dynamic property support for startup scripts Key: FLINK-28841 URL: https://issues.apache.org/jira/browse/FLINK-28841 Project: Flink

[jira] [Created] (FLINK-28842) Add client.id.prefix for the KafkaSink

Yaroslav Tkachenko created FLINK-28842: -- Summary: Add client.id.prefix for the KafkaSink Key: FLINK-28842 URL: https://issues.apache.org/jira/browse/FLINK-28842 Project: Flink Issue Type

[jira] [Created] (FLINK-28843) Failed to restore from changelog checkpoint in claim mode

Lihe Ma created FLINK-28843: --- Summary: Failed to restore from changelog checkpoint in claim mode Key: FLINK-28843 URL: https://issues.apache.org/jira/browse/FLINK-28843 Project: Flink Issue Type: B