[jira] [Commented] (FLINK-28214) ArrayDataSerializer can not be reused to copy customized type of array data

[ https://issues.apache.org/jira/browse/FLINK-28214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17558338#comment-17558338 ] Yi Tang commented on FLINK-28214: - Thanks [~Weijie Guo], let me describe it with some pseudocode.

[jira] [Commented] (FLINK-28214) ArrayDataSerializer can not be reused to copy customized type of array data

[ https://issues.apache.org/jira/browse/FLINK-28214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557819#comment-17557819 ] Yi Tang commented on FLINK-28214: - [~gyfora] Would you mind checking this issue? > ArrayDataSerializer

[jira] [Created] (FLINK-28214) ArrayDataSerializer can not be reused to copy customized type of array data

Yi Tang created FLINK-28214: --- Summary: ArrayDataSerializer can not be reused to copy customized type of array data Key: FLINK-28214 URL: https://issues.apache.org/jira/browse/FLINK-28214 Project: Flink

[jira] [Closed] (FLINK-27377) Job master blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang closed FLINK-27377. --- Resolution: Won't Fix > Job master blocks on marking vertex finished >

[jira] [Commented] (FLINK-27377) Job master blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528082#comment-17528082 ] Yi Tang commented on FLINK-27377: - [~maguowei] Looks like my original issue has been fixed in newer

[jira] [Commented] (FLINK-27377) Job master blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528066#comment-17528066 ] Yi Tang commented on FLINK-27377: - Thanks for you advice [~maguowei] > Job master blocks on marking

[jira] [Comment Edited] (FLINK-27377) Job master blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528014#comment-17528014 ] Yi Tang edited comment on FLINK-27377 at 4/26/22 8:46 AM: -- Looks like the

[jira] [Commented] (FLINK-27377) Job master blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528014#comment-17528014 ] Yi Tang commented on FLINK-27377: - Looks like the rename operation has been improved in HADOOP-15323. So

[jira] [Commented] (FLINK-27377) Job master blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527996#comment-17527996 ] Yi Tang commented on FLINK-27377: - Hi [~maguowei]  In my case, it blocks on rename operation as i

[jira] [Updated] (FLINK-27377) Job master blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-27377: Description: I have a case using FileSystem as batch sink, it will commit files by

[jira] [Updated] (FLINK-27377) Job master blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-27377: Summary: Job master blocks on marking vertex finished (was: Job manager blocks on marking vertex

[jira] [Comment Edited] (FLINK-27377) Job manager blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527376#comment-17527376 ] Yi Tang edited comment on FLINK-27377 at 4/25/22 9:04 AM: -- [~maguowei] I

[jira] [Commented] (FLINK-27377) Job manager blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527376#comment-17527376 ] Yi Tang commented on FLINK-27377: - [~maguowei] I checked it with the version of master. It still fall

[jira] [Updated] (FLINK-27377) Job manager blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-27377: Priority: Minor (was: Major) > Job manager blocks on marking vertex finished >

[jira] [Commented] (FLINK-27377) Job manager blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527371#comment-17527371 ] Yi Tang commented on FLINK-27377: - Thanks [~maguowei], really appreciate for letting me know this. If

[jira] [Comment Edited] (FLINK-27377) Job manager blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527303#comment-17527303 ] Yi Tang edited comment on FLINK-27377 at 4/25/22 4:50 AM: -- I think we can fix

[jira] [Comment Edited] (FLINK-27377) Job manager blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527303#comment-17527303 ] Yi Tang edited comment on FLINK-27377 at 4/25/22 4:45 AM: -- I think we can fix

[jira] [Commented] (FLINK-27377) Job manager blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527303#comment-17527303 ] Yi Tang commented on FLINK-27377: - I think we can fix it by invoking

[jira] [Updated] (FLINK-27377) Job manager blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-27377: Description: I have a case using FileSystem as batch sink, it will commit files by

[jira] [Created] (FLINK-27377) Job manager blocks on marking vertex finished

Yi Tang created FLINK-27377: --- Summary: Job manager blocks on marking vertex finished Key: FLINK-27377 URL: https://issues.apache.org/jira/browse/FLINK-27377 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520289#comment-17520289 ] Yi Tang commented on FLINK-25238: - Thanks [~martijnvisser], i'll close the PR for 1.13. > flink iceberg

[jira] [Commented] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518538#comment-17518538 ] Yi Tang commented on FLINK-25238: - Hi [~gyfora], thanks for helping merging these fixes. Since

[jira] [Commented] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517906#comment-17517906 ] Yi Tang commented on FLINK-25238: - [~gyfora], glad to do it. I think we should backport it to both

[jira] [Commented] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517879#comment-17517879 ] Yi Tang commented on FLINK-25238: - [~gyfora] Thanks, would you mind having a look at the [fix

[jira] [Comment Edited] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515682#comment-17515682 ] Yi Tang edited comment on FLINK-25238 at 4/1/22 3:06 AM: - [~sjwiesman] Shall we

[jira] [Commented] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515682#comment-17515682 ] Yi Tang commented on FLINK-25238: - [~sjwiesman] Shall we reopen this issue. The similar issue for

[jira] [Comment Edited] (FLINK-24819) Higher APIServer cpu load after using SharedIndexInformer replaced naked Kubernetes watch

[ https://issues.apache.org/jira/browse/FLINK-24819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450973#comment-17450973 ] Yi Tang edited comment on FLINK-24819 at 11/30/21, 9:46 AM: Hi

[jira] [Comment Edited] (FLINK-24819) Higher APIServer cpu load after using SharedIndexInformer replaced naked Kubernetes watch

[ https://issues.apache.org/jira/browse/FLINK-24819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450973#comment-17450973 ] Yi Tang edited comment on FLINK-24819 at 11/30/21, 9:15 AM: Hi

[jira] [Commented] (FLINK-24819) Higher APIServer cpu load after using SharedIndexInformer replaced naked Kubernetes watch

[ https://issues.apache.org/jira/browse/FLINK-24819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450973#comment-17450973 ] Yi Tang commented on FLINK-24819: - Hi [~wangyang0918], how many config maps of the particular namespace

[jira] [Commented] (FLINK-24819) Higher APIServer cpu load after using SharedIndexInformer replaced naked Kubernetes watch

[ https://issues.apache.org/jira/browse/FLINK-24819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450949#comment-17450949 ] Yi Tang commented on FLINK-24819: - [~wangyang0918] Sorry for the late response, i'll have a look and try

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415280#comment-17415280 ] Yi Tang commented on FLINK-22275: - Thanks [~jark], [~lirui], and [~luoyuxia]. > Datagen add a max lag

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413937#comment-17413937 ] Yi Tang commented on FLINK-22275: - [~jark] Please help to review the latest update of the PR. > Datagen

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413070#comment-17413070 ] Yi Tang commented on FLINK-22275: - Thanks [~jark], i'll do it later. > Datagen add a max lag option for

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413047#comment-17413047 ] Yi Tang commented on FLINK-22275: - Hi [~jark] [~lirui], does this feature still valid ? i 'll close it

[jira] [Closed] (FLINK-21921) Unreasonable ADDED event ignoring in callback handler in KubernetesLeaderRetrievalDriver

[ https://issues.apache.org/jira/browse/FLINK-21921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang closed FLINK-21921. --- Resolution: Won't Fix > Unreasonable ADDED event ignoring in callback handler in >

[jira] [Comment Edited] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17394485#comment-17394485 ] Yi Tang edited comment on FLINK-23478 at 8/6/21, 3:31 AM: -- Hi [~dwysakowicz],

[jira] [Comment Edited] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17394485#comment-17394485 ] Yi Tang edited comment on FLINK-23478 at 8/6/21, 3:30 AM: -- Hi [~dwysakowicz]

[jira] [Commented] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17394485#comment-17394485 ] Yi Tang commented on FLINK-23478: - Hi [~dwysakowicz] [~xtsong], thanks for your report about the test

[jira] [Commented] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387842#comment-17387842 ] Yi Tang commented on FLINK-23478: - Glad to hear the news, i think it can be fixed after upgrading the

[jira] [Comment Edited] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387799#comment-17387799 ] Yi Tang edited comment on FLINK-23478 at 7/27/21, 6:30 AM: --- It is likely

[jira] [Commented] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387799#comment-17387799 ] Yi Tang commented on FLINK-23478: - It is likely caused by the following logical, the first

[jira] [Commented] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387775#comment-17387775 ] Yi Tang commented on FLINK-23478: - I happened to reproduce the issue locally, it seems the indexer of

[jira] [Commented] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387754#comment-17387754 ] Yi Tang commented on FLINK-23478: - Maybe we can make use of Azure to reproduce it by removing all other

[jira] [Commented] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387725#comment-17387725 ] Yi Tang commented on FLINK-23478: - Thanks [~fly_in_gis]. I'll try to find the root cause again. It's a

[jira] [Commented] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387671#comment-17387671 ] Yi Tang commented on FLINK-23478: - [~fly_in_gis] Looks like the {{KubernetesSharedInformerITCase}} still

[jira] [Comment Edited] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387671#comment-17387671 ] Yi Tang edited comment on FLINK-23478 at 7/27/21, 1:37 AM: --- [~fly_in_gis]

[jira] [Commented] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17386232#comment-17386232 ] Yi Tang commented on FLINK-23478: - [~fly_in_gis] I've added a patch to fix this issue, please help to

[jira] [Comment Edited] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17386113#comment-17386113 ] Yi Tang edited comment on FLINK-23478 at 7/23/21, 10:04 AM: [~fly_in_gis]

[jira] [Comment Edited] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17386113#comment-17386113 ] Yi Tang edited comment on FLINK-23478 at 7/23/21, 10:03 AM: [~fly_in_gis]

[jira] [Comment Edited] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17386113#comment-17386113 ] Yi Tang edited comment on FLINK-23478 at 7/23/21, 10:03 AM: [~fly_in_gis]

[jira] [Comment Edited] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17386113#comment-17386113 ] Yi Tang edited comment on FLINK-23478 at 7/23/21, 10:03 AM: [~fly_in_gis]

[jira] [Comment Edited] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17386113#comment-17386113 ] Yi Tang edited comment on FLINK-23478 at 7/23/21, 10:00 AM: [~fly_in_gis]

[jira] [Comment Edited] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17386113#comment-17386113 ] Yi Tang edited comment on FLINK-23478 at 7/23/21, 9:32 AM: --- [~fly_in_gis] The

[jira] [Commented] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17386113#comment-17386113 ] Yi Tang commented on FLINK-23478: - [~fly_in_gis] The possible cause is still that a simpler lock can not

[jira] [Commented] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17386058#comment-17386058 ] Yi Tang commented on FLINK-23478: - [~fly_in_gis] yeah, i'll dig it >

[jira] [Updated] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-22054: Labels: k8s-ha pull-request-available (was: auto-unassigned k8s-ha pull-request-available) > Using a

[jira] [Updated] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-22275: Fix Version/s: 1.14.0 > Datagen add a max lag option for a series of timestamp-related types >

[jira] [Commented] (FLINK-21921) Unreasonable ADDED event ignoring in callback handler in KubernetesLeaderRetrievalDriver

[ https://issues.apache.org/jira/browse/FLINK-21921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348952#comment-17348952 ] Yi Tang commented on FLINK-21921: - [~trohrmann] You can assign it to me, i will provide a little change

[jira] [Commented] (FLINK-22704) ZooKeeperHaServicesTest.testCleanupJobData failed

[ https://issues.apache.org/jira/browse/FLINK-22704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347601#comment-17347601 ] Yi Tang commented on FLINK-22704: - [~mapohl] Thanks for letting me know, and [~trohrmann] thanks for

[jira] [Comment Edited] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332475#comment-17332475 ] Yi Tang edited comment on FLINK-22451 at 4/26/21, 2:53 PM: --- [~jark] When i try

[jira] [Commented] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332475#comment-17332475 ] Yi Tang commented on FLINK-22451: - [~jark] When i try to provide a implementation, i find a pair of

[jira] [Commented] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331888#comment-17331888 ] Yi Tang commented on FLINK-22451: - Please assign it to me if no others reject this feature and nothing

[jira] [Commented] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331730#comment-17331730 ] Yi Tang commented on FLINK-22451: - [~jark] It's clear and reasonable. I think we have reached consensus.

[jira] [Commented] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331708#comment-17331708 ] Yi Tang commented on FLINK-22451: - Did you mean, we can leave the choice to the users? If they want to

[jira] [Commented] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331693#comment-17331693 ] Yi Tang commented on FLINK-22451: - Great. Let me explain it in detail. We can allow users call function

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331675#comment-17331675 ] Yi Tang commented on FLINK-22275: - [~jark] [~lirui] Would you help to review the attached PR? > Datagen

[jira] [Commented] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331674#comment-17331674 ] Yi Tang commented on FLINK-22451: - [~jark] It's ok to close it, if it doesn't meet the standard, :) >

[jira] [Commented] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331564#comment-17331564 ] Yi Tang commented on FLINK-22451: - [~jark] I've noticed that it may be not suitable for SQL API. I think

[jira] [Updated] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-22451: Priority: Minor (was: Major) > Support (*) as parameter of table UserDefinedFunction >

[jira] [Updated] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-22451: Description: For now, one can use star \(*) to act as a wild card, selecting all of the columns in the

[jira] [Updated] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-22451: Description: For now, one can use star (*) to act as a wild card, selecting all of the columns in the

[jira] [Updated] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-22451: Description: For now, one can use star \(*) to act as a wild card, selecting all of the columns in the

[jira] [Commented] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331462#comment-17331462 ] Yi Tang commented on FLINK-22451: - cc [~jark] > Support (*) as parameter of table UserDefinedFunction

[jira] [Created] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

Yi Tang created FLINK-22451: --- Summary: Support (*) as parameter of table UserDefinedFunction Key: FLINK-22451 URL: https://issues.apache.org/jira/browse/FLINK-22451 Project: Flink Issue Type:

[jira] [Closed] (FLINK-21455) Deploy history server on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-21455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang closed FLINK-21455. --- Resolution: Won't Do > Deploy history server on kubernetes > > >

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325686#comment-17325686 ] Yi Tang commented on FLINK-22275: - [~jark] Yeah, An out-of-order configuration is exactly what i want.

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325511#comment-17325511 ] Yi Tang commented on FLINK-22275: - [~jark] Any thoughts more? > Datagen add a max lag option for a

[jira] [Commented] (FLINK-20695) Zookeeper node under leader and leaderlatch is not deleted after job finished

[ https://issues.apache.org/jira/browse/FLINK-20695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325415#comment-17325415 ] Yi Tang commented on FLINK-20695: - [~trohrmann] how to remove the stale label ? I added a github

[jira] [Commented] (FLINK-21455) Deploy history server on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-21455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324897#comment-17324897 ] Yi Tang commented on FLINK-21455: - [~chesnay] Thanks for your reply. Yeah, nothing is blocking me to use

[jira] [Commented] (FLINK-21455) Deploy history server on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-21455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321963#comment-17321963 ] Yi Tang commented on FLINK-21455: - [~mapohl] [~chesnay] Let's think about this from another angle, can

[jira] [Commented] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321933#comment-17321933 ] Yi Tang commented on FLINK-22054: - [~hayden zhou] Yes, it's an issue fixed in FLINK-21942, if you are

[jira] [Comment Edited] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321872#comment-17321872 ] Yi Tang edited comment on FLINK-22275 at 4/15/21, 3:23 AM: --- Of course. How

[jira] [Comment Edited] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321872#comment-17321872 ] Yi Tang edited comment on FLINK-22275 at 4/15/21, 3:22 AM: --- Of course. How

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321872#comment-17321872 ] Yi Tang commented on FLINK-22275: - Of course. First of all, it is obvious that this option can only be

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321842#comment-17321842 ] Yi Tang commented on FLINK-22275: - [~jark] You can assign it to me, if no further more discussion

[jira] [Created] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

Yi Tang created FLINK-22275: --- Summary: Datagen add a max lag option for a series of timestamp-related types Key: FLINK-22275 URL: https://issues.apache.org/jira/browse/FLINK-22275 Project: Flink

[jira] [Updated] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-22275: Description: For now, the {{datagen}} connector always resolves to the current timestamp for

[jira] [Updated] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-22275: Priority: Minor (was: Major) > Datagen add a max lag option for a series of timestamp-related types >

[jira] [Comment Edited] (FLINK-20695) Zookeeper node under leader and leaderlatch is not deleted after job finished

[ https://issues.apache.org/jira/browse/FLINK-20695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317636#comment-17317636 ] Yi Tang edited comment on FLINK-20695 at 4/9/21, 4:14 AM: -- [~trohrmann] As you

[jira] [Commented] (FLINK-20695) Zookeeper node under leader and leaderlatch is not deleted after job finished

[ https://issues.apache.org/jira/browse/FLINK-20695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317636#comment-17317636 ] Yi Tang commented on FLINK-20695: - [~trohrmann] As you say {{Dispatcher.cleanUpJobData}} is the proper

[jira] [Commented] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313508#comment-17313508 ] Yi Tang commented on FLINK-22054: - Great, I want attach a PR for this issue, [~trohrmann] please assign

[jira] [Commented] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311997#comment-17311997 ] Yi Tang commented on FLINK-22054: - Here[1] is a demo implementation using informer, which can deal the

[jira] [Commented] (FLINK-22006) Could not run more than 20 jobs in a native K8s session when K8s HA enabled

[ https://issues.apache.org/jira/browse/FLINK-22006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311996#comment-17311996 ] Yi Tang commented on FLINK-22006: - The watching for configMap is a little different from that for pods.

[jira] [Updated] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-22054: Description: While using K8s HA service, the watching for ConfigMap is separate for each job. As the

[jira] [Created] (FLINK-22054) Using a shared watcher for ConfigMap watching

Yi Tang created FLINK-22054: --- Summary: Using a shared watcher for ConfigMap watching Key: FLINK-22054 URL: https://issues.apache.org/jira/browse/FLINK-22054 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-22006) Could not run more than 20 jobs in a native K8s session when K8s HA enabled

[ https://issues.apache.org/jira/browse/FLINK-22006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311412#comment-17311412 ] Yi Tang commented on FLINK-22006: - [~trohrmann] Roughly speaking, yes. I think we can just replace the

[jira] [Commented] (FLINK-22006) Could not run more than 20 jobs in a native K8s session when K8s HA enabled

[ https://issues.apache.org/jira/browse/FLINK-22006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310715#comment-17310715 ] Yi Tang commented on FLINK-22006: - Yeah, there are the two configurations is relative, maxRequests and

[jira] [Comment Edited] (FLINK-22006) Could not run more than 20 jobs in a native K8s session when K8s HA enabled

[ https://issues.apache.org/jira/browse/FLINK-22006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310546#comment-17310546 ] Yi Tang edited comment on FLINK-22006 at 3/29/21, 10:30 AM: [~fly_in_gis]

[jira] [Commented] (FLINK-22006) Could not run more than 20 jobs in a native K8s session when K8s HA enabled

[ https://issues.apache.org/jira/browse/FLINK-22006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310546#comment-17310546 ] Yi Tang commented on FLINK-22006: - [~fly_in_gis] Did you reproduce the issue? I think it's easy to

[jira] [Commented] (FLINK-21942) KubernetesLeaderRetrievalDriver not closed after terminated which lead to connection leak

[ https://issues.apache.org/jira/browse/FLINK-21942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17308515#comment-17308515 ] Yi Tang commented on FLINK-21942: - [~trohrmann] Absolutely yes, this could solve the leak of globally

  1   2   >