[jira] [Comment Edited] (FLINK-31211) Flink chk files not delete automic after 1.13

2023-02-28 Thread leo.zhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694395#comment-17694395 ] leo.zhi edited comment on FLINK-31211 at 2/28/23 8:01 AM: -- I checked the flink

[jira] [Comment Edited] (FLINK-31140) Load additional dependencies in operator classpath

2023-02-28 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694379#comment-17694379 ] Tamir Sagi edited comment on FLINK-31140 at 2/28/23 8:23 AM: - I think you

[jira] [Created] (FLINK-31256) FLIP-297: Improve Auxiliary Sql Statements

2023-02-28 Thread Ran Tao (Jira)
Ran Tao created FLINK-31256: --- Summary: FLIP-297: Improve Auxiliary Sql Statements Key: FLINK-31256 URL: https://issues.apache.org/jira/browse/FLINK-31256 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on pull request #22045: [FLINK-31082][table-planner] Setting maven property 'flink.resueForks' to false in table planner module

2023-02-28 Thread via GitHub
flinkbot commented on PR #22045: URL: https://github.com/apache/flink/pull/22045#issuecomment-1447795296 ## CI report: * 83f73a810193e4f06984297367c3c050ed7d1542 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-22793) HybridSource Table Implementation

2023-02-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694450#comment-17694450 ] Martijn Visser commented on FLINK-22793: Looking forward to your contributor! > HybridSource

[jira] [Commented] (FLINK-31211) Flink chk files not delete automic after 1.13

2023-02-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694449#comment-17694449 ] Martijn Visser commented on FLINK-31211: [~leo.zhi] Yes, you need to upgrade > Flink chk files

[jira] [Commented] (FLINK-31246) Remove PodTemplate description from the SpecChange message

2023-02-28 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694419#comment-17694419 ] Wencong Liu commented on FLINK-31246: - Hello [~pvary], I'm quite interested in this issue could you

[jira] [Comment Edited] (FLINK-31246) Remove PodTemplate description from the SpecChange message

