[jira] [Updated] (FLINK-12147) Error for monitor kafka metrics when Use influxDB metric plugins,influxDB unsuport POSITIVE_INFINITY or NEGATIVE_INFINITY

2019-04-15 Thread ouyangwulin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-12147: Attachment: metric-error.log Description: when use influxDB store metric datas, and metric

[jira] [Updated] (FLINK-12147) Error for monitor kafka metrics when Use influxDB metric plugins,influxDB unsuport POSITIVE_INFINITY or NEGATIVE_INFINITY

2019-04-09 Thread ouyangwulin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-12147: Summary: Error for monitor kafka metrics when Use influxDB metric plugins,influxDB unsuport

[jira] [Created] (FLINK-12147) Error for monitor kafka metrics when Use influxDB metric plugins

2019-04-09 Thread ouyangwulin (JIRA)
ouyangwulin created FLINK-12147: --- Summary: Error for monitor kafka metrics when Use influxDB metric plugins Key: FLINK-12147 URL: https://issues.apache.org/jira/browse/FLINK-12147 Project: Flink

[jira] [Comment Edited] (FLINK-13418) Avoid InfluxdbReporter to report unnecessary tags

2019-08-19 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910926#comment-16910926 ] ouyangwulin edited comment on FLINK-13418 at 8/20/19 2:17 AM: -- We use

[jira] [Commented] (FLINK-13418) Avoid InfluxdbReporter to report unnecessary tags

2019-08-19 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910926#comment-16910926 ] ouyangwulin commented on FLINK-13418: - I use influxdbReporter in product env in NTES .When the flink

[jira] [Comment Edited] (FLINK-13418) Avoid InfluxdbReporter to report unnecessary tags

2019-08-19 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910926#comment-16910926 ] ouyangwulin edited comment on FLINK-13418 at 8/20/19 2:20 AM: -- We use

[jira] [Created] (FLINK-13873) Change the colum family as tags for influxdb reporter

2019-08-27 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-13873: --- Summary: Change the colum family as tags for influxdb reporter Key: FLINK-13873 URL: https://issues.apache.org/jira/browse/FLINK-13873 Project: Flink Issue

[jira] [Updated] (FLINK-13873) Change the column family as tags for influxdb reporter

2019-08-27 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-13873: Summary: Change the column family as tags for influxdb reporter (was: Change the colum family as

[jira] [Commented] (FLINK-14537) Improve influxdb reporter performance for kafka source/sink

2019-11-04 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967175#comment-16967175 ] ouyangwulin commented on FLINK-14537: - [~yunta] So , topic and partition is variable in

[jira] [Created] (FLINK-14803) Support Consistency Level for InfluxDB metrics reporter

2019-11-14 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-14803: --- Summary: Support Consistency Level for InfluxDB metrics reporter Key: FLINK-14803 URL: https://issues.apache.org/jira/browse/FLINK-14803 Project: Flink Issue

[jira] [Commented] (FLINK-14531) Add Kafka Metrics Reporter

2019-11-17 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976012#comment-16976012 ] ouyangwulin commented on FLINK-14531: - [~yong_chen] [~gyfora] I need this function too > Add

[jira] [Commented] (FLINK-14803) Support Consistency Level for InfluxDB metrics reporter

2019-11-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16975897#comment-16975897 ] ouyangwulin commented on FLINK-14803: - yes, I have test in our env. I will push to github > Support

[jira] [Updated] (FLINK-14803) Support Consistency Level for InfluxDB metrics

2019-11-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-14803: Summary: Support Consistency Level for InfluxDB metrics (was: -) > Support Consistency Level for

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

2019-11-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16975933#comment-16975933 ] ouyangwulin commented on FLINK-14831: - can assign this for me > When edit flink-metrics-influxdb,

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

2019-11-16 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-14831: --- Summary: When edit flink-metrics-influxdb, need add metrics.md by hand Key: FLINK-14831 URL: https://issues.apache.org/jira/browse/FLINK-14831 Project: Flink

[jira] [Created] (FLINK-14832) Support kafka metrics reporter

2019-11-16 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-14832: --- Summary: Support kafka metrics reporter Key: FLINK-14832 URL: https://issues.apache.org/jira/browse/FLINK-14832 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-14803) -

2019-11-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-14803: Summary: - (was: Support Consistency Level for InfluxDB metrics reporter) > - > - > >

[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] [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] [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] [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-14537) Improve influxdb reporter performance for kafka source/sink

2019-10-28 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961599#comment-16961599 ] ouyangwulin commented on FLINK-14537: - [~wind_ljy],I always use influxdb cli, `show measurements`

[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

[jira] [Closed] (FLINK-12147) Error for monitor kafka metrics when Use influxDB metric plugins,influxDB unsuport POSITIVE_INFINITY or NEGATIVE_INFINITY

2019-09-25 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin closed FLINK-12147. --- Resolution: Fixed > Error for monitor kafka metrics when Use influxDB metric plugins,influxDB >

[jira] [Updated] (FLINK-14210) influxdb reporter support connect timeout and write timeout config options for decrease timeout exception

2019-09-25 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-14210: Summary: influxdb reporter support connect timeout and write timeout config options for decrease

[jira] [Created] (FLINK-14210) influxdb reporter add connect timeout and write timeout config options for decrease timeout exception

2019-09-25 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-14210: --- Summary: influxdb reporter add connect timeout and write timeout config options for decrease timeout exception Key: FLINK-14210 URL:

[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] [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 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-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-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-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] [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.

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] [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:25 AM: - {code:java}  

[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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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-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-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-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] [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] [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-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] [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-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] [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] [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] [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] [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] [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] [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] (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-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] [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-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-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] [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-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] [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] [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] [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] [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

  1   2   >