[GitHub] [flink] dmvk opened a new pull request, #22375: [BP-1.17][FLINK-31738] Prevent name clash in generated clients

2023-04-10 Thread via GitHub
dmvk opened a new pull request, #22375: URL: https://github.com/apache/flink/pull/22375 Backport of https://github.com/apache/flink/pull/22358 -- 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

[jira] [Commented] (FLINK-31738) FlameGraphTypeQueryParameter#Type clashes with java.reflect.Type in generated clients

2023-04-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-31738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710426#comment-17710426 ] David Morávek commented on FLINK-31738: --- master: 4f15da77dcb7d83e211eb65f24e1b49cb

[jira] [Updated] (FLINK-31767) Improve the implementation for "analyze table" execution on partitioned table

2023-04-10 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-31767: --- Description: Currently, for partitioned table, the "analyze table" command will generate a separate

[GitHub] [flink] dmvk merged pull request #22358: [FLINK-31738] Prevent 'Type' name clash in generated clients

2023-04-10 Thread via GitHub
dmvk merged PR #22358: URL: https://github.com/apache/flink/pull/22358 -- 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.o

[GitHub] [flink] felixzh2020 commented on pull request #22118: [FLINK-31335][sql-gateway] When submit job to yarn, support kerberos

2023-04-10 Thread via GitHub
felixzh2020 commented on PR #22118: URL: https://github.com/apache/flink/pull/22118#issuecomment-1502774782 @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 commen

[jira] [Updated] (FLINK-31767) Improve the implementation for "analyze table" execution

2023-04-10 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-31767: --- Description: Currently,  > Improve the implementation for "analyze table" execution > --

[jira] [Updated] (FLINK-31767) Improve the implementation for "analyze table" execution on partitioned table

2023-04-10 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-31767: --- Description: Currently, for partitioned table,  (was: Currently, ) > Improve the implementation for

[jira] [Updated] (FLINK-31767) Improve the implementation for "analyze table" execution on partitioned table

