[jira] [Commented] (FLINK-31810) RocksDBException: Bad table magic number on checkpoint rescale

2023-05-14 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722656#comment-17722656 ] Yun Tang commented on FLINK-31810: -- [~david.artiga] what distributed-file-system did you use to store

[GitHub] [flink] fsk119 commented on pull request #17830: [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization

2023-05-14 Thread via GitHub
fsk119 commented on PR #17830: URL: https://github.com/apache/flink/pull/17830#issuecomment-1547203381 I ask the chatgbt about the idea. The answer as follows: > Q: Is it a good idea to put current catalog or database in the rest api headers? It can be a good idea to put the

[jira] [Commented] (FLINK-32094) startScheduling.BATCH performance regression since May 11th

2023-05-14 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722646#comment-17722646 ] Zhilong Hong commented on FLINK-32094: -- The extra cost may be caused by

[jira] [Updated] (FLINK-32094) startScheduling.BATCH performance regression since May 11th

2023-05-14 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-32094: - Attachment: image-2023-05-15-12-33-56-319.png > startScheduling.BATCH performance regression

[jira] [Comment Edited] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

2023-05-14 Thread lijie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722634#comment-17722634 ] lijie edited comment on FLINK-24696 at 5/15/23 4:28 AM: hi Piotr Nowojski. I

[GitHub] [flink] fsk119 commented on pull request #17830: [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization

2023-05-14 Thread via GitHub
fsk119 commented on PR #17830: URL: https://github.com/apache/flink/pull/17830#issuecomment-1547174183 The presto resposne headers contains the catalog/schema info[1], e.g `X-Presto-Set-Catalog` and `X-Presto-Catalog`. [1]

[jira] [Created] (FLINK-32095) HiveDialectITCase crashed with exit code 239

2023-05-14 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-32095: -- Summary: HiveDialectITCase crashed with exit code 239 Key: FLINK-32095 URL: https://issues.apache.org/jira/browse/FLINK-32095 Project: Flink Issue Type: Bug

[jira] (FLINK-32065) Got NoSuchFileException when initialize source function.

2023-05-14 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32065 ] Wencong Liu deleted comment on FLINK-32065: - was (Author: JIRAUSER281639): Hello [~SpongebobZ] , do you clean the tmp dir before the error happens ? It seems that the file was deleted when

[jira] [Commented] (FLINK-32065) Got NoSuchFileException when initialize source function.

2023-05-14 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722638#comment-17722638 ] Wencong Liu commented on FLINK-32065: - Hello [~SpongebobZ] , do you clean the tmp dir before the

[jira] [Commented] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-05-14 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722639#comment-17722639 ] Weijie Guo commented on FLINK-30629:

[jira] [Assigned] (FLINK-32094) startScheduling.BATCH performance regression since May 11th

2023-05-14 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-32094: -- Assignee: Yuxin Tan > startScheduling.BATCH performance regression since May 11th >

[jira] [Commented] (FLINK-32094) startScheduling.BATCH performance regression since May 11th

2023-05-14 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722637#comment-17722637 ] Weijie Guo commented on FLINK-32094: This may caused by FLINK-31635, [~tanyuxin] would you mind

[GitHub] [flink] fsk119 commented on a diff in pull request #17830: [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization

2023-05-14 Thread via GitHub
fsk119 commented on code in PR #17830: URL: https://github.com/apache/flink/pull/17830#discussion_r1193281401 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/PromptHandler.java: ## @@ -0,0 +1,186 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

2023-05-14 Thread lijie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722634#comment-17722634 ] lijie commented on FLINK-24696: --- hi Piotr Nowojski. I like flink and I learned how to contribute to our

[jira] [Commented] (FLINK-31033) UsingRemoteJarITCase.testUdfInRemoteJar failed with assertion

2023-05-14 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722632#comment-17722632 ] Weijie Guo commented on FLINK-31033: testCreateTemporarySystemFunctionUsingRemoteJar also report the

