[jira] [Commented] (FLINK-31676) Pulsar connector should not rely on Flink Shaded

2023-03-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707156#comment-17707156 ] Chesnay Schepler commented on FLINK-31676: -- Use your own guava version and relo

[GitHub] [flink] haishui126 commented on pull request #22291: [FLINK-31632] maxAllowedWatermark overflow

2023-03-31 Thread via GitHub
haishui126 commented on PR #22291: URL: https://github.com/apache/flink/pull/22291#issuecomment-1491418101 I have added a test base on [FLINK-25982](https://issues.apache.org/jira/browse/FLINK-25982). Is there anything else I need to do? -- This is an automated message from the Apache

[GitHub] [flink] zentol commented on a diff in pull request #22296: [FLINK-31468] Add mechanics to the Dispatcher for handling job resource requirements

2023-03-31 Thread via GitHub
zentol commented on code in PR #22296: URL: https://github.com/apache/flink/pull/22296#discussion_r1154104747 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -944,6 +940,19 @@ public CompletableFuture notifyNewBlockedNodes(Collection> ge

[jira] [Created] (FLINK-31679) [Flink][UI] Show data exchange type on web ui

2023-03-31 Thread Weihua Hu (Jira)
Weihua Hu created FLINK-31679: - Summary: [Flink][UI] Show data exchange type on web ui Key: FLINK-31679 URL: https://issues.apache.org/jira/browse/FLINK-31679 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-31679) [Flink][UI] Show data exchange type on web ui

2023-03-31 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707165#comment-17707165 ] Yun Tang commented on FLINK-31679: -- Do you think this ticket might be related to FLINK-

[jira] [Updated] (FLINK-31214) Add support for new command line option -py.pythonpath

2023-03-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31214: -- Fix Version/s: (was: 1.17.1) > Add support for new command line option -py.pythonpath > --

[jira] [Assigned] (FLINK-31214) Add support for new command line option -py.pythonpath

2023-03-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-31214: - Assignee: Samrat Deb > Add support for new command line option -py.pythonpath > ---

[GitHub] [flink] haishui126 commented on pull request #22291: [FLINK-31632] maxAllowedWatermark overflow

2023-03-31 Thread via GitHub
haishui126 commented on PR #22291: URL: https://github.com/apache/flink/pull/22291#issuecomment-1491451371 > The change makes sense. Can you add a unit test to verify the regression is fixed? > > I also think there needs to be another change to the `shouldWaitForAlignment()` to not w

[jira] [Commented] (FLINK-31679) [Flink][UI] Show data exchange type on web ui

2023-03-31 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707176#comment-17707176 ] Weihua Hu commented on FLINK-31679: --- [~yunta]Thanks for the quickly reply. Not exactl

[GitHub] [flink] zentol commented on a diff in pull request #22296: [FLINK-31468] Add mechanics to the Dispatcher for handling job resource requirements

2023-03-31 Thread via GitHub
zentol commented on code in PR #22296: URL: https://github.com/apache/flink/pull/22296#discussion_r1154129462 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -1115,6 +1127,66 @@ private void checkJobClientAliveness() { } }

[GitHub] [flink] nateab opened a new pull request, #22313: [FLINK-31660][connector-kafka] fix kafka connector pom so ITCases run in IDE

2023-03-31 Thread via GitHub
nateab opened a new pull request, #22313: URL: https://github.com/apache/flink/pull/22313 ## What is the purpose of the change This PR fixes the kafka-connector pom so that `ITCases` in that module can run in the Intellij IDE. This is due to an old Intellij bug that does not hand

[jira] [Updated] (FLINK-31660) flink-connectors-kafka ITCases are not runnable in the IDE

2023-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31660: --- Labels: pull-request-available (was: ) > flink-connectors-kafka ITCases are not runnable in

[jira] [Created] (FLINK-31680) Add priorityClassName to flink-operator's pods

