[GitHub] [flink] Myasuka commented on pull request #19503: [FLINK-16078] [docs-zh] Translate "Tuning Checkpoints and Large State".

2022-06-23 Thread GitBox
Myasuka commented on PR #19503: URL: https://github.com/apache/flink/pull/19503#issuecomment-1165263404 @liuzhuang2017 Thanks for your reminder, @mddxhj would you please help to take a review first? -- This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [flink] wanglijie95 commented on a diff in pull request #20043: [FLINK-28193][runtime] Enable to identify whether a job vertex contains source/sink operators

2022-06-23 Thread GitBox
wanglijie95 commented on code in PR #20043: URL: https://github.com/apache/flink/pull/20043#discussion_r905762619 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java: ## @@ -1178,6 +1180,27 @@ && isChainable(upStreamVertex.g

[GitHub] [flink] MartijnVisser commented on pull request #19473: [FLINK-27199][Connector/Pulsar] Bump pulsar to 2.10.0

2022-06-23 Thread GitBox
MartijnVisser commented on PR #19473: URL: https://github.com/apache/flink/pull/19473#issuecomment-1165259847 @syhily How quickly is it possible to improve this PR? If I'm not mistaken, this is the most important PR to get in since it should resolve the current test instabilities. In the cu

[jira] [Updated] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline

2022-06-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26721: --- Priority: Blocker (was: Critical) > PulsarSourceITCase.testSavepoint failed on azure pipeli

[jira] [Commented] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline

2022-06-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558349#comment-17558349 ] Martijn Visser commented on FLINK-26721: https://dev.azure.com/apache-flink/apac

[GitHub] [flink-web] MartijnVisser commented on pull request #552: [hotfix][docs] Eliminate the redundant symbol '/' from the jump link url

2022-06-23 Thread GitBox
MartijnVisser commented on PR #552: URL: https://github.com/apache/flink-web/pull/552#issuecomment-1165257037 I don't see it as a problem. Like I said, all links are currently working. Since work is being done on https://issues.apache.org/jira/browse/FLINK-22922 I think we should just close

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

2022-06-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558348#comment-17558348 ] Martijn Visser commented on FLINK-28171: I'm not sure it's that easy. You have t

[GitHub] [flink] flinkbot commented on pull request #20063: [FLINK-28238][sql-gateway] Fix unstable testCancelOperationAndFetchResultInParallel

2022-06-23 Thread GitBox
flinkbot commented on PR #20063: URL: https://github.com/apache/flink/pull/20063#issuecomment-1165256041 ## CI report: * b731645289cc8eaeb3179b373cef8bddf4d3f915 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-28238) Fix unstable testCancelOperationAndFetchResultInParallel

2022-06-23 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-28238: - Assignee: Shengkai Fang > Fix unstable testCancelOperationAndFetchResultInParallel > --

[GitHub] [flink-table-store] JingsongLi commented on pull request #173: [FLINK-28219] Refactor TableStoreCatalog: Introduce a dedicated Catalog for table store

2022-06-23 Thread GitBox
JingsongLi commented on PR #173: URL: https://github.com/apache/flink-table-store/pull/173#issuecomment-1165255264 > Q1: What are the criteria for choosing which interface not to implement. E.g. createDatabase is unsupported, which is confusing to me. I was previously considering dat

[jira] [Updated] (FLINK-28238) Fix unstable testCancelOperationAndFetchResultInParallel

2022-06-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28238: --- Labels: pull-request-available (was: ) > Fix unstable testCancelOperationAndFetchResultInPa

[GitHub] [flink] fsk119 opened a new pull request, #20063: [FLINK-28238][sql-gateway] Fix unstable testCancelOperationAndFetchResultInParallel

2022-06-23 Thread GitBox
fsk119 opened a new pull request, #20063: URL: https://github.com/apache/flink/pull/20063 …sultInParallel ## What is the purpose of the change *Fix the unstable test case. The root cause is the fetcher thread and another thread is in parallel. There are two cases:*

[jira] [Commented] (FLINK-27611) ConcurrentModificationException during Flink-Pulsar checkpoint notification

2022-06-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558346#comment-17558346 ] Martijn Visser commented on FLINK-27611: [~longtimer] The voting on Flink 1.15.1

[jira] [Commented] (FLINK-28078) ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers runs into timeout