[GitHub] [flink] xintongsong commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-14 Thread via GitHub
xintongsong commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1193288010 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManager.java: ## @@ -0,0 +1,96 @@ +/* + *

[jira] [Closed] (FLINK-20794) Support to select distinct columns in the Table API

2023-05-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20794. --- Fix Version/s: (was: 1.18.0) Resolution: Not A Problem > Support to select distinct columns in

[jira] [Closed] (FLINK-31638) Downstream supports reading buffers from tiered store

2023-05-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-31638. Fix Version/s: 1.18.0 Resolution: Done master (1.18):

[jira] [Commented] (FLINK-20794) Support to select distinct columns in the Table API

2023-05-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722623#comment-17722623 ] Dian Fu commented on FLINK-20794: - Thanks for the analysis. Since string based interfaces have been

[GitHub] [flink] xintongsong closed pull request #22316: [FLINK-31638][network] Downstream supports reading buffers from tiered store

2023-05-14 Thread via GitHub
xintongsong closed pull request #22316: [FLINK-31638][network] Downstream supports reading buffers from tiered store URL: https://github.com/apache/flink/pull/22316 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

2023-05-14 Thread Liam (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722618#comment-17722618 ] Liam commented on FLINK-31762: -- Hi master [~martijnvisser] [~tzulitai] any comment? > Subscribe to

[GitHub] [flink] flinkbot commented on pull request #22577: [FLINK-31882][sql-client] Fix sql client can't show result for DELETE…

2023-05-14 Thread via GitHub
flinkbot commented on PR #22577: URL: https://github.com/apache/flink/pull/22577#issuecomment-1547107421 ## CI report: * 498d9e8c2a576f2a9dbfcb5367b2e2d8beed8f83 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] fsk119 commented on a diff in pull request #22533: [FLINK-31687][jdbc-driver] Get rid of flink-core for jdbc driver

2023-05-14 Thread via GitHub
fsk119 commented on code in PR #22533: URL: https://github.com/apache/flink/pull/22533#discussion_r1193272280 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/Executor.java: ## @@ -46,7 +46,7 @@ static Executor create( * * @return

[GitHub] [flink] luoyuxia opened a new pull request, #22577: [FLINK-31882][sql-client] Fix sql client can't show result for DELETE…

2023-05-14 Thread via GitHub
luoyuxia opened a new pull request, #22577: URL: https://github.com/apache/flink/pull/22577 … statement when delete is pushed down (#22488) ## What is the purpose of the change Backport of #22488 -- This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (FLINK-31950) Introduce StateMetadata

2023-05-14 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-31950: -- Summary: Introduce StateMetadata (was: Introduce StateMetadata and StateMetadataJson SerDe) >

[jira] [Updated] (FLINK-31950) Introduce StateMetadata and StateMetadataJson SerDe

2023-05-14 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-31950: -- Description: According to the FLIP design, we're about to introduce * StateMetadata, which describes

[GitHub] [flink] dianfu commented on a diff in pull request #22571: [FLINK-32056][Python][Connector/Pulsar] Upgrade flink-connector-pulsar in flink-python to v4.0.0

2023-05-14 Thread via GitHub
dianfu commented on code in PR #22571: URL: https://github.com/apache/flink/pull/22571#discussion_r1191830067 ## flink-python/pyflink/datastream/connectors/pulsar.py: ## @@ -693,8 +668,7 @@ class PulsarSinkBuilder(object): ... .set_service_url(PULSAR_BROKER_URL) \\

[GitHub] [flink] luoyuxia merged pull request #22488: [FLINK-31882][sql-client] Fix sql client can't show result for DELETE statement when delete is pushed down

2023-05-14 Thread via GitHub
luoyuxia merged PR #22488: URL: https://github.com/apache/flink/pull/22488 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-31950) Introduce StateMetadata and StateMetadataJson SerDe

2023-05-14 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-31950. -- Resolution: Fixed Fixed in master: 62b11e2e117f874f073de93756c6b9889c464562 > Introduce

[GitHub] [flink] godfreyhe closed pull request #22492: [FLINK-31950][table-planner] Introduce StateMetadata and StateMetadataJson SerDe

2023-05-14 Thread via GitHub
godfreyhe closed pull request #22492: [FLINK-31950][table-planner] Introduce StateMetadata and StateMetadataJson SerDe URL: https://github.com/apache/flink/pull/22492 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] godfreyhe commented on a diff in pull request #22492: [FLINK-31950][table-planner] Introduce StateMetadata and StateMetadataJson SerDe

2023-05-14 Thread via GitHub
godfreyhe commented on code in PR #22492: URL: https://github.com/apache/flink/pull/22492#discussion_r1193258928 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/StateMetadata.java: ## @@ -0,0 +1,207 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-32094) startScheduling.BATCH performance regression since May 11th

2023-05-14 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-32094: --- Description:

[jira] [Updated] (FLINK-32094) startScheduling.BATCH performance regression since May 11th

2023-05-14 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-32094: --- Attachment: image-2023-05-14-22-58-00-886.png Description:

[jira] [Created] (FLINK-32094) startScheduling.BATCH performance regression since May 11th

2023-05-14 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-32094: -- Summary: startScheduling.BATCH performance regression since May 11th Key: FLINK-32094 URL: https://issues.apache.org/jira/browse/FLINK-32094 Project: Flink

[jira] [Commented] (FLINK-28842) Add client.id.prefix for the KafkaSink

2023-05-14 Thread Yaroslav Tkachenko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722601#comment-17722601 ] Yaroslav Tkachenko commented on FLINK-28842: Hi Valentina, unfortunately I didn’t have a

[GitHub] [flink-playgrounds] alainbrown commented on pull request #42: Create flink_data volume for operations playground.

2023-05-14 Thread via GitHub
alainbrown commented on PR #42: URL: https://github.com/apache/flink-playgrounds/pull/42#issuecomment-1546974310 Done! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[GitHub] [flink] flinkbot commented on pull request #22576: Remove savepoint and checkpoint mount instructions from flink playground.

2023-05-14 Thread via GitHub
flinkbot commented on PR #22576: URL: https://github.com/apache/flink/pull/22576#issuecomment-1546972941 ## CI report: * 7daebec55b3c0aadaf4e499ac61fe078b25b1eb6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] alainbrown opened a new pull request, #22576: Remove savepoint and checkpoint mount instructions from flink playground.

2023-05-14 Thread via GitHub
alainbrown opened a new pull request, #22576: URL: https://github.com/apache/flink/pull/22576 ## What is the purpose of the change With the addition of a docker volume, this step is no long needed. https://github.com/apache/flink-playgrounds/pull/42 re: mkdir -p

[jira] [Commented] (FLINK-32093) Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received

2023-05-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722593#comment-17722593 ] Gyula Fora commented on FLINK-32093: Can you please share both the operator and the FlinkDeployment

[jira] [Commented] (FLINK-32041) flink-kubernetes-operator RoleBinding for Leases not created in correct namespace when using watchNamespaces

2023-05-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722592#comment-17722592 ] Gyula Fora commented on FLINK-32041: Can you please share both the operator and FlinkDeployment

[jira] [Commented] (FLINK-32093) Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received

2023-05-14 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722589#comment-17722589 ] Tamir Sagi commented on FLINK-32093: I'm talking about Operator HA not Job HA. > Upon Delete

[jira] [Comment Edited] (FLINK-32041) flink-kubernetes-operator RoleBinding for Leases not created in correct namespace when using watchNamespaces

2023-05-14 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722588#comment-17722588 ] Tamir Sagi edited comment on FLINK-32041 at 5/14/23 5:12 PM: - I'm talking

[jira] [Commented] (FLINK-32041) flink-kubernetes-operator RoleBinding for Leases not created in correct namespace when using watchNamespaces

2023-05-14 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722588#comment-17722588 ] Tamir Sagi commented on FLINK-32041: I'm talking about Operator HA. My point was when creating

[jira] [Updated] (FLINK-32093) Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received

2023-05-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-32093: --- Labels: (was: flink-kubernetes-operator) > Upon Delete deployment idle pods throw -

[jira] [Updated] (FLINK-32093) Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received

2023-05-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-32093: --- Affects Version/s: kubernetes-operator-1.5.0 > Upon Delete deployment idle pods throw -

[jira] [Commented] (FLINK-32093) Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received

2023-05-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722586#comment-17722586 ] Gyula Fora commented on FLINK-32093: By HA again here you mean Flink Job HA? or Operator HA (leader

[jira] [Comment Edited] (FLINK-32093) Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received

2023-05-14 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722584#comment-17722584 ] Tamir Sagi edited comment on FLINK-32093 at 5/14/23 4:37 PM: - There are no

[jira] [Commented] (FLINK-32093) Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received

2023-05-14 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722584#comment-17722584 ] Tamir Sagi commented on FLINK-32093: I will try tomorrow and get back to you. > Upon Delete

[jira] [Commented] (FLINK-32041) flink-kubernetes-operator RoleBinding for Leases not created in correct namespace when using watchNamespaces

2023-05-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722585#comment-17722585 ] Gyula Fora commented on FLINK-32041: This may be completely unrelated to the original issue

[jira] [Comment Edited] (FLINK-32041) flink-kubernetes-operator RoleBinding for Leases not created in correct namespace when using watchNamespaces

2023-05-14 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722583#comment-17722583 ] Tamir Sagi edited comment on FLINK-32041 at 5/14/23 4:33 PM: - I need to try

[jira] [Comment Edited] (FLINK-32041) flink-kubernetes-operator RoleBinding for Leases not created in correct namespace when using watchNamespaces

2023-05-14 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722583#comment-17722583 ] Tamir Sagi edited comment on FLINK-32041 at 5/14/23 4:33 PM: - I need to try

[jira] [Commented] (FLINK-32041) flink-kubernetes-operator RoleBinding for Leases not created in correct namespace when using watchNamespaces

2023-05-14 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722583#comment-17722583 ] Tamir Sagi commented on FLINK-32041: I need to try and get back to youwith an answer (probably

[jira] [Comment Edited] (FLINK-32041) flink-kubernetes-operator RoleBinding for Leases not created in correct namespace when using watchNamespaces

2023-05-14 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722583#comment-17722583 ] Tamir Sagi edited comment on FLINK-32041 at 5/14/23 4:32 PM: - I need to try

[jira] [Comment Edited] (FLINK-32093) Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received

2023-05-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722581#comment-17722581 ] Gyula Fora edited comment on FLINK-32093 at 5/14/23 4:25 PM: - Can you share

[jira] [Commented] (FLINK-32041) flink-kubernetes-operator RoleBinding for Leases not created in correct namespace when using watchNamespaces

2023-05-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722582#comment-17722582 ] Gyula Fora commented on FLINK-32041: [~tamirsagi] does the same error occur without HA enabled? >

[jira] [Commented] (FLINK-32093) Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received

2023-05-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722581#comment-17722581 ] Gyula Fora commented on FLINK-32093: Can you share the operator logs? This this also happen without

[jira] [Created] (FLINK-32093) Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received

2023-05-14 Thread Tamir Sagi (Jira)
Tamir Sagi created FLINK-32093: -- Summary: Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received Key: FLINK-32093 URL:

[jira] [Comment Edited] (FLINK-32041) flink-kubernetes-operator RoleBinding for Leases not created in correct namespace when using watchNamespaces

2023-05-14 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17721192#comment-17721192 ] Tamir Sagi edited comment on FLINK-32041 at 5/14/23 4:18 PM: - Hey Gyula, I

[GitHub] [flink] xuzhiwen1255 commented on a diff in pull request #21971: [FLINK-31084][connectors/dataGen] Add default value for dataGen seque…

2023-05-14 Thread via GitHub
xuzhiwen1255 commented on code in PR #21971: URL: https://github.com/apache/flink/pull/21971#discussion_r1193156542 ## flink-table/flink-table-api-java-bridge/src/test/java/org/apache/flink/table/factories/DataGenTableSourceFactoryTest.java: ## @@ -264,57 +267,63 @@ void

[GitHub] [flink] xuzhiwen1255 commented on pull request #21971: [FLINK-31084][connectors/dataGen] Add default value for dataGen seque…

2023-05-14 Thread via GitHub
xuzhiwen1255 commented on PR #21971: URL: https://github.com/apache/flink/pull/21971#issuecomment-1546911786 @XComp 感谢您的review,我已经完成了修改. PTAL. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] xuzhiwen1255 commented on a diff in pull request #21971: [FLINK-31084][connectors/dataGen] Add default value for dataGen seque…

2023-05-14 Thread via GitHub
xuzhiwen1255 commented on code in PR #21971: URL: https://github.com/apache/flink/pull/21971#discussion_r1193156464 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java: ## @@ -49,10 +50,18 @@ /** *

[jira] [Updated] (FLINK-32092) Integrate snapshot file-merging with existing IT cases

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32092: - Affects Version/s: 1.18.0 > Integrate snapshot file-merging with existing IT cases >

[jira] [Updated] (FLINK-32092) Integrate snapshot file-merging with existing IT cases

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32092: - Component/s: Runtime / Checkpointing Runtime / State Backends > Integrate snapshot

[jira] [Updated] (FLINK-32091) Add necessary metrics for file-merging

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32091: - Component/s: Runtime / Checkpointing Runtime / State Backends > Add necessary metrics

[jira] [Updated] (FLINK-32091) Add necessary metrics for file-merging

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32091: - Affects Version/s: 1.18.0 > Add necessary metrics for file-merging >

[jira] [Updated] (FLINK-32090) Python API for enabling and configuring file merging snapshot

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32090: - Component/s: Runtime / Checkpointing Runtime / State Backends > Python API for

[jira] [Updated] (FLINK-32087) Space amplification statistics of file merging

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32087: - Component/s: Runtime / Checkpointing Runtime / State Backends > Space amplification

[jira] [Updated] (FLINK-32090) Python API for enabling and configuring file merging snapshot

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32090: - Affects Version/s: 1.18.0 > Python API for enabling and configuring file merging snapshot >

[jira] [Updated] (FLINK-32089) Do fast copy in best-effort during first checkpoint after restoration

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32089: - Affects Version/s: 1.18.0 > Do fast copy in best-effort during first checkpoint after restoration >

[jira] [Updated] (FLINK-32089) Do fast copy in best-effort during first checkpoint after restoration

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32089: - Component/s: Runtime / Checkpointing Runtime / State Backends > Do fast copy in

[jira] [Updated] (FLINK-32088) Re-uploading in state file-merging for space amplification control

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32088: - Affects Version/s: 1.18.0 > Re-uploading in state file-merging for space amplification control >

[jira] [Updated] (FLINK-32087) Space amplification statistics of file merging

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32087: - Affects Version/s: 1.18.0 > Space amplification statistics of file merging >

[jira] [Updated] (FLINK-32088) Re-uploading in state file-merging for space amplification control

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32088: - Component/s: Runtime / Checkpointing Runtime / State Backends > Re-uploading in state

[jira] [Updated] (FLINK-32086) Cleanup non-reported managed directory on exit of TM

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32086: - Component/s: Runtime / Checkpointing Runtime / State Backends > Cleanup non-reported

[jira] [Updated] (FLINK-32086) Cleanup non-reported managed directory on exit of TM

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32086: - Affects Version/s: 1.18.0 > Cleanup non-reported managed directory on exit of TM >

[jira] [Updated] (FLINK-32085) Implement and migrate batch uploading in changelog files into the file merging framework

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32085: - Affects Version/s: 1.18.0 > Implement and migrate batch uploading in changelog files into the file >

[jira] [Updated] (FLINK-32085) Implement and migrate batch uploading in changelog files into the file merging framework

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32085: - Component/s: Runtime / Checkpointing Runtime / State Backends > Implement and migrate

[jira] [Updated] (FLINK-32083) Chinese translation of documentation of checkpoint file-merging

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32083: - Component/s: Runtime / Checkpointing Runtime / State Backends > Chinese translation of

[jira] [Updated] (FLINK-32084) Migrate current file merging of channel state into the file merging framework

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32084: - Affects Version/s: 1.18.0 > Migrate current file merging of channel state into the file merging

[jira] [Updated] (FLINK-32084) Migrate current file merging of channel state into the file merging framework

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32084: - Component/s: Runtime / Checkpointing Runtime / State Backends > Migrate current file

[jira] [Updated] (FLINK-32083) Chinese translation of documentation of checkpoint file-merging

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32083: - Affects Version/s: 1.18.0 > Chinese translation of documentation of checkpoint file-merging >

[jira] [Updated] (FLINK-32082) Documentation of checkpoint file-merging

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32082: - Component/s: Runtime / Checkpointing Runtime / State Backends > Documentation of

[jira] [Updated] (FLINK-32082) Documentation of checkpoint file-merging

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32082: - Affects Version/s: 1.18.0 > Documentation of checkpoint file-merging >

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-14 Thread via GitHub
TanYuxin-tyx commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1193122906 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheFlushManager.java: ## @@ -0,0 +1,105 @@ +/* + * Licensed

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-14 Thread via GitHub
TanYuxin-tyx commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1193122840 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheFlushManager.java: ## @@ -0,0 +1,105 @@ +/* + * Licensed

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-14 Thread via GitHub
TanYuxin-tyx commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1193122816 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheFlushManager.java: ## @@ -0,0 +1,105 @@ +/* + * Licensed

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-14 Thread via GitHub
TanYuxin-tyx commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1193122680 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheFlushManager.java: ## @@ -0,0 +1,105 @@ +/* + * Licensed

[jira] [Updated] (FLINK-32081) Compatibility between file-merging on and off across job runs

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32081: - Component/s: Runtime / Checkpointing Runtime / State Backends > Compatibility between

[jira] [Updated] (FLINK-32081) Compatibility between file-merging on and off across job runs

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32081: - Affects Version/s: 1.18.0 > Compatibility between file-merging on and off across job runs >

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-14 Thread via GitHub
TanYuxin-tyx commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1193122499 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheFlushManager.java: ## @@ -0,0 +1,105 @@ +/* + * Licensed

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-14 Thread via GitHub
TanYuxin-tyx commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1193122339 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheBufferFlushTrigger.java: ## @@ -0,0 +1,26 @@ +/* + *

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-14 Thread via GitHub
TanYuxin-tyx commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1193122290 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/common/TieredStorageUtils.java: ## @@ -0,0 +1,32 @@ +/* + * Licensed to

[jira] [Updated] (FLINK-32080) Restoration of FileMergingSnapshotManager

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32080: - Component/s: Runtime / Checkpointing Runtime / State Backends > Restoration of

[jira] [Updated] (FLINK-32080) Restoration of FileMergingSnapshotManager

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32080: - Affects Version/s: 1.18.0 > Restoration of FileMergingSnapshotManager >

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-14 Thread via GitHub
TanYuxin-tyx commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1193122008 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemorySpec.java: ## @@ -0,0 +1,51 @@ +/* + *

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-14 Thread via GitHub
TanYuxin-tyx commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1193121929 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManagerImpl.java: ## @@ -0,0 +1,117 @@ +/* +

[jira] [Updated] (FLINK-32079) Read/write checkpoint metadata of merged files

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32079: - Affects Version/s: 1.18.0 > Read/write checkpoint metadata of merged files >

[jira] [Updated] (FLINK-32079) Read/write checkpoint metadata of merged files

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32079: - Component/s: Runtime / Checkpointing Runtime / State Backends > Read/write checkpoint

[jira] [Updated] (FLINK-32078) Implement private state file merging

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32078: - Component/s: Runtime / Checkpointing Runtime / State Backends > Implement private

[jira] [Updated] (FLINK-32077) Implement shared state file merging

2023-05-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-32077: - Component/s: Runtime / Checkpointing Runtime / State Backends > Implement shared state

  1   2   >