2023-03-31 Thread Jira
RafaƂ Boniecki created FLINK-31680: -- Summary: Add priorityClassName to flink-operator's pods Key: FLINK-31680 URL: https://issues.apache.org/jira/browse/FLINK-31680 Project: Flink Issue Type

[GitHub] [flink] pnowojski commented on a diff in pull request #22313: [FLINK-31660][connector-kafka] fix kafka connector pom so ITCases run in IDE

2023-03-31 Thread via GitHub
pnowojski commented on code in PR #22313: URL: https://github.com/apache/flink/pull/22313#discussion_r1154162779 ## flink-connectors/flink-connector-kafka/pom.xml: ## @@ -68,6 +67,20 @@ under the License. true + +

[GitHub] [flink-connector-jdbc] matriv commented on pull request #29: [FLINK-31551] Add support for CrateDB

2023-03-31 Thread via GitHub
matriv commented on PR #29: URL: https://github.com/apache/flink-connector-jdbc/pull/29#issuecomment-1491509754 @eskabetxe When you have the time, please take another look. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot commented on pull request #22313: [FLINK-31660][connector-kafka] fix kafka connector pom so ITCases run in IDE

2023-03-31 Thread via GitHub
flinkbot commented on PR #22313: URL: https://github.com/apache/flink/pull/22313#issuecomment-1491510392 ## CI report: * 65846031b0f3e2971a54a17ee64afc1668f84ab9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] nateab commented on a diff in pull request #22313: [FLINK-31660][connector-kafka] fix kafka connector pom so ITCases run in IDE

2023-03-31 Thread via GitHub
nateab commented on code in PR #22313: URL: https://github.com/apache/flink/pull/22313#discussion_r1154171363 ## flink-connectors/flink-connector-kafka/pom.xml: ## @@ -68,6 +67,20 @@ under the License. true + +

[jira] [Created] (FLINK-31681) Network connection timeout between operators should trigger either network re-connection or job failover

2023-03-31 Thread Dong Lin (Jira)
Dong Lin created FLINK-31681: Summary: Network connection timeout between operators should trigger either network re-connection or job failover Key: FLINK-31681 URL: https://issues.apache.org/jira/browse/FLINK-31681

[jira] [Commented] (FLINK-30844) TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a JVM shutdown with exit code 239

2023-03-31 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707189#comment-17707189 ] Matthias Pohl commented on FLINK-30844: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-27284) KafkaSinkITCase$IntegrationTests.testScaleUp failed on azures due to failed to create topic

2023-03-31 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707190#comment-17707190 ] Matthias Pohl commented on FLINK-27284: --- https://dev.azure.com/apache-flink/apache

[jira] [Updated] (FLINK-31446) KafkaSinkITCase$IntegrationTests.testMetrics failed because topic XXX already exists

2023-03-31 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31446: -- Parent: FLINK-31145 Issue Type: Sub-task (was: Bug) > KafkaSinkITCase$IntegrationTest

[jira] (FLINK-27284) KafkaSinkITCase$IntegrationTests.testScaleUp failed on azures due to failed to create topic

2023-03-31 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27284 ] Matthias Pohl deleted comment on FLINK-27284: --- was (Author: mapohl): https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=47750&view=logs&j=8eee98ee-a482-5f7c-2c51-b345645

[GitHub] [flink] qidian99 opened a new pull request, #22314: Fixed inaccurancy in Chinese doc of Execution Mode

2023-03-31 Thread via GitHub
qidian99 opened a new pull request, #22314: URL: https://github.com/apache/flink/pull/22314 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them o

[jira] [Commented] (FLINK-31446) KafkaSinkITCase$IntegrationTests.testMetrics failed because topic XXX already exists

2023-03-31 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707191#comment-17707191 ] Matthias Pohl commented on FLINK-31446: --- Here is one where it fails due to a timeo

[GitHub] [flink] flinkbot commented on pull request #22314: Fixed inaccurancy in Chinese doc of Execution Mode

