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

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

[GitHub] [flink] pgaref commented on a diff in pull request #22608: [FLINK-31893][runtime] Introduce AdaptiveBatchScheduler failure enrichment/labeling

2023-05-20 Thread via GitHub
pgaref commented on code in PR #22608: URL: https://github.com/apache/flink/pull/22608#discussion_r1199660170 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchSchedulerTest.java: ## @@ -91,6 +95,31 @@ void setUp() {

[GitHub] [flink] reswqa commented on a diff in pull request #22608: [FLINK-31893][runtime] Introduce AdaptiveBatchScheduler failure enrichment/labeling

2023-05-20 Thread via GitHub
reswqa commented on code in PR #22608: URL: https://github.com/apache/flink/pull/22608#discussion_r1199639985 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchSchedulerTest.java: ## @@ -91,6 +95,31 @@ void setUp() {

[jira] [Updated] (FLINK-31893) Introduce AdaptiveBatchScheduler failure enrichment/labeling

2023-05-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31893: --- Labels: pull-request-available (was: ) > Introduce AdaptiveBatchScheduler failure

[GitHub] [flink] reswqa commented on a diff in pull request #22608: [FLINK-31893][runtime] Introduce AdaptiveBatchScheduler failure enrichment/labeling

2023-05-20 Thread via GitHub
reswqa commented on code in PR #22608: URL: https://github.com/apache/flink/pull/22608#discussion_r1199639985 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchSchedulerTest.java: ## @@ -91,6 +95,31 @@ void setUp() {

[jira] [Comment Edited] (FLINK-32123) Avro Confluent Schema Registry nightly end-to-end test failed due to timeout

2023-05-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724561#comment-17724561 ] Weijie Guo edited comment on FLINK-32123 at 5/20/23 5:38 PM: - Reverted in

[jira] [Comment Edited] (FLINK-32123) Avro Confluent Schema Registry nightly end-to-end test failed due to timeout

2023-05-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724561#comment-17724561 ] Weijie Guo edited comment on FLINK-32123 at 5/20/23 5:38 PM: - Reverted in

[jira] [Commented] (FLINK-32123) Avro Confluent Schema Registry nightly end-to-end test failed due to timeout

2023-05-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724561#comment-17724561 ] Weijie Guo commented on FLINK-32123: Reverted in master(1.18) via

[jira] [Closed] (FLINK-32123) Avro Confluent Schema Registry nightly end-to-end test failed due to timeout

2023-05-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-32123. -- Fix Version/s: 1.18.0 Resolution: Fixed > Avro Confluent Schema Registry nightly end-to-end

[jira] [Updated] (FLINK-32123) Avro Confluent Schema Registry nightly end-to-end test failed due to timeout

2023-05-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32123: --- Labels: pull-request-available test-stability (was: test-stability) > Avro Confluent

[jira] [Updated] (FLINK-32108) KubernetesExtension calls assumeThat in @BeforeAll callback which doesn't print the actual failure message

2023-05-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32108: --- Labels: pull-request-available starter (was: starter) > KubernetesExtension calls

[GitHub] [flink] flinkbot commented on pull request #22613: [FLINK-32141][checkpointing] turn down a log level in the SharedState…

2023-05-20 Thread via GitHub
flinkbot commented on PR #22613: URL: https://github.com/apache/flink/pull/22613#issuecomment-1555953469 ## CI report: * 97ae387dfe466d2d1e32f10bfd4f62038e0b2ee4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32141) SharedStateRegistry print too much info log

2023-05-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32141: --- Labels: pull-request-available (was: ) > SharedStateRegistry print too much info log >

[jira] [Updated] (FLINK-32141) SharedStateRegistry print too much info log

2023-05-20 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-32141: Description: FLINK-29095 added some log to SharedStateRegistry for trouble shooting. Among them,

[jira] [Created] (FLINK-32141) SharedStateRegistry print too much info log

2023-05-20 Thread Feifan Wang (Jira)
Feifan Wang created FLINK-32141: --- Summary: SharedStateRegistry print too much info log Key: FLINK-32141 URL: https://issues.apache.org/jira/browse/FLINK-32141 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-32139) Data accidentally deleted and not deleted when upsert sink to hbase

2023-05-20 Thread LiuZeshan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724543#comment-17724543 ] LiuZeshan commented on FLINK-32139: --- [~ferenc-csaky] [~martijnvisser] Could you help to take a look at

