[jira] [Created] (FLINK-35459) Use Incremental Source Framework in Flink CDC TiKV Source Connector

2024-05-26 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-35459: --- Summary: Use Incremental Source Framework in Flink CDC TiKV Source Connector Key: FLINK-35459 URL: https://issues.apache.org/jira/browse/FLINK-35459 Project: Flink

[jira] [Created] (FLINK-35450) Introduce Tikv pipeline DataSource

2024-05-25 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-35450: --- Summary: Introduce Tikv pipeline DataSource Key: FLINK-35450 URL: https://issues.apache.org/jira/browse/FLINK-35450 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-34841) [3.1][pipeline-connectors] Add jdbc pipeline sink

2024-05-25 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849443#comment-17849443 ] ouyangwulin commented on FLINK-34841: - [~gongzhongqiang] Looks like a very good job, cdc data entry

[jira] [Commented] (FLINK-34688) CDC framework split snapshot chunks asynchronously

2024-05-25 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849441#comment-17849441 ] ouyangwulin commented on FLINK-34688: - When the size of the data is relatively large, this feature

[jira] [Updated] (FLINK-34901) Update clause must EXCLUDED unique index

2024-05-23 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-34901: Summary: Update clause must EXCLUDED unique index (was: Improve the performance of the update

[jira] [Updated] (FLINK-34901) Update clause must EXCLUDED unique index

2024-05-23 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-34901: Description: When writing Postgres data using flinke-connector-jdbc, using upsert mode, As docs

[jira] [Commented] (FLINK-35360) [Feature] Submit Flink CDC pipeline job yarn Application mode

2024-05-21 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848423#comment-17848423 ] ouyangwulin commented on FLINK-35360: - With many enterprises still running on yarn, this

[jira] [Closed] (FLINK-35337) Keep up with the latest version of tikv client

2024-05-21 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin closed FLINK-35337. --- Release Note: tikv version not supported Resolution: Won't Fix > Keep up with the latest

[jira] [Updated] (FLINK-35354) Support host mapping in Flink tikv cdc

2024-05-14 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-35354: Description: In tidb production environment deployment, there are usually two kinds of network:

[jira] [Updated] (FLINK-35354) Support host mapping in Flink tikv cdc

2024-05-14 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-35354: Description: In tidb production environment deployment, there are usually two kinds of network:

[jira] [Updated] (FLINK-35354) Support host mapping in Flink tikv cdc

2024-05-14 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-35354: Description: In tidb production environment deployment, there are usually two kinds of network:

[jira] [Updated] (FLINK-35354) Support host mapping in Flink tikv cdc

2024-05-14 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-35354: Description: In tidb production environment deployment, there are usually two kinds of network:

[jira] [Updated] (FLINK-35354) Support host mapping in Flink tikv cdc

2024-05-14 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-35354: Summary: Support host mapping in Flink tikv cdc (was: [discuss] Support host mapping in Flink

[jira] [Created] (FLINK-35354) [discuss] Support host mapping in Flink tikv cdc

2024-05-14 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-35354: --- Summary: [discuss] Support host mapping in Flink tikv cdc Key: FLINK-35354 URL: https://issues.apache.org/jira/browse/FLINK-35354 Project: Flink Issue Type:

[jira] [Updated] (FLINK-34901) Improve the performance of the update Postgres database

2024-05-14 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-34901: Affects Version/s: jdbc-3.1.2 > Improve the performance of the update Postgres database >

[jira] [Updated] (FLINK-34901) Improve the performance of the update Postgres database

2024-05-14 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-34901: Priority: Critical (was: Minor) > Improve the performance of the update Postgres database >

[jira] [Commented] (FLINK-34901) Improve the performance of the update Postgres database

2024-05-14 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846235#comment-17846235 ] ouyangwulin commented on FLINK-34901: - Some versions of pgsql also give this error: {code:java}

[jira] [Commented] (FLINK-35337) Keep up with the latest version of tikv client

2024-05-13 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845887#comment-17845887 ] ouyangwulin commented on FLINK-35337: - [~Leonard], Our production environment has been updated  tikv

[jira] [Updated] (FLINK-35337) Keep up with the latest version of tikv client

2024-05-13 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-35337: Component/s: Flink CDC > Keep up with the latest version of tikv client >

[jira] [Created] (FLINK-35337) Keep up with the latest version of tikv client

2024-05-13 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-35337: --- Summary: Keep up with the latest version of tikv client Key: FLINK-35337 URL: https://issues.apache.org/jira/browse/FLINK-35337 Project: Flink Issue Type:

[jira] [Commented] (FLINK-34722) Support conditional upserts with Postgres JDBC sink

2024-03-22 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829775#comment-17829775 ] ouyangwulin commented on FLINK-34722: - [~pietro97] I think it is a very useful provement for jdbc

[jira] [Created] (FLINK-34901) Improve the performance of the update Postgres database

2024-03-21 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-34901: --- Summary: Improve the performance of the update Postgres database Key: FLINK-34901 URL: https://issues.apache.org/jira/browse/FLINK-34901 Project: Flink Issue

[jira] [Commented] (FLINK-33319) Add AverageTime metric to measure delta change in GC time

2024-01-04 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803379#comment-17803379 ] ouyangwulin commented on FLINK-33319: - [~gyfora]  Could you assign this ticket to me? > Add

[jira] [Closed] (FLINK-33491) Support json column validated

2023-11-13 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin closed FLINK-33491. --- Resolution: Not A Problem > Support json column validated > - > >

[jira] [Commented] (FLINK-33491) Support json column validated

2023-11-13 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785468#comment-17785468 ] ouyangwulin commented on FLINK-33491: - This is my error, I didn't find the is json function. >

[jira] [Updated] (FLINK-33491) Support json column validated

2023-11-09 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-33491: Description: Just like the {{is_valid_json}} function in PostgreSQL, it would be useful to have

[jira] [Created] (FLINK-33491) Support json column validated

2023-11-09 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-33491: --- Summary: Support json column validated Key: FLINK-33491 URL: https://issues.apache.org/jira/browse/FLINK-33491 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-27925) Avoid to create watcher without the resourceVersion

2023-05-11 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17721745#comment-17721745 ] ouyangwulin commented on FLINK-27925: - [~huwh]  tks, I will update. > Avoid to create watcher

[jira] [Comment Edited] (FLINK-29705) Document the least access with RBAC setting for native K8s integration

2023-03-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701118#comment-17701118 ] ouyangwulin edited comment on FLINK-29705 at 3/16/23 11:49 AM: ---

[jira] [Commented] (FLINK-29705) Document the least access with RBAC setting for native K8s integration

2023-03-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701118#comment-17701118 ] ouyangwulin commented on FLINK-29705: - apiVersion: v1 kind: ServiceAccount metadata:   labels:    

[jira] [Commented] (FLINK-30231) Update to Fabric8 Kubernetes Client to a version that has automatic renewal of service account tokens

2023-01-04 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654420#comment-17654420 ] ouyangwulin commented on FLINK-30231: - [~martijnvisser]  Can you help me check it out? > Update to

[jira] [Commented] (FLINK-29705) Document the least access with RBAC setting for native K8s integration

2023-01-03 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654320#comment-17654320 ] ouyangwulin commented on FLINK-29705: - [~wangyang0918]  Can assign this ticket for me ? > Document

[jira] [Comment Edited] (FLINK-27925) Avoid to create watcher without the resourceVersion

2022-12-19 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649232#comment-17649232 ] ouyangwulin edited comment on FLINK-27925 at 12/19/22 12:31 PM: In the

[jira] [Commented] (FLINK-27925) Avoid to create watcher without the resourceVersion

2022-12-19 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649232#comment-17649232 ] ouyangwulin commented on FLINK-27925: - In the case of large-scale start and stop jobs, constantly

[jira] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

2022-12-18 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26541 ] ouyangwulin deleted comment on FLINK-26541: - was (Author: ouyangwuli): Please assign the ticket to me [~wangyang0918]  > SQL Client should support submitting SQL jobs in application mode >

[jira] [Commented] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

2022-12-18 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649023#comment-17649023 ] ouyangwulin commented on FLINK-26541: - Please assign the ticket to me [~wangyang0918]  > SQL Client

[jira] [Comment Edited] (FLINK-24334) Configuration kubernetes.flink.log.dir not working

2021-10-07 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425441#comment-17425441 ] ouyangwulin edited comment on FLINK-24334 at 10/7/21, 9:44 AM: ---

[jira] [Commented] (FLINK-24334) Configuration kubernetes.flink.log.dir not working

2021-10-07 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425441#comment-17425441 ] ouyangwulin commented on FLINK-24334: - Solving this problem can be divided into two steps:    1.

[jira] [Commented] (FLINK-24178) Flink on Kubernetes TaskManager

2021-10-07 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425392#comment-17425392 ] ouyangwulin commented on FLINK-24178: - [~frey] I guess, if the tm resource address error? Is the

[jira] [Commented] (FLINK-24315) Cannot rebuild watcher thread while the K8S API server is unavailable

2021-09-17 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416493#comment-17416493 ] ouyangwulin commented on FLINK-24315: - [~karmagyz]  Can we configure parameters

[jira] [Created] (FLINK-24315) Flink native on k8s wacther thread will down,when k8s api server not work or network timeout

2021-09-17 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-24315: --- Summary: Flink native on k8s wacther thread will down,when k8s api server not work or network timeout Key: FLINK-24315 URL: https://issues.apache.org/jira/browse/FLINK-24315

[jira] [Commented] (FLINK-14986) Support to get detailed Kubernetes cluster description

2020-08-31 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17187663#comment-17187663 ] ouyangwulin commented on FLINK-14986: - [~trohrmann] I have implement it, but Not have enough test. I

[jira] [Comment Edited] (FLINK-15641) Support to start init container

2020-04-18 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17086760#comment-17086760 ] ouyangwulin edited comment on FLINK-15641 at 4/19/20, 5:38 AM: ---

[jira] [Commented] (FLINK-15641) Support to start init container

2020-04-18 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17086760#comment-17086760 ] ouyangwulin commented on FLINK-15641: - [~fly_in_gis],in progressing. > Support to start init

[jira] [Comment Edited] (FLINK-15656) Support user-specified pod templates

2020-04-08 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078050#comment-17078050 ] ouyangwulin edited comment on FLINK-15656 at 4/8/20, 10:51 AM: --- I have

[jira] [Comment Edited] (FLINK-15656) Support user-specified pod templates

2020-04-08 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078050#comment-17078050 ] ouyangwulin edited comment on FLINK-15656 at 4/8/20, 10:51 AM: --- I have

[jira] [Commented] (FLINK-15656) Support user-specified pod templates

2020-04-08 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078050#comment-17078050 ] ouyangwulin commented on FLINK-15656: - I have implement init-container for download jar files. But I

[jira] [Commented] (FLINK-15656) Support user-specified pod templates

2020-03-17 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060856#comment-17060856 ] ouyangwulin commented on FLINK-15656: - Ok, If the pod templement support  sidecar container and init

[jira] [Commented] (FLINK-15871) Support to start sidecar container

2020-03-17 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060854#comment-17060854 ] ouyangwulin commented on FLINK-15871: - [~felixzheng] [~fly_in_gis]  Sidecar for log is worked in our

[jira] [Comment Edited] (FLINK-15641) Support to start init container

2020-03-17 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060654#comment-17060654 ] ouyangwulin edited comment on FLINK-15641 at 3/17/20, 6:00 AM: ---

[jira] [Commented] (FLINK-15641) Support to start init container

2020-03-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060654#comment-17060654 ] ouyangwulin commented on FLINK-15641: - [~fly_in_gis]  As flink on k8s ,not native. I think init

[jira] [Commented] (FLINK-15871) Support to start sidecar container

2020-03-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060649#comment-17060649 ] ouyangwulin commented on FLINK-15871: - [~felixzheng]   >  As collect logs, I think have two method,

[jira] [Commented] (FLINK-15641) Support to start init container

2020-03-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060144#comment-17060144 ] ouyangwulin commented on FLINK-15641: - Ok I will complement it this week. > Support to start init

[jira] [Commented] (FLINK-14986) Support to get detailed Kubernetes cluster description

2020-03-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060136#comment-17060136 ] ouyangwulin commented on FLINK-14986: - Last time, I am busy in push flink on k8s online env, this

[jira] [Commented] (FLINK-15400) elasticsearch sink support dynamic index.

2020-02-20 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041547#comment-17041547 ] ouyangwulin commented on FLINK-15400: - [~Leonard Xu] If configed 'connector.dynamicIndex',

[jira] [Commented] (FLINK-15400) elasticsearch sink support dynamic index.

2020-02-20 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041545#comment-17041545 ] ouyangwulin commented on FLINK-15400: - [~Leonard Xu]. Yes I have a design from blink. And I have a

[jira] [Commented] (FLINK-15641) Support to start init container

2020-02-05 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031314#comment-17031314 ] ouyangwulin commented on FLINK-15641: - [~fly_in_gis] ok, I will do this job > Support to start init

[jira] [Commented] (FLINK-15641) Support to start init container

2020-02-03 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029524#comment-17029524 ] ouyangwulin commented on FLINK-15641: - [~gjy] , I think I can do this work。 and I will test the

[jira] [Commented] (FLINK-15871) Support to start sidecar container

2020-02-03 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029522#comment-17029522 ] ouyangwulin commented on FLINK-15871: - Could assign this ticket for me? > Support to start sidecar

[jira] [Commented] (FLINK-15641) Support to start sidecar container and init container

2020-02-03 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029503#comment-17029503 ] ouyangwulin commented on FLINK-15641: - [~fly_in_gis]  A sidecar container is running beside the

[jira] [Commented] (FLINK-14460) Active Kubernetes integration phase2 - Advanced Features

2020-01-18 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018774#comment-17018774 ] ouyangwulin commented on FLINK-14460: - I have try to implement sidecars and initcontainer in flink

[jira] [Commented] (FLINK-15642) Support to set JobManager liveness check

2020-01-18 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018771#comment-17018771 ] ouyangwulin commented on FLINK-15642: - Could assign this ticket for me? > Support to set JobManager

[jira] [Commented] (FLINK-15641) Support to start sidecar container and init container

2020-01-18 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018770#comment-17018770 ] ouyangwulin commented on FLINK-15641: - Could assign this ticket for me? > Support to start sidecar

[jira] [Comment Edited] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2020-01-02 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006769#comment-17006769 ] ouyangwulin edited comment on FLINK-15378 at 1/3/20 2:49 AM: - [~pnowojski] 

[jira] [Comment Edited] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2020-01-02 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006769#comment-17006769 ] ouyangwulin edited comment on FLINK-15378 at 1/3/20 2:49 AM: - [~pnowojski] 

[jira] [Commented] (FLINK-12382) HA + ResourceManager exception: Fencing token not set

2020-01-02 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007184#comment-17007184 ] ouyangwulin commented on FLINK-12382: - The program finished with the following exception:

[jira] [Commented] (FLINK-12382) HA + ResourceManager exception: Fencing token not set

2020-01-02 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007183#comment-17007183 ] ouyangwulin commented on FLINK-12382: - I have try zookeeper, But the error log seems same > HA +

[jira] [Comment Edited] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2020-01-02 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006769#comment-17006769 ] ouyangwulin edited comment on FLINK-15378 at 1/2/20 12:36 PM: -- [~pnowojski] 

[jira] [Commented] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2020-01-02 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006769#comment-17006769 ] ouyangwulin commented on FLINK-15378: - [~pnowojski] thanks for your reply.  {noformat} For one

[jira] [Commented] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2020-01-01 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006568#comment-17006568 ] ouyangwulin commented on FLINK-15378: - [~fly_in_gis] Also, I need different kerberos auth between

[jira] [Comment Edited] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2020-01-01 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006557#comment-17006557 ] ouyangwulin edited comment on FLINK-15378 at 1/2/20 3:27 AM: - {code:java}  

[jira] [Comment Edited] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2020-01-01 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006557#comment-17006557 ] ouyangwulin edited comment on FLINK-15378 at 1/2/20 3:25 AM: - {code:java}  

[jira] [Commented] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2020-01-01 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006557#comment-17006557 ] ouyangwulin commented on FLINK-15378: - {code:java}  do I understand your problem correctly, that you

[jira] [Comment Edited] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-27 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17004032#comment-17004032 ] ouyangwulin edited comment on FLINK-15378 at 12/27/19 9:52 AM: ---

[jira] [Comment Edited] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-27 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003237#comment-17003237 ] ouyangwulin edited comment on FLINK-15378 at 12/27/19 9:51 AM: ---

[jira] [Commented] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-27 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17004032#comment-17004032 ] ouyangwulin commented on FLINK-15378: - [~fly_in_gis] 

[jira] [Commented] (FLINK-15400) elasticsearch sink support dynamic index.

2019-12-26 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003531#comment-17003531 ] ouyangwulin commented on FLINK-15400: - Please assign this for me > elasticsearch sink support

[jira] [Updated] (FLINK-15400) elasticsearch sink support dynamic index.

2019-12-26 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-15400: Description: >From

[jira] [Created] (FLINK-15400) elasticsearch sink support dynamic index.

2019-12-26 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-15400: --- Summary: elasticsearch sink support dynamic index. Key: FLINK-15400 URL: https://issues.apache.org/jira/browse/FLINK-15400 Project: Flink Issue Type: New

[jira] [Comment Edited] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-25 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003237#comment-17003237 ] ouyangwulin edited comment on FLINK-15378 at 12/26/19 5:58 AM: ---

[jira] [Comment Edited] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-25 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17002704#comment-17002704 ] ouyangwulin edited comment on FLINK-15378 at 12/26/19 3:07 AM: --- Please

[jira] [Commented] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-25 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003237#comment-17003237 ] ouyangwulin commented on FLINK-15378: - [~fly_in_gis]  >> For request 1,      Change plugin to not

[jira] [Updated] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-25 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-15378: Description: [As report from

[jira] [Updated] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-25 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-15378: Description: [As report from

[jira] [Updated] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-25 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-15378: Description: [As report from

[jira] [Commented] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-24 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17002719#comment-17002719 ] ouyangwulin commented on FLINK-15378: - [~pnowojski] When I read the code 

[jira] [Updated] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-23 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-15378: Description: Request 1:  FileSystem plugins not effect the default yarn dependecies. Request 2: 

[jira] [Commented] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-23 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17002704#comment-17002704 ] ouyangwulin commented on FLINK-15378: - Please assign the for me! > StreamFileSystemSink supported

[jira] [Updated] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-23 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-15378: Description: Request 1:  FileSystem plugins not effect the default yarn dependecies. Request 2: 

[jira] [Updated] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-23 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-15378: Attachment: jobmananger.log > StreamFileSystemSink supported mutil hdfs plugins. >

[jira] [Updated] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-23 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-15378: Description: Request 1:  FileSystem plugins not effect the default yarn dependecies. Request 2: 

[jira] [Created] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

2019-12-23 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-15378: --- Summary: StreamFileSystemSink supported mutil hdfs plugins. Key: FLINK-15378 URL: https://issues.apache.org/jira/browse/FLINK-15378 Project: Flink Issue Type:

[jira] [Closed] (FLINK-14831) When edit flink-metrics-influxdb, need add metrics.md by hand

2019-12-13 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin closed FLINK-14831. --- Resolution: Won't Fix > When edit flink-metrics-influxdb, need add metrics.md by hand >

[jira] [Commented] (FLINK-14831) When edit flink-metrics-influxdb, need add metrics.md by hand

2019-12-13 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995493#comment-16995493 ] ouyangwulin commented on FLINK-14831: - I will close this jira, I know your mean.  > When edit

[jira] [Commented] (FLINK-14831) When edit flink-metrics-influxdb, need add metrics.md by hand

2019-12-12 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995283#comment-16995283 ] ouyangwulin commented on FLINK-14831: - [~rmetzger] I have try to fixed this problems. and add

[jira] [Commented] (FLINK-14172) Implement KubeClient with official Java client library for kubernetes

2019-12-10 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993247#comment-16993247 ] ouyangwulin commented on FLINK-14172: - Please assign this to me > Implement KubeClient with

[jira] [Commented] (FLINK-14986) Support to get detailed Kubernetes cluster description

2019-12-10 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992498#comment-16992498 ] ouyangwulin commented on FLINK-14986: - Please assign this for me [~fly_in_gis] > Support to get

[jira] [Created] (FLINK-15176) Add '--job-classname' to flink-container 'job-cluster-job.yaml.template'

2019-12-10 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-15176: --- Summary: Add '--job-classname' to flink-container 'job-cluster-job.yaml.template' Key: FLINK-15176 URL: https://issues.apache.org/jira/browse/FLINK-15176 Project:

[jira] [Created] (FLINK-14855) travis-ci error.

2019-11-19 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-14855: --- Summary: travis-ci error. Key: FLINK-14855 URL: https://issues.apache.org/jira/browse/FLINK-14855 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-14831) When edit flink-metrics-influxdb, need add metrics.md by hand

2019-11-18 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977066#comment-16977066 ] ouyangwulin commented on FLINK-14831: - [~yunta] , I add a option config  in

  1   2   >