[jira] [Commented] (FLINK-18602) Support specific offset for topic list for kafka connector in table api

2020-09-16 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196817#comment-17196817 ] Shengkai Fang commented on FLINK-18602: --- Currently

[jira] [Updated] (FLINK-19651) Support the filter push down for the Jdbc connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19651: -- Summary: Support the filter push down for the Jdbc connector (was: Support filter push down

[jira] [Updated] (FLINK-19650) Support the limit push down for the Jdbc connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19650: -- Parent: FLINK-16987 Issue Type: Sub-task (was: New Feature) > Support the limit push

[jira] [Updated] (FLINK-19647) Support the limit push down for the hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19647: -- Parent: FLINK-16987 Issue Type: Sub-task (was: New Feature) > Support the limit push

[jira] [Updated] (FLINK-19647) Support the limit push down for the hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19647: -- Summary: Support the limit push down for the hbase connector (was: Support limit push down

[jira] [Created] (FLINK-19647) Support limit push down for hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-19647: - Summary: Support limit push down for hbase connector Key: FLINK-19647 URL: https://issues.apache.org/jira/browse/FLINK-19647 Project: Flink Issue Type:

[jira] [Created] (FLINK-19651) Support filter push down for the Jdbc connector

2020-10-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-19651: - Summary: Support filter push down for the Jdbc connector Key: FLINK-19651 URL: https://issues.apache.org/jira/browse/FLINK-19651 Project: Flink Issue

[jira] [Created] (FLINK-19650) Support the limit push down for the Jdbc connector

2020-10-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-19650: - Summary: Support the limit push down for the Jdbc connector Key: FLINK-19650 URL: https://issues.apache.org/jira/browse/FLINK-19650 Project: Flink Issue

[jira] [Updated] (FLINK-19647) Support limit push down for the hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19647: -- Summary: Support limit push down for the hbase connector (was: Support limit push down for

[jira] [Created] (FLINK-19648) Support nested projection push down for hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-19648: - Summary: Support nested projection push down for hbase connector Key: FLINK-19648 URL: https://issues.apache.org/jira/browse/FLINK-19648 Project: Flink

[jira] [Updated] (FLINK-19648) Support the nested projection push down for the hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19648: -- Parent: FLINK-16987 Issue Type: Sub-task (was: New Feature) > Support the nested

[jira] [Updated] (FLINK-19648) Support nested projection push down for the hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19648: -- Summary: Support nested projection push down for the hbase connector (was: Support nested

[jira] [Updated] (FLINK-19648) Support the nested projection push down for the hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19648: -- Summary: Support the nested projection push down for the hbase connector (was: Support

[jira] [Updated] (FLINK-19651) Support filter push down for the Jdbc connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19651: -- Parent: FLINK-16987 Issue Type: Sub-task (was: New Feature) > Support filter push

[jira] [Updated] (FLINK-19639) Support SupportsNestedProjectionPushDown in planner

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19639: -- Description: Support to push nested projection into {{TableSourceScan}}. But it may cause

[jira] [Created] (FLINK-19639) Support SupportsNestedProjectionPushDown in planner

2020-10-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-19639: - Summary: Support SupportsNestedProjectionPushDown in planner Key: FLINK-19639 URL: https://issues.apache.org/jira/browse/FLINK-19639 Project: Flink Issue

[jira] [Commented] (FLINK-19639) Support SupportsNestedProjectionPushDown in planner

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213764#comment-17213764 ] Shengkai Fang commented on FLINK-19639: --- CC [~godfreyhe] [~jark] > Support

[jira] [Commented] (FLINK-18826) Support to emit and encode upsert messages to Kafka

2020-08-27 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185716#comment-17185716 ] Shengkai Fang commented on FLINK-18826: --- hi, all. I think it's a good idea to add an option such

[jira] [Created] (FLINK-19282) Support watermark push down with WatermarkStrategy

2020-09-17 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-19282: - Summary: Support watermark push down with WatermarkStrategy Key: FLINK-19282 URL: https://issues.apache.org/jira/browse/FLINK-19282 Project: Flink Issue

[jira] [Updated] (FLINK-17940) It will throw NullPointerException when write data with Avro format using new property key in SQL-Client

2020-05-26 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-17940: -- Environment: Docker Environment: zookeeper: image: wurstmeister/zookeeper:3.4.6 ports: -

[jira] [Updated] (FLINK-17948) Strange precision performance of Timestamp and Decimal

2020-05-26 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-17948: -- Description: My job is following:   {code:java} CREATE TABLE currency ( currency_id

[jira] [Updated] (FLINK-17948) Strange precision performance of Timestamp and Decimal

2020-05-26 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-17948: -- Attachment: image-2020-05-26-22-58-02-326.png > Strange precision performance of Timestamp

[jira] [Created] (FLINK-17948) Strange precision performance of Timestamp and Decimal

2020-05-26 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-17948: - Summary: Strange precision performance of Timestamp and Decimal Key: FLINK-17948 URL: https://issues.apache.org/jira/browse/FLINK-17948 Project: Flink

[jira] [Updated] (FLINK-17948) Strange precision performance of Timestamp and Decimal

2020-05-26 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-17948: -- Description: My job is following:   {code:java} CREATE TABLE currency ( currency_id

[jira] [Updated] (FLINK-17948) Strange precision performance of Timestamp and Decimal

2020-05-26 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-17948: -- Attachment: image-2020-05-26-22-56-43-835.png > Strange precision performance of Timestamp

[jira] [Created] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format

2020-05-28 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-18006: - Summary: It will throw Invalid lambda deserialization Exception when writing to elastic search with new format Key: FLINK-18006 URL:

[jira] [Updated] (FLINK-17908) Vague document about Kafka config in SQL-CLI

2020-05-24 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-17908: -- Description: Currently Flink doesn't offer any default config value for Kafka and use the

[jira] [Created] (FLINK-17908) Vague document about Kafka config in SQL-CLI

2020-05-24 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-17908: - Summary: Vague document about Kafka config in SQL-CLI Key: FLINK-17908 URL: https://issues.apache.org/jira/browse/FLINK-17908 Project: Flink Issue Type:

[jira] [Updated] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format

2020-05-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-18006: -- Priority: Critical (was: Major) > It will throw Invalid lambda deserialization Exception

[jira] [Comment Edited] (FLINK-18021) Complement tests for 1.11 SQL

2020-05-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120547#comment-17120547 ] Shengkai Fang edited comment on FLINK-18021 at 5/31/20, 2:08 PM: - It

[jira] [Commented] (FLINK-18021) Complement tests for 1.11 SQL

2020-05-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120547#comment-17120547 ] Shengkai Fang commented on FLINK-18021: --- It seems huge work if we test every pair of connectors!

[jira] [Commented] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format

2020-05-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120553#comment-17120553 ] Shengkai Fang commented on FLINK-18006: --- It seems that it just can't write data into

[jira] [Created] (FLINK-17940) It will throw NullPointerException when write data with Avro format using new property key in SQL-Client

2020-05-26 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-17940: - Summary: It will throw NullPointerException when write data with Avro format using new property key in SQL-Client Key: FLINK-17940 URL:

[jira] [Commented] (FLINK-18667) Data Types documentation misunderstand users

2020-07-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162609#comment-17162609 ] Shengkai Fang commented on FLINK-18667: --- Hi, [~lzljs3620320] I am interested in this jiar. Could

[jira] [Updated] (FLINK-18857) Invalid lambda deserialization when use ElasticsearchSink#Builder to build ElasticserachSink

2020-08-08 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-18857: -- Description: Currently when we use code below {code:java} new

[jira] [Commented] (FLINK-18857) Invalid lambda deserialization when use ElasticsearchSink#Builder to build ElasticserachSink

2020-08-08 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173603#comment-17173603 ] Shengkai Fang commented on FLINK-18857: --- cc [~jark] > Invalid lambda deserialization when use

[jira] [Created] (FLINK-18857) Invalid lambda deserialization when use ElasticsearchSink#Builder to build ElasticserachSink

2020-08-08 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-18857: - Summary: Invalid lambda deserialization when use ElasticsearchSink#Builder to build ElasticserachSink Key: FLINK-18857 URL: https://issues.apache.org/jira/browse/FLINK-18857

[jira] [Commented] (FLINK-18779) Support the SupportsFilterPushDown interface for LookupTableSource

2020-08-06 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172112#comment-17172112 ] Shengkai Fang commented on FLINK-18779: --- Hi [~jark], I am interested in this jira. Could you

[jira] [Commented] (FLINK-18240) Correct modulus function usage in documentation or allow % operator

2020-07-02 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17150247#comment-17150247 ] Shengkai Fang commented on FLINK-18240: --- Hi [~jark] I'm very interested in this issue. Could you

[jira] [Created] (FLINK-18602) Support specific offset for topic list for kafka connector in table api

2020-07-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-18602: - Summary: Support specific offset for topic list for kafka connector in table api Key: FLINK-18602 URL: https://issues.apache.org/jira/browse/FLINK-18602 Project:

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

2020-07-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157848#comment-17157848 ] Shengkai Fang commented on FLINK-18449: --- Hi, all. I find that FlinkKafkaProducer doesn't support

[jira] [Updated] (FLINK-18602) Support specific offset for topic list for kafka connector in table api

2020-07-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-18602: -- Description: During FLINK-18449, we decide to support topic discovery for kafka connector in

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

2020-07-04 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151472#comment-17151472 ] Shengkai Fang commented on FLINK-18449: --- I'm also fine with [~jark]'s proposal. Although

[jira] [Commented] (FLINK-15221) supporting Exactly-once for kafka table APi

2020-06-30 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17149050#comment-17149050 ] Shengkai Fang commented on FLINK-15221: --- According to [FLIP-122

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

2020-07-01 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17149183#comment-17149183 ] Shengkai Fang commented on FLINK-18449: --- It's my pleasure to work on this. For the first

[jira] [Commented] (FLINK-18351) ModuleManager creates a lot of duplicate/similar log messages

2020-06-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142594#comment-17142594 ] Shengkai Fang commented on FLINK-18351: --- The reason why we have repeated logs is that

[jira] [Comment Edited] (FLINK-18351) ModuleManager creates a lot of duplicate/similar log messages

2020-06-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142594#comment-17142594 ] Shengkai Fang edited comment on FLINK-18351 at 6/23/20, 3:36 AM: - The

[jira] [Commented] (FLINK-18351) ModuleManager creates a lot of duplicate/similar log messages

2020-06-23 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142905#comment-17142905 ] Shengkai Fang commented on FLINK-18351: --- OK, I will fix this problem soon. > ModuleManager

[jira] [Commented] (FLINK-14719) Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API

2020-06-29 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147741#comment-17147741 ] Shengkai Fang commented on FLINK-14719: --- In release 1.11, we still can't set `semantic` in

[jira] [Reopened] (FLINK-14719) Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API

2020-06-29 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reopened FLINK-14719: --- > Making Semantic configurable in Flinkkafkaproducer to support exactly-once > semantic in

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

2020-06-29 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-18449: -- Description: In streaming api, we can use regex to find topic and enable partiton discovery

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

2020-06-29 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-18449: -- Description: In streaming api, we can use regex to find topic and enable partiton discovery

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

2020-06-29 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-18449: - Summary: Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API Key: FLINK-18449 URL: https://issues.apache.org/jira/browse/FLINK-18449

[jira] [Created] (FLINK-18296) Add support for datetype TIMESTAMP_WITH_LOCAL_ZONE for Json format

2020-06-15 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-18296: - Summary: Add support for datetype TIMESTAMP_WITH_LOCAL_ZONE for Json format Key: FLINK-18296 URL: https://issues.apache.org/jira/browse/FLINK-18296 Project: Flink

[jira] [Created] (FLINK-18299) Add keyword in json format to parse timestamp in different standard

2020-06-15 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-18299: - Summary: Add keyword in json format to parse timestamp in different standard Key: FLINK-18299 URL: https://issues.apache.org/jira/browse/FLINK-18299 Project: Flink

[jira] [Updated] (FLINK-18296) Add support for datetype TIMESTAMP_WITH_LOCAL_ZONE for Json format

2020-06-15 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-18296: -- Parent: FLINK-17752 Issue Type: Sub-task (was: Bug) > Add support for datetype

[jira] [Updated] (FLINK-18299) Add keyword in json format to parse timestamp in different standard

2020-06-15 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-18299: -- Description: Add keyword such as 'timestamp-format.standard' in json format to parse

[jira] [Updated] (FLINK-18299) Add keyword in json format to parse timestamp in different standard

2020-06-15 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-18299: -- Parent: FLINK-17752 Issue Type: Sub-task (was: Bug) > Add keyword in json format to

[jira] [Commented] (FLINK-18390) Translate "JSON Format" page into Chinese

2020-06-19 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140948#comment-17140948 ] Shengkai Fang commented on FLINK-18390: --- Hi, [~jark]. I am willing to help. Please assign it to

[jira] [Commented] (FLINK-17544) NPE JDBCUpsertOutputFormat

2020-06-17 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138957#comment-17138957 ] Shengkai Fang commented on FLINK-17544: --- It seems that TableJdbcUpsertOutputFormat exits

[jira] [Closed] (FLINK-18093) E2E tests manually for Elasticsearch Sink

2020-06-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-18093. - Resolution: Fixed > E2E tests manually for Elasticsearch Sink >

[jira] [Created] (FLINK-18176) Add supplement for file system connector document

2020-06-08 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-18176: - Summary: Add supplement for file system connector document Key: FLINK-18176 URL: https://issues.apache.org/jira/browse/FLINK-18176 Project: Flink Issue

[jira] [Commented] (FLINK-18026) E2E tests manually for Kafka connector and all formats

2020-06-07 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127854#comment-17127854 ] Shengkai Fang commented on FLINK-18026: --- Currently we have cases: KafkaAvro2Kafka, KafkaCsv2Kafka

[jira] [Comment Edited] (FLINK-18093) E2E tests manually for Elasticsearch Sink

2020-06-07 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127853#comment-17127853 ] Shengkai Fang edited comment on FLINK-18093 at 6/8/20, 3:48 AM:

[jira] [Commented] (FLINK-18028) E2E tests manually for MySQL JDBC

2020-06-07 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127861#comment-17127861 ] Shengkai Fang commented on FLINK-18028: --- Currently we have cases: KafkaJoinJdbc2AppendJdbc and

[jira] [Commented] (FLINK-18093) E2E tests manually for Elasticsearch Sink

2020-06-07 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127853#comment-17127853 ] Shengkai Fang commented on FLINK-18093: --- Currently we have cases:  Kafka2AppendEs,

[jira] [Closed] (FLINK-18028) E2E tests manually for MySQL JDBC

2020-06-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-18028. - Resolution: Fixed > E2E tests manually for MySQL JDBC > - > >

[jira] [Closed] (FLINK-18026) E2E tests manually for Kafka connector and all formats

2020-06-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-18026. - Resolution: Fixed > E2E tests manually for Kafka connector and all formats >

[jira] [Commented] (FLINK-18616) Add SHOW CURRENT DDLs

2020-07-16 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159147#comment-17159147 ] Shengkai Fang commented on FLINK-18616: --- Hi, [~lzljs3620320] I am interested in this issue. Could

[jira] [Commented] (FLINK-18747) Make Debezium Json format support timestamp with timezone

2020-07-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166852#comment-17166852 ] Shengkai Fang commented on FLINK-18747: --- [~lhao] Yes. Debezium uses the same json format. > Make

[jira] [Commented] (FLINK-18747) Make Debezium Json format support timestamp with timezone

2020-07-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166839#comment-17166839 ] Shengkai Fang commented on FLINK-18747: --- Currently, we have implemented TIMESTAMP_WITH_LOCAL_ZONE

[jira] [Commented] (FLINK-16528) Support Limit push down for streaming sources

2020-07-21 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161858#comment-17161858 ] Shengkai Fang commented on FLINK-16528: --- Hi, [~app-tarush] I am also interested in this jira. Do

[jira] [Commented] (FLINK-17427) Support SupportsPartitionPushDown in planner

2020-07-21 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161964#comment-17161964 ] Shengkai Fang commented on FLINK-17427: --- Hi, [~jark] I'm interested in this Jira. Could you assign

[jira] [Commented] (FLINK-16384) Support SHOW CREATE TABLE command in SQL Client

2020-07-21 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161969#comment-17161969 ] Shengkai Fang commented on FLINK-16384: --- Hi, [~jark]. Could you assign it to me? It's my pleasure

[jira] [Updated] (FLINK-16528) Support Limit push down for streaming sources

2020-07-21 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-16528: -- Attachment: PushProjectIntoTableSourceScanRule.java > Support Limit push down for streaming

[jira] [Updated] (FLINK-16528) Support Limit push down for streaming sources

2020-07-21 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-16528: -- Attachment: (was: PushProjectIntoTableSourceScanRule.java) > Support Limit push down for

[jira] [Created] (FLINK-18958) Lose column comment when create table

2020-08-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-18958: - Summary: Lose column comment when create table Key: FLINK-18958 URL: https://issues.apache.org/jira/browse/FLINK-18958 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-20880) Turn Json String into Row

2021-01-11 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-20880: -- Component/s: (was: API / Core) Formats (JSON, Avro, Parquet, ORC,

[jira] [Updated] (FLINK-20273) Fix Table api Kafka connector Sink Partitioner Document Error

2020-11-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-20273: -- Description: The

[jira] [Created] (FLINK-20273) Fix Table api Kafka connector Sink Partitioner Document Error

2020-11-22 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-20273: - Summary: Fix Table api Kafka connector Sink Partitioner Document Error Key: FLINK-20273 URL: https://issues.apache.org/jira/browse/FLINK-20273 Project: Flink

[jira] [Created] (FLINK-20271) ArrayIndexOutOfBounds When using Rank

2020-11-21 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-20271: - Summary: ArrayIndexOutOfBounds When using Rank Key: FLINK-20271 URL: https://issues.apache.org/jira/browse/FLINK-20271 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20272) Wrong result of Rank Function

2020-11-21 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-20272: - Summary: Wrong result of Rank Function Key: FLINK-20272 URL: https://issues.apache.org/jira/browse/FLINK-20272 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-20362) Broken Link in dev/table/sourceSinks.zh.md

2020-11-25 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239014#comment-17239014 ] Shengkai Fang commented on FLINK-20362: --- ok. I will fix it. > Broken Link in

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

2020-11-26 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239139#comment-17239139 ] Shengkai Fang commented on FLINK-20370: --- I am not sure whether this Jira will take the example

[jira] [Commented] (FLINK-20372) flink sql kafka connector cannot config kerberos

2020-11-26 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239152#comment-17239152 ] Shengkai Fang commented on FLINK-20372: --- ok. Please assign it to me. > flink sql kafka connector

[jira] [Created] (FLINK-20321) Get NPE when using AvroDeserializationSchema to deserialize null input

2020-11-24 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-20321: - Summary: Get NPE when using AvroDeserializationSchema to deserialize null input Key: FLINK-20321 URL: https://issues.apache.org/jira/browse/FLINK-20321 Project:

[jira] [Commented] (FLINK-20314) Empty Calc is not removed by CalcRemoveRule

2020-11-24 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238474#comment-17238474 ] Shengkai Fang commented on FLINK-20314: --- Please assign it to me [~jark] . I will fix it. > Empty

[jira] [Comment Edited] (FLINK-20121) Test the upsert-kafka Connector

2020-11-25 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235996#comment-17235996 ] Shengkai Fang edited comment on FLINK-20121 at 11/25/20, 8:45 AM: -- E2E

[jira] [Comment Edited] (FLINK-20121) Test the upsert-kafka Connector

2020-11-25 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235996#comment-17235996 ] Shengkai Fang edited comment on FLINK-20121 at 11/25/20, 8:46 AM: -- E2E

[jira] [Closed] (FLINK-20121) Test the upsert-kafka Connector

2020-11-25 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-20121. - Resolution: Fixed > Test the upsert-kafka Connector > --- > >

[jira] [Commented] (FLINK-20734) SQL client error when running joining query

2020-12-23 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254365#comment-17254365 ] Shengkai Fang commented on FLINK-20734: --- Could you give us more information about how to reproduce

[jira] [Updated] (FLINK-20760) Broken doc link in Apache Flink Code Style and Quality Guide

2020-12-23 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-20760: -- Description: The link in pic is broken. The [usage of Java

[jira] [Updated] (FLINK-20760) Broken doc link in Apache Flink Code Style and Quality Guide

2020-12-23 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-20760: -- Description: The link in pic is broken. The [usage of Java

[jira] [Updated] (FLINK-20760) Broken doc link in Apache Flink Code Style and Quality Guide

2020-12-23 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-20760: -- Attachment: image-2020-12-24-15-56-04-643.png > Broken doc link in Apache Flink Code Style

[jira] [Created] (FLINK-20760) Broken doc link in Apache Flink Code Style and Quality Guide

2020-12-23 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-20760: - Summary: Broken doc link in Apache Flink Code Style and Quality Guide Key: FLINK-20760 URL: https://issues.apache.org/jira/browse/FLINK-20760 Project: Flink

[jira] [Commented] (FLINK-20760) Broken doc link in Apache Flink Code Style and Quality Guide

2020-12-24 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254733#comment-17254733 ] Shengkai Fang commented on FLINK-20760: --- [~liqi25] Sure. > Broken doc link in Apache Flink Code

[jira] [Closed] (FLINK-17752) Align the timestamp format with Flink SQL types in JSON format

2020-11-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-17752. - Resolution: Fixed > Align the timestamp format with Flink SQL types in JSON format >

[jira] [Commented] (FLINK-20128) Data loss for over windows with rows unbounded preceding

2020-11-13 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231347#comment-17231347 ] Shengkai Fang commented on FLINK-20128: --- [~dian.fu] In my local enviroment, my java code are

[jira] [Commented] (FLINK-20128) Data loss for over windows with rows unbounded preceding

2020-11-13 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231243#comment-17231243 ] Shengkai Fang commented on FLINK-20128: --- I don't get the expected bug by sql-client and java table

[jira] [Commented] (FLINK-18784) Push Projection through WatermarkAssigner

2020-11-16 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233197#comment-17233197 ] Shengkai Fang commented on FLINK-18784: --- This work has been done during the watermark push down.

  1   2   3   4   5   6   7   8   9   10   >