2023-04-10 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-31767: --- Summary: Improve the implementation for "analyze table" execution on partitioned table (was: Improv

[jira] [Assigned] (FLINK-31765) Disable changelog backend for the StatefulJobSavepointMigrationITCase and StatefulJobWBroadcastStateMigrationITCase with RocksDB and checkpoints

2023-04-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-31765: - Assignee: Matthias Pohl > Disable changelog backend for the StatefulJobSavepointMigrati

[jira] [Commented] (FLINK-31593) Update reference data for Migration Tests

2023-04-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710422#comment-17710422 ] Matthias Pohl commented on FLINK-31593: --- thanks for verification. I create FLINK-3

[jira] [Updated] (FLINK-31766) Restoring from a retained checkpoint that was generated with changelog backend enabled might fail due to missing files

2023-04-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31766: -- Attachment: FLINK-31593.StatefulJobSavepointMigrationITCase.verify_snapshot.log

[jira] [Created] (FLINK-31767) Improve the implementation for "analyze table" execution

2023-04-10 Thread Godfrey He (Jira)
Godfrey He created FLINK-31767: -- Summary: Improve the implementation for "analyze table" execution Key: FLINK-31767 URL: https://issues.apache.org/jira/browse/FLINK-31767 Project: Flink Issue Ty

[jira] [Created] (FLINK-31766) Restoring from a retained checkpoint that was generated with changelog backend enabled might fail due to missing files

2023-04-10 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-31766: - Summary: Restoring from a retained checkpoint that was generated with changelog backend enabled might fail due to missing files Key: FLINK-31766 URL: https://issues.apache.org/j

[jira] [Closed] (FLINK-13611) Introduce analyze statistic utility to generate table & column statistics

2023-04-10 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-13611. -- Resolution: Invalid see https://issues.apache.org/jira/browse/FLINK-28492 > Introduce analyze statist

[jira] [Created] (FLINK-31765) Disable changelog backend for the StatefulJobSavepointMigrationITCase and StatefulJobWBroadcastStateMigrationITCase with RocksDB and checkpoints

2023-04-10 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-31765: - Summary: Disable changelog backend for the StatefulJobSavepointMigrationITCase and StatefulJobWBroadcastStateMigrationITCase with RocksDB and checkpoints Key: FLINK-31765 URL:

[jira] [Commented] (FLINK-31760) COALESCE() with NULL arguments throws error

2023-04-10 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710418#comment-17710418 ] Ran Tao commented on FLINK-31760: - thanks lee for explanations. cast works well. > COAL

[GitHub] [flink] felixzh2020 commented on pull request #22118: [FLINK-31335][sql-gateway] When submit job to yarn, support kerberos

2023-04-10 Thread via GitHub
felixzh2020 commented on PR #22118: URL: https://github.com/apache/flink/pull/22118#issuecomment-1502756739 @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 commen

[GitHub] [flink] felixzh2020 commented on a diff in pull request #22118: [FLINK-31335][sql-gateway] When submit job to yarn, support kerberos

2023-04-10 Thread via GitHub
felixzh2020 commented on code in PR #22118: URL: https://github.com/apache/flink/pull/22118#discussion_r1162357805 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/SqlGateway.java: ## @@ -109,18 +113,21 @@ static void startSqlGateway(PrintStream stre

[jira] [Commented] (FLINK-31760) COALESCE() with NULL arguments throws error

2023-04-10 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710415#comment-17710415 ] lincoln lee commented on FLINK-31760: - Currently it's by-design behavior because we

[jira] [Closed] (FLINK-31510) Use getMemorySize instead of getMemory

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31510. -- Fix Version/s: 1.18.0 Resolution: Fixed master(1.18) via 0c4db2dd577fdfca1a12c115948bf67931d0bc

[GitHub] [flink] reswqa closed pull request #22207: [FLINK-31510][yarn] Use getMemorySize instead of getMemory.

2023-04-10 Thread via GitHub
reswqa closed pull request #22207: [FLINK-31510][yarn] Use getMemorySize instead of getMemory. URL: https://github.com/apache/flink/pull/22207 -- 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 spe

[jira] [Created] (FLINK-31764) Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool

2023-04-10 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-31764: -- Summary: Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool Key: FLINK-31764 URL: https://issues.apache.org/jira/browse/FLINK-31764 Project: Flink

[jira] [Commented] (FLINK-31301) Unsupported nested columns in column list of insert statement

2023-04-10 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710396#comment-17710396 ] Aitozi commented on FLINK-31301: [~lincoln.86xy] , I opened PR for this, could you help

[jira] [Updated] (FLINK-31763) Ensure that the total number of requested buffers does not exceed poolSize + maxOverdraftBuffersPerGate

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31763: --- Description: As we discussed in FLINK-31610, new buffers can be requested only when "{_}numOfReques

[jira] [Created] (FLINK-31763) Ensure that the total number of requested buffers does not exceed poolSize + maxOverdraftBuffersPerGate

2023-04-10 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-31763: -- Summary: Ensure that the total number of requested buffers does not exceed poolSize + maxOverdraftBuffersPerGate Key: FLINK-31763 URL: https://issues.apache.org/jira/browse/FLINK-3176

[GitHub] [flink] xintongsong commented on a diff in pull request #22330: [FLINK-31635][network] Support writing records to the new tiered store architecture

2023-04-10 Thread via GitHub
xintongsong commented on code in PR #22330: URL: https://github.com/apache/flink/pull/22330#discussion_r1162243590 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/upstream/common/TierStorage.java: ## @@ -0,0 +1,44 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-31760) COALESCE() with NULL arguments throws error

2023-04-10 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710379#comment-17710379 ] Ran Tao commented on FLINK-31760: - [~morezaei00]  Hi, Mohsen, I think it's a bug, coales

[jira] [Comment Edited] (FLINK-28171) Adjust Job and Task manager port definitions to work with Istio+mTLS

2023-04-10 Thread Sergio Sainz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710375#comment-17710375 ] Sergio Sainz edited comment on FLINK-28171 at 4/11/23 2:42 AM: ---

[jira] [Commented] (FLINK-28171) Adjust Job and Task manager port definitions to work with Istio+mTLS

2023-04-10 Thread Sergio Sainz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710375#comment-17710375 ] Sergio Sainz commented on FLINK-28171: -- Hello [~wangyang0918] ! also experiencing t

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

2023-04-10 Thread Liam (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liam updated FLINK-31762: - Summary: Subscribe to multiple Kafka topics may cause partition assignment skew (was: Subscribe multiple Kafka

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

2023-04-10 Thread Liam (Jira)
Liam created FLINK-31762: Summary: Subscribe multiple Kafka topics may cause partition assignment skew Key: FLINK-31762 URL: https://issues.apache.org/jira/browse/FLINK-31762 Project: Flink Issue Ty

[jira] [Closed] (FLINK-27463) The JDBC connector should support option for ‘upsert’ or ‘insert’

2023-04-10 Thread Liam (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liam closed FLINK-27463. Resolution: Won't Do > The JDBC connector should support option for ‘upsert’ or ‘insert’ > ---

[GitHub] [flink] flinkbot commented on pull request #22374: [FLINK-31761] Fix Some Typo And Improve lambda expressions.

2023-04-10 Thread via GitHub
flinkbot commented on PR #22374: URL: https://github.com/apache/flink/pull/22374#issuecomment-1502413566 ## CI report: * 1f37f1de408883d6e75632851034a056c8d1083c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31761) Fix Some Typo And Improve lambda expressions.

2023-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31761: --- Labels: pull-request-available (was: ) > Fix Some Typo And Improve lambda expressions. > --

[GitHub] [flink] slfan1989 opened a new pull request, #22374: [FLINK-31761] Fix Some Typo And Improve lambda expressions.

2023-04-10 Thread via GitHub
slfan1989 opened a new pull request, #22374: URL: https://github.com/apache/flink/pull/22374 ## What is the purpose of the change When reading the code, I found 2 typo errors and improved the lambada expression. This PR will improve this part of the content. ## Brief

[jira] [Created] (FLINK-31761) Fix Some Typo And Improve lambda expressions.

2023-04-10 Thread Shilun Fan (Jira)
Shilun Fan created FLINK-31761: -- Summary: Fix Some Typo And Improve lambda expressions. Key: FLINK-31761 URL: https://issues.apache.org/jira/browse/FLINK-31761 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-31760) COALESCE() with NULL arguments throws error

2023-04-10 Thread Mohsen Rezaei (Jira)
Mohsen Rezaei created FLINK-31760: - Summary: COALESCE() with NULL arguments throws error Key: FLINK-31760 URL: https://issues.apache.org/jira/browse/FLINK-31760 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Description: # FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}}) for exte

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Component/s: (was: Connectors / Kafka) > Update some external connectors to use sql_connector_do

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Component/s: Connectors / Kafka > Update some external connectors to use sql_connector_download_tabl

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Description: # FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}}) for exte

[GitHub] [flink-connector-opensearch] reswqa commented on pull request #17: [hotfix] Add opensearch.yml to enable flink to find the data

2023-04-10 Thread via GitHub
reswqa commented on PR #17: URL: https://github.com/apache/flink-connector-opensearch/pull/17#issuecomment-1502153037 cc @dannycranmer. I realized we have synced the docs to flink 1.17 branch in https://github.com/apache/flink/pull/22365, to fix this, do we need to push a v1.0.0-docs branc

[GitHub] [flink-connector-opensearch] boring-cyborg[bot] commented on pull request #17: [hotfix] Add opensearch.yml to enable flink to find the data

2023-04-10 Thread via GitHub
boring-cyborg[bot] commented on PR #17: URL: https://github.com/apache/flink-connector-opensearch/pull/17#issuecomment-1502150744 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This

[GitHub] [flink-connector-opensearch] reswqa opened a new pull request, #17: [hotfix] Add opensearch.yml to enable flink to find the data

2023-04-10 Thread via GitHub
reswqa opened a new pull request, #17: URL: https://github.com/apache/flink-connector-opensearch/pull/17 I compiled the flink documentation locally and found the problem shown in the figure below: https://user-images.githubusercontent.com/19502505/230966931-7decad8f-c43c-4a3d-bc4f-9f8

[GitHub] [flink-connector-gcp-pubsub] reswqa opened a new pull request, #7: [FLINK-31759][pubsub] Using connector_artifact shortcode for datastream document.

2023-04-10 Thread via GitHub
reswqa opened a new pull request, #7: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/7 This should also backports to v3.0 branch. -- 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 t

[GitHub] [flink-connector-gcp-pubsub] boring-cyborg[bot] commented on pull request #7: [FLINK-31759][pubsub] Using connector_artifact shortcode for datastream document.

2023-04-10 Thread via GitHub
boring-cyborg[bot] commented on PR #7: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/7#issuecomment-1502116737 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This i

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Component/s: Connectors / Google Cloud PubSub > Update some external connectors to use sql_connector

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Description: # FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}}) for exte

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Component/s: Connectors / HBase > Update some external connectors to use sql_connector_download_tabl

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Description: # FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}}) for exte

[GitHub] [flink-connector-hbase] boring-cyborg[bot] commented on pull request #8: [FLINK-31759][hbase] Using sql_connector_download_table shortcode for table document.

2023-04-10 Thread via GitHub
boring-cyborg[bot] commented on PR #8: URL: https://github.com/apache/flink-connector-hbase/pull/8#issuecomment-1502107159 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is an

[GitHub] [flink-connector-hbase] reswqa opened a new pull request, #8: [FLINK-31759][hbase] Using sql_connector_download_table shortcode for table document.

2023-04-10 Thread via GitHub
reswqa opened a new pull request, #8: URL: https://github.com/apache/flink-connector-hbase/pull/8 This should also backports to v3.0 branch. -- 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 sp

[GitHub] [flink-connector-rabbitmq] boring-cyborg[bot] commented on pull request #9: [FLINK-31759][rabbitmq] Update some external connectors to use sql_connector_download_table and connector_artifact

2023-04-10 Thread via GitHub
boring-cyborg[bot] commented on PR #9: URL: https://github.com/apache/flink-connector-rabbitmq/pull/9#issuecomment-1502092259 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

[jira] [Commented] (FLINK-31746) Batch workload output completes while the job client fails

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710240#comment-17710240 ] Weijie Guo commented on FLINK-31746: Details about the failed task should be found i

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Description: # FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}}) for exte

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Component/s: Connectors/ RabbitMQ > Update some external connectors to use sql_connector_download_ta

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Description: # FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}}) for exte

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31759: --- Labels: pull-request-available (was: ) > Update some external connectors to use sql_connect

[GitHub] [flink-connector-jdbc] boring-cyborg[bot] commented on pull request #38: [FLINK-31759][JDBC] Update some external connectors to use sql_connector_download_table and connector_artifact shortco

2023-04-10 Thread via GitHub
boring-cyborg[bot] commented on PR #38: URL: https://github.com/apache/flink-connector-jdbc/pull/38#issuecomment-1502053994 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is an

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Description: # FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}}) for exte

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Summary: Update some external connectors to use sql_connector_download_table and connector_artifact

[jira] [Commented] (FLINK-31746) Batch workload output completes while the job client fails

2023-04-10 Thread Haoze Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710214#comment-17710214 ] Haoze Wu commented on FLINK-31746: -- [~martijnvisser] I reproduced the similar issue in

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Component/s: Connectors / JDBC > Update some external connectors to use sql_connector_download_table

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Description: FLINK-30291 introduce a new shortcode(sql_connector_download_table) for externalized c

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Description: FLINK-30291 introduce a new shortcode(\{{sql_connector_download_table}}) for externali

[jira] [Updated] (FLINK-31759) Update some external connectors to use modified sql_connector_download_table shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Description: FLINK-30291 introduce a new  > Update some external connectors to use modified sql_conn

[jira] [Updated] (FLINK-31759) Update some external connectors to use sql_connector_download_table shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Summary: Update some external connectors to use sql_connector_download_table shortcode (was: Update

[jira] [Updated] (FLINK-31759) Update some external connectors to use modified sql_connector_download_table shortcode

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31759: --- Component/s: Connectors / ElasticSearch > Update some external connectors to use modified sql_connec

[jira] [Created] (FLINK-31759) Update some external connectors to use modified sql_connector_download_table shortcode

2023-04-10 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-31759: -- Summary: Update some external connectors to use modified sql_connector_download_table shortcode Key: FLINK-31759 URL: https://issues.apache.org/jira/browse/FLINK-31759 Pr

[GitHub] [flink] flinkbot commented on pull request #22373: [FLINK-31758][doc] Handles $full_version for sql_url in document.

2023-04-10 Thread via GitHub
flinkbot commented on PR #22373: URL: https://github.com/apache/flink/pull/22373#issuecomment-1501938278 ## CI report: * a92df67bc3b466b4fb84552aa3f55c1f25d70893 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31758) Some external connectors sql client jar has a wrong download url in document

2023-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31758: --- Labels: pull-request-available (was: ) > Some external connectors sql client jar has a wron

[GitHub] [flink] reswqa opened a new pull request, #22373: [FLINK-31758][doc] Handles $full_version for sql_url in document.

2023-04-10 Thread via GitHub
reswqa opened a new pull request, #22373: URL: https://github.com/apache/flink/pull/22373 ## What is the purpose of the change *After [FLINK-30378](https://issues.apache.org/jira/browse/FLINK-30378), we can load sql connector data from external connector's own data file. However, we

[jira] [Updated] (FLINK-31758) Some external connectors sql client jar has a wrong download url in document

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31758: --- Component/s: Connectors / Common > Some external connectors sql client jar has a wrong download url

[jira] [Updated] (FLINK-31758) Some external connectors sql client jar has a wrong download url in document

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31758: --- Affects Version/s: 1.17.0 > Some external connectors sql client jar has a wrong download url in docu

[jira] [Updated] (FLINK-31758) Some external connectors sql client jar has a wrong download url in document

2023-04-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31758: --- Description: After FLINK-30378, we can load sql connector data from external connector's own data fi

[jira] [Created] (FLINK-31758) Some external connectors sql client jar has a wrong download url in document

2023-04-10 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-31758: -- Summary: Some external connectors sql client jar has a wrong download url in document Key: FLINK-31758 URL: https://issues.apache.org/jira/browse/FLINK-31758 Project: Fli

[GitHub] [flink] clownxc commented on pull request #22353: [FLINK-31320][table]Modify DATE_FORMAT system (built-in) function to accepts DATEs

2023-04-10 Thread via GitHub
clownxc commented on PR #22353: URL: https://github.com/apache/flink/pull/22353#issuecomment-1501898847 Could you please take a look when you have time? thanks a lot ! @luoyuxia -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink-connector-pulsar] nikolasten commented on pull request #16: [BK-3.0][FLINK-30552][Connector/Pulsar] drop batch message size assertion, better set the cursor position.

2023-04-10 Thread via GitHub
nikolasten commented on PR #16: URL: https://github.com/apache/flink-connector-pulsar/pull/16#issuecomment-1501806550 Repo is this `https://repository.apache.org/content/repositories/snapshots`. Tried using `4.0-snapshot` but i get this when upgrading from 1.16.0 version `java.lang

[jira] [Comment Edited] (FLINK-31165) Over Agg: The window rank function without order by error in top N query

2023-04-10 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706652#comment-17706652 ] lincoln lee edited comment on FLINK-31165 at 4/10/23 1:06 PM:

[GitHub] [flink] lincoln-lil merged pull request #22372: [FLINK-31165][table-planner] Improve the error message for order by clause

2023-04-10 Thread via GitHub
lincoln-lil merged PR #22372: URL: https://github.com/apache/flink/pull/22372 -- 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.a

[jira] [Closed] (FLINK-30264) Set session job status to FAILED if already have retried max attempts

2023-04-10 Thread Xin Hao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Hao closed FLINK-30264. --- Resolution: Fixed > Set session job status to FAILED if already have retried max attempts >

[GitHub] [flink] BoYiZhang commented on a diff in pull request #22204: [Flink 31170] [docs]The spelling error of the document word causes sq…

2023-04-10 Thread via GitHub
BoYiZhang commented on code in PR #22204: URL: https://github.com/apache/flink/pull/22204#discussion_r1161678153 ## docs/content/docs/dev/table/sql/create.md: ## @@ -316,7 +316,7 @@ CREATE TABLE MyTable ( `user_id` BIGINT, `price` DOUBLE, `quantity` DOUBLE, - `cost` AS

[jira] [Closed] (FLINK-31713) k8s operator should gather job version metrics

2023-04-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-31713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-31713. -- Fix Version/s: kubernetes-operator-1.5.0 Resolution: Fixed 8d7758c in main > k8s opera

[GitHub] [flink-kubernetes-operator] mbalassi merged pull request #562: [FLINK-31713] Expose FlinkDeployment version metrics

2023-04-10 Thread via GitHub
mbalassi merged PR #562: URL: https://github.com/apache/flink-kubernetes-operator/pull/562 -- 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-unsubs

[GitHub] [flink-ml] jiangxin369 commented on pull request #231: [FLINK-31374] ProxyStreamPartitioner should implement ConfigurableStreamPartitioner

2023-04-10 Thread via GitHub
jiangxin369 commented on PR #231: URL: https://github.com/apache/flink-ml/pull/231#issuecomment-1501661163 @zhipeng93 Could you help review this PR? -- 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 t

[GitHub] [flink-ml] jiangxin369 commented on pull request #229: [FLINK-31255] Wraps the operator config about serializer

2023-04-10 Thread via GitHub
jiangxin369 commented on PR #229: URL: https://github.com/apache/flink-ml/pull/229#issuecomment-1501660711 @zhipeng93 Thanks for the review, I've updated the PR. -- 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-ml] jiangxin369 commented on a diff in pull request #229: [FLINK-31255] Wraps the operator config about serializer

2023-04-10 Thread via GitHub
jiangxin369 commented on code in PR #229: URL: https://github.com/apache/flink-ml/pull/229#discussion_r1161619708 ## flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java: ## @@ -104,6 +107,33 @@ public static StreamConfig createWrappedOperatorC

[jira] [Commented] (FLINK-29672) Support oracle catalog

2023-04-10 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710104#comment-17710104 ] RocMarshal commented on FLINK-29672: It looks like a duplicated Jira as https://iss

[jira] [Resolved] (FLINK-31702) Integrate Opensearch connector docs into Flink docs v1.17/master

2023-04-10 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-31702. --- Resolution: Fixed > Integrate Opensearch connector docs into Flink docs v1.17/master > -

[jira] [Commented] (FLINK-31702) Integrate Opensearch connector docs into Flink docs v1.17/master

2023-04-10 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710101#comment-17710101 ] Danny Cranmer commented on FLINK-31702: --- Merged to master [https://github.com/apa

[GitHub] [flink] dannycranmer merged pull request #22366: [FLINK-31702][Connectors/Opensearch][docs] Integrate Opensearch docs …

2023-04-10 Thread via GitHub
dannycranmer merged PR #22366: URL: https://github.com/apache/flink/pull/22366 -- 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.

[GitHub] [flink] dannycranmer merged pull request #22365: [FLINK-31702][Connectors/Opensearch][docs] Integrate Opensearch docs …

2023-04-10 Thread via GitHub
dannycranmer merged PR #22365: URL: https://github.com/apache/flink/pull/22365 -- 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.

[jira] [Commented] (FLINK-29334) StateHandleStore#releaseAndTryRemoveAll is not used and can be removed

2023-04-10 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710097#comment-17710097 ] Wencong Liu commented on FLINK-29334: - [~mapohl]  CI on GitHub has passed :), please

[GitHub] [flink-connector-pulsar] nikolasten commented on pull request #16: [BK-3.0][FLINK-30552][Connector/Pulsar] drop batch message size assertion, better set the cursor position.

2023-04-10 Thread via GitHub
nikolasten commented on PR #16: URL: https://github.com/apache/flink-connector-pulsar/pull/16#issuecomment-1501605205 Is there a way to use latest snapshot version instead of waiting for a release of this? In which repo is snapshot version published? We are having production issues due t

[GitHub] [flink] TanYuxin-tyx commented on pull request #22330: [FLINK-31635][network] Support writing records to the new tiered store architecture

2023-04-10 Thread via GitHub
TanYuxin-tyx commented on PR #22330: URL: https://github.com/apache/flink/pull/22330#issuecomment-1501547675 @xintongsong Thanks for reviewing the PR. I have updated the code according to the comments. Could you please review it again when having free time? -- This is an automate

[GitHub] [flink] flinkbot commented on pull request #22372: [FLINK-31165][table-planner] Improve the error message for order by clause

2023-04-10 Thread via GitHub
flinkbot commented on PR #22372: URL: https://github.com/apache/flink/pull/22372#issuecomment-1501543466 ## CI report: * 3ef17fe2df8ba9fa4ffc92b7a37430c523f6b094 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] TanYuxin-tyx commented on pull request #22330: [FLINK-31635][network] Support writing records to the new tiered store architecture

2023-04-10 Thread via GitHub
TanYuxin-tyx commented on PR #22330: URL: https://github.com/apache/flink/pull/22330#issuecomment-1501539681 @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 c

[GitHub] [flink] LadyForest opened a new pull request, #22372: [FLINK-31165][table-planner] Improve the error message for order by clause

2023-04-10 Thread via GitHub
LadyForest opened a new pull request, #22372: URL: https://github.com/apache/flink/pull/22372 ## What is the purpose of the change This PR is cherry-picked from commit eeb446c0ed07c38175efdadf7e2e21702ff02b70 ## Brief change log Improve the error message in `FlinkLogi

[GitHub] [flink] TanYuxin-tyx commented on pull request #22330: [FLINK-31635][network] Support writing records to the new tiered store architecture

2023-04-10 Thread via GitHub
TanYuxin-tyx commented on PR #22330: URL: https://github.com/apache/flink/pull/22330#issuecomment-1501526262 @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 comme

[GitHub] [flink] LadyForest commented on pull request #22300: [FLINK-31165][table-planner] Improve the error message for order by clause

2023-04-10 Thread via GitHub
LadyForest commented on PR #22300: URL: https://github.com/apache/flink/pull/22300#issuecomment-1501523853 > @LadyForest could you also backport this to 1.17 branch? Sure. I'll do it right now. -- This is an automated message from the Apache Git Service. To respond to the message, p

  1   2   >