[jira] [Commented] (FLINK-16521) Remove unused FileUtils#isClassFile

[ https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057693#comment-17057693 ] jinhai commented on FLINK-16521: Why does it have to be deleted? it's just not in use now > Remove

[jira] [Updated] (FLINK-16567) Get the API error of the StreamQueryConfig on Page "Query Configuration"

[ https://issues.apache.org/jira/browse/FLINK-16567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinhai updated FLINK-16567: --- Description: {code:java} // code placeholder StreamExecutionEnvironment env =

[jira] [Created] (FLINK-16567) Get the API error of the StreamQueryConfig on Page "Query Configuration"

jinhai created FLINK-16567: -- Summary: Get the API error of the StreamQueryConfig on Page "Query Configuration" Key: FLINK-16567 URL: https://issues.apache.org/jira/browse/FLINK-16567 Project: Flink

[jira] [Commented] (FLINK-16567) Get the API error of the StreamQueryConfig on Page "Query Configuration"

[ https://issues.apache.org/jira/browse/FLINK-16567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057742#comment-17057742 ] jinhai commented on FLINK-16567: Can I have this issue? > Get the API error of the StreamQueryConfig on

[jira] [Created] (FLINK-17200) Add connectors to ClickHouse

jinhai created FLINK-17200: -- Summary: Add connectors to ClickHouse Key: FLINK-17200 URL: https://issues.apache.org/jira/browse/FLINK-17200 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-17201) Implement Streaming ClickHouseSink

jinhai created FLINK-17201: -- Summary: Implement Streaming ClickHouseSink Key: FLINK-17201 URL: https://issues.apache.org/jira/browse/FLINK-17201 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-17203) Add metrics for ClickHouse sink

jinhai created FLINK-17203: -- Summary: Add metrics for ClickHouse sink Key: FLINK-17203 URL: https://issues.apache.org/jira/browse/FLINK-17203 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-17202) Add SQL for ClickHouse connector

jinhai created FLINK-17202: -- Summary: Add SQL for ClickHouse connector Key: FLINK-17202 URL: https://issues.apache.org/jira/browse/FLINK-17202 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-17200) Add connectors to ClickHouse

[ https://issues.apache.org/jira/browse/FLINK-17200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085541#comment-17085541 ] jinhai commented on FLINK-17200: [~chesnay] [~dwysakowicz] Thanks.I get it > Add connectors to

[jira] [Updated] (FLINK-17200) Add connectors to ClickHouse

[ https://issues.apache.org/jira/browse/FLINK-17200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinhai updated FLINK-17200: --- Description: Clickhouse is a powerful OLAP query engine and supports real-time data mini batch writing.

[jira] [Commented] (FLINK-17200) Add connectors to ClickHouse

[ https://issues.apache.org/jira/browse/FLINK-17200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085523#comment-17085523 ] jinhai commented on FLINK-17200: @Dawid @dev Can we separate the flink-connectors project so that we

[jira] [Commented] (FLINK-16592) The doc of Streaming File Sink has a mistake of grammar

[ https://issues.apache.org/jira/browse/FLINK-16592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059635#comment-17059635 ] jinhai commented on FLINK-16592: Can I have this issue? > The doc of Streaming File Sink has a mistake

[jira] [Commented] (FLINK-16567) Get the API error of the StreamQueryConfig on Page "Query Configuration"

[ https://issues.apache.org/jira/browse/FLINK-16567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059644#comment-17059644 ] jinhai commented on FLINK-16567: Hi [~ykt836] StreamQueryConfig is deprecated and replaced by

[jira] [Commented] (FLINK-16793) Add jobName to log4j ConversionPattern

[ https://issues.apache.org/jira/browse/FLINK-16793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072837#comment-17072837 ] jinhai commented on FLINK-16793: [~chesnay] Thank you. it works > Add jobName to log4j

[jira] [Created] (FLINK-16793) Add jobName to log4j ConversionPattern

jinhai created FLINK-16793: -- Summary: Add jobName to log4j ConversionPattern Key: FLINK-16793 URL: https://issues.apache.org/jira/browse/FLINK-16793 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-16793) Add jobName to log4j ConversionPattern

[ https://issues.apache.org/jira/browse/FLINK-16793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072537#comment-17072537 ] jinhai commented on FLINK-16793: [~chesnay] sorry I tried setting the `env.java.opts` in

[jira] [Created] (FLINK-16875) Tracking replace QueryConfig and TableConfig implementation with ConfigOption

jinhai created FLINK-16875: -- Summary: Tracking replace QueryConfig and TableConfig implementation with ConfigOption Key: FLINK-16875 URL: https://issues.apache.org/jira/browse/FLINK-16875 Project: Flink

[jira] [Commented] (FLINK-16793) Add jobName to log4j ConversionPattern

[ https://issues.apache.org/jira/browse/FLINK-16793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071449#comment-17071449 ] jinhai commented on FLINK-16793: [~chesnay]  Modify the log4j property files and pass in the additional

[jira] [Commented] (FLINK-16793) Add jobName to log4j ConversionPattern

[ https://issues.apache.org/jira/browse/FLINK-16793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071646#comment-17071646 ] jinhai commented on FLINK-16793: [~chesnay] when submit a job by shell command like: flink run

[jira] [Issue Comment Deleted] (FLINK-16793) Add jobName to log4j ConversionPattern

[ https://issues.apache.org/jira/browse/FLINK-16793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinhai updated FLINK-16793: --- Comment: was deleted (was: [~chesnay] sorry I tried setting the `env.java.opts` in flink-conf.yaml. But

[jira] [Closed] (FLINK-16793) Add jobName to log4j ConversionPattern

[ https://issues.apache.org/jira/browse/FLINK-16793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinhai closed FLINK-16793. -- Resolution: Fixed > Add jobName to log4j ConversionPattern > -- > >

[jira] [Comment Edited] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065296#comment-17065296 ] jinhai edited comment on FLINK-16662 at 3/25/20, 2:45 AM: --

[jira] [Created] (FLINK-17495) Add custom labels on PrometheusReporter like PrometheusPushGatewayReporter's groupingKey

jinhai created FLINK-17495: -- Summary: Add custom labels on PrometheusReporter like PrometheusPushGatewayReporter's groupingKey Key: FLINK-17495 URL: https://issues.apache.org/jira/browse/FLINK-17495

[jira] [Created] (FLINK-16648) Clean up the input parameter StreamQueryConfig of the API in StreamTableEnvironment

jinhai created FLINK-16648: -- Summary: Clean up the input parameter StreamQueryConfig of the API in StreamTableEnvironment Key: FLINK-16648 URL: https://issues.apache.org/jira/browse/FLINK-16648 Project:

[jira] [Commented] (FLINK-16648) Clean up the input parameter StreamQueryConfig of the API in StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061527#comment-17061527 ] jinhai commented on FLINK-16648: Can I have this issue? > Clean up the input parameter

[jira] [Updated] (FLINK-16648) Clean up the input parameter StreamQueryConfig of the API in StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinhai updated FLINK-16648: --- Attachment: image-2020-03-18-17-19-08-122.png > Clean up the input parameter StreamQueryConfig of the API

[jira] [Updated] (FLINK-16648) Clean up the input parameter StreamQueryConfig of the API in StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinhai updated FLINK-16648: --- Description: Input parameter StreamQueryConfig of the API in StreamTableEnvironment is  deprecated and

[jira] [Commented] (FLINK-16648) Clean up the input parameter StreamQueryConfig of the API in StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061529#comment-17061529 ] jinhai commented on FLINK-16648: Another similar issue: 

[jira] [Updated] (FLINK-13691) Remove deprecated query config

[ https://issues.apache.org/jira/browse/FLINK-13691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinhai updated FLINK-13691: --- Attachment: image-2020-03-24-13-57-05-958.png > Remove deprecated query config >

[jira] [Commented] (FLINK-13691) Remove deprecated query config

[ https://issues.apache.org/jira/browse/FLINK-13691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065346#comment-17065346 ] jinhai commented on FLINK-13691: [~twalthr] TableConfig#setIdleStateRetentionTime has some validation

[jira] [Commented] (FLINK-16737) Remove KubernetesUtils#getContentFromFile

[ https://issues.apache.org/jira/browse/FLINK-16737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065348#comment-17065348 ] jinhai commented on FLINK-16737: Can I have this issue? > Remove KubernetesUtils#getContentFromFile >

[jira] [Comment Edited] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065296#comment-17065296 ] jinhai edited comment on FLINK-16662 at 3/24/20, 3:53 AM: --

[jira] [Commented] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065296#comment-17065296 ] jinhai commented on FLINK-16662: similar issue: https://issues.apache.org/jira/browse/FLINK-16585 >

[jira] [Comment Edited] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065296#comment-17065296 ] jinhai edited comment on FLINK-16662 at 3/24/20, 3:52 AM: -- similar issue: 

[jira] [Commented] (FLINK-16585) Table program cannot be compiled.Cannot determine simple type name "com"

[ https://issues.apache.org/jira/browse/FLINK-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060668#comment-17060668 ] jinhai commented on FLINK-16585: I haven't been able to reproduce this issue. Can you be more specific?

[jira] [Commented] (FLINK-19151) Flink does not normalize container resource with correct configurations when Yarn FairScheduler is used

[ https://issues.apache.org/jira/browse/FLINK-19151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17191911#comment-17191911 ] jinhai commented on FLINK-19151: [~xintongsong] Can i have this issue? > Flink does not normalize

[jira] [Commented] (FLINK-19151) Flink does not normalize container resource with correct configurations when Yarn FairScheduler is used

[ https://issues.apache.org/jira/browse/FLINK-19151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17191623#comment-17191623 ] jinhai commented on FLINK-19151: [~xintongsong] Can we add two fields to the class

[jira] [Commented] (FLINK-19151) Flink does not normalize container resource with correct configurations when Yarn FairScheduler is used

[ https://issues.apache.org/jira/browse/FLINK-19151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17191637#comment-17191637 ] jinhai commented on FLINK-19151: [~xintongsong] Yes, we can set the unit resources in the constructor of