2022-06-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558345#comment-17558345 ] Matthias Pohl commented on FLINK-28078: --- I did a comparison of a successful run an

[GitHub] [flink] Myasuka commented on pull request #19503: [FLINK-16078] [docs-zh] Translate "Tuning Checkpoints and Large State".

2022-06-23 Thread GitBox
Myasuka commented on PR #19503: URL: https://github.com/apache/flink/pull/19503#issuecomment-1165250086 @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] [Commented] (FLINK-28214) ArrayDataSerializer can not be reused to copy customized type of array data

2022-06-23 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558338#comment-17558338 ] Yi Tang commented on FLINK-28214: - Thanks [~Weijie Guo], let me describe it with some ps

[jira] [Commented] (FLINK-28236) managed memory  no  matter how much I configure, it will be exhausted

2022-06-23 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558333#comment-17558333 ] JasonLee commented on FLINK-28236: -- hi [~LCER] ,This error is not necessarily a managed

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

2022-06-23 Thread Moshe Elisha (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558329#comment-17558329 ] Moshe Elisha commented on FLINK-28171: -- Thanks [~martijnvisser] and [~wangyang0918]

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #173: [FLINK-28219] Refactor TableStoreCatalog: Introduce a dedicated Catalog for table store

2022-06-23 Thread GitBox
JingsongLi commented on code in PR #173: URL: https://github.com/apache/flink-table-store/pull/173#discussion_r905728693 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/Catalog.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache Software F

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #173: [FLINK-28219] Refactor TableStoreCatalog: Introduce a dedicated Catalog for table store

2022-06-23 Thread GitBox
JingsongLi commented on code in PR #173: URL: https://github.com/apache/flink-table-store/pull/173#discussion_r905726586 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/Catalog.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache Software F

[jira] [Created] (FLINK-28238) Fix unstable testCancelOperationAndFetchResultInParallel

2022-06-23 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-28238: - Summary: Fix unstable testCancelOperationAndFetchResultInParallel Key: FLINK-28238 URL: https://issues.apache.org/jira/browse/FLINK-28238 Project: Flink Is

[GitHub] [flink] swuferhong commented on a diff in pull request #20007: [FLINK-27989][table-planner] Csv format supports reporting statistics

2022-06-23 Thread GitBox
swuferhong commented on code in PR #20007: URL: https://github.com/apache/flink/pull/20007#discussion_r905699266 ## flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFileFormatFactory.java: ## @@ -136,6 +147,45 @@ public BulkFormat createRuntimeDecoder(

[GitHub] [flink] swuferhong commented on a diff in pull request #20007: [FLINK-27989][table-planner] Csv format supports reporting statistics

2022-06-23 Thread GitBox
swuferhong commented on code in PR #20007: URL: https://github.com/apache/flink/pull/20007#discussion_r905696463 ## flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFileFormatFactory.java: ## @@ -136,6 +147,45 @@ public BulkFormat createRuntimeDecoder(

[jira] [Updated] (FLINK-28234) Infinite or NaN exception for power(-1, 0.5)

2022-06-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28234: --- Labels: pull-request-available (was: ) > Infinite or NaN exception for power(-1, 0.5) > --

[GitHub] [flink] luoyuxia opened a new pull request, #20062: [FLINK-28234][hive] fix Infinite or NaN exception in ExpressionReducer

2022-06-23 Thread GitBox
luoyuxia opened a new pull request, #20062: URL: https://github.com/apache/flink/pull/20062 ## What is the purpose of the change To fix the "Infinite or NaN exception" thrown by ExpressionReducer when the reduced value is `NaN`. ## Brief change log - When the redu

[GitHub] [flink] flinkbot commented on pull request #20062: [FLINK-28234][hive] fix Infinite or NaN exception in ExpressionReducer

2022-06-23 Thread GitBox
flinkbot commented on PR #20062: URL: https://github.com/apache/flink/pull/20062#issuecomment-1165165092 ## CI report: * 5c2c8c7d4f9dc77fb04d13b5a328985915451937 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] wanglijie95 commented on a diff in pull request #20039: [FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions

2022-06-23 Thread GitBox
wanglijie95 commented on code in PR #20039: URL: https://github.com/apache/flink/pull/20039#discussion_r905694491 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultExecutionDeployerTest.java: ## @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache Software Fou

[GitHub] [flink] luoyuxia commented on pull request #20062: [FLINK-28234][hive] fix Infinite or NaN exception in ExpressionReducer

2022-06-23 Thread GitBox
luoyuxia commented on PR #20062: URL: https://github.com/apache/flink/pull/20062#issuecomment-1165163685 @godfreyhe Could you please help review. -- 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] zhuzhurk commented on a diff in pull request #20039: [FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions

2022-06-23 Thread GitBox
zhuzhurk commented on code in PR #20039: URL: https://github.com/apache/flink/pull/20039#discussion_r905687352 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionDeployer.java: ## @@ -0,0 +1,77 @@ +/* + * Licensed to the Apache Software Foundation (ASF) u

[GitHub] [flink] zhuzhurk commented on a diff in pull request #20039: [FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions

2022-06-23 Thread GitBox
zhuzhurk commented on code in PR #20039: URL: https://github.com/apache/flink/pull/20039#discussion_r905687273 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionDeployer.java: ## @@ -0,0 +1,77 @@ +/* + * Licensed to the Apache Software Foundation (ASF) u

[GitHub] [flink] zhuzhurk commented on a diff in pull request #20039: [FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions

2022-06-23 Thread GitBox
zhuzhurk commented on code in PR #20039: URL: https://github.com/apache/flink/pull/20039#discussion_r905685825 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocator.java: ## @@ -94,6 +96,34 @@ class SlotSharingExecutionSlotAllocator

[GitHub] [flink] zhuzhurk commented on a diff in pull request #20039: [FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions

2022-06-23 Thread GitBox
zhuzhurk commented on code in PR #20039: URL: https://github.com/apache/flink/pull/20039#discussion_r905685423 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultExecutionDeployerTest.java: ## @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] [flink] zhuzhurk commented on a diff in pull request #20039: [FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions

2022-06-23 Thread GitBox
zhuzhurk commented on code in PR #20039: URL: https://github.com/apache/flink/pull/20039#discussion_r905684724 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultExecutionDeployerTest.java: ## @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] [flink] zhuzhurk commented on a diff in pull request #20039: [FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions

2022-06-23 Thread GitBox
zhuzhurk commented on code in PR #20039: URL: https://github.com/apache/flink/pull/20039#discussion_r905684231 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocator.java: ## @@ -117,8 +147,7 @@ class SlotSharingExecutionSlotAllocator

[GitHub] [flink] zhuzhurk commented on a diff in pull request #20039: [FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions

2022-06-23 Thread GitBox
zhuzhurk commented on code in PR #20039: URL: https://github.com/apache/flink/pull/20039#discussion_r905682843 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionDeployer.java: ## @@ -0,0 +1,386 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] zhuzhurk commented on a diff in pull request #20039: [FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions

2022-06-23 Thread GitBox
zhuzhurk commented on code in PR #20039: URL: https://github.com/apache/flink/pull/20039#discussion_r905682558 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionDeployer.java: ## @@ -0,0 +1,386 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] zhoulii commented on a diff in pull request #20059: [FLINK-28222][formats] Add sql modules for csv/json formats

2022-06-23 Thread GitBox
zhoulii commented on code in PR #20059: URL: https://github.com/apache/flink/pull/20059#discussion_r905681337 ## flink-formats/flink-sql-csv/pom.xml: ## @@ -0,0 +1,69 @@ + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; +

[jira] [Created] (FLINK-28237) Improve the flink-ml python examples in doc

2022-06-23 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28237: Summary: Improve the flink-ml python examples in doc Key: FLINK-28237 URL: https://issues.apache.org/jira/browse/FLINK-28237 Project: Flink Issue Type: Impro

[jira] [Closed] (FLINK-27343) flink jdbc sink will lead to unordered result, because the sink buffer records execute unorder

2022-06-23 Thread pengyusong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pengyusong closed FLINK-27343. -- Resolution: Not A Bug > flink jdbc sink will lead to unordered result, because the sink buffer > reco

[jira] [Updated] (FLINK-28236) managed memory  no  matter how much I configure, it will be exhausted

2022-06-23 Thread LCER (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LCER updated FLINK-28236: - Description: managed memory  no  matter how much I configure, it will be exhausted, resulting in taskmanager cr

[jira] [Updated] (FLINK-28236) managed memory  no  matter how much I configure, it will be exhausted

2022-06-23 Thread LCER (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LCER updated FLINK-28236: - Description: managed memory  no  matter how much I configure, it will be exhausted, resulting in taskmanager cr

[jira] [Updated] (FLINK-28236) managed memory  no  matter how much I configure, it will be exhausted

2022-06-23 Thread LCER (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LCER updated FLINK-28236: - Affects Version/s: 1.15.0 > managed memory  no  matter how much I configure, it will be exhausted >

[jira] [Created] (FLINK-28236) managed memory  no  matter how much I configure, it will be exhausted

2022-06-23 Thread LCER (Jira)
LCER created FLINK-28236: Summary: managed memory  no  matter how much I configure, it will be exhausted Key: FLINK-28236 URL: https://issues.apache.org/jira/browse/FLINK-28236 Project: Flink Issue

[jira] [Created] (FLINK-28235) Min aggregate function support type: ''ARRAY''.

2022-06-23 Thread tartarus (Jira)
tartarus created FLINK-28235: Summary: Min aggregate function support type: ''ARRAY''. Key: FLINK-28235 URL: https://issues.apache.org/jira/browse/FLINK-28235 Project: Flink Issue Type: Sub-task

[GitHub] [flink] liuzhuang2017 commented on pull request #19503: [FLINK-16078] [docs-zh] Translate "Tuning Checkpoints and Large State".

2022-06-23 Thread GitBox
liuzhuang2017 commented on PR #19503: URL: https://github.com/apache/flink/pull/19503#issuecomment-1165136538 @Myasuka , Sorry to bother you, can you help me review this pr? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-28234) Infinite or NaN exception for power(-1, 0.5)

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28234: - Description: When using the follwiing sql  , it will throw the "java.lang.NumberFormatException: Infini

[jira] [Updated] (FLINK-28234) Infinite or NaN exception for power(-1, 0.5)

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28234: - Description: When using the follwiing sql  , it will throw the "java.lang.NumberFormatException: Infini

[jira] [Commented] (FLINK-28234) Infinite or NaN exception for power(-1, 0.5)

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558298#comment-17558298 ] luoyuxia commented on FLINK-28234: -- I will fix it. > Infinite or NaN exception for po

[jira] [Updated] (FLINK-28234) Infinite or NaN exception for power(-1, 0.5)

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28234: - Description: When  > Infinite or NaN exception for power(-1, 0.5) > ---

[jira] [Commented] (FLINK-28231) Support Apache Ozone FileSystem

2022-06-23 Thread bianqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558297#comment-17558297 ] bianqi commented on FLINK-28231: this is debug log  {code:java} 2022-06-24 10:23:06,547

[jira] [Created] (FLINK-28234) Infinite or NaN exception for power(-1, 0.5)

2022-06-23 Thread luoyuxia (Jira)
luoyuxia created FLINK-28234: Summary: Infinite or NaN exception for power(-1, 0.5) Key: FLINK-28234 URL: https://issues.apache.org/jira/browse/FLINK-28234 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-28206) EOFException on Checkpoint Recovery

2022-06-23 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558290#comment-17558290 ] Yun Tang commented on FLINK-28206: -- [~chenya_zhang] I don't think your problem is the s

[GitHub] [flink] zuston commented on pull request #19675: [FLINK-27550] The method of checkYarnQueues is compatible with capacity scheduler

2022-06-23 Thread GitBox
zuston commented on PR #19675: URL: https://github.com/apache/flink/pull/19675#issuecomment-1165119101 Gentle ping again @wangyang0918 -- 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 specifi

[jira] (FLINK-28231) Support Apache Ozone FileSystem

2022-06-23 Thread bianqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28231 ] bianqi deleted comment on FLINK-28231: was (Author: bianqi): !mapreduce-webui.png! > Support Apache Ozone FileSystem > --- > > Key: FLINK-28231 >

[jira] [Comment Edited] (FLINK-28231) Support Apache Ozone FileSystem

2022-06-23 Thread bianqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558274#comment-17558274 ] bianqi edited comment on FLINK-28231 at 6/24/22 2:13 AM: - [~prab

[jira] [Comment Edited] (FLINK-28231) Support Apache Ozone FileSystem

2022-06-23 Thread bianqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558274#comment-17558274 ] bianqi edited comment on FLINK-28231 at 6/24/22 2:08 AM: - [~prab

[GitHub] [flink] liuzhuang2017 commented on pull request #20061: [hotfix][flink-rpc] Fix the RemoteRpcInvocation class typo.

2022-06-23 Thread GitBox
liuzhuang2017 commented on PR #20061: URL: https://github.com/apache/flink/pull/20061#issuecomment-1165107138 @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 comm

[GitHub] [flink-web] yangjf2019 commented on pull request #552: [hotfix][docs] Eliminate the redundant symbol '/' from the jump link url

2022-06-23 Thread GitBox
yangjf2019 commented on PR #552: URL: https://github.com/apache/flink-web/pull/552#issuecomment-1165101638 Hi @MartijnVisser ,Thanks for your review. You are right!There is not much additional value in this.But the dike of a thousand miles is collapsed by an ant hole!I'm just trying to fix

[GitHub] [flink] flinkbot commented on pull request #20061: [hotfix][flink-rpc] Fix the RemoteRpcInvocation class typo.

2022-06-23 Thread GitBox
flinkbot commented on PR #20061: URL: https://github.com/apache/flink/pull/20061#issuecomment-1165099640 ## CI report: * fa9aa1ac09fa0a627a6c7ba3387dae5b30e2a57e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 opened a new pull request, #20061: [hotfix][flink-rpc] Fix the RemoteRpcInvocation class typo.

2022-06-23 Thread GitBox
liuzhuang2017 opened a new pull request, #20061: URL: https://github.com/apache/flink/pull/20061 ## 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

[GitHub] [flink] alec-brooks closed pull request #15994: [hotfix] [docs] Fix typo in JDBC Execution Options Documentation

2022-06-23 Thread GitBox
alec-brooks closed pull request #15994: [hotfix] [docs] Fix typo in JDBC Execution Options Documentation URL: https://github.com/apache/flink/pull/15994 -- 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

[jira] [Commented] (FLINK-28231) Support Apache Ozone FileSystem

2022-06-23 Thread bianqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558275#comment-17558275 ] bianqi commented on FLINK-28231: !mapreduce-webui.png! > Support Apache Ozone FileSyste

[jira] [Updated] (FLINK-28231) Support Apache Ozone FileSystem

2022-06-23 Thread bianqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bianqi updated FLINK-28231: --- Attachment: mapreduce-webui.png > Support Apache Ozone FileSystem > --- > >

[jira] [Commented] (FLINK-28231) Support Apache Ozone FileSystem

2022-06-23 Thread bianqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558274#comment-17558274 ] bianqi commented on FLINK-28231: [~prabhujoseph]  thank you relpay. ozone om doesn't ha

[jira] [Updated] (FLINK-28231) Support Apache Ozone FileSystem

2022-06-23 Thread bianqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bianqi updated FLINK-28231: --- Attachment: abc.png > Support Apache Ozone FileSystem > --- > >

[jira] [Commented] (FLINK-28210) FlinkSessionJob fails after FlinkDeployment is updated

2022-06-23 Thread Daniel Crowe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558270#comment-17558270 ] Daniel Crowe commented on FLINK-28210: -- Thank you. I'll give it a go. > FlinkSessi

[GitHub] [flink] luoyuxia commented on pull request #20060: [FLINK-28212][hive] Trim the project node with window expressions to fix IndexOutOfBoundsException when using Hive dialect.

2022-06-23 Thread GitBox
luoyuxia commented on PR #20060: URL: https://github.com/apache/flink/pull/20060#issuecomment-1165015327 @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] [Assigned] (FLINK-28169) GlueSchemaRegistryJsonKinesisITCase fails on JDK11 due to NoSuchMethodError

2022-06-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-28169: -- Assignee: Ahmed Hamdy > GlueSchemaRegistryJsonKinesisITCase fails on JDK11 due to NoS

[jira] [Commented] (FLINK-28169) GlueSchemaRegistryJsonKinesisITCase fails on JDK11 due to NoSuchMethodError

2022-06-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558220#comment-17558220 ] Martijn Visser commented on FLINK-28169: Thanks [~chalixar] I've assigned it to

[jira] [Commented] (FLINK-27611) ConcurrentModificationException during Flink-Pulsar checkpoint notification

2022-06-23 Thread Jason Kania (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558211#comment-17558211 ] Jason Kania commented on FLINK-27611: - Is there a possibility of this getting into t

[jira] [Comment Edited] (FLINK-27933) Savepoint status cannot be queried from standby jobmanager

2022-06-23 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552776#comment-17552776 ] Chesnay Schepler edited comment on FLINK-27933 at 6/23/22 7:22 PM: ---

[jira] [Closed] (FLINK-27933) Savepoint status cannot be queried from standby jobmanager

2022-06-23 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27933. Resolution: Fixed > Savepoint status cannot be queried from standby jobmanager > -

[GitHub] [flink] zentol merged pull request #20022: [FLINK-27933][coordination] OperationResult is serializable

2022-06-23 Thread GitBox
zentol merged PR #20022: URL: https://github.com/apache/flink/pull/20022 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

[jira] [Commented] (FLINK-28169) GlueSchemaRegistryJsonKinesisITCase fails on JDK11 due to NoSuchMethodError

2022-06-23 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558203#comment-17558203 ] Ahmed Hamdy commented on FLINK-28169: - Hello [~martijnvisser] Can you assign the iss

[GitHub] [flink-kubernetes-operator] usamj opened a new pull request, #278: [FLINK-27443][FLINK-27444][FLINK-27445][FLINK-27446]

2022-06-23 Thread GitBox
usamj opened a new pull request, #278: URL: https://github.com/apache/flink-kubernetes-operator/pull/278 This is the initial MVP implementation of Standalone mode with only stateless upgrade mode currently supported. -- This is an automated message from the Apache Git Service. To respond

[jira] [Closed] (FLINK-28233) Successful observe doesn't clear errors due to patching

2022-06-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-28233. -- Resolution: Fixed merged to main 5e03a618b22ac8d77fe3e7886fd20be8ab518f75 > Successful observe doesn'

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #277: [FLINK-28233] Clear error status correctly for stable deployments

2022-06-23 Thread GitBox
gyfora merged PR #277: URL: https://github.com/apache/flink-kubernetes-operator/pull/277 -- 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

[jira] [Commented] (FLINK-28199) Failures on YARNHighAvailabilityITCase.testClusterClientRetrieval and YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint

2022-06-23 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558171#comment-17558171 ] Ferenc Csaky commented on FLINK-28199: -- I would say to keep it open for now, it is

[jira] [Closed] (FLINK-27912) Improve operator config names

2022-06-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-27912. -- Resolution: Fixed merged to main 794df5844b158aab0cbe8ef6d9a44277aba639c3 > Improve operator config n

[jira] [Updated] (FLINK-28233) Successful observe doesn't clear errors due to patching

2022-06-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28233: --- Labels: pull-request-available (was: ) > Successful observe doesn't clear errors due to pat

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #275: [FLINK-27912] Improve operator config names

2022-06-23 Thread GitBox
gyfora merged PR #275: URL: https://github.com/apache/flink-kubernetes-operator/pull/275 -- 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-kubernetes-operator] gyfora commented on pull request #277: [FLINK-28233] Clear error status correctly for stable deployments

2022-06-23 Thread GitBox
gyfora commented on PR #277: URL: https://github.com/apache/flink-kubernetes-operator/pull/277#issuecomment-1164658447 cc @tweise @morhidi -- 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-kubernetes-operator] gyfora opened a new pull request, #277: [FLINK-28233] Clear error status correctly for stable deployments

2022-06-23 Thread GitBox
gyfora opened a new pull request, #277: URL: https://github.com/apache/flink-kubernetes-operator/pull/277 We used to try clearing errors out by setting this `null` but due to how Status patching works, this basically means no update was made. This commit fixes this by setting to empty

[jira] [Updated] (FLINK-28225) Supports custom ENVs in the Helm chart

2022-06-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28225: --- Labels: pull-request-available (was: ) > Supports custom ENVs in the Helm chart > -

[GitHub] [flink-kubernetes-operator] mbalassi commented on pull request #276: [FLINK-28225] Add custom env supports in the Helm chart

2022-06-23 Thread GitBox
mbalassi commented on PR #276: URL: https://github.com/apache/flink-kubernetes-operator/pull/276#issuecomment-1164624452 Thanks, @haoxins. I will give it a try tomorrow. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-28231) Support Apache Ozone FileSystem

2022-06-23 Thread Prabhu Joseph (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558153#comment-17558153 ] Prabhu Joseph commented on FLINK-28231: --- [~bianqi] The client fails to invoke the

[GitHub] [flink-kubernetes-operator] czy006 commented on pull request #275: [FLINK-27912] Improve operator config names

2022-06-23 Thread GitBox
czy006 commented on PR #275: URL: https://github.com/apache/flink-kubernetes-operator/pull/275#issuecomment-1164596244 ok i've changed it all -- 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-training] alpinegizmo commented on pull request #49: My solutions

2022-06-23 Thread GitBox
alpinegizmo commented on PR #49: URL: https://github.com/apache/flink-training/pull/49#issuecomment-1164584499 @kkaravitis No worries. Happy to see someone was looking at the exercises, and thanks for closing the PR. -- This is an automated message from the Apache Git Service. To respond

[jira] [Created] (FLINK-28233) Successful observe doesn't clear errors due to patching

2022-06-23 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-28233: -- Summary: Successful observe doesn't clear errors due to patching Key: FLINK-28233 URL: https://issues.apache.org/jira/browse/FLINK-28233 Project: Flink Issue Typ

[GitHub] [flink] zentol commented on pull request #20022: [FLINK-27933][coordination] OperationResult is serializable

2022-06-23 Thread GitBox
zentol commented on PR #20022: URL: https://github.com/apache/flink/pull/20022#issuecomment-1164564569 @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. T

[jira] [Commented] (FLINK-27998) Upgrade Calcite version to 1.30

2022-06-23 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558125#comment-17558125 ] Sergey Nuyanzin commented on FLINK-27998: - Hi [~martijnvisser]  could you please

[jira] [Created] (FLINK-28232) Allow for custom pre-flight checks for SQL UDFs

2022-06-23 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-28232: -- Summary: Allow for custom pre-flight checks for SQL UDFs Key: FLINK-28232 URL: https://issues.apache.org/jira/browse/FLINK-28232 Project: Flink Issue Typ

[jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

2022-06-23 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558119#comment-17558119 ] Alexis Sarda-Espinosa commented on FLINK-16686: --- It seems I spoke to soon,

[jira] [Updated] (FLINK-28231) Support Apache Ozone FileSystem

2022-06-23 Thread bianqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bianqi updated FLINK-28231: --- Attachment: 微信图片_20220623224142.png > Support Apache Ozone FileSystem > --- > >

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #275: [FLINK-27912] Improve operator config names

2022-06-23 Thread GitBox
gyfora commented on PR #275: URL: https://github.com/apache/flink-kubernetes-operator/pull/275#issuecomment-1164496942 Please also update the config keys used in the helm chard default configuration yaml to be consistent with the new ones. -- This is an automated message from the Apache

[jira] [Updated] (FLINK-28231) Support Apache Ozone FileSystem

2022-06-23 Thread bianqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bianqi updated FLINK-28231: --- Description: After the ozone environment is currently configured, mapreduce tasks can be submitted to read

[jira] [Updated] (FLINK-28231) Support Ozone file system

2022-06-23 Thread bianqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bianqi updated FLINK-28231: --- Affects Version/s: 1.12.1 (was: 1.14.5) > Support Ozone file system > ---

[jira] [Updated] (FLINK-28231) Support Apache Ozone FileSystem

2022-06-23 Thread bianqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bianqi updated FLINK-28231: --- Summary: Support Apache Ozone FileSystem (was: Support Ozone file system) > Support Apache Ozone FileSystem

[jira] [Created] (FLINK-28231) Support Ozone file system

2022-06-23 Thread bianqi (Jira)
bianqi created FLINK-28231: -- Summary: Support Ozone file system Key: FLINK-28231 URL: https://issues.apache.org/jira/browse/FLINK-28231 Project: Flink Issue Type: New Feature Components: f

[jira] [Comment Edited] (FLINK-26891) Emit events for important Deployment / Job changes

2022-06-23 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558113#comment-17558113 ] Thomas Weise edited comment on FLINK-26891 at 6/23/22 2:33 PM: ---

  1   2   3   >