[jira] [Commented] (FLINK-34105) Akka timeout happens in TPC-DS benchmarks

[ https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823929#comment-17823929 ] Yangze Guo commented on FLINK-34105: master: 7a709bf > Akka timeout happens in TPC-DS benchmarks >

[jira] [Resolved] (FLINK-34434) DefaultSlotStatusSyncer doesn't complete the returned future

[ https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo resolved FLINK-34434. Resolution: Fixed > DefaultSlotStatusSyncer doesn't complete the returned future >

[jira] [Commented] (FLINK-34434) DefaultSlotStatusSyncer doesn't complete the returned future

[ https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818657#comment-17818657 ] Yangze Guo commented on FLINK-34434: 1.19: 8cf29969d9aec4943713f0a6096b703718ce0dd0

[jira] [Updated] (FLINK-34434) DefaultSlotStatusSyncer doesn't complete the returned future

[ https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-34434: --- Fix Version/s: 1.19.0 1.18.2 1.20.0 > DefaultSlotStatusSyncer

[jira] [Commented] (FLINK-34434) DefaultSlotStatusSyncer doesn't complete the returned future

[ https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818613#comment-17818613 ] Yangze Guo commented on FLINK-34434: master: 15af3e49ca42fea1e3f6c53d6d1498315b1322ac

[jira] [Resolved] (FLINK-25015) job name should not always be `collect` submitted by sql client

[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo resolved FLINK-25015. Resolution: Fixed > job name should not always be `collect` submitted by sql client >

[jira] [Updated] (FLINK-25015) job name should not always be `collect` submitted by sql client

[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-25015: --- Fix Version/s: 1.20.0 > job name should not always be `collect` submitted by sql client >

[jira] [Commented] (FLINK-25015) job name should not always be `collect` submitted by sql client

[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818334#comment-17818334 ] Yangze Guo commented on FLINK-25015: master: dcb30f934a7953e33d35460414c6ee57cb982ab3 > job name

[jira] [Comment Edited] (FLINK-34434) DefaultSlotStatusSyncer doesn't complete the returned future

[ https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818325#comment-17818325 ] Yangze Guo edited comment on FLINK-34434 at 2/19/24 2:33 AM: - Good catch

[jira] [Commented] (FLINK-34434) DefaultSlotStatusSyncer doesn't complete the returned future

[ https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818325#comment-17818325 ] Yangze Guo commented on FLINK-34434: Good catch [~mapohl]. I think the returnedFuture should be

[jira] [Assigned] (FLINK-34434) DefaultSlotStatusSyncer doesn't complete the returned future

[ https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-34434: -- Assignee: Yangze Guo > DefaultSlotStatusSyncer doesn't complete the returned future >

[jira] [Commented] (FLINK-34299) Release Testing Instructions: Verify FLINK-33203 Adding a separate configuration for specifying Java Options of the SQL Gateway

[ https://issues.apache.org/jira/browse/FLINK-34299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813464#comment-17813464 ] Yangze Guo commented on FLINK-34299: This change doesn't need crossteam testing. > Release Testing

[jira] [Closed] (FLINK-34299) Release Testing Instructions: Verify FLINK-33203 Adding a separate configuration for specifying Java Options of the SQL Gateway

[ https://issues.apache.org/jira/browse/FLINK-34299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-34299. -- Resolution: Fixed > Release Testing Instructions: Verify FLINK-33203 Adding a separate >

[jira] [Commented] (FLINK-34105) Akka timeout happens in TPC-DS benchmarks

[ https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812121#comment-17812121 ] Yangze Guo commented on FLINK-34105: [~lsdy] has some personal affairs and will back this Thursday.

[jira] [Assigned] (FLINK-33683) FLIP-407 Improve Flink Client performance in interactive scenarios

[ https://issues.apache.org/jira/browse/FLINK-33683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-33683: -- Assignee: xiangyu feng > FLIP-407 Improve Flink Client performance in interactive scenarios

[jira] [Commented] (FLINK-34105) Akka timeout happens in TPC-DS benchmarks

[ https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807526#comment-17807526 ] Yangze Guo commented on FLINK-34105: [~zhuzh] I encountered the same Akka timeout issue in my

[jira] [Commented] (FLINK-34105) Akka timeout happens in TPC-DS benchmarks

[ https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807238#comment-17807238 ] Yangze Guo commented on FLINK-34105: We'll try to reproduce this issue in our environment. > Akka

[jira] [Commented] (FLINK-34105) Akka timeout happens in TPC-DS benchmarks

[ https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807234#comment-17807234 ] Yangze Guo commented on FLINK-34105: [~zhuzh] My gut feeling is that the change leads to payload

[jira] [Assigned] (FLINK-34105) Akka timeout happens in TPC-DS benchmarks

[ https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-34105: -- Assignee: Yangze Guo > Akka timeout happens in TPC-DS benchmarks >

[jira] [Commented] (FLINK-34105) Akka timeout happens in TPC-DS benchmarks

[ https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807164#comment-17807164 ] Yangze Guo commented on FLINK-34105: Thanks for the pointer, [~zhuzh]. How does the pekko.framesize

[jira] [Commented] (FLINK-33880) Introducing Retry Mechanism for Listing TaskManager Pods to Prevent API Server Connection Failures

[ https://issues.apache.org/jira/browse/FLINK-33880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801648#comment-17801648 ] Yangze Guo commented on FLINK-33880: I think it's a valid issue, go ahead. > Introducing Retry

[jira] [Assigned] (FLINK-33880) Introducing Retry Mechanism for Listing TaskManager Pods to Prevent API Server Connection Failures

[ https://issues.apache.org/jira/browse/FLINK-33880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-33880: -- Assignee: Yuan Huang > Introducing Retry Mechanism for Listing TaskManager Pods to Prevent

[jira] [Created] (FLINK-33870) Split the HighAvailabilityServices into LeaderServices and PersistentServices

Yangze Guo created FLINK-33870: -- Summary: Split the HighAvailabilityServices into LeaderServices and PersistentServices Key: FLINK-33870 URL: https://issues.apache.org/jira/browse/FLINK-33870 Project:

[jira] [Updated] (FLINK-32667) Enable users to independently adjust the high availability strategies related to jobs through configuration

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-32667: --- Description: In OLAP scenarios, we only require the leader election services for the Dispatcher /

[jira] [Updated] (FLINK-32667) Enable users to independently adjust the high availability strategies related to jobs through configuration

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-32667: --- Summary: Enable users to independently adjust the high availability strategies related to jobs

[jira] [Updated] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-32667: --- Parent: FLINK-33852 Issue Type: Sub-task (was: Improvement) > Use standalone store and

[jira] [Updated] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-32667: --- Parent: (was: FLINK-25318) Issue Type: Improvement (was: Sub-task) > Use standalone

[jira] [Created] (FLINK-33852) FLIP-403 High Availability Services for OLAP Scenarios

Yangze Guo created FLINK-33852: -- Summary: FLIP-403 High Availability Services for OLAP Scenarios Key: FLINK-33852 URL: https://issues.apache.org/jira/browse/FLINK-33852 Project: Flink Issue

[jira] [Commented] (FLINK-32756) Reuse ClientHighAvailabilityServices when creating RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17790862#comment-17790862 ] Yangze Guo commented on FLINK-32756: [~xiangyu0xf] Done, go ahead! > Reuse

[jira] [Assigned] (FLINK-32756) Reuse ClientHighAvailabilityServices when creating RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-32756: -- Assignee: xiangyu feng > Reuse ClientHighAvailabilityServices when creating

[jira] [Commented] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789941#comment-17789941 ] Yangze Guo commented on FLINK-32667: FYI, since FLINK-33033 has been merged and proves the benefit

[jira] [Assigned] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-32667: -- Assignee: Yangze Guo (was: Fang Yong) > Use standalone store and embedding writer for jobs

[jira] [Commented] (FLINK-33626) Wrong style in flink ui

[ https://issues.apache.org/jira/browse/FLINK-33626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789394#comment-17789394 ] Yangze Guo commented on FLINK-33626: Could we find a way to guard it? > Wrong style in flink ui >

[jira] [Closed] (FLINK-32299) Upload python jar when sql contains python udf jar

[ https://issues.apache.org/jira/browse/FLINK-32299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-32299. -- Resolution: Fixed > Upload python jar when sql contains python udf jar >

[jira] [Commented] (FLINK-32299) Upload python jar when sql contains python udf jar

[ https://issues.apache.org/jira/browse/FLINK-32299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17787106#comment-17787106 ] Yangze Guo commented on FLINK-32299: master: febbbf3c09c1670faed4dbf1c46a1d1719d8fa8f > Upload

[jira] [Commented] (FLINK-33532) Move the serialization of ShuffleDescriptorGroup out of the RPC main thread

[ https://issues.apache.org/jira/browse/FLINK-33532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786645#comment-17786645 ] Yangze Guo commented on FLINK-33532: master: 8ef71ba1f190a5cf6093adb6c40c6a6d04944d20

[jira] [Closed] (FLINK-33532) Move the serialization of ShuffleDescriptorGroup out of the RPC main thread

[ https://issues.apache.org/jira/browse/FLINK-33532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-33532. -- Resolution: Fixed > Move the serialization of ShuffleDescriptorGroup out of the RPC main thread >

[jira] [Assigned] (FLINK-32299) Upload python jar when sql contains python udf jar

[ https://issues.apache.org/jira/browse/FLINK-32299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-32299: -- Assignee: Yangze Guo (was: Fang Yong) > Upload python jar when sql contains python udf jar

[jira] [Updated] (FLINK-33532) Move the serialization of ShuffleDescriptorGroup out of the RPC main thread

[ https://issues.apache.org/jira/browse/FLINK-33532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-33532: --- Description: Currently, the serilization of ShuffleDescriptorGroup would happen in the RPC main

[jira] [Assigned] (FLINK-33532) Move the serialization of ShuffleDescriptorGroup out of the RPC main thread

[ https://issues.apache.org/jira/browse/FLINK-33532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-33532: -- Assignee: dizhou cao (was: Yangze Guo) > Move the serialization of ShuffleDescriptorGroup

[jira] [Updated] (FLINK-33532) Move the serialization of ShuffleDescriptorGroup out of the RPC main thread

[ https://issues.apache.org/jira/browse/FLINK-33532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-33532: --- Description: Currently, the serilization of ShuffleDescriptorGroup would happen in the RPC main

[jira] [Created] (FLINK-33532) Move the serialization of ShuffleDescriptorGroup out of the RPC main thread

Yangze Guo created FLINK-33532: -- Summary: Move the serialization of ShuffleDescriptorGroup out of the RPC main thread Key: FLINK-33532 URL: https://issues.apache.org/jira/browse/FLINK-33532 Project:

[jira] [Assigned] (FLINK-33467) Support concurrent serialization in akka

[ https://issues.apache.org/jira/browse/FLINK-33467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-33467: -- Assignee: dizhou cao > Support concurrent serialization in akka >

[jira] [Updated] (FLINK-32299) Upload python jar when sql contains python udf jar

[ https://issues.apache.org/jira/browse/FLINK-32299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-32299: --- Parent: FLINK-25318 Issue Type: Sub-task (was: Improvement) > Upload python jar when sql

[jira] [Assigned] (FLINK-32299) Upload python jar when sql contains python udf jar

[ https://issues.apache.org/jira/browse/FLINK-32299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-32299: -- Assignee: Fang Yong (was: FangYong) > Upload python jar when sql contains python udf jar >

[jira] [Commented] (FLINK-33235) Improve the Quickstart guide for Flink OLAP and translate to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781973#comment-17781973 ] Yangze Guo commented on FLINK-33235: master: ff5d8f08662bd50479039914e7a8b85ca539e6c1

[jira] [Closed] (FLINK-32309) Shared classpaths and jars manager for jobs in sql gateway cause confliction

[ https://issues.apache.org/jira/browse/FLINK-32309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-32309. -- Resolution: Fixed > Shared classpaths and jars manager for jobs in sql gateway cause confliction >

[jira] [Commented] (FLINK-32309) Shared classpaths and jars manager for jobs in sql gateway cause confliction

[ https://issues.apache.org/jira/browse/FLINK-32309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781695#comment-17781695 ] Yangze Guo commented on FLINK-32309: master: dd47530f1eee829242c1c7a5fab9b4b8553cba5a > Shared

[jira] [Updated] (FLINK-32309) Shared classpaths and jars manager for jobs in sql gateway cause confliction

[ https://issues.apache.org/jira/browse/FLINK-32309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-32309: --- Fix Version/s: 1.19.0 > Shared classpaths and jars manager for jobs in sql gateway cause

[jira] [Updated] (FLINK-25055) Support listen and notify mechanism for PartitionRequest

[ https://issues.apache.org/jira/browse/FLINK-25055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-25055: --- Fix Version/s: 1.19.0 > Support listen and notify mechanism for PartitionRequest >

[jira] [Closed] (FLINK-25055) Support listen and notify mechanism for PartitionRequest

[ https://issues.apache.org/jira/browse/FLINK-25055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-25055. -- Resolution: Fixed > Support listen and notify mechanism for PartitionRequest >

[jira] [Commented] (FLINK-25055) Support listen and notify mechanism for PartitionRequest

[ https://issues.apache.org/jira/browse/FLINK-25055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781342#comment-17781342 ] Yangze Guo commented on FLINK-25055: master: 9c3b18b0320c7260f1fe6e9dbbf489423a729cb4 > Support

[jira] [Closed] (FLINK-33033) Add haservice micro benchmark for olap

[ https://issues.apache.org/jira/browse/FLINK-33033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-33033. -- Fix Version/s: 1.19.0 Resolution: Fixed > Add haservice micro benchmark for olap >

[jira] [Commented] (FLINK-33033) Add haservice micro benchmark for olap

[ https://issues.apache.org/jira/browse/FLINK-33033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780163#comment-17780163 ] Yangze Guo commented on FLINK-33033: master: 6e61678dc7fffa4529d27ec674a6b57a1e79b097 > Add

[jira] [Closed] (FLINK-32512) SHOW JARS should not show the jars for temporary function

[ https://issues.apache.org/jira/browse/FLINK-32512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-32512. -- Resolution: Fixed > SHOW JARS should not show the jars for temporary function >

[jira] [Updated] (FLINK-32512) SHOW JARS should not show the jars for temporary function

[ https://issues.apache.org/jira/browse/FLINK-32512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-32512: --- Fix Version/s: 1.19.0 > SHOW JARS should not show the jars for temporary function >

[jira] [Assigned] (FLINK-32512) SHOW JARS should not show the jars for temporary function

[ https://issues.apache.org/jira/browse/FLINK-32512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-32512: -- Assignee: Fang Yong (was: FangYong) > SHOW JARS should not show the jars for temporary

[jira] [Assigned] (FLINK-32512) SHOW JARS should not show the jars for temporary function

[ https://issues.apache.org/jira/browse/FLINK-32512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-32512: -- Assignee: FangYong > SHOW JARS should not show the jars for temporary function >

[jira] [Commented] (FLINK-32512) SHOW JARS should not show the jars for temporary function

[ https://issues.apache.org/jira/browse/FLINK-32512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1032#comment-1032 ] Yangze Guo commented on FLINK-32512: master: c2e14ff411e806f9ccf176c85eb8249b8ff12e56 > SHOW JARS

[jira] [Closed] (FLINK-33289) SQL Gateway supports IPv6 addresses.

[ https://issues.apache.org/jira/browse/FLINK-33289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-33289. -- Resolution: Fixed > SQL Gateway supports IPv6 addresses. > > >

[jira] [Commented] (FLINK-33289) SQL Gateway supports IPv6 addresses.

[ https://issues.apache.org/jira/browse/FLINK-33289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776538#comment-17776538 ] Yangze Guo commented on FLINK-33289: master: 1182d15ec0d1047375f007ead26c09e86425b02c > SQL Gateway

[jira] [Updated] (FLINK-33289) SQL Gateway supports IPv6 addresses.

[ https://issues.apache.org/jira/browse/FLINK-33289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-33289: --- Parent: FLINK-32898 Issue Type: Sub-task (was: Improvement) > SQL Gateway supports IPv6

[jira] [Created] (FLINK-33289) SQL Gateway supports IPv6 addresses.

Yangze Guo created FLINK-33289: -- Summary: SQL Gateway supports IPv6 addresses. Key: FLINK-33289 URL: https://issues.apache.org/jira/browse/FLINK-33289 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-33203) FLIP-374: Adding a separate configuration for specifying Java Options of the SQL Gateway

[ https://issues.apache.org/jira/browse/FLINK-33203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-33203. -- Release Note: Flink introduces "env.java.opts.sql-gateway" for specifying the Java options for the

[jira] [Commented] (FLINK-33203) FLIP-374: Adding a separate configuration for specifying Java Options of the SQL Gateway

[ https://issues.apache.org/jira/browse/FLINK-33203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775661#comment-17775661 ] Yangze Guo commented on FLINK-33203: master: 07a614b387817b9443ae8d8c64eb7cfcfc4c > FLIP-374:

[jira] [Commented] (FLINK-33185) HybridShuffleITCase fails with TimeoutException: Pending slot request timed out in slot pool on AZP

[ https://issues.apache.org/jira/browse/FLINK-33185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775540#comment-17775540 ] Yangze Guo commented on FLINK-33185: Another instance [~Weijie Guo] 

[jira] [Assigned] (FLINK-33209) Translate Flink OLAP quick start guide to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-33209: -- Assignee: xiangyu feng > Translate Flink OLAP quick start guide to Chinese >

[jira] [Assigned] (FLINK-33235) Quickstart guide for Flink OLAP should support building from master branch

[ https://issues.apache.org/jira/browse/FLINK-33235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-33235: -- Assignee: xiangyu feng > Quickstart guide for Flink OLAP should support building from master

[jira] [Closed] (FLINK-33228) Fix the total current resource calculation when fulfilling requirements

[ https://issues.apache.org/jira/browse/FLINK-33228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-33228. -- Resolution: Fixed > Fix the total current resource calculation when fulfilling requirements >

[jira] [Commented] (FLINK-33228) Fix the total current resource calculation when fulfilling requirements

[ https://issues.apache.org/jira/browse/FLINK-33228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773872#comment-17773872 ] Yangze Guo commented on FLINK-33228: master: 5269631af525a01d944cfa9994a116fb27b80b1b > Fix the

[jira] [Assigned] (FLINK-33228) Fix the total current resource calculation when fulfilling requirements

[ https://issues.apache.org/jira/browse/FLINK-33228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-33228: -- Assignee: xiangyu feng > Fix the total current resource calculation when fulfilling

[jira] [Updated] (FLINK-33228) Fix the total current resource calculation when fulfilling requirements

[ https://issues.apache.org/jira/browse/FLINK-33228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-33228: --- Fix Version/s: 1.19.0 > Fix the total current resource calculation when fulfilling requirements >

[jira] [Updated] (FLINK-33228) Fix the total current resource calculation when fulfilling requirements

[ https://issues.apache.org/jira/browse/FLINK-33228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-33228: --- Affects Version/s: 1.19.0 > Fix the total current resource calculation when fulfilling requirements

[jira] [Assigned] (FLINK-25055) Support listen and notify mechanism for PartitionRequest

[ https://issues.apache.org/jira/browse/FLINK-25055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-25055: -- Assignee: Yangze Guo (was: Fang Yong) > Support listen and notify mechanism for

[jira] [Comment Edited] (FLINK-33112) Support placement constraint

[ https://issues.apache.org/jira/browse/FLINK-33112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773110#comment-17773110 ] Yangze Guo edited comment on FLINK-33112 at 10/9/23 6:09 AM: - Not quite

[jira] [Commented] (FLINK-33112) Support placement constraint

[ https://issues.apache.org/jira/browse/FLINK-33112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773110#comment-17773110 ] Yangze Guo commented on FLINK-33112: Can this feature be supported with pod templete? > Support

[jira] [Closed] (FLINK-15959) Add min number of slots configuration to limit total number of slots

[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-15959. -- Release Note: Flink now supports defining the minimum resource requirements that the Flink cluster

[jira] [Reopened] (FLINK-15959) Add min number of slots configuration to limit total number of slots

[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reopened FLINK-15959: > Add min number of slots configuration to limit total number of slots >

[jira] [Commented] (FLINK-15959) Add min number of slots configuration to limit total number of slots

[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17772939#comment-17772939 ] Yangze Guo commented on FLINK-15959: master: f15942c565851dc483e884f02e3bec825fe8abd9

[jira] [Closed] (FLINK-15959) Add min number of slots configuration to limit total number of slots

[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-15959. -- Fix Version/s: 1.19.0 Resolution: Fixed > Add min number of slots configuration to limit total

[jira] [Closed] (FLINK-32985) Support setting env.java.opts.sql-gateway to specify the jvm opts for sql gateway

[ https://issues.apache.org/jira/browse/FLINK-32985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-32985. -- Resolution: Duplicate > Support setting env.java.opts.sql-gateway to specify the jvm opts for sql >

[jira] [Updated] (FLINK-33203) FLIP-374: Adding a separate configuration for specifying Java Options of the SQL Gateway

[ https://issues.apache.org/jira/browse/FLINK-33203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-33203: --- Parent: FLINK-32898 Issue Type: Sub-task (was: Improvement) > FLIP-374: Adding a separate

[jira] [Created] (FLINK-33203) FLIP-374: Adding a separate configuration for specifying Java Options of the SQL Gateway

Yangze Guo created FLINK-33203: -- Summary: FLIP-374: Adding a separate configuration for specifying Java Options of the SQL Gateway Key: FLINK-33203 URL: https://issues.apache.org/jira/browse/FLINK-33203

[jira] [Closed] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-33053. -- Resolution: Fixed > Watcher leak in Zookeeper HA mode > - > >

[jira] [Updated] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-33053: --- Fix Version/s: 1.19.0 > Watcher leak in Zookeeper HA mode > - > >

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766646#comment-17766646 ] Yangze Guo commented on FLINK-33053: master: d5e151f72336abcc13082fe4bb3e05fd5a785e86 > Watcher

[jira] [Assigned] (FLINK-31896) Extend web interface to support failure labels

[ https://issues.apache.org/jira/browse/FLINK-31896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-31896: -- Assignee: Panagiotis Garefalakis > Extend web interface to support failure labels >

[jira] [Assigned] (FLINK-33086) Protect failure enrichment against unhandled exceptions

[ https://issues.apache.org/jira/browse/FLINK-33086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-33086: -- Assignee: Panagiotis Garefalakis > Protect failure enrichment against unhandled exceptions >

[jira] [Closed] (FLINK-32863) Improve Flink UI's time precision from second level to millisecond level

[ https://issues.apache.org/jira/browse/FLINK-32863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-32863. -- Fix Version/s: 1.19.0 Resolution: Fixed > Improve Flink UI's time precision from second level

[jira] [Commented] (FLINK-32863) Improve Flink UI's time precision from second level to millisecond level

[ https://issues.apache.org/jira/browse/FLINK-32863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764946#comment-17764946 ] Yangze Guo commented on FLINK-32863: master: 2d74260f41275add3c16ea72ee4ecedbec45f9d4 > Improve

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764943#comment-17764943 ] Yangze Guo commented on FLINK-33053: Thanks for the pointer [~tison] . I'd like to add a safetynet

[jira] [Assigned] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-33053: -- Assignee: Yangze Guo > Watcher leak in Zookeeper HA mode > -

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764640#comment-17764640 ] Yangze Guo commented on FLINK-33053: JFYI, I'm still investigating the root cause of this, but I

[jira] [Assigned] (FLINK-32863) Improve Flink UI's time precision from second level to millisecond level

[ https://issues.apache.org/jira/browse/FLINK-32863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-32863: -- Assignee: Jufang He > Improve Flink UI's time precision from second level to millisecond

[jira] [Commented] (FLINK-32488) Introduce configuration to control ExecutionGraph cache in REST API

[ https://issues.apache.org/jira/browse/FLINK-32488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17763992#comment-17763992 ] Yangze Guo commented on FLINK-32488: Thanks for the PR [~hejufang001] and [~xiangyu0xf] . I'm now

[jira] [Assigned] (FLINK-32488) Introduce configuration to control ExecutionGraph cache in REST API

[ https://issues.apache.org/jira/browse/FLINK-32488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-32488: -- Assignee: Jufang He (was: xiangyu feng) > Introduce configuration to control ExecutionGraph

[jira] [Updated] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-33053: --- Priority: Blocker (was: Critical) > Watcher leak in Zookeeper HA mode >

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17763713#comment-17763713 ] Yangze Guo commented on FLINK-33053: I just find that this issue is very easy to reproduce. To

[jira] [Updated] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-33053: --- Priority: Critical (was: Blocker) > Watcher leak in Zookeeper HA mode >

[jira] [Updated] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-33053: --- Priority: Blocker (was: Critical) > Watcher leak in Zookeeper HA mode >

  1   2   3   4   5   6   7   8   9   >