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

2022-05-16 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537400#comment-17537400 ] zhisheng commented on FLINK-27576: -- hi [~aitozi] , Have you started a PR? > Flink will

[jira] [Updated] (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)
[ https://issues.apache.org/jira/browse/FLINK-27576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-27576: - Description: flink 1.12.0 enable the ha(zk) and checkpoint, when i use kubectl delete the jm pod, the j

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

[jira] [Commented] (FLINK-26884) Move Elasticsearch connector to external connector repository

2022-03-31 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515674#comment-17515674 ] zhisheng commented on FLINK-26884: -- [~martijnvisser] thanks your quickly reply, I get i

[jira] [Commented] (FLINK-26884) Move Elasticsearch connector to external connector repository

2022-03-30 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514761#comment-17514761 ] zhisheng commented on FLINK-26884: -- I've seen similar discussions in the dev mail befor

[jira] [Commented] (FLINK-26884) Move Elasticsearch connector to external connector repository

2022-03-30 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514758#comment-17514758 ] zhisheng commented on FLINK-26884: -- hi, why move the es connector to external connector

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

2022-03-10 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-26601: - Description: [https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-hbase-2.2/src

[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.apache.org/j

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

2022-02-21 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495933#comment-17495933 ] zhisheng commented on FLINK-26248: -- [~wangyang0918]  thank you very much, i closed this

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

2022-02-21 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng closed FLINK-26248. Resolution: Not A Bug > flink job not recover from latest checkpoint on native k8s > -

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

2022-02-21 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495867#comment-17495867 ] zhisheng commented on FLINK-26248: -- thanks [~wangyang0918] , I have a question to ask y

[jira] [Commented] (FLINK-20219) Rethink the HA related ZNodes/ConfigMap clean up for session cluster

2022-02-21 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495865#comment-17495865 ] zhisheng commented on FLINK-20219: -- thanks [~wangyang0918]  > Rethink the HA related Z

[jira] [Updated] (FLINK-20219) Rethink the HA related ZNodes/ConfigMap clean up for session cluster

2022-02-21 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-20219: - Attachment: image-2022-02-22-10-54-03-439.png > Rethink the HA related ZNodes/ConfigMap clean up for ses

[jira] [Commented] (FLINK-20219) Rethink the HA related ZNodes/ConfigMap clean up for session cluster

2022-02-21 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495831#comment-17495831 ] zhisheng commented on FLINK-20219: -- [~wangyang0918] hello, I found out that it's not ju

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

2022-02-21 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-26248: - Attachment: image-2022-02-22-10-26-53-699.png > flink job not recover from latest checkpoint on native k

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

2022-02-18 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494589#comment-17494589 ] zhisheng commented on FLINK-26248: -- https://issues.apache.org/jira/browse/FLINK-19358

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

2022-02-18 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494573#comment-17494573 ] zhisheng edited comment on FLINK-26248 at 2/18/22, 12:28 PM: -

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

2022-02-18 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494573#comment-17494573 ] zhisheng edited comment on FLINK-26248 at 2/18/22, 12:26 PM: -

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

2022-02-18 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494573#comment-17494573 ] zhisheng edited comment on FLINK-26248 at 2/18/22, 12:25 PM: -

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

2022-02-18 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494573#comment-17494573 ] zhisheng commented on FLINK-26248: -- thanks [~wangyang0918] quickly response, sorry , i

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

2022-02-18 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-26248: - Description: flink version: 1.12.0 ha: zk mode: application mode native k8s   1、if flink job start

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

2022-02-18 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494550#comment-17494550 ] zhisheng commented on FLINK-26248: -- delete the TM pod then the JM log:   {code:java} 2

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

2022-02-18 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494543#comment-17494543 ] zhisheng commented on FLINK-26248: -- start job shell: {code:java} ./bin/flink run-applic

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

[jira] [Commented] (FLINK-25057) Streaming File Sink writing to HDFS

2021-11-26 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449438#comment-17449438 ] zhisheng commented on FLINK-25057: -- it seems like the https://issues.apache.org/jira/br

[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] [Commented] (FLINK-20527) Support side output for late events in Flink SQL

2021-03-21 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305921#comment-17305921 ] zhisheng commented on FLINK-20527: -- + 1 for this feature > Support side output for lat

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

[jira] [Commented] (FLINK-21219) FlinkKafkaConsumer ignores offset overrides for new topics when restoring from savepoint.

2021-02-01 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276292#comment-17276292 ] zhisheng commented on FLINK-21219: -- Duplicated in https://issues.apache.org/jira/browse

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

2021-01-27 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272699#comment-17272699 ] zhisheng commented on FLINK-21143: -- first, i config the `execution.target` in flink-con

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

2021-01-27 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-21143: - Attachment: image-2021-01-27-17-00-38-661.png > 【runtime】flink job use the lib jars instead of the `yarn

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

2021-01-27 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-21143: - Attachment: image-2021-01-27-17-00-01-553.png > 【runtime】flink job use the lib jars instead of the `yarn

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

2021-01-27 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-21143: - Attachment: image-2021-01-27-16-58-43-372.png > 【runtime】flink job use the lib jars instead of the `yarn

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

2021-01-27 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-21143: - Attachment: image-2021-01-27-16-56-47-400.png > 【runtime】flink job use the lib jars instead of the `yarn

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

2021-01-27 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-21143: - Attachment: image-2021-01-27-16-55-06-104.png > 【runtime】flink job use the lib jars instead of the `yarn

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

2021-01-27 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-21143: - Attachment: image-2021-01-27-16-53-11-255.png > 【runtime】flink job use the lib jars instead of the `yarn

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

2021-01-26 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272600#comment-17272600 ] zhisheng commented on FLINK-21143: -- [~fly_in_gis] yes, the  /data/HDATA/yarn/local/file

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

2021-01-26 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-21143: - Attachment: (was: flink-deploy-sql-client.log) > 【runtime】flink job use the lib jars instead of the

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

2021-01-26 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272524#comment-17272524 ] zhisheng commented on FLINK-21143: -- [~fly_in_gis] The job can be submitted successfully

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

2021-01-26 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272522#comment-17272522 ] zhisheng commented on FLINK-21146: -- [~jark] good (y) > 【SQL】Flink SQL Client not suppo

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

2021-01-26 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-21143: - Attachment: flink-deploy-sql-client-.log > 【runtime】flink job use the lib jars instead of the `yarn.prov

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

2021-01-26 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272100#comment-17272100 ] zhisheng commented on FLINK-21143: -- [^flink-deploy-sql-client-.log]   thanks [~xintong

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

2021-01-26 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-21143: - Comment: was deleted (was: [^flink-deploy-sql-client.log] ^thanks [~xintongsong]  [~fly_in_gis]       I

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

2021-01-26 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272083#comment-17272083 ] zhisheng commented on FLINK-21143: -- [^flink-deploy-sql-client.log] ^thanks [~xintongso

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

2021-01-26 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-21143: - Attachment: flink-deploy-sql-client.log > 【runtime】flink job use the lib jars instead of the `yarn.provi

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

2021-01-26 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272066#comment-17272066 ] zhisheng commented on FLINK-21146: -- hi,[~jark]  set a fixed configuration does not seem

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

[jira] [Commented] (FLINK-19944) Support sink parallelism configuration to Hive connector

2020-12-08 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245909#comment-17245909 ] zhisheng commented on FLINK-19944: -- hi [~neighborhood] do you start for this subtask?

[jira] [Commented] (FLINK-19946) Support sink parallelism configuration to Hbase connector

2020-12-04 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243875#comment-17243875 ] zhisheng commented on FLINK-19946: -- [~jark] get it > Support sink parallelism configur

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

2020-12-04 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243866#comment-17243866 ] zhisheng commented on FLINK-20481: -- [~873925...@qq.com] yes, i compile the mster branch

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

2020-12-04 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243866#comment-17243866 ] zhisheng edited comment on FLINK-20481 at 12/4/20, 9:11 AM:

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

2020-12-03 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-20481: - Description: MySQL table sql : {code:java} DROP TABLE IF EXISTS `yarn_app_logs_count`; CREATE TABLE `ya

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

[jira] [Commented] (FLINK-19946) Support sink parallelism configuration to Hbase connector

2020-12-03 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243746#comment-17243746 ] zhisheng commented on FLINK-19946: -- [~ZhuShang] [~jark] hi, i find the HBaseUpsertTable

[jira] [Commented] (FLINK-20473) when get metrics option, its hard to see the full name unless u choosed

2020-12-03 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243673#comment-17243673 ] zhisheng commented on FLINK-20473: -- +1 > when get metrics option, its hard to see the

[jira] [Commented] (FLINK-19943) Support sink parallelism configuration to ElasticSearch connector

2020-12-01 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242126#comment-17242126 ] zhisheng commented on FLINK-19943: -- [~lzljs3620320] hi, this subtask will merge to 1.12

[jira] [Commented] (FLINK-20414) 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist

2020-12-01 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242045#comment-17242045 ] zhisheng commented on FLINK-20414: -- [~jark] yes, i solved it, but the exception is not 

[jira] [Closed] (FLINK-20414) 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist

2020-11-29 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng closed FLINK-20414. Resolution: Fixed > 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist > --

[jira] [Updated] (FLINK-20414) 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist

2020-11-29 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-20414: - Summary: 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist (was: 【HBase】)

[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] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

2020-11-17 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233539#comment-17233539 ] zhisheng commented on FLINK-20143: -- thanks [~fly_in_gis] , it works well now, thanks [~

[jira] [Commented] (FLINK-20109) java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231377#comment-17231377 ] zhisheng commented on FLINK-20109: -- could you please show you sql and ddl ? > java.lan

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231369#comment-17231369 ] zhisheng edited comment on FLINK-20143 at 11/13/20, 10:51 AM:

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231369#comment-17231369 ] zhisheng commented on FLINK-20143: -- {code:java} 22020-11-13 18:46:43,014 INFO  org.apac

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231365#comment-17231365 ] zhisheng commented on FLINK-20143: -- !image-2020-11-13-18-43-55-188.png!   does not ha

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-20143: - Attachment: image-2020-11-13-18-43-55-188.png > use `yarn.provided.lib.dirs` config deploy job failed in

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231346#comment-17231346 ] zhisheng edited comment on FLINK-20143 at 11/13/20, 10:12 AM:

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231346#comment-17231346 ] zhisheng edited comment on FLINK-20143 at 11/13/20, 10:10 AM:

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-20143: - Description: use follow command deploy flink job to yarn failed  {code:java} ./bin/flink run -m yarn-clu

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231346#comment-17231346 ] zhisheng edited comment on FLINK-20143 at 11/13/20, 10:07 AM:

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231346#comment-17231346 ] zhisheng commented on FLINK-20143: -- {code:java} $ ./bin/flink run -t yarn-per-job -Dexe

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231321#comment-17231321 ] zhisheng commented on FLINK-20143: -- Are there any other methods to make job config comp

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231319#comment-17231319 ] zhisheng commented on FLINK-20143: -- in our production environment,has many flink job,ev

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231317#comment-17231317 ] zhisheng commented on FLINK-20143: --   {code:java} ./bin/flink run -m yarn-cluster -d

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231300#comment-17231300 ] zhisheng commented on FLINK-20143: -- [~kkl0u] yes, -ytm and -yjm does not take effect,i

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231287#comment-17231287 ] zhisheng commented on FLINK-20143: -- !image-2020-11-13-17-21-47-751.png!   !image-2020

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-20143: - Attachment: image-2020-11-13-17-22-06-111.png > use `yarn.provided.lib.dirs` config deploy job failed in

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-20143: - Attachment: image-2020-11-13-17-21-47-751.png > use `yarn.provided.lib.dirs` config deploy job failed in

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

2020-11-13 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231284#comment-17231284 ] zhisheng commented on FLINK-20143: -- [~kkl0u] it does not have jobmanager log and taskma

[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] [Commented] (FLINK-20109) java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer

2020-11-12 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230623#comment-17230623 ] zhisheng commented on FLINK-20109: -- Do you restart the sql client or restart the cluste

[jira] [Commented] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

2020-11-08 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17228314#comment-17228314 ] zhisheng commented on FLINK-19973: -- [~kkl0u] closed > 【Flink-Deployment】YARN CLI Param

[jira] [Closed] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

2020-11-08 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng closed FLINK-19973. Resolution: Not A Bug > 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: > y

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

2020-11-05 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng closed FLINK-19995. Resolution: Won't Fix > 【Flink SQL Client】Use Flink Kafka Connector in SQL-Client has more than one > exc

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

2020-11-05 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227133#comment-17227133 ] zhisheng commented on FLINK-19995: -- I restart the SQL Client, but not the Flink Cluster

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

2020-11-05 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-19995: - Description: when i add flink-sql-connector-kafka_2.11-1.12-SNAPSHOT.jar in lib, I run  sql job has an

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

2020-11-05 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-19995: - Description: when i add flink-sql-connector-kafka_2.11-1.12-SNAPSHOT.jar in lib, I run  sql job has an

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

2020-11-05 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-19995: - Summary: 【Flink SQL Client】Use Flink Kafka Connector in SQL-Client has more than one exception (was: 【F

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

2020-11-05 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-19995: - Summary: 【Flink SQL Client】Use Flink Kafka Connector has more than one exception (was: 【Flink SQL Clien

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

2020-11-05 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-19995: - Attachment: image-2020-11-05-17-57-38-381.png Description: when i add flink-sql-connector-kafka_2.1

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

2020-11-05 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-19995: - Description: when i add flink-sql-connector-kafka_2.11-1.12-SNAPSHOT.jar in lib, I run  sql job has an

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

2020-11-05 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-19995: - Description: when i add flink-sql-connector-kafka_2.11-1.12-SNAPSHOT.jar in lib, I run  sql job has an

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

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

2020-11-04 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-19973: - Description: when i use flink-sql-client to deploy job to yarn(per job mod), I set `execution.target: y

[jira] [Updated] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

2020-11-04 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-19973: - Summary: 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` con

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

[jira] [Commented] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

2020-07-05 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151727#comment-17151727 ] zhisheng commented on FLINK-18449: -- In FlinkKafkaConsumer, the constructor method as th

[jira] [Comment Edited] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

2020-07-03 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151165#comment-17151165 ] zhisheng edited comment on FLINK-18449 at 7/4/20, 4:23 AM: --- wh

[jira] [Comment Edited] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

2020-07-03 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151165#comment-17151165 ] zhisheng edited comment on FLINK-18449 at 7/4/20, 4:23 AM: --- wh

  1   2   >