[GitHub] [flink] flinkbot commented on pull request #22612: [FLINK-32139][connector/hbase] Using strongly increasing nanosecond timestamp and DeleteColumn type to fix data accidental deletion and non

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

[jira] [Updated] (FLINK-32139) Data accidentally deleted and not deleted when upsert sink to hbase

2023-05-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32139: --- Labels: pull-request-available (was: ) > Data accidentally deleted and not deleted when

[GitHub] [flink] lzshlzsh opened a new pull request, #22612: [FLINK-32139][connector/hbase] Using strongly increasing nanosecond timestamp and DeleteColumn type to fix data accidental deletion and non

2023-05-20 Thread via GitHub
lzshlzsh opened a new pull request, #22612: URL: https://github.com/apache/flink/pull/22612 ## What is the purpose of the change Using strongly increasing nanosecond timestamp and DeleteColumn type to fix data accidental deletion and non deletion issues when sink upsert data

[jira] [Closed] (FLINK-32140) Data accidentally deleted and not deleted when upsert sink to hbase

2023-05-20 Thread LiuZeshan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan closed FLINK-32140. - Resolution: Duplicate > Data accidentally deleted and not deleted when upsert sink to hbase >

[jira] [Created] (FLINK-32140) Data accidentally deleted and not deleted when upsert sink to hbase

2023-05-20 Thread LiuZeshan (Jira)
LiuZeshan created FLINK-32140: - Summary: Data accidentally deleted and not deleted when upsert sink to hbase Key: FLINK-32140 URL: https://issues.apache.org/jira/browse/FLINK-32140 Project: Flink

[jira] [Created] (FLINK-32139) Data accidentally deleted and not deleted when upsert sink to hbase

2023-05-20 Thread LiuZeshan (Jira)
LiuZeshan created FLINK-32139: - Summary: Data accidentally deleted and not deleted when upsert sink to hbase Key: FLINK-32139 URL: https://issues.apache.org/jira/browse/FLINK-32139 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #22611: [hotfix][doc] mvn 3.8.6 is recommended or higher version could be used

2023-05-20 Thread via GitHub
flinkbot commented on PR #22611: URL: https://github.com/apache/flink/pull/22611#issuecomment-1555903469 ## CI report: * 286348435be40dec54af80f156cb989833a375f0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] JingGe opened a new pull request, #22611: [hotfix][doc] mvn 3.8.6 is recommended or higher version could be used

2023-05-20 Thread via GitHub
JingGe opened a new pull request, #22611: URL: https://github.com/apache/flink/pull/22611 ## What is the purpose of the change update the doc to help developer use the feasible maven version. ## Brief change log - pointed out that 3.8.6 is recommended according to

[jira] [Reopened] (FLINK-25989) EventTimeWindowCheckpointingITCase failed with exit code 137

2023-05-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reopened FLINK-25989: - reopen since it seems it happened again

[jira] [Updated] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2023-05-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-18356: Affects Version/s: 1.18.0 > flink-table-planner Exit code 137 returned from process >

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2023-05-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724502#comment-17724502 ] Sergey Nuyanzin commented on FLINK-18356: -

[jira] [Commented] (FLINK-26974) Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure

2023-05-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724501#comment-17724501 ] Sergey Nuyanzin commented on FLINK-26974: -

[jira] [Commented] (FLINK-30433) HiveDialectITCase#testCreateDatabase fails with "Could not execute CREATE DATABASE"

2023-05-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724500#comment-17724500 ] Sergey Nuyanzin commented on FLINK-30433: -

[jira] [Commented] (FLINK-26990) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByTime failed

2023-05-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724498#comment-17724498 ] Sergey Nuyanzin commented on FLINK-26990: -

[jira] [Reopened] (FLINK-26990) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByTime failed

2023-05-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reopened FLINK-26990: - reopen since it is reproduced again >

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

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

[jira] [Created] (FLINK-32138) SQLClientSchemaRegistryITCase fails with timeout on AZP

2023-05-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-32138: --- Summary: SQLClientSchemaRegistryITCase fails with timeout on AZP Key: FLINK-32138 URL: https://issues.apache.org/jira/browse/FLINK-32138 Project: Flink

[jira] [Commented] (FLINK-25343) HBaseConnectorITCase.testTableSourceSinkWithDDL fail on azure

2023-05-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724494#comment-17724494 ] Sergey Nuyanzin commented on FLINK-25343: -

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

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