2023-03-31 Thread via GitHub
flinkbot commented on PR #22314: URL: https://github.com/apache/flink/pull/22314#issuecomment-1491531606 ## CI report: * e227f2951786bdaa66ebde3fcad8e58c74bb15f5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31680) Add priorityClassName to flink-operator's pods

2023-03-31 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-31680: --- Component/s: Kubernetes Operator > Add priorityClassName to flink-operator's pods >

[jira] [Commented] (FLINK-31681) Network connection timeout between operators should trigger either network re-connection or job failover

2023-03-31 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707197#comment-17707197 ] Martijn Visser commented on FLINK-31681: [~pnowojski] Any thought on this one?

[jira] [Created] (FLINK-31682) map_from_arrays should take whether allow duplicate keys and null key into consideration

2023-03-31 Thread jackylau (Jira)
jackylau created FLINK-31682: Summary: map_from_arrays should take whether allow duplicate keys and null key into consideration Key: FLINK-31682 URL: https://issues.apache.org/jira/browse/FLINK-31682 Proj

[jira] [Commented] (FLINK-31679) [Flink][UI] Show data exchange type on web ui

2023-03-31 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707200#comment-17707200 ] Benchao Li commented on FLINK-31679: +1 for this. > [Flink][UI] Show data exchange

[jira] [Updated] (FLINK-31682) map_from_arrays should take whether allow duplicate keys and null key into consideration

2023-03-31 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-31682: - Description: after research the spark/presto/maxcompute about map_from_arrays/map_from_entries, there a

[jira] [Commented] (FLINK-31681) Network connection timeout between operators should trigger either network re-connection or job failover

2023-03-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707203#comment-17707203 ] Piotr Nowojski commented on FLINK-31681: Which version does this issue affect? W

[jira] [Commented] (FLINK-31660) flink-connectors-kafka ITCases are not runnable in the IDE

2023-03-31 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707207#comment-17707207 ] Dawid Wysakowicz commented on FLINK-31660: -- I think the way I did it is that I

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #222: [FLINK-31029] Fix bug when using quantile in KbinsDiscretizer

2023-03-31 Thread via GitHub
zhipeng93 commented on code in PR #222: URL: https://github.com/apache/flink-ml/pull/222#discussion_r1154216841 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizer.java: ## @@ -220,22 +220,46 @@ private static double[][] findBinEdgesWithQ

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on pull request #4: [hotfix] Fix unstable test of MongoSinkITCase.testRecovery

2023-03-31 Thread via GitHub
Jiabao-Sun commented on PR #4: URL: https://github.com/apache/flink-connector-mongodb/pull/4#issuecomment-1491579741 > So...would this also fail with this error in production? > > The sink supports AT_LEAST_ONCE semantics, which should imply that duplicate writes are fine and don't c

[GitHub] [flink] rkhachatryan commented on a diff in pull request #22296: [FLINK-31468] Add mechanics to the Dispatcher for handling job resource requirements

2023-03-31 Thread via GitHub
rkhachatryan commented on code in PR #22296: URL: https://github.com/apache/flink/pull/22296#discussion_r1154221880 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -1115,6 +1127,66 @@ private void checkJobClientAliveness() { }

[GitHub] [flink] gaborgsomogyi commented on pull request #22298: [FLINK-31656][runtime][security] Obtain delegation tokens early to support external file system usage in HA services

2023-03-31 Thread via GitHub
gaborgsomogyi commented on PR #22298: URL: https://github.com/apache/flink/pull/22298#issuecomment-1491595469 I've just fixed the unit tests + changed the title and description. The cluster tests are green. -- This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [flink] gaborgsomogyi commented on pull request #22298: [FLINK-31656][runtime][security] Obtain delegation tokens early to support external file system usage in HA services

2023-03-31 Thread via GitHub
gaborgsomogyi commented on PR #22298: URL: https://github.com/apache/flink/pull/22298#issuecomment-1491595867 cc @gyfora @mbalassi -- 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

[GitHub] [flink] gaborgsomogyi commented on a diff in pull request #22298: [FLINK-31656][runtime][security] Obtain delegation tokens early to support external file system usage in HA services

