[jira] [Created] (FLINK-27130) unable to read custom System properties in job class

2022-04-07 Thread Adrian Zhong (Jira)
Adrian Zhong created FLINK-27130: Summary: unable to read custom System properties in job class Key: FLINK-27130 URL: https://issues.apache.org/jira/browse/FLINK-27130 Project: Flink Issue

Re: Re: Re: Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-04-07 Thread 刘大龙
Hi, Martijn Do you have any question about this FLIP? looking forward to your more feedback. Best, Ron > -原始邮件- > 发件人: "刘大龙" > 发送时间: 2022-03-29 19:33:58 (星期二) > 收件人: dev@flink.apache.org > 抄送: > 主题: Re: Re: Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL > > > > > >

[jira] [Created] (FLINK-27129) Hardcoded namespace in FlinkDeployment manifests may fail to deploy

2022-04-07 Thread Ted Chang (Jira)
Ted Chang created FLINK-27129: - Summary: Hardcoded namespace in FlinkDeployment manifests may fail to deploy Key: FLINK-27129 URL: https://issues.apache.org/jira/browse/FLINK-27129 Project: Flink

[jira] [Created] (FLINK-27128) Broadcast stream Iteration closeWith failed starting version 1.12.2

2022-04-07 Thread Jeff Hu (Jira)
Jeff Hu created FLINK-27128: --- Summary: Broadcast stream Iteration closeWith failed starting version 1.12.2 Key: FLINK-27128 URL: https://issues.apache.org/jira/browse/FLINK-27128 Project: Flink

[jira] [Created] (FLINK-27127) Local recovery on task manager process restart

2022-04-07 Thread Abdullah alkhawatrah (Jira)
Abdullah alkhawatrah created FLINK-27127: Summary: Local recovery on task manager process restart Key: FLINK-27127 URL: https://issues.apache.org/jira/browse/FLINK-27127 Project: Flink

[jira] [Created] (FLINK-27126) Respect the state cache size configurations in Python DataStream API operators

2022-04-07 Thread Dian Fu (Jira)
Dian Fu created FLINK-27126: --- Summary: Respect the state cache size configurations in Python DataStream API operators Key: FLINK-27126 URL: https://issues.apache.org/jira/browse/FLINK-27126 Project: Flink

[jira] [Created] (FLINK-27125) Tests leak executor services

2022-04-07 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27125: Summary: Tests leak executor services Key: FLINK-27125 URL: https://issues.apache.org/jira/browse/FLINK-27125 Project: Flink Issue Type: Technical

[jira] [Created] (FLINK-27124) Flink Kubernetes operator prints starting logs with wrong version

2022-04-07 Thread Yang Wang (Jira)
Yang Wang created FLINK-27124: - Summary: Flink Kubernetes operator prints starting logs with wrong version Key: FLINK-27124 URL: https://issues.apache.org/jira/browse/FLINK-27124 Project: Flink

[jira] [Created] (FLINK-27123) Introduce filter predicate for 'IN' and 'LIKE'

2022-04-07 Thread Jane Chan (Jira)
Jane Chan created FLINK-27123: - Summary: Introduce filter predicate for 'IN' and 'LIKE' Key: FLINK-27123 URL: https://issues.apache.org/jira/browse/FLINK-27123 Project: Flink Issue Type:

[jira] [Created] (FLINK-27122) Remove FutureUtils#retryWithDelay variants without RetryStrategy

2022-04-07 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27122: Summary: Remove FutureUtils#retryWithDelay variants without RetryStrategy Key: FLINK-27122 URL: https://issues.apache.org/jira/browse/FLINK-27122 Project:

[jira] [Created] (FLINK-27121) Translate "Configuration#overview" paragraph and the code example in "Application Development > Table API & SQL" to Chinese

2022-04-07 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-27121: --- Summary: Translate "Configuration#overview" paragraph and the code example in "Application Development > Table API & SQL" to Chinese Key: FLINK-27121 URL:

Performance Engineering Track CFP for ApacheCon NA New Orleans

2022-04-07 Thread sharanf
Hi All I hope that you have already heard that ApacheCon NA is back as a live event in New Orleans later this year. You can find out more details here: https://apachecon.com/acna2022/ For the first time ever - we will be running a Performance Engineering track. So what is Performance

[jira] [Created] (FLINK-27120) Translate "configuration" page of "Application Development > Project Configuration > Overview > Gradle (tab)" to Chinese

2022-04-07 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-27120: --- Summary: Translate "configuration" page of "Application Development > Project Configuration > Overview > Gradle (tab)" to Chinese Key: FLINK-27120 URL:

