[jira] [Created] (FLINK-27576) Flink will request new pod when jm pod is delete, but will remove when TaskExecutor exceeded the idle timeout

2022-05-11 Thread zhisheng (Jira)
zhisheng created FLINK-27576: Summary: Flink will request new pod when jm pod is delete, but will remove when TaskExecutor exceeded the idle timeout Key: FLINK-27576 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-26601) Flink HBase HBaseRowDataAsyncLookupFunction threadPool not close cause container has so many 'hbase-async-lookup-worker' thread

2022-03-10 Thread zhisheng (Jira)
zhisheng created FLINK-26601: Summary: Flink HBase HBaseRowDataAsyncLookupFunction threadPool not close cause container has so many 'hbase-async-lookup-worker' thread Key: FLINK-26601 URL: https://issues.

[jira] [Created] (FLINK-26248) flink job not recover from latest checkpoint on native k8s

2022-02-18 Thread zhisheng (Jira)
zhisheng created FLINK-26248: Summary: flink job not recover from latest checkpoint on native k8s Key: FLINK-26248 URL: https://issues.apache.org/jira/browse/FLINK-26248 Project: Flink Issue

[jira] [Created] (FLINK-24528) Flink HBase Asyc Lookup throw NPE if rowkey is null

2021-10-12 Thread zhisheng (Jira)
zhisheng created FLINK-24528: Summary: Flink HBase Asyc Lookup throw NPE if rowkey is null Key: FLINK-24528 URL: https://issues.apache.org/jira/browse/FLINK-24528 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21493) Flink Command Line Interface Document can add command usage

2021-02-24 Thread zhisheng (Jira)
zhisheng created FLINK-21493: Summary: Flink Command Line Interface Document can add command usage Key: FLINK-21493 URL: https://issues.apache.org/jira/browse/FLINK-21493 Project: Flink Issue

[jira] [Created] (FLINK-21146) 【SQL】Flink SQL Client not support specify the queue to submit the job

2021-01-25 Thread zhisheng (Jira)
zhisheng created FLINK-21146: Summary: 【SQL】Flink SQL Client not support specify the queue to submit the job Key: FLINK-21146 URL: https://issues.apache.org/jira/browse/FLINK-21146 Project: Flink

[jira] [Created] (FLINK-21143) 【runtime】flink job use the lib jars instead of the `yarn.provided.lib.dirs` config jars

2021-01-25 Thread zhisheng (Jira)
zhisheng created FLINK-21143: Summary: 【runtime】flink job use the lib jars instead of the `yarn.provided.lib.dirs` config jars Key: FLINK-21143 URL: https://issues.apache.org/jira/browse/FLINK-21143

?????? [DISCUSS] Correct time-related function behavior in Flink SQL

2021-01-20 Thread zhisheng
results will naturally be incorrect.  The user needs to deal with the time zone manually in order to solve the problem.  If Flink itself can solve these time zone issues, then I think it will be user-friendly. Thank you Best!  zhisheng

[jira] [Created] (FLINK-20481) java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer

2020-12-03 Thread zhisheng (Jira)
zhisheng created FLINK-20481: Summary: java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer Key: FLINK-20481 URL: https://issues.apache.org/jira/browse/FLINK-20481 Project

[jira] [Created] (FLINK-20414) 【HBase】

2020-11-29 Thread zhisheng (Jira)
zhisheng created FLINK-20414: Summary: 【HBase】 Key: FLINK-20414 URL: https://issues.apache.org/jira/browse/FLINK-20414 Project: Flink Issue Type: Bug Components: Connectors / HBase

[jira] [Created] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

2020-11-13 Thread zhisheng (Jira)
zhisheng created FLINK-20143: Summary: use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode Key: FLINK-20143 URL: https://issues.apache.org/jira/browse/FLINK-20143 Project: Flink

[jira] [Created] (FLINK-19995) 【Flink SQL Client】Use Flink Kafka Connector has more one exception

2020-11-05 Thread zhisheng (Jira)
zhisheng created FLINK-19995: Summary: 【Flink SQL Client】Use Flink Kafka Connector has more one exception Key: FLINK-19995 URL: https://issues.apache.org/jira/browse/FLINK-19995 Project: Flink

[jira] [Created] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work

2020-11-04 Thread zhisheng (Jira)
zhisheng created FLINK-19973: Summary: 【Flink-Deployment】YARN CLI Parameter doesn't work Key: FLINK-19973 URL: https://issues.apache.org/jira/browse/FLINK-19973 Project: Flink Issue Type

[jira] [Created] (FLINK-17314) 【Flink Kafka Connector】The Config(connector.topic)support list topic

2020-04-21 Thread zhisheng (Jira)
zhisheng created FLINK-17314: Summary: 【Flink Kafka Connector】The Config(connector.topic)support list topic Key: FLINK-17314 URL: https://issues.apache.org/jira/browse/FLINK-17314 Project: Flink

[jira] [Created] (FLINK-17129) 【Flink Kafka Connector】The DDL config(connector.properties.zookeeper.connect) could be optioanal

2020-04-13 Thread zhisheng (Jira)
zhisheng created FLINK-17129: Summary: 【Flink Kafka Connector】The DDL config(connector.properties.zookeeper.connect) could be optioanal Key: FLINK-17129 URL: https://issues.apache.org/jira/browse/FLINK-17129

[jira] [Created] (FLINK-16865) 【Flink Kafka Connector】Restore from Savepoint,if add new Kafka topic,Flink will consume the new topic from earlist,it may cause duplicate data sink

2020-03-30 Thread zhisheng (Jira)
zhisheng created FLINK-16865: Summary: 【Flink Kafka Connector】Restore from Savepoint,if add new Kafka topic,Flink will consume the new topic from earlist,it may cause duplicate data sink Key: FLINK-16865 URL: https

[jira] [Created] (FLINK-16788) ElasticSearch Connector SQL DDL add optional config (eg: enable-auth/username/password)

2020-03-25 Thread zhisheng (Jira)
zhisheng created FLINK-16788: Summary: ElasticSearch Connector SQL DDL add optional config (eg: enable-auth/username/password) Key: FLINK-16788 URL: https://issues.apache.org/jira/browse/FLINK-16788

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

2019-06-25 Thread zhisheng
Congratulations, Jincheng ---Original--- From: "Fan Liya" Date: Tue, Jun 25, 2019 18:23 PM To: "dev"; Subject: Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC Congratulations! Best, Liya Fan On Tue, Jun 25, 2019 at 6:21 PM Shaoxuan Wang wrote: > Congratulations, Jincheng! > > On