2023-03-31 Thread via GitHub
gaborgsomogyi commented on code in PR #22298: URL: https://github.com/apache/flink/pull/22298#discussion_r1154229815 ## flink-runtime/src/main/java/org/apache/flink/runtime/security/token/DefaultDelegationTokenManager.java: ## @@ -213,6 +213,20 @@ public void obtainDelegationTo

[GitHub] [flink] zentol commented on pull request #22313: [FLINK-31660][connector-kafka] fix kafka connector pom so ITCases run in IDE

2023-03-31 Thread via GitHub
zentol commented on PR #22313: URL: https://github.com/apache/flink/pull/22313#issuecomment-1491601098 This also is arguably not really an IntelliJ issue, but more of how the planner dependencies are organized. The planner modules apply several relocations (to, for example, jayway) bu

[jira] [Commented] (FLINK-31682) map_from_arrays should take whether allow duplicate keys and null key into consideration

2023-03-31 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707211#comment-17707211 ] Sergey Nuyanzin commented on FLINK-31682: - Can you provide some cases to reprodu

[jira] [Commented] (FLINK-31660) flink-connectors-kafka ITCases are not runnable in the IDE

2023-03-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707214#comment-17707214 ] Chesnay Schepler commented on FLINK-31660: -- Bundling json-path in the table-pla

[GitHub] [flink] zzzzzzzs commented on pull request #20342: [FLINK-26939][Table SQL/API] Add TRANSLATE supported in SQL & Table API

2023-03-31 Thread via GitHub
zzzs commented on PR #20342: URL: https://github.com/apache/flink/pull/20342#issuecomment-1491611206 @snuyanzin Could you please help to review this PR in your free time? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[GitHub] [flink-connector-mongodb] zentol commented on pull request #4: [hotfix] Fix unstable test of MongoSinkITCase.testRecovery

2023-03-31 Thread via GitHub
zentol commented on PR #4: URL: https://github.com/apache/flink-connector-mongodb/pull/4#issuecomment-1491623124 So this is more an issue of the `AppendOnlySerializationSchema` used in the test, because it uses the `InsertOneModel` which fails on duplicates? -- This is an automated messa

[jira] [Created] (FLINK-31683) Align the outdated Chinese filesystem connector docs

2023-03-31 Thread Yun Tang (Jira)
Yun Tang created FLINK-31683: Summary: Align the outdated Chinese filesystem connector docs Key: FLINK-31683 URL: https://issues.apache.org/jira/browse/FLINK-31683 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-31189) Allow special handle of less frequent values in StringIndexer

2023-03-31 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang reassigned FLINK-31189: - Assignee: Zhipeng Zhang > Allow special handle of less frequent values in StringIndexer

[GitHub] [flink-connector-mongodb] zentol commented on pull request #4: [hotfix] Fix unstable test of MongoSinkITCase.testRecovery

2023-03-31 Thread via GitHub
zentol commented on PR #4: URL: https://github.com/apache/flink-connector-mongodb/pull/4#issuecomment-1491627450 I assume this was compounded by us passing `Documents` to the sink which already have an idea, while without that an ID would be auto-generated? -- This is an automated messag

[GitHub] [flink-ml] zhipeng93 commented on pull request #221: [FLINK-31189] Add HasMaxIndexNum param to StringIndexer

2023-03-31 Thread via GitHub
zhipeng93 commented on PR #221: URL: https://github.com/apache/flink-ml/pull/221#issuecomment-1491627983 > Thanks for the PR. LGTM overall. > > My only concern is that the term `bucket` is not explicitly introduced before introducing the parameter. `Bucket` appears to be an uncommon t

[GitHub] [flink-connector-mongodb] zentol commented on pull request #4: [hotfix] Fix unstable test of MongoSinkITCase.testRecovery

2023-03-31 Thread via GitHub
zentol commented on PR #4: URL: https://github.com/apache/flink-connector-mongodb/pull/4#issuecomment-1491630637 If so, then it may be a good idea to explicitly say that using the `InsertOneModel` without only writing on checkpoint will likely fail at some point. -- This is an automated