[jira] [Created] (FLINK-27119) Cleanup JobMasters

2022-04-07 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27119: Summary: Cleanup JobMasters Key: FLINK-27119 URL: https://issues.apache.org/jira/browse/FLINK-27119 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-27118) Flink on Yarned failed with the default flink-conf

2022-04-07 Thread Yun Gao (Jira)
Yun Gao created FLINK-27118: --- Summary: Flink on Yarned failed with the default flink-conf Key: FLINK-27118 URL: https://issues.apache.org/jira/browse/FLINK-27118 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27117) FLIP-217: Support watermark alignment of source splits

2022-04-07 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-27117: -- Summary: FLIP-217: Support watermark alignment of source splits Key: FLINK-27117 URL: https://issues.apache.org/jira/browse/FLINK-27117 Project: Flink

[jira] [Created] (FLINK-27116) Supports Hive table partitioned by decimal

2022-04-07 Thread luoyuxia (Jira)
luoyuxia created FLINK-27116: Summary: Supports Hive table partitioned by decimal Key: FLINK-27116 URL: https://issues.apache.org/jira/browse/FLINK-27116 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

2022-04-07 Thread zhiyuan (Jira)
zhiyuan created FLINK-27115: --- Summary: Error while executing BLOB connection. java.io.IOException: Unknown operation 80 Key: FLINK-27115 URL: https://issues.apache.org/jira/browse/FLINK-27115 Project:

[jira] [Created] (FLINK-27114) On JM restart, the information about the initial checkpoints can be lost

2022-04-07 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-27114: - Summary: On JM restart, the information about the initial checkpoints can be lost Key: FLINK-27114 URL: https://issues.apache.org/jira/browse/FLINK-27114

[jira] [Created] (FLINK-27113) Flink Sql Client CREATE CATALOG 'type'='jdbc', 'base-url' = 'jdbc:mysql://ip:port', ERROR MySQLDialect is not supported

2022-04-07 Thread haojiawei (Jira)
haojiawei created FLINK-27113: - Summary: Flink Sql Client CREATE CATALOG 'type'='jdbc', 'base-url' = 'jdbc:mysql://ip:port', ERROR MySQLDialect is not supported Key: FLINK-27113 URL:

[jira] [Created] (FLINK-27112) Optimize the term usage on the job overview WebUI

2022-04-07 Thread Jing Ge (Jira)
Jing Ge created FLINK-27112: --- Summary: Optimize the term usage on the job overview WebUI Key: FLINK-27112 URL: https://issues.apache.org/jira/browse/FLINK-27112 Project: Flink Issue Type:

[jira] [Created] (FLINK-27111) Update docs regarding EnvironmentSettings / TableConfig

2022-04-07 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-27111: --- Summary: Update docs regarding EnvironmentSettings / TableConfig Key: FLINK-27111 URL: https://issues.apache.org/jira/browse/FLINK-27111 Project: Flink

[jira] [Created] (FLINK-27110) using TIMESTAMP_LTZ cause Flink web ui watermark display problem

2022-04-07 Thread tanjialiang (Jira)
tanjialiang created FLINK-27110: --- Summary: using TIMESTAMP_LTZ cause Flink web ui watermark display problem Key: FLINK-27110 URL: https://issues.apache.org/jira/browse/FLINK-27110 Project: Flink

[jira] [Created] (FLINK-27109) The naming pattern of ClusterRole in Flink K8s operator should consider namespace

2022-04-07 Thread Biao Geng (Jira)
Biao Geng created FLINK-27109: - Summary: The naming pattern of ClusterRole in Flink K8s operator should consider namespace Key: FLINK-27109 URL: https://issues.apache.org/jira/browse/FLINK-27109 Project:

[jira] [Created] (FLINK-27108) State cache clean up doesn't work as expected

2022-04-07 Thread Dian Fu (Jira)
Dian Fu created FLINK-27108: --- Summary: State cache clean up doesn't work as expected Key: FLINK-27108 URL: https://issues.apache.org/jira/browse/FLINK-27108 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27107) Typo in Task

2022-04-07 Thread dizhou cao (Jira)
dizhou cao created FLINK-27107: -- Summary: Typo in Task Key: FLINK-27107 URL: https://issues.apache.org/jira/browse/FLINK-27107 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-27106) Flink command line support submit one job with multi jars

2022-04-07 Thread FanJia (Jira)
FanJia created FLINK-27106: -- Summary: Flink command line support submit one job with multi jars Key: FLINK-27106 URL: https://issues.apache.org/jira/browse/FLINK-27106 Project: Flink Issue Type: