[GitHub] [flink] JunRuiLee commented on pull request #21963: [FLINK-31114][runtime] Set parallelism of job vertices in forward group at compilation phase

JunRuiLee commented on PR #21963: URL: https://github.com/apache/flink/pull/21963#issuecomment-1443025904 LGTM. -- 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

[GitHub] [flink] gaborgsomogyi commented on pull request #22009: [FLINK-31109][yarn] Support Hadoop proxy user when delegation token f…

gaborgsomogyi commented on PR #22009: URL: https://github.com/apache/flink/pull/22009#issuecomment-1443023755 e2e tests are still running so most probably it's going to pass. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] gaborgsomogyi commented on a diff in pull request #22009: [FLINK-31109][yarn] Support Hadoop proxy user when delegation token f…

gaborgsomogyi commented on code in PR #22009: URL: https://github.com/apache/flink/pull/22009#discussion_r1116617650 ## flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/HadoopModule.java: ## @@ -70,10 +71,22 @@ public void install() throws

[GitHub] [flink] flinkbot commented on pull request #22010: [FLINK-31192][connectors/dataGen] Fix dataGen takes too long to initi…

flinkbot commented on PR #22010: URL: https://github.com/apache/flink/pull/22010#issuecomment-1443013003 ## CI report: * 5f4a9ee58a62b1b2e4d540ea6293554638722e53 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] xuzhiwen1255 commented on pull request #22010: [FLINK-31192][connectors/dataGen] Fix dataGen takes too long to initi…

xuzhiwen1255 commented on PR #22010: URL: https://github.com/apache/flink/pull/22010#issuecomment-1442997250 @reswqa Can you review it for me, Thank you. -- 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

[jira] [Commented] (FLINK-30583) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693055#comment-17693055 ] Piotr Nowojski commented on FLINK-30583: Thanks for this improvement! I've just found it in the

[jira] [Closed] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