[GitHub] [flink] Myasuka opened a new pull request, #22315: [FLINK-31683][docs-zh] Update the outdated Chinese filesystem connector docs

2023-03-31 Thread via GitHub
Myasuka opened a new pull request, #22315: URL: https://github.com/apache/flink/pull/22315 ## What is the purpose of the change Update the outdated Chinese filesystem connector docs. ## Brief change log Update the outdated Chinese filesystem connector docs. ##

[GitHub] [flink-ml] Fanoid commented on pull request #222: [FLINK-31029] Fix bug when using quantile in KbinsDiscretizer

2023-03-31 Thread via GitHub
Fanoid commented on PR #222: URL: https://github.com/apache/flink-ml/pull/222#issuecomment-1491638545 Thanks for your updates. Current version can meet my needs now. LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[jira] [Updated] (FLINK-31683) Align the outdated Chinese filesystem connector docs

2023-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31683: --- Labels: pull-request-available (was: ) > Align the outdated Chinese filesystem connector do

[GitHub] [flink] reswqa merged pull request #22295: [BP-1.17][FLINK-31626] HsSubpartitionFileReaderImpl should recycle skipped read buffers.

2023-03-31 Thread via GitHub
reswqa merged PR #22295: URL: https://github.com/apache/flink/pull/22295 -- 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

[GitHub] [flink] WencongLiu opened a new pull request, #22316: [FLINK-31638][runtime] Downstream supports reading buffers from tiered store

2023-03-31 Thread via GitHub
WencongLiu opened a new pull request, #22316: URL: https://github.com/apache/flink/pull/22316 ## What is the purpose of the change *Downstream supports reading buffers from tiered store* ## Brief change log - *Introduce the EndOfSegmentEvent* - *Introduce the s

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

2023-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31638: --- Labels: pull-request-available (was: ) > Downstream supports reading buffers from tiered st

[jira] [Comment Edited] (FLINK-31626) HsSubpartitionFileReaderImpl should recycle skipped read buffers.

2023-03-31 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707221#comment-17707221 ] Weijie Guo edited comment on FLINK-31626 at 3/31/23 9:42 AM: -

[jira] [Closed] (FLINK-31626) HsSubpartitionFileReaderImpl should recycle skipped read buffers.

2023-03-31 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31626. -- Fix Version/s: 1.18.0 1.17.1 Resolution: Fixed master(1.18) via 59462197ba72

[GitHub] [flink] flinkbot commented on pull request #22315: [FLINK-31683][docs-zh] Update the outdated Chinese filesystem connector docs

2023-03-31 Thread via GitHub
flinkbot commented on PR #22315: URL: https://github.com/apache/flink/pull/22315#issuecomment-1491644661 ## CI report: * f4e654e8ea2284100420dfef0e3b27fe59d90aa1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #22316: [FLINK-31638][runtime] Downstream supports reading buffers from tiered store

2023-03-31 Thread via GitHub
flinkbot commented on PR #22316: URL: https://github.com/apache/flink/pull/22316#issuecomment-1491651580 ## CI report: * 09cfbcc61a465986d80a1bfd2f6892ed81004fb3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] pnowojski commented on pull request #22313: [FLINK-31660][connector-kafka] fix kafka connector pom so ITCases run in IDE

2023-03-31 Thread via GitHub
pnowojski commented on PR #22313: URL: https://github.com/apache/flink/pull/22313#issuecomment-1491654230 Is there something wrong with fixing this issue for the time being here? It's after all causing some problems. When the Kafka connector is going to be removed? What if it's going to be

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

2023-03-31 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-31638: - Assignee: Wencong Liu > Downstream supports reading buffers from tiered store > ---

[jira] [Assigned] (FLINK-31635) Support writing records to the new tiered store architecture

2023-03-31 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-31635: - Assignee: Yuxin Tan > Support writing records to the new tiered store architecture > --

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #221: [FLINK-31189] Add HasMaxIndexNum param to StringIndexer

