[jira] [Updated] (FLINK-32760) Version Conflict in flink-sql-connector-hive for shaded.parquet prefix packages

2023-08-06 Thread dongwoo.kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dongwoo.kim updated FLINK-32760: Affects Version/s: 1.17.1 > Version Conflict in flink-sql-connector-hive for shaded.parquet prefix

[GitHub] [flink] pegasas commented on a diff in pull request #23135: [FLINK-32741]Remove DataSet related descriptions in doc

2023-08-06 Thread via GitHub
pegasas commented on code in PR #23135: URL: https://github.com/apache/flink/pull/23135#discussion_r1285223853 ## docs/content/docs/concepts/stateful-stream-processing.md: ## @@ -342,26 +342,3 @@ give *exactly once* guarantees even in *at least once* mode. {{< /hint >}} {{<

[GitHub] [flink-kubernetes-operator] SteNicholas opened a new pull request, #643: [FLINK-32164] LifecycleState count metrics are not reported correctly by namespace

2023-08-06 Thread via GitHub
SteNicholas opened a new pull request, #643: URL: https://github.com/apache/flink-kubernetes-operator/pull/643 ## What is the purpose of the change The per namespace lifecycle state count metrics are incorrectly show a global count at [LifecycleMetrics.java#L145](https://github.com/a

[jira] [Updated] (FLINK-32164) LifecycleState count metrics are not reported correctly by namespace

2023-08-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32164: --- Labels: pull-request-available (was: ) > LifecycleState count metrics are not reported corr

[jira] [Commented] (FLINK-32761) Use UUID based on PhysicalStateHandleID as SharedStateRegistryKey ChangelogStateHandleStreamImpl

2023-08-06 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751409#comment-17751409 ] Roman Khachatryan commented on FLINK-32761: --- Good point [~Feifan Wang], I thin

[GitHub] [flink] rkhachatryan commented on a diff in pull request #23146: [FLINK-32761][state/backends] Use UUID based on PhysicalStateHandleID…

2023-08-06 Thread via GitHub
rkhachatryan commented on code in PR #23146: URL: https://github.com/apache/flink/pull/23146#discussion_r1285261372 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java: ## @@ -106,4 +108,12 @@ StreamStateHandle registerReference( void regi

[GitHub] [flink] rkhachatryan commented on a diff in pull request #23146: [FLINK-32761][state/backends] Use UUID based on PhysicalStateHandleID…

2023-08-06 Thread via GitHub
rkhachatryan commented on code in PR #23146: URL: https://github.com/apache/flink/pull/23146#discussion_r1285261372 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java: ## @@ -106,4 +108,12 @@ StreamStateHandle registerReference( void regi

[GitHub] [flink] RocMarshal commented on a diff in pull request #23143: [FLINK-32759][doc] Remove the `cluster.declarative-resource-management.enabled` in doc

2023-08-06 Thread via GitHub
RocMarshal commented on code in PR #23143: URL: https://github.com/apache/flink/pull/23143#discussion_r1285302436 ## docs/content/docs/deployment/elastic_scaling.md: ## @@ -135,10 +135,9 @@ One benefit of the Adaptive Scheduler over the default scheduler is that it can ### U

[GitHub] [flink] hanyuzheng7 opened a new pull request, #23149: [BP-1.17][FLINK-32257][table] Add built-in ARRAY_MAX function.

2023-08-06 Thread via GitHub
hanyuzheng7 opened a new pull request, #23149: URL: https://github.com/apache/flink/pull/23149 ## What is the purpose of the change This is an implementation of ARRAY_MAX ## Brief change log The array_max() function get the maximum element from input array. The result matc

[GitHub] [flink] flinkbot commented on pull request #23149: [BP-1.17][FLINK-32257][table] Add built-in ARRAY_MAX function.

2023-08-06 Thread via GitHub
flinkbot commented on PR #23149: URL: https://github.com/apache/flink/pull/23149#issuecomment-1667074038 ## CI report: * 1c02840490e86ce38de1f238bfbf4d1b39fc05b6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] jiangxin369 commented on a diff in pull request #23021: [FLINK-32603] Avoid consuming twice when two planners have the same table source

2023-08-06 Thread via GitHub
jiangxin369 commented on code in PR #23021: URL: https://github.com/apache/flink/pull/23021#discussion_r1285308593 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java: ## @@ -103,56 +106,63 @@ prot

[GitHub] [flink] flinkbot commented on pull request #23150: fix(sec): upgrade com.google.guava:guava to 32.0.0-jre

2023-08-06 Thread via GitHub
flinkbot commented on PR #23150: URL: https://github.com/apache/flink/pull/23150#issuecomment-1667085423 ## CI report: * 454315f9f121b1e2e4e358289d3b0172e4e80dee UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] hanyuzheng7 opened a new pull request, #23151: [BP-1.17][FLINK-32256][table] Add built-in ARRAY_ MIN function.