[ https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-27115. -- Resolution: Fixed master(1.18) via 67bd4ba7f300749c4831b37df525b82a76d3c36c release-1.17 via

[jira] [Updated] (FLINK-31192) dataGen takes too long to initialize under sequence

[ https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31192: --- Labels: pull-request-available (was: ) > dataGen takes too long to initialize under

[GitHub] [flink] xuzhiwen1255 opened a new pull request, #22010: [FLINK-31192][connectors/dataGen] Fix dataGen takes too long to initi…

xuzhiwen1255 opened a new pull request, #22010: URL: https://github.com/apache/flink/pull/22010 ## What is the purpose of the change In the sequence mode, the dataGen field will preload all the sequence values when it is initialized, and it will take a long time during this period

[jira] [Updated] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

[ https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-27115: --- Affects Version/s: 1.17.0 > Error while executing BLOB connection. java.io.IOException: Unknown

[jira] [Updated] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

[ https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-27115: --- Fix Version/s: 1.17.0 > Error while executing BLOB connection. java.io.IOException: Unknown

[jira] [Assigned] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

[ https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-27115: -- Assignee: Weihua Hu > Error while executing BLOB connection. java.io.IOException: Unknown

[GitHub] [flink] reswqa merged pull request #22004: [FLINK-27115][blob] Enrich the error log with remote address for blobServer

reswqa merged PR #22004: URL: https://github.com/apache/flink/pull/22004 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] reswqa commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

reswqa commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1116565034 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java: ## @@ -362,30 +357,28 @@ private void testSyncSavepointWithEndInput(

[jira] [Commented] (FLINK-31089) pin L0 index in memory can lead to slow memory grow finally lead to memory beyond limit

[ https://issues.apache.org/jira/browse/FLINK-31089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693022#comment-17693022 ] Yanfei Lei commented on FLINK-31089: Let me try to summarize this issue: # Enable

[GitHub] [flink] reswqa commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

reswqa commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1116563643 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java: ## @@ -368,17 +368,19 @@ void testCleanUpExceptionSuppressing()

[GitHub] [flink] jhkkhtd commented on pull request #21998: [Flink-clients][api] Adding a method to get ClusterClientProvider

jhkkhtd commented on PR #21998: URL: https://github.com/apache/flink/pull/21998#issuecomment-1442874077 > Thanks @jhkkhtd. Firstly, You should open a [jira ticket](https://issues.apache.org/jira/projects/FLINK/issues) and describe clearly why you need this change and how you plan to change

[jira] [Updated] (FLINK-31208) KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits)

[ https://issues.apache.org/jira/browse/FLINK-31208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-31208: -- Description: KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits) ，which

[jira] [Created] (FLINK-31208) KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits)

Hongshun Wang created FLINK-31208: - Summary: KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits) Key: FLINK-31208 URL: https://issues.apache.org/jira/browse/FLINK-31208 Project:

[GitHub] [flink] RocMarshal commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

RocMarshal commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1116556431 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java: ## @@ -1085,27 +1081,27 @@ public void

[GitHub] [flink] RocMarshal commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

RocMarshal commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1116556097 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java: ## @@ -1121,13 +1117,14 @@ private void

[GitHub] [flink] RocMarshal commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

RocMarshal commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1116555777 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java: ## @@ -362,30 +357,28 @@ private void

[GitHub] [flink] RocMarshal commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

RocMarshal commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1116555051 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java: ## @@ -362,30 +357,28 @@ private void

[jira] [Commented] (FLINK-22484) Built-in functions for collections

[ https://issues.apache.org/jira/browse/FLINK-22484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693015#comment-17693015 ] jackylau commented on FLINK-22484: -- hi [~Sergey Nuyanzin] how aboult add

[GitHub] [flink] reswqa commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

reswqa commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1116492529 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java: ## @@ -362,30 +357,28 @@ private void testSyncSavepointWithEndInput(

[jira] [Updated] (FLINK-31207) Supports high order function like other engine

[ https://issues.apache.org/jira/browse/FLINK-31207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-31207: - Description: spark [https://spark.apache.org/docs/latest/api/sql/index.html#transform]

[GitHub] [flink-table-store] zhuangchong opened a new pull request, #556: [hotfix] Add version reference in the pom

zhuangchong opened a new pull request, #556: URL: https://github.com/apache/flink-table-store/pull/556 Add version reference of `kafka` dependent package -- 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

[jira] [Commented] (FLINK-22091) env.java.home option didn't take effect in resource negotiator

[ https://issues.apache.org/jira/browse/FLINK-22091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693008#comment-17693008 ] Samrat Deb commented on FLINK-22091: i would like to work on this issue. > env.java.home option

[jira] [Updated] (FLINK-31207) Supports high order function like other engine

[ https://issues.apache.org/jira/browse/FLINK-31207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-31207: - Summary: Supports high order function like other engine (was: supports high order function like other

[jira] [Created] (FLINK-31207) supports high order function like other engine

jackylau created FLINK-31207: Summary: supports high order function like other engine Key: FLINK-31207 URL: https://issues.apache.org/jira/browse/FLINK-31207 Project: Flink Issue Type: Sub-task

[GitHub] [flink] 1996fanrui commented on pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

1996fanrui commented on PR #21999: URL: https://github.com/apache/flink/pull/21999#issuecomment-1442822176 Please squish these commits, and follow the rules that @reswqa mentioned before. > This PR will eventually have two commits in the following order: > 1.[hotfix] Migrate

[jira] [Updated] (FLINK-31196) Flink on YARN honors env.java.home

[ https://issues.apache.org/jira/browse/FLINK-31196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabhu Joseph updated FLINK-31196: -- Description: Flink on YARN, honor env.java.home, and launch JobManager and TaskMananger

[jira] [Resolved] (FLINK-31196) Flink on YARN honors env.java.home

[ https://issues.apache.org/jira/browse/FLINK-31196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabhu Joseph resolved FLINK-31196. --- Resolution: Duplicate > Flink on YARN honors env.java.home >

[jira] [Commented] (FLINK-31196) Flink on YARN honors env.java.home

[ https://issues.apache.org/jira/browse/FLINK-31196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693003#comment-17693003 ] Prabhu Joseph commented on FLINK-31196: --- Thanks [~zlzhang0122]  for the update. Have missed to

[jira] [Assigned] (FLINK-20395) Migrate test_netty_shuffle_memory_control.sh

[ https://issues.apache.org/jira/browse/FLINK-20395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-20395: -- Assignee: Weijie Guo > Migrate test_netty_shuffle_memory_control.sh >

[jira] [Created] (FLINK-31206) Broken links on flink.apache.org

Zili Chen created FLINK-31206: - Summary: Broken links on flink.apache.org Key: FLINK-31206 URL: https://issues.apache.org/jira/browse/FLINK-31206 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-31204) HiveCatalogITCase fails due to avro conflict in table store

[ https://issues.apache.org/jira/browse/FLINK-31204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31204. Fix Version/s: table-store-0.4.0 Assignee: Shammon Resolution: Fixed master:

[GitHub] [flink] wanglijie95 commented on pull request #20006: [FLINK-27415][Connectors / FileSystem] Read empty csv file throws exception in FileSystem table connector

wanglijie95 commented on PR #20006: URL: https://github.com/apache/flink/pull/20006#issuecomment-1442775810 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink-table-store] JingsongLi merged pull request #555: [FLINK-31204] Fix HiveCatalogITCase fails in IDEA

JingsongLi merged PR #555: URL: https://github.com/apache/flink-table-store/pull/555 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] wanglijie95 commented on pull request #21963: [FLINK-31114][runtime] Set parallelism of job vertices in forward group at compilation phase

wanglijie95 commented on PR #21963: URL: https://github.com/apache/flink/pull/21963#issuecomment-1442773339 Thanks for review @JunRuiLee @zhuzhurk . I 've addressed all comments, please take a look. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] wanglijie95 commented on a diff in pull request #21963: [FLINK-31114][runtime] Set parallelism of job vertices in forward group at compilation phase

wanglijie95 commented on code in PR #21963: URL: https://github.com/apache/flink/pull/21963#discussion_r1116480439 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java: ## @@ -1060,14 +,97 @@ private void

[jira] [Updated] (FLINK-31107) Can't subscribe the non-persistent topics by using regex in Pulsar 2.11.0

[ https://issues.apache.org/jira/browse/FLINK-31107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-31107: Description: This is a ticket for tracking [the known

[GitHub] [flink] wanglijie95 commented on a diff in pull request #21963: [FLINK-31114][runtime] Set parallelism of job vertices in forward group at compilation phase

wanglijie95 commented on code in PR #21963: URL: https://github.com/apache/flink/pull/21963#discussion_r1116477683 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java: ## @@ -568,12 +592,7 @@ &&

[GitHub] [flink] wanglijie95 commented on a diff in pull request #21963: [FLINK-31114][runtime] Set parallelism of job vertices in forward group at compilation phase

wanglijie95 commented on code in PR #21963: URL: https://github.com/apache/flink/pull/21963#discussion_r1116477303 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/forwardgroup/ForwardGroup.java: ## @@ -53,9 +55,22 @@ public ForwardGroup(final Set jobVertices) {

[GitHub] [flink] venkata91 commented on pull request #22009: [FLINK-31109][yarn] Support Hadoop proxy user when delegation token f…

venkata91 commented on PR #22009: URL: https://github.com/apache/flink/pull/22009#issuecomment-1442766757 Looking into the test failure, somehow it worked locally but failing in the pipeline. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] wanglijie95 commented on a diff in pull request #21963: [FLINK-31114][runtime] Set parallelism of job vertices in forward group at compilation phase

wanglijie95 commented on code in PR #21963: URL: https://github.com/apache/flink/pull/21963#discussion_r1116476622 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java: ## @@ -928,14 +1011,8 @@ private StreamConfig

[GitHub] [flink] wanglijie95 commented on a diff in pull request #21963: [FLINK-31114][runtime] Set parallelism of job vertices in forward group at compilation phase

wanglijie95 commented on code in PR #21963: URL: https://github.com/apache/flink/pull/21963#discussion_r1116476465 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java: ## @@ -1060,14 +,97 @@ private void

[GitHub] [flink] wuchong commented on pull request #21966: [FLINK-29729][parquet] Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader

wuchong commented on PR #21966: URL: https://github.com/apache/flink/pull/21966#issuecomment-1442759082 @stayrascal thank you for helping to verifying 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

[GitHub] [flink] lsyldliu commented on pull request #21966: [FLINK-29729][parquet] Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader

lsyldliu commented on PR #21966: URL: https://github.com/apache/flink/pull/21966#issuecomment-1442750732 @stayrascal Very thanks you can make double-check. I think it works well because it works on JM side. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-31117) Split flink connector to each module of each version

[ https://issues.apache.org/jira/browse/FLINK-31117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31117. Resolution: Fixed master: 37f75a85091697b75c6968293edfb060595adae3 > Split flink connector to

[GitHub] [flink-table-store] JingsongLi merged pull request #545: [FLINK-31117] Split flink connector to each module of each version

JingsongLi merged PR #545: URL: https://github.com/apache/flink-table-store/pull/545 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] stayrascal commented on pull request #21966: [FLINK-29729][parquet] Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader

stayrascal commented on PR #21966: URL: https://github.com/apache/flink/pull/21966#issuecomment-1442721215 @lsyldliu thanks a lot for looking at this issue, may I check that if we use flink filesytem instead of hadoop filesytem to open parquet file, so that flink fs can retrieve the

[GitHub] [flink-table-store] FangYongs commented on a diff in pull request #555: [FLINK-31204] Fix HiveCatalogITCase fails in IDEA

FangYongs commented on code in PR #555: URL: https://github.com/apache/flink-table-store/pull/555#discussion_r1116445519 ## flink-table-store-hive/flink-table-store-hive-catalog/pom.xml: ## @@ -535,6 +535,65 @@ under the License. org.jamon

[jira] [Commented] (FLINK-22922) Migrate flink project website to Hugo

[ https://issues.apache.org/jira/browse/FLINK-22922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692982#comment-17692982 ] Zili Chen commented on FLINK-22922: --- Hi [~martijnvisser]! I see now we use `asf-site` for both dev and

[GitHub] [flink] Mulavar commented on pull request #21545: [FLINK-30396][table]make alias hint take effect in correlate

Mulavar commented on PR #21545: URL: https://github.com/apache/flink/pull/21545#issuecomment-1442717916 @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 comment.

[jira] [Updated] (FLINK-31204) HiveCatalogITCase fails due to avro conflict in table store

[ https://issues.apache.org/jira/browse/FLINK-31204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31204: --- Labels: pull-request-available (was: ) > HiveCatalogITCase fails due to avro conflict in

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #555: [FLINK-31204] Fix HiveCatalogITCase fails in IDEA

JingsongLi commented on code in PR #555: URL: https://github.com/apache/flink-table-store/pull/555#discussion_r111644 ## flink-table-store-hive/flink-table-store-hive-catalog/pom.xml: ## @@ -535,6 +535,65 @@ under the License. org.jamon

[jira] [Commented] (FLINK-12450) [Bitwise Functions] Add BIT_LSHIFT, BIT_RSHIFT functions supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692979#comment-17692979 ] Ran Tao commented on FLINK-12450: - [~jark] Hi, Jark. can you assign this ticket to me? i'm glad to

[jira] [Commented] (FLINK-12449) [Bitwise Functions] Add BIT_AND, BIT_OR functions supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-12449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692978#comment-17692978 ] Ran Tao commented on FLINK-12449: - [~lzljs3620320] hi,Jingsong, can you assign this ticket to me? i'm

[GitHub] [flink-table-store] JingsongLi merged pull request #553: Unify the version of `kafka` in pom.

JingsongLi merged PR #553: URL: https://github.com/apache/flink-table-store/pull/553 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot commented on pull request #22009: [FLINK-31109][yarn] Support Hadoop proxy user when delegation token f…

flinkbot commented on PR #22009: URL: https://github.com/apache/flink/pull/22009#issuecomment-1442699380 ## CI report: * c7e58124ab18ef98248a279359ee9014071847dc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] lsyldliu commented on pull request #21966: [FLINK-29729][parquet] Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader

lsyldliu commented on PR #21966: URL: https://github.com/apache/flink/pull/21966#issuecomment-1442697375 @wuchong Thanks for reviewing. Regarding your question, we can't verify the configuration in ParquetReader now because the `ParquetFileReader` doesn't contain the credential info. The

[jira] [Commented] (FLINK-31109) Fails with proxy user not supported even when security.kerberos.fetch.delegation-token is set to false

[ https://issues.apache.org/jira/browse/FLINK-31109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692973#comment-17692973 ] Venkata krishnan Sowrirajan commented on FLINK-31109: - [~martijnvisser] Sure, I have

[GitHub] [flink] venkata91 commented on pull request #22009: [FLINK-31109][yarn] Support Hadoop proxy user when delegation token f…

venkata91 commented on PR #22009: URL: https://github.com/apache/flink/pull/22009#issuecomment-1442696039 Please review. cc @MartijnVisser @gaborgsomogyi @becketqin -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Updated] (FLINK-31109) Fails with proxy user not supported even when security.kerberos.fetch.delegation-token is set to false

[ https://issues.apache.org/jira/browse/FLINK-31109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31109: --- Labels: pull-request-available (was: ) > Fails with proxy user not supported even when >

[GitHub] [flink] venkata91 opened a new pull request, #22009: [FLINK-31109][yarn] Support Hadoop proxy user when delegation token f…

venkata91 opened a new pull request, #22009: URL: https://github.com/apache/flink/pull/22009 …etch is disabled ## What is the purpose of the change FLINK-28330 removed old delegation token framework code as part of it removed the existing support for delegation tokens

[jira] [Created] (FLINK-31205) do optimize for multi sink in a single relNode tree

Aitozi created FLINK-31205: -- Summary: do optimize for multi sink in a single relNode tree Key: FLINK-31205 URL: https://issues.apache.org/jira/browse/FLINK-31205 Project: Flink Issue Type:

[GitHub] [flink] zlzhang0122 commented on pull request #20183: [FLINK-24306][table]Group by index throw SqlValidatorException

zlzhang0122 commented on PR #20183: URL: https://github.com/apache/flink/pull/20183#issuecomment-1442682491 @wuchong Could you pls help to confirm and review this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Assigned] (FLINK-31201) Provides option to sort partition for full stage in streaming read

[ https://issues.apache.org/jira/browse/FLINK-31201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31201: Assignee: Jingsong Lee > Provides option to sort partition for full stage in streaming

[jira] [Commented] (FLINK-31196) Flink on YARN honors env.java.home

[ https://issues.apache.org/jira/browse/FLINK-31196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692966#comment-17692966 ] zlzhang0122 commented on FLINK-31196: - Maybe duplicate with this?

[jira] [Updated] (FLINK-31201) Provides option to sort partition for full stage in streaming read

[ https://issues.apache.org/jira/browse/FLINK-31201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31201: --- Labels: pull-request-available (was: ) > Provides option to sort partition for full stage

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #554: [FLINK-31201] Scan to generate splits should care about file order

JingsongLi opened a new pull request, #554: URL: https://github.com/apache/flink-table-store/pull/554 Currently, it is out of order for partitions. Because HashMap is used, we may be able to use LinkedHashMap to make the order according to the creation time of the first file. -- This is

[jira] [Created] (FLINK-31204) HiveCatalogITCase fails due to avro conflict in table store

Shammon created FLINK-31204: --- Summary: HiveCatalogITCase fails due to avro conflict in table store Key: FLINK-31204 URL: https://issues.apache.org/jira/browse/FLINK-31204 Project: Flink Issue

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

rkhachatryan commented on PR #21981: URL: https://github.com/apache/flink/pull/21981#issuecomment-1442587044 Thanks for the feedback, @zentol and @dmvk . I've updated the PR, would you mind taking another look? I've significantly restructured the code after the offline discussions.

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

rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1116364006 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotAllocator.java: ## @@ -54,6 +54,18 @@ public interface SlotAllocator {

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

rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1116362299 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java: ## @@ -0,0 +1,209 @@ +/* + * Licensed to the

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

rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1116362006 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java: ## @@ -0,0 +1,209 @@ +/* + * Licensed to the

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

rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1116360889 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java: ## @@ -0,0 +1,209 @@ +/* + * Licensed to the

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

rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1116359613 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java: ## @@ -0,0 +1,209 @@ +/* + * Licensed to the

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

rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1116359318 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java: ## @@ -0,0 +1,209 @@ +/* + * Licensed to the

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

rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1116358878 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateTransitions.java: ## @@ -163,7 +165,12 @@ CompletableFuture goToStopWithSavepoint(

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

rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1116358657 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java: ## @@ -0,0 +1,209 @@ +/* + * Licensed to the

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

rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1116358477 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java: ## @@ -0,0 +1,209 @@ +/* + * Licensed to the

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

rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1116356436 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java: ## @@ -794,7 +802,23 @@ public void goToWaitingForResources() {

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

rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1116355057 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java: ## @@ -121,16 +133,13 @@ public Optional

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

rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1116355057 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java: ## @@ -121,16 +133,13 @@ public Optional

[GitHub] [flink] gunnarmorling commented on pull request #21648: [FLINK-30636] [docs]: Typo fix; 'to to' -> 'to'

gunnarmorling commented on PR #21648: URL: https://github.com/apache/flink/pull/21648#issuecomment-1442297939 @rmetzger, could we get this one 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

[GitHub] [flink-kubernetes-operator] mxm merged pull request #537: [docs] Use Prometheus factory class in metric reporter examples

mxm merged PR #537: URL: https://github.com/apache/flink-kubernetes-operator/pull/537 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-web] dannycranmer commented on a diff in pull request #611: Flink 1.15.4

dannycranmer commented on code in PR #611: URL: https://github.com/apache/flink-web/pull/611#discussion_r1116091205 ## docs/content/posts/2023-02-23-release-1.15.4.md: ## @@ -0,0 +1,152 @@ +--- +authors: +- fapaul: null + name: Danny Cranmer +date: "2023-02-23T17:00:00Z"

[GitHub] [flink-web] snuyanzin commented on a diff in pull request #611: Flink 1.15.4

snuyanzin commented on code in PR #611: URL: https://github.com/apache/flink-web/pull/611#discussion_r1116071377 ## docs/content/posts/2023-02-23-release-1.15.4.md: ## @@ -0,0 +1,152 @@ +--- +authors: +- fapaul: null + name: Danny Cranmer +date: "2023-02-23T17:00:00Z"

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

snuyanzin commented on code in PR #21993: URL: https://github.com/apache/flink/pull/21993#discussion_r1116007389 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java: ## @@ -31,24 +31,28 @@

[jira] [Assigned] (FLINK-27954) JobVertexFlameGraphHandler does not work on standby Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-27954: -- Assignee: Weijie Guo > JobVertexFlameGraphHandler does not work on standby Dispatcher >

[GitHub] [flink-kubernetes-operator] mxm opened a new pull request, #537: [docs] Use Prometheus factory class in metric reporter examples

mxm opened a new pull request, #537: URL: https://github.com/apache/flink-kubernetes-operator/pull/537 Using the reporter class directly is not supported anymore with Flink 1.16. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-27954) JobVertexFlameGraphHandler does not work on standby Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692801#comment-17692801 ] Weijie Guo commented on FLINK-27954: Thanks [~chesnay] for reporting this and giving fix suggestion,

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

snuyanzin commented on code in PR #21993: URL: https://github.com/apache/flink/pull/21993#discussion_r1116011807 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java: ## @@ -71,7 +71,11 @@ public

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

snuyanzin commented on code in PR #21993: URL: https://github.com/apache/flink/pull/21993#discussion_r1116007389 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java: ## @@ -31,24 +31,28 @@

[jira] [Resolved] (FLINK-31183) Flink Kinesis EFO Consumer can fail to stop gracefully

[ https://issues.apache.org/jira/browse/FLINK-31183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-31183. --- Resolution: Fixed > Flink Kinesis EFO Consumer can fail to stop gracefully >

[jira] [Comment Edited] (FLINK-31183) Flink Kinesis EFO Consumer can fail to stop gracefully

[ https://issues.apache.org/jira/browse/FLINK-31183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692651#comment-17692651 ] Danny Cranmer edited comment on FLINK-31183 at 2/23/23 5:05 PM: Merged

[GitHub] [flink] dannycranmer merged pull request #22008: [FLINK-31183][Connector/Kinesis] Fix bug where EFO Consumer can fail …

dannycranmer merged PR #22008: URL: https://github.com/apache/flink/pull/22008 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21963: [FLINK-31114][runtime] Set parallelism of job vertices in forward group at compilation phase

zhuzhurk commented on code in PR #21963: URL: https://github.com/apache/flink/pull/21963#discussion_r1115923261 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java: ## @@ -928,14 +1011,8 @@ private StreamConfig

  1   2   3   4   >