[jira] [Comment Edited] (FLINK-32246) javax.management.InstanceAlreadyExistsException

[ https://issues.apache.org/jira/browse/FLINK-32246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728937#comment-17728937 ] jeff-zou edited comment on FLINK-32246 at 6/3/23 11:19 AM: --- [~aitozi]  No,

[jira] [Commented] (FLINK-32246) javax.management.InstanceAlreadyExistsException

[ https://issues.apache.org/jira/browse/FLINK-32246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728937#comment-17728937 ] jeff-zou commented on FLINK-32246: -- No, It's run in the Native Kubernates. The code like below:

[jira] [Created] (FLINK-32246) javax.management.InstanceAlreadyExistsException

jeff-zou created FLINK-32246: Summary: javax.management.InstanceAlreadyExistsException Key: FLINK-32246 URL: https://issues.apache.org/jira/browse/FLINK-32246 Project: Flink Issue Type: Bug

[jira] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018 ] jeff-zou deleted comment on FLINK-27018: -- was (Author: JIRAUSER282259): [~paul8263]  ok, thx, but I don't know how to assigne this issue to you. [~fpaul]  Can you do this? > timestamp missing

[jira] [Commented] (FLINK-31835) DataTypeHint don't support Row>

[ https://issues.apache.org/jira/browse/FLINK-31835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716152#comment-17716152 ] jeff-zou commented on FLINK-31835: -- hi [~jark] [~aitozi]  Under Flink 1.15, how do I solve this

[jira] [Created] (FLINK-31835) DataTypeHint don't support Row>

jeff-zou created FLINK-31835: Summary: DataTypeHint don't support Row> Key: FLINK-31835 URL: https://issues.apache.org/jira/browse/FLINK-31835 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-31375) the values of map are truncated by the CASE WHEN function.

[ https://issues.apache.org/jira/browse/FLINK-31375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703921#comment-17703921 ] jeff-zou commented on FLINK-31375: -- Great，it's ok to use this method, thank u. > the values of map are

[jira] [Updated] (FLINK-31375) the values of map are truncated by the CASE WHEN function.

[ https://issues.apache.org/jira/browse/FLINK-31375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeff-zou updated FLINK-31375: - Component/s: Table SQL / Runtime > the values of map are truncated by the CASE WHEN function. >

[jira] [Updated] (FLINK-31375) the values of map are truncated by the CASE WHEN function.

[ https://issues.apache.org/jira/browse/FLINK-31375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeff-zou updated FLINK-31375: - Description: the values of map are truncated by the CASE WHEN function. {code:java} // sql create table

[jira] [Updated] (FLINK-31375) the values of map are truncated by the CASE WHEN function.

[ https://issues.apache.org/jira/browse/FLINK-31375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeff-zou updated FLINK-31375: - Description: the values of map are truncated by the CASE WHEN function. {code:java} // sql create table

[jira] [Updated] (FLINK-31375) the values of map are truncated by the CASE WHEN function.

[ https://issues.apache.org/jira/browse/FLINK-31375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeff-zou updated FLINK-31375: - Description: the values of map are truncated by the CASE WHEN function. {code:java} // sql create table

[jira] [Updated] (FLINK-31375) the values of map are truncated by the CASE WHEN function.

[ https://issues.apache.org/jira/browse/FLINK-31375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeff-zou updated FLINK-31375: - Description: the values of map are truncated by the CASE WHEN function. {code:java} // sql create table

[jira] [Created] (FLINK-31375) the values of map are truncated by the CASE WHEN function.

jeff-zou created FLINK-31375: Summary: the values of map are truncated by the CASE WHEN function. Key: FLINK-31375 URL: https://issues.apache.org/jira/browse/FLINK-31375 Project: Flink Issue

[jira] [Updated] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeff-zou updated FLINK-27018: - Description: the bug is described as follows:   {code:java} data in source:  2022-04-02 03:34:21.260

[jira] [Created] (FLINK-28729) flink hive catalog don't support jdk11

jeff-zou created FLINK-28729: Summary: flink hive catalog don't support jdk11 Key: FLINK-28729 URL: https://issues.apache.org/jira/browse/FLINK-28729 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526959#comment-17526959 ] jeff-zou commented on FLINK-27018: -- [~paul8263]  ok, thx, but I don't know how to assigne this issue to

[jira] [Commented] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523033#comment-17523033 ] jeff-zou commented on FLINK-27018: -- [~paul8263] Why can't we use LocalDateTime.toString()? I check it

[jira] [Commented] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522793#comment-17522793 ] jeff-zou commented on FLINK-27018: -- I think it's better to be consistent  in converting, because many

[jira] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018 ] jeff-zou deleted comment on FLINK-27018: -- was (Author: JIRAUSER282259): [~fpaul]   yes, just kafka will trailing end 0, and i am sure the record coming to the sink is container end 0 when i

[jira] [Comment Edited] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519282#comment-17519282 ] jeff-zou edited comment on FLINK-27018 at 4/8/22 3:06 AM: -- [~fpaul]   yes,

[jira] [Comment Edited] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519282#comment-17519282 ] jeff-zou edited comment on FLINK-27018 at 4/8/22 3:05 AM: -- [~fpaul]   yes,

[jira] [Commented] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519282#comment-17519282 ] jeff-zou commented on FLINK-27018: -- [~fpaul]   yes, just kafka will trailing end 0, and i am sure the

[jira] [Commented] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519283#comment-17519283 ] jeff-zou commented on FLINK-27018: -- [~fpaul]   yes, just kafka will trailing end 0, and i am sure the

[jira] [Updated] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeff-zou updated FLINK-27018: - Attachment: kafka.png > timestamp missing end zero when outputing to kafka >

[jira] [Commented] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517785#comment-17517785 ] jeff-zou commented on FLINK-27018: -- It had the same problem when i tried it with flink 1.14.4. Martijn

[jira] [Created] (FLINK-27018) timestamp missing end zero when outputing to kafka

jeff-zou created FLINK-27018: Summary: timestamp missing end zero when outputing to kafka Key: FLINK-27018 URL: https://issues.apache.org/jira/browse/FLINK-27018 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-25377) kubernetes's request/limit resource can been seperated?

[ https://issues.apache.org/jira/browse/FLINK-25377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480581#comment-17480581 ] jeff-zou commented on FLINK-25377: -- i have tried it,event if u set limit in jm/tm pod template,flink

[jira] [Created] (FLINK-25652) Can "duration“ and ”received records" be updated at the same time in WebUI's task detail ?

jeff-zou created FLINK-25652: Summary: Can "duration“ and ”received records" be updated at the same time in WebUI's task detail ? Key: FLINK-25652 URL: https://issues.apache.org/jira/browse/FLINK-25652

[jira] [Created] (FLINK-25378) kubernetes's request/limit resource can been seperated?

jeff-zou created FLINK-25378: Summary: kubernetes's request/limit resource can been seperated? Key: FLINK-25378 URL: https://issues.apache.org/jira/browse/FLINK-25378 Project: Flink Issue Type:

[jira] [Created] (FLINK-25377) kubernetes's request/limit resource can been seperated?

jeff-zou created FLINK-25377: Summary: kubernetes's request/limit resource can been seperated? Key: FLINK-25377 URL: https://issues.apache.org/jira/browse/FLINK-25377 Project: Flink Issue Type: