[jira] [Commented] (FLINK-20671) Partition doesn't commit until the end of partition

2020-12-18 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251630#comment-17251630 ] xiaozilong commented on FLINK-20671: I'm also confused about this. > Partition does

[jira] [Commented] (FLINK-20746) Support ignore-first-line option for CSV format

2020-12-23 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17254446#comment-17254446 ] xiaozilong commented on FLINK-20746: Hi [~Leonard Xu], I think `ignore-first-line` o

[jira] [Created] (FLINK-20773) Support allow-unescaped-control-chars option for JSON format

2020-12-25 Thread xiaozilong (Jira)
xiaozilong created FLINK-20773: -- Summary: Support allow-unescaped-control-chars option for JSON format Key: FLINK-20773 URL: https://issues.apache.org/jira/browse/FLINK-20773 Project: Flink Iss

[jira] [Updated] (FLINK-20773) Support allow-unescaped-control-chars option for JSON format

2020-12-25 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20773: --- Description: Can we add an option `allow-unquoted-ctrl-char` for json format because of it will thr

[jira] [Commented] (FLINK-20773) Support allow-unescaped-control-chars option for JSON format

2020-12-25 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17254818#comment-17254818 ] xiaozilong commented on FLINK-20773: cc [~jark] > Support allow-unescaped-control-c

[jira] [Updated] (FLINK-20773) Support allow-unescaped-control-chars option for JSON format

2020-12-25 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20773: --- Description: Can we add an option `allow-unquoted-ctrl-char` for json format because of it will thr

[jira] [Updated] (FLINK-20773) Support allow-unescaped-control-chars option for JSON format

2020-12-25 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20773: --- Description: Can we add an option `allow-unescaped-control-chars` for json format because of it wil

[jira] [Commented] (FLINK-20773) Support allow-unescaped-control-chars option for JSON format

2020-12-27 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255207#comment-17255207 ] xiaozilong commented on FLINK-20773: Thanks [~jark] , i will do it. > Support allow

[jira] [Created] (FLINK-20776) Error message is incomplete in JSON format

2020-12-27 Thread xiaozilong (Jira)
xiaozilong created FLINK-20776: -- Summary: Error message is incomplete in JSON format Key: FLINK-20776 URL: https://issues.apache.org/jira/browse/FLINK-20776 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-20776) Error message is incomplete in JSON format

2020-12-27 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255353#comment-17255353 ] xiaozilong commented on FLINK-20776: ok > Error message is incomplete in JSON forma

[jira] [Closed] (FLINK-20776) Error message is incomplete in JSON format

2020-12-27 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong closed FLINK-20776. -- Resolution: Not A Problem > Error message is incomplete in JSON format > -

[jira] [Created] (FLINK-20789) Add a metric named `deserializeFaildCount` for kafka connectors

2020-12-28 Thread xiaozilong (Jira)
xiaozilong created FLINK-20789: -- Summary: Add a metric named `deserializeFaildCount` for kafka connectors Key: FLINK-20789 URL: https://issues.apache.org/jira/browse/FLINK-20789 Project: Flink

[jira] [Commented] (FLINK-20789) Add a metric named `deserializeFaildCount` for kafka connectors

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255766#comment-17255766 ] xiaozilong commented on FLINK-20789: cc [~jark] > Add a metric named `deserializeFa

[jira] [Updated] (FLINK-20789) Add a metric named `deserializeFaildCount` for kafka connectors

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20789: --- Description: Counts the number of deserialize failed when the option `ignore-parse-errors` is enabl

[jira] [Commented] (FLINK-20795) add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255804#comment-17255804 ] xiaozilong commented on FLINK-20795: Hi [~zoucao], I think is useful. Mayby we shoul

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255804#comment-17255804 ] xiaozilong edited comment on FLINK-20795 at 12/29/20, 4:33 AM: ---

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255804#comment-17255804 ] xiaozilong edited comment on FLINK-20795 at 12/29/20, 4:35 AM: ---

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255804#comment-17255804 ] xiaozilong edited comment on FLINK-20795 at 12/29/20, 5:01 AM: ---

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255804#comment-17255804 ] xiaozilong edited comment on FLINK-20795 at 12/29/20, 5:09 AM: ---