2023-02-28 Thread Peter Vary (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694443#comment-17694443 ] Peter Vary edited comment on FLINK-31246 at 2/28/23 8:57 AM: - Talked with

[jira] [Commented] (FLINK-31255) OperatorUtils#createWrappedOperatorConfig fails to wrap operator config

2023-02-28 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694417#comment-17694417 ] Zhipeng Zhang commented on FLINK-31255: --- It seems that the bug comes from not unwrapping the

[jira] [Updated] (FLINK-30978) ExecutorImplITCase.testInterruptExecution hangs waiting for SQL gateway service closing

2023-02-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-30978: -- Priority: Major (was: Blocker) > ExecutorImplITCase.testInterruptExecution hangs waiting for

[jira] [Comment Edited] (FLINK-31255) OperatorUtils#createWrappedOperatorConfig fails to wrap operator config

2023-02-28 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694417#comment-17694417 ] Zhipeng Zhang edited comment on FLINK-31255 at 2/28/23 8:17 AM: It seems

[GitHub] [flink] 1996fanrui merged pull request #22019: [hotfix] [FLINK-31221] Fix Typo in YarnConfigOptions.

2023-02-28 Thread via GitHub
1996fanrui merged PR #22019: URL: https://github.com/apache/flink/pull/22019 -- 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:

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #550: [FLINK-31178] Public Writer API

2023-02-28 Thread via GitHub
tsreaper commented on code in PR #550: URL: https://github.com/apache/flink-table-store/pull/550#discussion_r1119644649 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/TableCommit.java: ## @@ -18,121 +18,55 @@ package

[jira] [Commented] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module

2023-02-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694411#comment-17694411 ] Martijn Visser commented on FLINK-31082: Re-opened to create backport to release-1.16 > Setting

[jira] [Created] (FLINK-31255) OperatorUtils#createWrappedOperatorConfig fails to wrap operator config

2023-02-28 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31255: - Summary: OperatorUtils#createWrappedOperatorConfig fails to wrap operator config Key: FLINK-31255 URL: https://issues.apache.org/jira/browse/FLINK-31255 Project:

[jira] [Commented] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

2023-02-28 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694438#comment-17694438 ] Yanfei Lei commented on FLINK-31238: Thanks for your sharing, this drastically reduces the number of

[jira] [Commented] (FLINK-31246) Remove PodTemplate description from the SpecChange message

2023-02-28 Thread Peter Vary (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694443#comment-17694443 ] Peter Vary commented on FLINK-31246: Talked with [~gyfora] about this, and he is concerned that this

[jira] [Commented] (FLINK-31140) Load additional dependencies in operator classpath

2023-02-28 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694408#comment-17694408 ] Alexis Sarda-Espinosa commented on FLINK-31140: --- It does, I just wanted to corroborate,

[jira] [Reopened] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module

2023-02-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reopened FLINK-31082: > Setting maven property 'flink.resueForks' to false in table planner module >

[jira] [Commented] (FLINK-30978) ExecutorImplITCase.testInterruptExecution hangs waiting for SQL gateway service closing

2023-02-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694409#comment-17694409 ] Shengkai Fang commented on FLINK-30978: --- Hello [~mapohl]. Thanks for sharing this with me. It's

[jira] [Commented] (FLINK-31104) TPC-DS test timed out in query 36

2023-02-28 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694425#comment-17694425 ] dalongliu commented on FLINK-31104: --- cc [~guoweijie] , can you also help take a look? > TPC-DS test

[GitHub] [flink] 1996fanrui commented on pull request #22020: [FLINK-31222] Remove usage of deprecated ConverterUtils.toApplicationId.

2023-02-28 Thread via GitHub
1996fanrui commented on PR #22020: URL: https://github.com/apache/flink/pull/22020#issuecomment-1447768293 @flinkbot run azure -- 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

[GitHub] [flink] swuferhong opened a new pull request, #22045: [FLINK-31082][table-planner] Setting maven property 'flink.resueForks' to false in table planner module

2023-02-28 Thread via GitHub
swuferhong opened a new pull request, #22045: URL: https://github.com/apache/flink/pull/22045 ## What is the purpose of the change This pr is a cherry-pick pr aims to alleviate the CI OOM problem mentioned in issue: https://issues.apache.org/jira/browse/FLINK-18356 in

[jira] [Comment Edited] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

2023-02-28 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694438#comment-17694438 ] Yanfei Lei edited comment on FLINK-31238 at 2/28/23 8:49 AM: - Thanks for

[jira] [Updated] (FLINK-31256) FLIP-297: Improve Auxiliary Sql Statements

2023-02-28 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-31256: Component/s: Table SQL / API > FLIP-297: Improve Auxiliary Sql Statements >

[jira] [Updated] (FLINK-31256) FLIP-297: Improve Auxiliary Sql Statements

2023-02-28 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-31256: Component/s: Table SQL / Planner > FLIP-297: Improve Auxiliary Sql Statements >

[jira] [Updated] (FLINK-31221) Fix Typo in YarnConfigOptions

2023-02-28 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-31221: Fix Version/s: 1.18.0 > Fix Typo in YarnConfigOptions > - > >

[jira] [Commented] (FLINK-31221) Fix Typo in YarnConfigOptions

2023-02-28 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694424#comment-17694424 ] Rui Fan commented on FLINK-31221: - Hi [~slfan1989] , thanks for your fix:) apache:master commit :

[jira] [Closed] (FLINK-31221) Fix Typo in YarnConfigOptions

2023-02-28 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-31221. --- Resolution: Fixed > Fix Typo in YarnConfigOptions > - > > Key:

[jira] [Comment Edited] (FLINK-22793) HybridSource Table Implementation

2023-02-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694450#comment-17694450 ] Martijn Visser edited comment on FLINK-22793 at 2/28/23 9:02 AM: -

[jira] [Commented] (FLINK-31253) Port itcases to Flink 1.15 and 1.14

2023-02-28 Thread Chao Tian (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694418#comment-17694418 ] Chao Tian commented on FLINK-31253: --- I want to try it. Coule you please assign it to me? Thanks! cc

[jira] [Commented] (FLINK-31104) TPC-DS test timed out in query 36

2023-02-28 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694431#comment-17694431 ] dalongliu commented on FLINK-31104: --- I also occur the query timeout when running tpcds in the yarn

[jira] [Comment Edited] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

2023-02-28 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694438#comment-17694438 ] Yanfei Lei edited comment on FLINK-31238 at 2/28/23 8:48 AM: - Thanks for

[jira] [Updated] (FLINK-31256) FLIP-297: Improve Auxiliary Sql Statements

2023-02-28 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-31256: Description: The FLIP design doc can be found at page

[GitHub] [flink] libenchao commented on a diff in pull request #13081: [FLINK-18590][json] Support json array explode to multi messages

2023-02-28 Thread via GitHub
libenchao commented on code in PR #13081: URL: https://github.com/apache/flink/pull/13081#discussion_r1119750413 ## docs/content/docs/connectors/table/formats/json.md: ## @@ -241,6 +241,41 @@ The following table lists the type mapping from Flink type to JSON type.

[jira] [Updated] (FLINK-31246) Remove PodTemplate description from the SpecChange message

2023-02-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31246: --- Labels: pull-request-available (was: ) > Remove PodTemplate description from the

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-28 Thread via GitHub
rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1119813160 ## flink-tests/src/test/java/org/apache/flink/test/recovery/LocalRecoveryITCase.java: ## @@ -67,12 +68,14 @@ import java.util.Optional; import

[jira] [Commented] (FLINK-30829) Make the backpressure tab could be sort by the backpressure level

2023-02-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694486#comment-17694486 ] Xintong Song commented on FLINK-30829: -- Sorting subtasks by busy/idle/backpressure time sounds to

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #533: [FLINK-30920] [AutoScaler] adds exclude vertex ids for autoscaler to ignore for evaluation and scaling

2023-02-28 Thread via GitHub
gyfora merged PR #533: URL: https://github.com/apache/flink-kubernetes-operator/pull/533 -- 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:

[GitHub] [flink-table-store] FangYongs commented on pull request #564: [FLINK-31254] Improve the read performance for files table

2023-02-28 Thread via GitHub
FangYongs commented on PR #564: URL: https://github.com/apache/flink-table-store/pull/564#issuecomment-1448039969 LGTM +1 -- 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.

[jira] [Created] (FLINK-31258) can not get kerberos keytab in flink operator

2023-02-28 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-31258: - Summary: can not get kerberos keytab in flink operator Key: FLINK-31258 URL: https://issues.apache.org/jira/browse/FLINK-31258 Project: Flink Issue Type: Bug

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #562: [FLINK-31248] Improve documentation for append-only table

2023-02-28 Thread via GitHub
JingsongLi commented on code in PR #562: URL: https://github.com/apache/flink-table-store/pull/562#discussion_r1119974300 ## docs/content/docs/features/primary-key-table.md: ## @@ -158,12 +154,21 @@ Full compaction changelog producer can produce complete changelog for any type

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-28 Thread via GitHub
rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1119982866 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/VertexParallelism.java: ## @@ -23,14 +23,27 @@ import java.util.Map; /**

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-28 Thread via GitHub
rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1120015731 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotAllocator.java: ## @@ -54,14 +58,35 @@ public interface SlotAllocator {

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-28 Thread via GitHub
rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1119982866 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/VertexParallelism.java: ## @@ -23,14 +23,27 @@ import java.util.Map; /**

[GitHub] [flink-table-store] Myasuka opened a new pull request, #565: [FLINK-31226] Bump FRocksDB version to 6.20.3-ververica-2.0

2023-02-28 Thread via GitHub
Myasuka opened a new pull request, #565: URL: https://github.com/apache/flink-table-store/pull/565 Current FRocksDB version in flink-table-store is still 6.20.3-ververica-1.0, which cannot run with Apple's silicon chips. Newly released 6.20.3-ververica-2.0 FRocksDB could run well with

[GitHub] [flink] liuyongvs commented on a diff in pull request #21993: [FLINK-31166][table] Fix array_contains does not support null argumen…

2023-02-28 Thread via GitHub
liuyongvs commented on code in PR #21993: URL: https://github.com/apache/flink/pull/21993#discussion_r1119824562 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java: ## @@ -31,24 +31,28 @@

[jira] [Updated] (FLINK-31226) Bump the FRocksDB version in table-store's lookup module

2023-02-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31226: --- Labels: pull-request-available (was: ) > Bump the FRocksDB version in table-store's lookup

[jira] [Commented] (FLINK-31244) OffHeapUnsafeMemorySegmentTest.testCallCleanerOnceOnConcurrentFree prints IllegalStateException

2023-02-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694485#comment-17694485 ] Xintong Song commented on FLINK-31244: -- IIRC, the conclusions of previous discussions were: 1. A

[GitHub] [flink-table-store] JingsongLi merged pull request #564: [FLINK-31254] Improve the read performance for files table

2023-02-28 Thread via GitHub
JingsongLi merged PR #564: URL: https://github.com/apache/flink-table-store/pull/564 -- 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:

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #562: [FLINK-31248] Improve documentation for append-only table

2023-02-28 Thread via GitHub
JingsongLi commented on code in PR #562: URL: https://github.com/apache/flink-table-store/pull/562#discussion_r1119972451 ## docs/content/docs/features/append-only-table.md: ## @@ -0,0 +1,98 @@ +--- +title: "Append Only Table" +weight: 2 +type: docs +aliases: +-

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-28 Thread via GitHub
rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1119982866 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/VertexParallelism.java: ## @@ -23,14 +23,27 @@ import java.util.Map; /**

[jira] [Assigned] (FLINK-31259) Gateway supports initialization of catalog at startup

2023-02-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-31259: - Assignee: Shammon > Gateway supports initialization of catalog at startup >

[jira] [Commented] (FLINK-31257) Fix errors in “CSV Formats" page

2023-02-28 Thread ZhengYi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694511#comment-17694511 ] ZhengYi Weng commented on FLINK-31257: -- Hi,[~jark] ,I have put the screenshot into the

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-28 Thread via GitHub
rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1120003300 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotAllocator.java: ## @@ -54,14 +58,35 @@ public interface SlotAllocator {

[jira] [Created] (FLINK-31261) Make AdaptiveScheduler aware of the (local) state size

2023-02-28 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-31261: - Summary: Make AdaptiveScheduler aware of the (local) state size Key: FLINK-31261 URL: https://issues.apache.org/jira/browse/FLINK-31261 Project: Flink

[jira] [Assigned] (FLINK-31104) TPC-DS test timed out in query 36

2023-02-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-31104: - Assignee: Weijie Guo > TPC-DS test timed out in query 36 >

[GitHub] [flink] dmvk commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-28 Thread via GitHub
dmvk commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1119751778 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/VertexParallelism.java: ## @@ -23,14 +23,27 @@ import java.util.Map; /** - * Core

[GitHub] [flink] weng1424 commented on a diff in pull request #22001: [FLINK-30242][table-planner] Swap local aggregate and union node to a…

2023-02-28 Thread via GitHub
weng1424 commented on code in PR #22001: URL: https://github.com/apache/flink/pull/22001#discussion_r1119652784 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkBatchProgram.scala: ## @@ -292,6 +293,16 @@ object

[GitHub] [flink] XComp commented on pull request #22042: [FLINK-27954] JobVertexFlameGraphHandler does not work on standby Dispatcher.

2023-02-28 Thread via GitHub
XComp commented on PR #22042: URL: https://github.com/apache/flink/pull/22042#issuecomment-1447912114 Hi @reswqa , unfortunately, with the release coming up, I'm not having much capacity right now to pick up another task. Therefore, I cannot promise you to pick it up soon. I'll keep it on

[jira] [Comment Edited] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

2023-02-28 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694475#comment-17694475 ] Yue Ma edited comment on FLINK-31238 at 2/28/23 10:18 AM: -- [~Yanfei Lei] 1.

[jira] [Commented] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

2023-02-28 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694475#comment-17694475 ] Yue Ma commented on FLINK-31238: 1. IngestExternalFile will use global_seq_no, but when we rewrite, the

[GitHub] [flink-table-store] JingsongLi merged pull request #565: [FLINK-31226] Bump FRocksDB version to 6.20.3-ververica-2.0

2023-02-28 Thread via GitHub
JingsongLi merged PR #565: URL: https://github.com/apache/flink-table-store/pull/565 -- 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:

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-28 Thread via GitHub
rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1119952982 ## flink-tests/src/test/java/org/apache/flink/test/recovery/LocalRecoveryITCase.java: ## @@ -67,12 +68,14 @@ import java.util.Optional; import

[jira] [Updated] (FLINK-25788) Add show connectors command

2023-02-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-25788: Parent: FLINK-31256 Issue Type: Sub-task (was: Bug) > Add show connectors

[jira] [Updated] (FLINK-25788) Add show connectors command

2023-02-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-25788: Description: Currently the only work around to see available connectors is to create a

[jira] [Updated] (FLINK-25788) Add show connectors command

2023-02-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-25788: Description: Currently the only work around to see available connectors is to create a

[GitHub] [flink] wangyang0918 commented on pull request #21978: [FLINK-31161][build] bump versions-maven-plugin to 2.14.2.

2023-02-28 Thread via GitHub
wangyang0918 commented on PR #21978: URL: https://github.com/apache/flink/pull/21978#issuecomment-1447831049 Given that `org.codehaus.mojo:versions-maven-plugin:2.8.1` works well for the current Flink release process, I also could not fully understand why we need to bump the version. --

[GitHub] [flink-table-store] FangYongs commented on a diff in pull request #564: [FLINK-31254] Improve the read performance for files table

2023-02-28 Thread via GitHub
FangYongs commented on code in PR #564: URL: https://github.com/apache/flink-table-store/pull/564#discussion_r1119864296 ## flink-table-store-common/src/main/java/org/apache/flink/table/store/data/LazyGenericRow.java: ## @@ -0,0 +1,171 @@ +/* + * Licensed to the Apache Software

[jira] [Closed] (FLINK-30920) K8 cluster autoscaler | exclude operator ids from scaler

2023-02-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30920. -- Assignee: Gaurav Miglani Resolution: Fixed merged to main

[GitHub] [flink] dianfu commented on a diff in pull request #22003: [FLINK-31185][Python] Support side-output in broadcast processing

2023-02-28 Thread via GitHub
dianfu commented on code in PR #22003: URL: https://github.com/apache/flink/pull/22003#discussion_r1119985077 ## flink-python/pyflink/datastream/tests/test_data_stream.py: ## @@ -589,6 +589,40 @@ def process_element2(self, value, ctx: 'CoProcessFunction.Context'):

[GitHub] [flink] slfan1989 commented on pull request #22020: [FLINK-31222] Remove usage of deprecated ConverterUtils.toApplicationId.

2023-02-28 Thread via GitHub
slfan1989 commented on PR #22020: URL: https://github.com/apache/flink/pull/22020#issuecomment-1448129413 @flinkbot run azure -- 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

[jira] [Created] (FLINK-31260) PushLocalHashAggIntoScanRule should also work with union RelNode

2023-02-28 Thread Aitozi (Jira)
Aitozi created FLINK-31260: -- Summary: PushLocalHashAggIntoScanRule should also work with union RelNode Key: FLINK-31260 URL: https://issues.apache.org/jira/browse/FLINK-31260 Project: Flink Issue

[jira] [Updated] (FLINK-31260) PushLocalHashAggIntoScanRule should also work with union RelNode

2023-02-28 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-31260: --- Component/s: Table SQL / Planner > PushLocalHashAggIntoScanRule should also work with union RelNode >

[GitHub] [flink] swuferhong commented on pull request #22045: [FLINK-31082][table-planner] Setting maven property 'flink.resueForks' to false in table planner module

2023-02-28 Thread via GitHub
swuferhong commented on PR #22045: URL: https://github.com/apache/flink/pull/22045#issuecomment-1448154544 @flinkbot run azure -- 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

[GitHub] [flink-kubernetes-operator] pvary opened a new pull request, #539: [FLINK-31246] Remove PodTemplate description from the SpecChange message

2023-02-28 Thread via GitHub
pvary opened a new pull request, #539: URL: https://github.com/apache/flink-kubernetes-operator/pull/539 ## What is the purpose of the change Currently the Spec Change message contains the full PodTemplate twice. This makes the message seriously big and also contains very little

[jira] [Closed] (FLINK-31226) Bump the FRocksDB version in table-store's lookup module

2023-02-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31226. Resolution: Fixed master: 3f56f3b8cf5bd4075be84690bb8e8c677506e8ef > Bump the FRocksDB version

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #550: [FLINK-31178] Public Writer API

2023-02-28 Thread via GitHub
JingsongLi commented on code in PR #550: URL: https://github.com/apache/flink-table-store/pull/550#discussion_r1119923441 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/TableCommit.java: ## @@ -18,121 +18,55 @@ package

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #564: [FLINK-31254] Improve the read performance for files table

2023-02-28 Thread via GitHub
JingsongLi commented on code in PR #564: URL: https://github.com/apache/flink-table-store/pull/564#discussion_r1119936701 ## flink-table-store-common/src/main/java/org/apache/flink/table/store/data/LazyGenericRow.java: ## @@ -0,0 +1,171 @@ +/* + * Licensed to the Apache

[jira] [Closed] (FLINK-31254) Improve the read performance for files table

2023-02-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31254. Resolution: Fixed master: 0a8c3a1c426454258b663ffd52de5bcdc1e8ed20 > Improve the read

[jira] [Created] (FLINK-31259) Gateway supports initialization of catalog at startup

2023-02-28 Thread Shammon (Jira)
Shammon created FLINK-31259: --- Summary: Gateway supports initialization of catalog at startup Key: FLINK-31259 URL: https://issues.apache.org/jira/browse/FLINK-31259 Project: Flink Issue Type:

[GitHub] [flink] Aitozi commented on a diff in pull request #22001: [FLINK-30242][table-planner] Swap local aggregate and union node to a…

2023-02-28 Thread via GitHub
Aitozi commented on code in PR #22001: URL: https://github.com/apache/flink/pull/22001#discussion_r1120009253 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkBatchProgram.scala: ## @@ -292,6 +293,16 @@ object

[GitHub] [flink] Aitozi commented on a diff in pull request #22001: [FLINK-30242][table-planner] Swap local aggregate and union node to a…

2023-02-28 Thread via GitHub
Aitozi commented on code in PR #22001: URL: https://github.com/apache/flink/pull/22001#discussion_r1120021883 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkBatchProgram.scala: ## @@ -292,6 +293,16 @@ object

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-28 Thread via GitHub
rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1120034105 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateSizeEstimates.java: ## @@ -0,0 +1,129 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-31144) Slow scheduling on large-scale batch jobs

2023-02-28 Thread Julien Tournay (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694551#comment-17694551 ] Julien Tournay commented on FLINK-31144: Hey there! I finally found some time to test the fix

[GitHub] [flink] JingsongLi merged pull request #22043: [FLINK-31250][formats][parquet] Parquet format supports MULTISET type

2023-02-28 Thread via GitHub
JingsongLi merged PR #22043: URL: https://github.com/apache/flink/pull/22043 -- 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-31250) Parquet format supports MULTISET type

2023-02-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31250. Assignee: Nicholas Jiang Resolution: Fixed master: 161014149e803bfd1d3653badb230b2ed36ce3cb

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #562: [FLINK-31248] Improve documentation for append-only table

2023-02-28 Thread via GitHub
tsreaper commented on code in PR #562: URL: https://github.com/apache/flink-table-store/pull/562#discussion_r1119793489 ## docs/content/docs/features/append-only-table.md: ## @@ -0,0 +1,98 @@ +--- +title: "Append Only Table" +weight: 2 +type: docs +aliases: +-

[jira] [Updated] (FLINK-31248) Improve documentation for append-only table

2023-02-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31248: --- Labels: pull-request-available (was: ) > Improve documentation for append-only table >

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #564: [FLINK-31254] Improve the read performance for files table

2023-02-28 Thread via GitHub
JingsongLi commented on code in PR #564: URL: https://github.com/apache/flink-table-store/pull/564#discussion_r1119935439 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/FieldStatsConverters.java: ## @@ -33,12 +33,14 @@ public class

[jira] [Commented] (FLINK-31257) Fix errors in “CSV Formats" page

2023-02-28 Thread ZhengYi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694505#comment-17694505 ] ZhengYi Weng commented on FLINK-31257: -- Hi,[~jark].Could you please assign it to me? I'd like to

[jira] [Closed] (FLINK-29859) TPC-DS end-to-end test with adaptive batch scheduler failed due to oo non-empty .out files.

2023-02-28 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-29859. --- Resolution: Fixed master: 28e75620db7b0794ff1c19f8928ce7d33516ba64 release-1.17:

[GitHub] [flink] reswqa commented on pull request #22042: [FLINK-27954] JobVertexFlameGraphHandler does not work on standby Dispatcher.

2023-02-28 Thread via GitHub
reswqa commented on PR #22042: URL: https://github.com/apache/flink/pull/22042#issuecomment-1448085323 Thanks @XComp for your quick reply. Never mind, this is not a very urgent bug-fix, so I'm happy to wait for you. And also thank you from the bottom of my heart for your great contribution

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-28 Thread via GitHub
rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1119993003 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java: ## @@ -1401,7 +1403,9 @@ public void

[GitHub] [flink-connector-shared-utils] eskabetxe opened a new pull request, #8: Move cache save after is downloaded

2023-02-28 Thread via GitHub
eskabetxe opened a new pull request, #8: URL: https://github.com/apache/flink-connector-shared-utils/pull/8 this change avoid download flink binary again if tests fails.. as now it uses archive this could be 10m of time -- This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-31181) Support LIKE operator pushdown

2023-02-28 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li closed FLINK-31181. -- Resolution: Fixed > Support LIKE operator pushdown > -- > >

[jira] [Updated] (FLINK-31181) Support LIKE operator pushdown

2023-02-28 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li updated FLINK-31181: --- Fix Version/s: jdbc-3.1.0 > Support LIKE operator pushdown > -- > >

[jira] [Commented] (FLINK-31181) Support LIKE operator pushdown

2023-02-28 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694530#comment-17694530 ] Benchao Li commented on FLINK-31181: fixed via

[jira] [Commented] (FLINK-31104) TPC-DS test timed out in query 36

2023-02-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694462#comment-17694462 ] Weijie Guo commented on FLINK-31104: The failure case in CI may not be easy to troubleshoot. I will

[GitHub] [flink] dmvk commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-28 Thread via GitHub
dmvk commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1119818006 ## flink-tests/src/test/java/org/apache/flink/test/recovery/LocalRecoveryITCase.java: ## @@ -67,12 +68,14 @@ import java.util.Optional; import

  1   2   3   >