[jira] [Created] (FLINK-36895) The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed.

ouyangwulin created FLINK-36895: --- Summary: The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed. Key: FLINK-36895 URL: https://issues.apache.org/jira/browse/FLINK-36895

[jira] [Created] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type.

ouyangwulin created FLINK-36812: --- Summary: The flink jdbc connector's 'scan.partition.column' supports the varchar field type. Key: FLINK-36812 URL: https://issues.apache.org/jira/browse/FLINK-36812 Pro

[jira] [Created] (FLINK-36588) flink catalog is supported in cdc yaml

ouyangwulin created FLINK-36588: --- Summary: flink catalog is supported in cdc yaml Key: FLINK-36588 URL: https://issues.apache.org/jira/browse/FLINK-36588 Project: Flink Issue Type: New Feature

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

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

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] [Created] (FLINK-35354) [discuss] Support host mapping in Flink tikv cdc

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: Im

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

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: Impr

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

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] [Created] (FLINK-24315) Flink native on k8s wacther thread will down，when k8s api server not work or network timeout

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] [Created] (FLINK-15400) elasticsearch sink support dynamic index.

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 Featu

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

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] [Created] (FLINK-15176) Add '--job-classname' to flink-container 'job-cluster-job.yaml.template'

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: Flink

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

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: Document

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

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] [Created] (FLINK-14831) When edit flink-metrics-influxdb, need add metrics.md by hand

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-14803) Support Consistency Level for InfluxDB metrics reporter

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 T

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

ouyangwulin created FLINK-14210: --- Summary: influxdb reporter add connect timeout and write timeout config options for decrease timeout exception Key: FLINK-14210 URL: https://issues.apache.org/jira/browse/FLINK-1421

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

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 Typ

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

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