[jira] [Updated] (FLINK-20789) Add a metric named `deserializeFaildCount` for formats which has option ``

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20789: --- Summary: Add a metric named `deserializeFaildCount` for formats which has option `` (was: Add a met

[jira] [Updated] (FLINK-20789) Add a metric named `deserializeFaildCount` for formats

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20789: --- Summary: Add a metric named `deserializeFaildCount` for formats (was: Add a metric named `deseriali

[jira] [Commented] (FLINK-20789) Add a metric named `deserializeFaildCount` for kafka connectors

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255827#comment-17255827 ] xiaozilong commented on FLINK-20789: [~jark] Sorry, I updated the title. > Add a me

[jira] [Updated] (FLINK-20789) Add a metric named `deserializeFaildCount` for formats which has option `ignore-parse-errors`

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20789: --- Summary: Add a metric named `deserializeFaildCount` for formats which has option `ignore-parse-error

[jira] [Updated] (FLINK-20789) Add a metric named `deserializeFailedCount` for formats which has option `ignore-parse-errors`

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20789: --- Summary: Add a metric named `deserializeFailedCount` for formats which has option `ignore-parse-erro

[jira] [Updated] (FLINK-20789) Add a metric named `deserializeFailedCount` for formats which has option `ignore-parse-errors`

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20789: --- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Add a metric named `deserializeFaile

[jira] [Commented] (FLINK-20795) add a parameter to decide whether print dirty record when `ignore-parse-errors` is true

2021-01-01 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17257168#comment-17257168 ] xiaozilong commented on FLINK-20795: [~zoucao] Yes, i think so. What do you think ab

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether print dirty record when `ignore-parse-errors` is true

2021-01-01 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255804#comment-17255804 ] xiaozilong edited comment on FLINK-20795 at 1/1/21, 10:51 AM:

[jira] [Updated] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-11-05 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19687: --- Description: Hi, I want to get job's execution plan in Flink SQL 1.11, but i meet exception  "No ope

[jira] [Commented] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-11-16 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232660#comment-17232660 ] xiaozilong commented on FLINK-19687: Hi [~jark], Could you talk about your thoughts

[jira] [Commented] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-11-18 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234464#comment-17234464 ] xiaozilong commented on FLINK-19687: [~jark] Yes, that sounds good. Can assign this

[jira] [Commented] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-11-18 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234509#comment-17234509 ] xiaozilong commented on FLINK-19687: [~jark] Okay, Thanks for your reminder. > Supp

[jira] [Commented] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-11-18 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235107#comment-17235107 ] xiaozilong commented on FLINK-19687: [~jark] Thanks~ > Support to get execution pla

[jira] [Created] (FLINK-20243) Remove useless words in documents

2020-11-19 Thread xiaozilong (Jira)
xiaozilong created FLINK-20243: -- Summary: Remove useless words in documents Key: FLINK-20243 URL: https://issues.apache.org/jira/browse/FLINK-20243 Project: Flink Issue Type: Bug Compo

[jira] [Commented] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-10-21 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218724#comment-17218724 ] xiaozilong commented on FLINK-19687: cc [~godfreyhe] > Support to get execution pla

[jira] [Commented] (FLINK-19779) Remove the "record_" field name prefix for Confluent Avro format deserialization

2020-10-23 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17219588#comment-17219588 ] xiaozilong commented on FLINK-19779: Hi [~danny0405] , I think there is still existe

[jira] [Comment Edited] (FLINK-19779) Remove the "record_" field name prefix for Confluent Avro format deserialization

2020-10-23 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17219588#comment-17219588 ] xiaozilong edited comment on FLINK-19779 at 10/23/20, 9:54 AM: ---

[jira] [Comment Edited] (FLINK-19779) Remove the "record_" field name prefix for Confluent Avro format deserialization

2020-10-23 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17219588#comment-17219588 ] xiaozilong edited comment on FLINK-19779 at 10/23/20, 10:03 AM: --

[jira] [Commented] (FLINK-19779) Remove the "record_" field name prefix for Confluent Avro format deserialization

2020-10-26 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220568#comment-17220568 ] xiaozilong commented on FLINK-19779: [~danny0405] So, we should update the code? I t

[jira] [Comment Edited] (FLINK-19779) Remove the "record_" field name prefix for Confluent Avro format deserialization

2020-10-26 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220568#comment-17220568 ] xiaozilong edited comment on FLINK-19779 at 10/26/20, 8:54 AM: ---

[jira] [Comment Edited] (FLINK-19779) Remove the "record_" field name prefix for Confluent Avro format deserialization

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

[jira] [Comment Edited] (FLINK-19779) Remove the "record_" field name prefix for Confluent Avro format deserialization

2020-10-26 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220568#comment-17220568 ] xiaozilong edited comment on FLINK-19779 at 10/26/20, 12:21 PM: --

[jira] [Created] (FLINK-19291) Meeting `SchemaParseException` when I use `AvroSchemaConverter` converts flink logical type

2020-09-18 Thread xiaozilong (Jira)
xiaozilong created FLINK-19291: -- Summary: Meeting `SchemaParseException` when I use `AvroSchemaConverter` converts flink logical type Key: FLINK-19291 URL: https://issues.apache.org/jira/browse/FLINK-19291

[jira] [Commented] (FLINK-19291) Meeting `SchemaParseException` when I use `AvroSchemaConverter` converts flink logical type

2020-09-18 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198230#comment-17198230 ] xiaozilong commented on FLINK-19291: if it determinated, can assign this issue to me

[jira] [Updated] (FLINK-19291) Meeting `SchemaParseException` when I use `AvroSchemaConverter` converts flink logical type

2020-09-18 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19291: --- Description: Hi, I use `AvroSchemaConverter` to converts flink logical type into an avro schema wil

[jira] [Updated] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-09-18 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19291: --- Summary: Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

[jira] [Updated] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-09-18 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19291: --- Description: Hi, I use `AvroSchemaConverter` to converts flink logical type into an avro schema wil

[jira] [Updated] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-09-18 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19291: --- Description: Hi, I use `AvroSchemaConverter` to converts flink logical type into an avro schema wil

[jira] [Updated] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-09-18 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19291: --- Description: Hi, I use `AvroSchemaConverter` to converts flink logical type into an avro schema wil

[jira] [Comment Edited] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-09-18 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198230#comment-17198230 ] xiaozilong edited comment on FLINK-19291 at 9/18/20, 12:03 PM: ---

[jira] [Commented] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-09-21 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199310#comment-17199310 ] xiaozilong commented on FLINK-19291: @benchao hi benchao, can you help me to review

[jira] [Comment Edited] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-09-21 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199310#comment-17199310 ] xiaozilong edited comment on FLINK-19291 at 9/21/20, 10:30 AM: ---

[jira] [Comment Edited] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-09-21 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199310#comment-17199310 ] xiaozilong edited comment on FLINK-19291 at 9/21/20, 1:02 PM:

[jira] [Updated] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-09-22 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19291: --- Attachment: image-2020-09-22-15-16-50-130.png > Meeting `SchemaParseException` when use `AvroSchemaC

[jira] [Commented] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-09-22 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1719#comment-1719 ] xiaozilong commented on FLINK-19291: Thanks for review this issue [~jark] , I think

[jira] [Commented] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-09-22 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200596#comment-17200596 ] xiaozilong commented on FLINK-19291: okay:D > Meeting `SchemaParseException` when u

[jira] [Updated] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-10-09 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19291: --- Description: Hi, I use `AvroSchemaConverter` to converts flink logical type into an avro schema wil

[jira] [Updated] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-10-09 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19291: --- Description: Hi, I use `AvroSchemaConverter` to converts flink logical type into an avro schema wil

[jira] [Updated] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-10-09 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19291: --- Description: Hi, I use `AvroSchemaConverter` to converts flink logical type into an avro schema wil

[jira] [Updated] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-10-09 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19291: --- Description: Hi, I use `AvroSchemaConverter` to converts flink logical type into an avro schema wil

[jira] [Created] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-10-17 Thread xiaozilong (Jira)
xiaozilong created FLINK-19687: -- Summary: Support to get execution plan in `StatementSet` Key: FLINK-19687 URL: https://issues.apache.org/jira/browse/FLINK-19687 Project: Flink Issue Type: Wish

[jira] [Commented] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-10-17 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17215811#comment-17215811 ] xiaozilong commented on FLINK-19687: [~jark] Hi Jark, can you help me to review this

[jira] [Commented] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-10-17 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17215827#comment-17215827 ] xiaozilong commented on FLINK-19687: Hi [~hailong wang], I want to visualize the exe

[jira] [Comment Edited] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-10-17 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17215827#comment-17215827 ] xiaozilong edited comment on FLINK-19687 at 10/17/20, 9:37 AM: ---

[jira] [Created] (FLINK-19713) Update `JobGraphUtils` type to class

2020-10-19 Thread xiaozilong (Jira)
xiaozilong created FLINK-19713: -- Summary: Update `JobGraphUtils` type to class Key: FLINK-19713 URL: https://issues.apache.org/jira/browse/FLINK-19713 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-19713) Update `JobGraphUtils` type to class

2020-10-19 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19713: --- Attachment: image-2020-10-19-20-26-04-187.png > Update `JobGraphUtils` type to class > -

[jira] [Commented] (FLINK-19713) Update `JobGraphUtils` type to class

2020-10-19 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216678#comment-17216678 ] xiaozilong commented on FLINK-19713: !image-2020-10-19-20-26-04-187.png! > Update `

[jira] [Comment Edited] (FLINK-19713) Update `JobGraphUtils` type to class

2020-10-19 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216678#comment-17216678 ] xiaozilong edited comment on FLINK-19713 at 10/19/20, 12:26 PM: --

[jira] [Updated] (FLINK-19713) Update `JobGraphUtils` type to class

2020-10-19 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19713: --- Attachment: (was: image-2020-10-19-20-26-04-187.png) > Update `JobGraphUtils` type to class > --

[jira] [Closed] (FLINK-19713) Update `JobGraphUtils` type to class

2020-10-19 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong closed FLINK-19713. -- Resolution: Invalid > Update `JobGraphUtils` type to class > > >

[jira] [Created] (FLINK-20451) Taskmanager Could't apply resources if use configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
xiaozilong created FLINK-20451: -- Summary: Taskmanager Could't apply resources if use configs `env.java.opts.taskmanager: -javaagent:` Key: FLINK-20451 URL: https://issues.apache.org/jira/browse/FLINK-20451

[jira] [Updated] (FLINK-20451) Taskmanager Could't apply resources if use configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20451: --- Description: Hi, I meet an unexpected problem that the taskmanager can't apply resources when use c

[jira] [Updated] (FLINK-20451) Taskmanager Could't apply resources if use configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20451: --- Attachment: (was: image-2020-12-02-20-16-50-002.png) > Taskmanager Could't apply resources if us

[jira] [Updated] (FLINK-20451) Taskmanager can't apply resources if use configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20451: --- Summary: Taskmanager can't apply resources if use configs `env.java.opts.taskmanager: -javaagent:`

[jira] [Updated] (FLINK-20451) Taskmanager can't apply resources when submit job with configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20451: --- Summary: Taskmanager can't apply resources when submit job with configs `env.java.opts.taskmanager:

[jira] [Updated] (FLINK-20451) Taskmanager can't apply resources when submit job with configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20451: --- Description: Hi, I meet an unexpected problem that the taskmanager can't apply resources when submi

[jira] [Updated] (FLINK-20451) Taskmanager can't apply resources when submit job with configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20451: --- Component/s: Deployment / YARN > Taskmanager can't apply resources when submit job with configs > `

[jira] [Commented] (FLINK-20451) Taskmanager can't apply resources when submit job with configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242892#comment-17242892 ] xiaozilong commented on FLINK-20451: Hi [~xintongsong],  The problem is that TM can

[jira] [Updated] (FLINK-20451) Taskmanager can't allocate resources when submit job with configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20451: --- Summary: Taskmanager can't allocate resources when submit job with configs `env.java.opts.taskmanage

[jira] [Closed] (FLINK-20451) Taskmanager can't allocate resources when submit job with configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong closed FLINK-20451. -- Resolution: Not A Problem > Taskmanager can't allocate resources when submit job with configs > `env.

[jira] [Commented] (FLINK-20510) Enable log4j2 monitor interval by default

2020-12-07 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245181#comment-17245181 ] xiaozilong commented on FLINK-20510: Hi [~chesnay] , Logback also support it, Do we

[jira] [Comment Edited] (FLINK-20510) Enable log4j2 monitor interval by default

2020-12-07 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245181#comment-17245181 ] xiaozilong edited comment on FLINK-20510 at 12/7/20, 12:52 PM: ---

[jira] [Commented] (FLINK-20510) Enable log4j2 monitor interval by default

2020-12-07 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245214#comment-17245214 ] xiaozilong commented on FLINK-20510: Okay, I will try it. Thanks! > Enable log4j2 m

[jira] [Created] (FLINK-20526) Enable logback scan configuration by default

2020-12-07 Thread xiaozilong (Jira)
xiaozilong created FLINK-20526: -- Summary: Enable logback scan configuration by default Key: FLINK-20526 URL: https://issues.apache.org/jira/browse/FLINK-20526 Project: Flink Issue Type: Improvem

[jira] [Commented] (FLINK-20526) Enable logback scan configuration by default

2020-12-07 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245690#comment-17245690 ] xiaozilong commented on FLINK-20526: Hi @[~chesnay] , Everything runs fine when i te

[jira] [Updated] (FLINK-20526) Enable logback scan configuration by default

2020-12-08 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20526: --- Description: We should enable this by default which same as FLINK-20510 This was:We should enabl

[jira] [Updated] (FLINK-20526) Enable logback scan configuration by default

2020-12-08 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20526: --- Description: We should enable this by default which same as FLINK-20510 This my logback.xml {code:j

[jira] [Created] (FLINK-20530) Invalid metric named `lastCheckpointExternalPath`

2020-12-08 Thread xiaozilong (Jira)
xiaozilong created FLINK-20530: -- Summary: Invalid metric named `lastCheckpointExternalPath` Key: FLINK-20530 URL: https://issues.apache.org/jira/browse/FLINK-20530 Project: Flink Issue Type: Bu

[jira] [Commented] (FLINK-20530) Invalid metric named `lastCheckpointExternalPath`

2020-12-08 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245800#comment-17245800 ] xiaozilong commented on FLINK-20530: cc [~chesnay] , Could you help to review this?

[jira] [Commented] (FLINK-20530) Invalid metric named `lastCheckpointExternalPath`

2020-12-08 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245827#comment-17245827 ] xiaozilong commented on FLINK-20530: [~chesnay] Sorry, I did not consider other repo

[jira] [Created] (FLINK-20543) Fix typo in upsert kafka docs

2020-12-08 Thread xiaozilong (Jira)
xiaozilong created FLINK-20543: -- Summary: Fix typo in upsert kafka docs Key: FLINK-20543 URL: https://issues.apache.org/jira/browse/FLINK-20543 Project: Flink Issue Type: Bug Component

[jira] [Commented] (FLINK-20526) Enable logback scan configuration by default

2020-12-08 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246337#comment-17246337 ] xiaozilong commented on FLINK-20526: The configuration scan is enabled by default fo

[jira] [Comment Edited] (FLINK-20526) Enable logback scan configuration by default

2020-12-09 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246337#comment-17246337 ] xiaozilong edited comment on FLINK-20526 at 12/9/20, 9:08 AM:

[jira] [Updated] (FLINK-20561) Add documentation for `records-lag-max` metric.

2020-12-10 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20561: --- Description: Currently, there are no metric description for kafka topic's lag in f[link metrics do

[jira] [Created] (FLINK-20561) Add documentation for `records-lag-max` metric.

2020-12-10 Thread xiaozilong (Jira)
xiaozilong created FLINK-20561: -- Summary: Add documentation for `records-lag-max` metric. Key: FLINK-20561 URL: https://issues.apache.org/jira/browse/FLINK-20561 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-20561) Add documentation for `records-lag-max` metric.

2020-12-10 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247139#comment-17247139 ] xiaozilong commented on FLINK-20561: We can type `flink_taskmanager_job_task_operato

[jira] [Created] (FLINK-20565) Fix typo in EXPLAIN Statements docs.

2020-12-10 Thread xiaozilong (Jira)
xiaozilong created FLINK-20565: -- Summary: Fix typo in EXPLAIN Statements docs. Key: FLINK-20565 URL: https://issues.apache.org/jira/browse/FLINK-20565 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-20566) Fix typo in `Cassandra Connector` docs.

2020-12-10 Thread xiaozilong (Jira)
xiaozilong created FLINK-20566: -- Summary: Fix typo in `Cassandra Connector` docs. Key: FLINK-20566 URL: https://issues.apache.org/jira/browse/FLINK-20566 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-20561) Add documentation for `records-lag-max` metric.

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

[jira] [Created] (FLINK-20582) Fix typos in `CREATE Statements` docs

2020-12-11 Thread xiaozilong (Jira)
xiaozilong created FLINK-20582: -- Summary: Fix typos in `CREATE Statements` docs Key: FLINK-20582 URL: https://issues.apache.org/jira/browse/FLINK-20582 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-21062) Meeting NPE when using the dynamic Index in elasticsearch connector

2021-01-20 Thread xiaozilong (Jira)
xiaozilong created FLINK-21062: -- Summary: Meeting NPE when using the dynamic Index in elasticsearch connector Key: FLINK-21062 URL: https://issues.apache.org/jira/browse/FLINK-21062 Project: Flink

  1   2   >