2023-03-31 Thread via GitHub
Fanoid commented on code in PR #221: URL: https://github.com/apache/flink-ml/pull/221#discussion_r1154268534 ## docs/content/docs/operators/feature/stringindexer.md: ## @@ -59,9 +59,10 @@ Below are the parameters required by `StringIndexerModel`. `StringIndexer` needs paramet

[GitHub] [flink] zentol commented on pull request #22313: [FLINK-31660][connector-kafka] fix kafka connector pom so ITCases run in IDE

2023-03-31 Thread via GitHub
zentol commented on PR #22313: URL: https://github.com/apache/flink/pull/22313#issuecomment-1491677580 > But is there something wrong with fixing this issue for the time being here? It breaks the code freeze that we decided on the ML. If you want to merge it regardless, then please b

[GitHub] [flink-kubernetes-operator] mbalassi commented on a diff in pull request #558: [FLINK-31303] Expose Flink application resource usage via metrics and status

2023-03-31 Thread via GitHub
mbalassi commented on code in PR #558: URL: https://github.com/apache/flink-kubernetes-operator/pull/558#discussion_r1154290969 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java: ## @@ -627,14 +637,42 @@ public Map

[GitHub] [flink] zentol commented on pull request #22313: [FLINK-31660][connector-kafka] fix kafka connector pom so ITCases run in IDE

2023-03-31 Thread via GitHub
zentol commented on PR #22313: URL: https://github.com/apache/flink/pull/22313#issuecomment-1491678202 Mind you, that merging this to release-1.17 is a completely different story. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] zentol commented on pull request #22313: [FLINK-31660][connector-kafka] fix kafka connector pom so ITCases run in IDE

2023-03-31 Thread via GitHub
zentol commented on PR #22313: URL: https://github.com/apache/flink/pull/22313#issuecomment-1491680270 I'd also suggest to look into https://issues.apache.org/jira/browse/FLINK-31660?focusedCommentId=17707214&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-17707

[jira] (FLINK-26692) migrate TpcdsTestProgram.java to new source

2023-03-31 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26692 ] Zhu Zhu deleted comment on FLINK-26692: - was (Author: flink-jira-bot): I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see

[jira] (FLINK-26692) migrate TpcdsTestProgram.java to new source

2023-03-31 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26692 ] Zhu Zhu deleted comment on FLINK-26692: - was (Author: flink-jira-bot): I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see

[GitHub] [flink] snuyanzin commented on a diff in pull request #20342: [FLINK-26939][Table SQL/API] Add TRANSLATE supported in SQL & Table API

2023-03-31 Thread via GitHub
snuyanzin commented on code in PR #20342: URL: https://github.com/apache/flink/pull/20342#discussion_r1154293981 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/SqlFunctionUtils.java: ## @@ -371,6 +371,11 @@ public static String repeat(S

[GitHub] [flink] liuyongvs commented on pull request #22312: [FLINK-31677][table] Add built-in MAP_ENTRIES function.

2023-03-31 Thread via GitHub
liuyongvs commented on PR #22312: URL: https://github.com/apache/flink/pull/22312#issuecomment-1491722243 hi @snuyanzin do you have time to review it? -- 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

[GitHub] [flink] liuyongvs commented on pull request #22277: [FLINK-31621][table] Add built-in ARRAY_REVERSE function.

2023-03-31 Thread via GitHub
liuyongvs commented on PR #22277: URL: https://github.com/apache/flink/pull/22277#issuecomment-1491725693 @snuyanzin @fsk119 will it be merged? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink-connector-opensearch] dannycranmer opened a new pull request, #13: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
dannycranmer opened a new pull request, #13: URL: https://github.com/apache/flink-connector-opensearch/pull/13 As per https://github.com/apache/flink-connector-mongodb/commit/a4a3250423592a9bff8859f3132fb72840d0f2b5 Disable dependency convergence for nightly builds to unblock Flink 1.