2023-08-06 Thread via GitHub
hanyuzheng7 opened a new pull request, #23151: URL: https://github.com/apache/flink/pull/23151 ## What is the purpose of the change This is an implementation of ARRAY_MIN ## Brief change log The array_min() function get the minimum element from input array. The result matc

[GitHub] [flink] WencongLiu commented on pull request #23100: [FLINK-32708][network] Fix the write logic in remote tier of hybrid shuffle

2023-08-06 Thread via GitHub
WencongLiu commented on PR #23100: URL: https://github.com/apache/flink/pull/23100#issuecomment-1667088551 CI has passed. Thanks for the careful review! @reswqa -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot commented on pull request #23151: [BP-1.17][FLINK-32256][table] Add built-in ARRAY_ MIN function.

2023-08-06 Thread via GitHub
flinkbot commented on PR #23151: URL: https://github.com/apache/flink/pull/23151#issuecomment-1667091263 ## CI report: * d0d55540272e8b5a5c4fcb2282aa88cdc5f85c05 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-ml] zhipeng93 closed pull request #242: [FLINK-32293] Support sparse vector with long index

2023-08-06 Thread via GitHub
zhipeng93 closed pull request #242: [FLINK-32293] Support sparse vector with long index URL: https://github.com/apache/flink-ml/pull/242 -- 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] [Commented] (FLINK-32754) Using SplitEnumeratorContext.metricGroup() in restoreEnumerator causes NPE

2023-08-06 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751437#comment-17751437 ] Hang Ruan commented on FLINK-32754: --- [~Yu Chen] [~yunta] ,Thanks for the issue. I hav

[GitHub] [flink] Tartarus0zm commented on pull request #23116: [FLINK-32581][docs] Add docs for atomic CTAS and RTAS

2023-08-06 Thread via GitHub
Tartarus0zm commented on PR #23116: URL: https://github.com/apache/flink/pull/23116#issuecomment-1667124002 @luoyuxia PTAL, thanks -- 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 co

[jira] [Created] (FLINK-32764) SlotManager supports pulling up all TaskManagers at initialization

2023-08-06 Thread xiangyu feng (Jira)
xiangyu feng created FLINK-32764: Summary: SlotManager supports pulling up all TaskManagers at initialization Key: FLINK-32764 URL: https://issues.apache.org/jira/browse/FLINK-32764 Project: Flink

[jira] [Created] (FLINK-32765) create view should reuse calcite tree

2023-08-06 Thread xiaogang zhou (Jira)
xiaogang zhou created FLINK-32765: - Summary: create view should reuse calcite tree Key: FLINK-32765 URL: https://issues.apache.org/jira/browse/FLINK-32765 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-32766) Support kafka catalog

2023-08-06 Thread melin (Jira)
melin created FLINK-32766: - Summary: Support kafka catalog Key: FLINK-32766 URL: https://issues.apache.org/jira/browse/FLINK-32766 Project: Flink Issue Type: New Feature Reporter: melin

[GitHub] [flink] 1996fanrui merged pull request #23143: [FLINK-32759][doc] Remove the `cluster.declarative-resource-management.enabled` in doc

2023-08-06 Thread via GitHub
1996fanrui merged PR #23143: URL: https://github.com/apache/flink/pull/23143 -- 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: issues-unsubscr...@flink.ap

[jira] [Commented] (FLINK-32759) Remove the removed config in the doc

2023-08-06 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751450#comment-17751450 ] Rui Fan commented on FLINK-32759: - Merged via e69f410baf93b7a172b2aeac01bb0e5b893c9a14

[jira] [Resolved] (FLINK-32759) Remove the removed config in the doc

2023-08-06 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-32759. - Fix Version/s: 1.18.0 Resolution: Fixed > Remove the removed config in the doc >

[jira] [Updated] (FLINK-32765) create view should reuse calcite tree

2023-08-06 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-32765: -- Component/s: Table SQL / API (was: Table SQL / Planner) > create view sho

[GitHub] [flink] reswqa merged pull request #23100: [FLINK-32708][network] Fix the write logic in remote tier of hybrid shuffle

2023-08-06 Thread via GitHub
reswqa merged PR #23100: URL: https://github.com/apache/flink/pull/23100 -- 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: issues-unsubscr...@flink.apache

[jira] [Closed] (FLINK-32708) Fix the write logic in remote tier of Hybrid Shuffle

2023-08-06 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-32708. -- Assignee: Wencong Liu Resolution: Fixed master(1.18) via 6e138f1a4832bd4379fa6289f0445f1ede9b5a5

[jira] [Commented] (FLINK-31361) job created by sql-client can't authenticate to kafka, can't find org.apache.kafka.common.security.plain.PlainLoginModule

2023-08-06 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751485#comment-17751485 ] Leonard Xu commented on FLINK-31361: I checked the error still exits in https://nig