[GitHub] [flink-connector-opensearch] boring-cyborg[bot] commented on pull request #13: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
boring-cyborg[bot] commented on PR #13: URL: https://github.com/apache/flink-connector-opensearch/pull/13#issuecomment-1491751467 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-aws] z3d1k opened a new pull request, #63: [hotfix][ci] Update Flink versions in CI builds

2023-03-31 Thread via GitHub
z3d1k opened a new pull request, #63: URL: https://github.com/apache/flink-connector-aws/pull/63 ## Purpose of the change - Update CI workflows to include Flink 1.17.0 in PR build and 1.18-SNAPSHOT in nightly builds - Use archive.apache.org for downloading binaries in line

[GitHub] [flink] fsk119 merged pull request #22277: [FLINK-31621][table] Add built-in ARRAY_REVERSE function.

2023-03-31 Thread via GitHub
fsk119 merged PR #22277: URL: https://github.com/apache/flink/pull/22277 -- 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

[GitHub] [flink-connector-elasticsearch] dannycranmer opened a new pull request, #54: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
dannycranmer opened a new pull request, #54: URL: https://github.com/apache/flink-connector-elasticsearch/pull/54 As per https://github.com/apache/flink-connector-mongodb/commit/a4a3250423592a9bff8859f3132fb72840d0f2b5 Disable dependency convergence for nightly builds to unblock Flink

[GitHub] [flink-connector-elasticsearch] boring-cyborg[bot] commented on pull request #54: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
boring-cyborg[bot] commented on PR #54: URL: https://github.com/apache/flink-connector-elasticsearch/pull/54#issuecomment-1491760352 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- T

[jira] [Closed] (FLINK-31621) Add ARRAY_REVERSE supported in SQL & Table API

2023-03-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-31621. - Resolution: Implemented Merged into master: 122429f99b9b75737cd218a56a37a7ced750582f > Add ARRA

[jira] [Assigned] (FLINK-31621) Add ARRAY_REVERSE supported in SQL & Table API

2023-03-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-31621: - Assignee: jackylau > Add ARRAY_REVERSE supported in SQL & Table API > -

[GitHub] [flink-connector-rabbitmq] boring-cyborg[bot] commented on pull request #6: [hotfix] Disable nighty dependency convergence

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

[GitHub] [flink-connector-rabbitmq] dannycranmer opened a new pull request, #6: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
dannycranmer opened a new pull request, #6: URL: https://github.com/apache/flink-connector-rabbitmq/pull/6 As per apache/flink-connector-mongodb@a4a3250 Disable dependency convergence for nightly builds to unblock Flink 1.17 build verification -- This is an automated message from t

[GitHub] [flink-connector-cassandra] dannycranmer opened a new pull request, #4: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
dannycranmer opened a new pull request, #4: URL: https://github.com/apache/flink-connector-cassandra/pull/4 As per apache/flink-connector-mongodb@a4a3250 Disable dependency convergence for nightly builds to unblock Flink 1.17 build verification -- This is an automated message from

[GitHub] [flink-connector-cassandra] boring-cyborg[bot] commented on pull request #4: [hotfix] Disable nighty dependency convergence

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

[GitHub] [flink-connector-mongodb] zentol merged pull request #4: [hotfix] Fix unstable test of MongoSinkITCase.testRecovery

2023-03-31 Thread via GitHub
zentol merged PR #4: URL: https://github.com/apache/flink-connector-mongodb/pull/4 -- 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...@fl

[GitHub] [flink-connector-jdbc] boring-cyborg[bot] commented on pull request #34: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
boring-cyborg[bot] commented on PR #34: URL: https://github.com/apache/flink-connector-jdbc/pull/34#issuecomment-1491778630 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] zentol commented on pull request #22313: [FLINK-31660][connector-kafka] fix kafka connector pom so ITCases run in IDE

2023-03-31 Thread via GitHub
zentol commented on PR #22313: URL: https://github.com/apache/flink/pull/22313#issuecomment-1491780342 You may also be able to work around this issue by working against https://github.com/apache/flink-connector-kafka instead. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] MartijnVisser commented on a diff in pull request #21873: [FLINK-30921][ci] Adds mirrors instead of relying on a single source for Ubuntu packages

2023-03-31 Thread via GitHub
MartijnVisser commented on code in PR #21873: URL: https://github.com/apache/flink/pull/21873#discussion_r1154369959 ## tools/azure-pipelines/e2e-template.yml: ## @@ -98,6 +98,19 @@ jobs: echo "Free up disk space" ./tools/azure-pipelines/free_disk_space.sh +

[GitHub] [flink] gyfora commented on a diff in pull request #22298: [FLINK-31656][runtime][security] Obtain delegation tokens early to support external file system usage in HA services

2023-03-31 Thread via GitHub
gyfora commented on code in PR #22298: URL: https://github.com/apache/flink/pull/22298#discussion_r1154386632 ## flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java: ## @@ -418,6 +418,21 @@ public void start() throws Exception {

[GitHub] [flink] zzzzzzzs commented on a diff in pull request #20342: [FLINK-26939][Table SQL/API] Add TRANSLATE supported in SQL & Table API

2023-03-31 Thread via GitHub
zzzs commented on code in PR #20342: URL: https://github.com/apache/flink/pull/20342#discussion_r1154393863 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/SqlFunctionUtils.java: ## @@ -371,6 +371,11 @@ public static String repeat(St

[GitHub] [flink-connector-elasticsearch] boring-cyborg[bot] commented on pull request #54: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
boring-cyborg[bot] commented on PR #54: URL: https://github.com/apache/flink-connector-elasticsearch/pull/54#issuecomment-1491841143 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-connector-opensearch] dannycranmer merged pull request #13: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
dannycranmer merged PR #13: URL: https://github.com/apache/flink-connector-opensearch/pull/13 -- 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-uns

[GitHub] [flink-connector-elasticsearch] dannycranmer merged pull request #54: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
dannycranmer merged PR #54: URL: https://github.com/apache/flink-connector-elasticsearch/pull/54 -- 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-

[GitHub] [flink-connector-opensearch] boring-cyborg[bot] commented on pull request #13: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
boring-cyborg[bot] commented on PR #13: URL: https://github.com/apache/flink-connector-opensearch/pull/13#issuecomment-1491841203 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink-connector-rabbitmq] dannycranmer merged pull request #6: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
dannycranmer merged PR #6: URL: https://github.com/apache/flink-connector-rabbitmq/pull/6 -- 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-unsubsc

[GitHub] [flink-connector-jdbc] dannycranmer merged pull request #34: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
dannycranmer merged PR #34: URL: https://github.com/apache/flink-connector-jdbc/pull/34 -- 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.

[GitHub] [flink-connector-rabbitmq] boring-cyborg[bot] commented on pull request #6: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
boring-cyborg[bot] commented on PR #6: URL: https://github.com/apache/flink-connector-rabbitmq/pull/6#issuecomment-1491841279 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink-connector-cassandra] dannycranmer merged pull request #4: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
dannycranmer merged PR #4: URL: https://github.com/apache/flink-connector-cassandra/pull/4 -- 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-connector-cassandra] boring-cyborg[bot] commented on pull request #4: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
boring-cyborg[bot] commented on PR #4: URL: https://github.com/apache/flink-connector-cassandra/pull/4#issuecomment-1491841503 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [flink-connector-jdbc] boring-cyborg[bot] commented on pull request #34: [hotfix] Disable nighty dependency convergence

2023-03-31 Thread via GitHub
boring-cyborg[bot] commented on PR #34: URL: https://github.com/apache/flink-connector-jdbc/pull/34#issuecomment-1491841620 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [flink-connector-aws] dannycranmer merged pull request #63: [hotfix][ci] Update Flink versions in CI builds

2023-03-31 Thread via GitHub
dannycranmer merged PR #63: URL: https://github.com/apache/flink-connector-aws/pull/63 -- 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..

  1   2   >