[jira] [Updated] (FLINK-29549) Add Aws Glue Catalog support in Flink

[ https://issues.apache.org/jira/browse/FLINK-29549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samrat Deb updated FLINK-29549: --- Labels: pull-request-available (was: ) > Add Aws Glue Catalog support in Flink >

[jira] [Assigned] (FLINK-32135) FRocksDB fix log file create failed caused by file name too long

[ https://issues.apache.org/jira/browse/FLINK-32135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-32135: Assignee: Feifan Wang > FRocksDB fix log file create failed caused by file name too long >

[jira] [Created] (FLINK-32137) Flame graph is hard to use with many task managers

Vladimir Matveev created FLINK-32137: Summary: Flame graph is hard to use with many task managers Key: FLINK-32137 URL: https://issues.apache.org/jira/browse/FLINK-32137 Project: Flink

[GitHub] [flink] pgaref commented on pull request #22608: [FLINK-31893][runtime] Introduce AdaptiveBatchScheduler failure enrichment/labeling

pgaref commented on PR #22608: URL: https://github.com/apache/flink/pull/22608#issuecomment-1555179837 @dmvk @zhuzhurk this is ready for review too :) Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot commented on pull request #22610: Revert "[FLINK-32123][e2e] Fix E2E kafka download timeout"

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

[jira] [Assigned] (FLINK-32007) Implement Python Wrappers for DynamoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-32007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-32007: - Assignee: Khanh Vu > Implement Python Wrappers for DynamoDB Connector >

[jira] [Updated] (FLINK-32136) Pyflink gateway server launch fails when purelib != platlib

[ https://issues.apache.org/jira/browse/FLINK-32136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] William Ashley updated FLINK-32136: --- Description: On distros where python's {{purelib}} is different than {{platlib}} (e.g.

[jira] [Updated] (FLINK-32136) Pyflink gateway server launch fails when purelib != platlib

[ https://issues.apache.org/jira/browse/FLINK-32136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] William Ashley updated FLINK-32136: --- Description: On distros where python's {{purelib}} is different than {{platlib}} (e.g.

[jira] [Created] (FLINK-32136) Pyflink gateway server launch fails when purelib != platlib

William Ashley created FLINK-32136: -- Summary: Pyflink gateway server launch fails when purelib != platlib Key: FLINK-32136 URL: https://issues.apache.org/jira/browse/FLINK-32136 Project: Flink

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #591: fix : enable operatorVolumeMounts mountPath repeat

gyfora commented on PR #591: URL: https://github.com/apache/flink-kubernetes-operator/pull/591#issuecomment-1554773076 Is there a JIRA ticket for this? If not can you please open one and rename the commit accordingly? -- This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-32111) Replacing cluster in failed state with a new one failed

[ https://issues.apache.org/jira/browse/FLINK-32111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32111. -- Fix Version/s: kubernetes-operator-1.6.0 Assignee: Tamir Sagi Resolution: Fixed

[jira] [Comment Edited] (FLINK-31743) Avoid relocating the RocksDB's log failure when filename exceeds 255 characters

[ https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724325#comment-17724325 ] Feifan Wang edited comment on FLINK-31743 at 5/19/23 3:41 PM: -- Thanks for

[jira] [Comment Edited] (FLINK-31743) Avoid relocating the RocksDB's log failure when filename exceeds 255 characters

[ https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724325#comment-17724325 ] Feifan Wang edited comment on FLINK-31743 at 5/19/23 3:40 PM: -- Thank for

[jira] [Commented] (FLINK-31743) Avoid relocating the RocksDB's log failure when filename exceeds 255 characters

[ https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724325#comment-17724325 ] Feifan Wang commented on FLINK-31743: - Thank for reminding, I created a new ticket, can you assign

[GitHub] [flink] RyanSkraba commented on a diff in pull request #18109: [FLINK-25284][Table SQL / API] Add proportion of null values to generate with datagen

RyanSkraba commented on code in PR #18109: URL: https://github.com/apache/flink/pull/18109#discussion_r1199094836 ## flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/types/RowDataGenerator.java: ## @@ -70,10 +74,13 @@ public boolean

[jira] [Created] (FLINK-32135) FRocksDB fix log file create failed caused by file name too long

Feifan Wang created FLINK-32135: --- Summary: FRocksDB fix log file create failed caused by file name too long Key: FLINK-32135 URL: https://issues.apache.org/jira/browse/FLINK-32135 Project: Flink

[jira] [Updated] (FLINK-32130) previous checkpoint will be broke by the subsequent incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-32130: Component/s: Runtime / Checkpointing > previous checkpoint will be broke by the subsequent

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #605: [FLINK-32134] Autoscaler min/max parallelism configs should respect current parallelism

gyfora opened a new pull request, #605: URL: https://github.com/apache/flink-kubernetes-operator/pull/605 ## What is the purpose of the change Currently the min/max parallelism configs for the autoscaler are handled strictly and they can potentially override the user defined current

[GitHub] [flink-kubernetes-operator] tchin25 opened a new pull request, #604: [FLINK-32041] - Allow operator to manage leases when using watchNamespaces

tchin25 opened a new pull request, #604: URL: https://github.com/apache/flink-kubernetes-operator/pull/604 ## What is the purpose of the change The operator doesn't have the ability to manage leases in its own namespace when using `watchNamespaces`. This fixes that by adding a `Role`

[jira] [Created] (FLINK-32134) Autoscaler min/max parallelism configs should respect the current job parallelism

Gyula Fora created FLINK-32134: -- Summary: Autoscaler min/max parallelism configs should respect the current job parallelism Key: FLINK-32134 URL: https://issues.apache.org/jira/browse/FLINK-32134

[jira] [Commented] (FLINK-32133) Batch requests and remove requests in the end to reduce YarnResourceManager's excess containers

[ https://issues.apache.org/jira/browse/FLINK-32133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724268#comment-17724268 ] Liu commented on FLINK-32133: - A related issue is https://issues.apache.org/jira/browse/FLINK-10848. >

[jira] [Created] (FLINK-32133) Batch requests and remove requests in the end to reduce YarnResourceManager's excess containers

Liu created FLINK-32133: --- Summary: Batch requests and remove requests in the end to reduce YarnResourceManager's excess containers Key: FLINK-32133 URL: https://issues.apache.org/jira/browse/FLINK-32133

[jira] [Commented] (FLINK-31743) Avoid relocating the RocksDB's log failure when filename exceeds 255 characters

[ https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724237#comment-17724237 ] Yun Tang commented on FLINK-31743: -- [~Feifan Wang] You can create another ticket to focus on the

[jira] [Closed] (FLINK-31687) Flink jdbc driver get rid of flink core

[ https://issues.apache.org/jira/browse/FLINK-31687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li closed FLINK-31687. -- Fix Version/s: 1.18.0 Assignee: Fang Yong Resolution: Fixed Fixed via

[GitHub] [flink] libenchao closed pull request #22533: [FLINK-31687][jdbc-driver] Get rid of flink-core for jdbc driver

libenchao closed pull request #22533: [FLINK-31687][jdbc-driver] Get rid of flink-core for jdbc driver URL: https://github.com/apache/flink/pull/22533 -- 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] [Updated] (FLINK-32132) Cast function CODEGEN does not work as expected when nullOnFailure enabled

[ https://issues.apache.org/jira/browse/FLINK-32132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-32132: -- Description: I am trying to generate code cast string to bigint, and got generated code like:

[jira] [Created] (FLINK-32132) Cast function CODEGEN does not work as expected when nullOnFailure enabled

xiaogang zhou created FLINK-32132: - Summary: Cast function CODEGEN does not work as expected when nullOnFailure enabled Key: FLINK-32132 URL: https://issues.apache.org/jira/browse/FLINK-32132

[jira] [Closed] (FLINK-30664) [Connector/Hive] cleanup hive/haoop package ambiguous package dependencies

[ https://issues.apache.org/jira/browse/FLINK-30664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia closed FLINK-30664. Resolution: Invalid Close it now as it's invalid to me. Feel free to open it if I make mistake. >

[jira] [Assigned] (FLINK-31575) Don't swap table-planner-loader and table-planner to use hive dialect

[ https://issues.apache.org/jira/browse/FLINK-31575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-31575: Assignee: luoyuxia > Don't swap table-planner-loader and table-planner to use hive dialect >

[jira] [Assigned] (FLINK-30660) move SQLClientHiveITCase and TestHiveCatalogFactory to flink-connector-hive e2e

[ https://issues.apache.org/jira/browse/FLINK-30660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-30660: Assignee: luoyuxia > move SQLClientHiveITCase and TestHiveCatalogFactory to flink-connector-hive

[GitHub] [flink] fsk119 commented on a diff in pull request #22599: [FLINK-31967][table-runner] Solving the Initial Value Problem of LagA…

fsk119 commented on code in PR #22599: URL: https://github.com/apache/flink/pull/22599#discussion_r1198686686 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/LagAggFunction.java: ## @@ -44,6 +44,11 @@ public

[GitHub] [flink] Zakelly commented on a diff in pull request #22590: [FLINK-32071] Implement the snapshot manager for merged checkpoint files in TM

Zakelly commented on code in PR #22590: URL: https://github.com/apache/flink/pull/22590#discussion_r1198715572 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/merging/FileMergingSnapshotManagerTest.java: ## @@ -0,0 +1,288 @@ +/* + * Licensed to the Apache

[jira] [Updated] (FLINK-31519) The watermark alignment docs is outdated after FLIP-217 finished

[ https://issues.apache.org/jira/browse/FLINK-31519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31519: --- Fix Version/s: 1.17.2 (was: 1.17.1) > The watermark alignment docs is

[jira] [Updated] (FLINK-31863) Add 'Hostname' enum val to k8s NodeAddress type.

[ https://issues.apache.org/jira/browse/FLINK-31863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31863: --- Fix Version/s: 1.17.2 (was: 1.17.1) > Add 'Hostname' enum val to k8s

[jira] [Updated] (FLINK-31601) While waiting for resources, resources check might be scheduled unlimited number of times (Adaptive Scheduler)

[ https://issues.apache.org/jira/browse/FLINK-31601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31601: --- Fix Version/s: 1.17.2 (was: 1.17.1) > While waiting for resources, resources

[jira] [Commented] (FLINK-31890) Introduce DefaultScheduler failure enrichment/labeling

[ https://issues.apache.org/jira/browse/FLINK-31890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724182#comment-17724182 ] David Morávek commented on FLINK-31890: --- master: a9383fd4d51b1161292628145e2f427f574a07d4 >

[jira] [Updated] (FLINK-31511) Translate documentation sql_functions_zh.yml to the latest version

[ https://issues.apache.org/jira/browse/FLINK-31511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31511: --- Fix Version/s: 1.17.2 (was: 1.17.1) > Translate documentation

[jira] [Updated] (FLINK-31875) OSS throwns NoClassDefFoundError due to old hadoop-common version

[ https://issues.apache.org/jira/browse/FLINK-31875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31875: --- Fix Version/s: 1.17.2 (was: 1.17.1) > OSS throwns NoClassDefFoundError due

[jira] [Resolved] (FLINK-31890) Introduce DefaultScheduler failure enrichment/labeling

[ https://issues.apache.org/jira/browse/FLINK-31890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-31890. --- Fix Version/s: 1.18.0 Resolution: Fixed > Introduce DefaultScheduler failure

[jira] [Updated] (FLINK-31335) using sql-gateway to submit job to yarn cluster, sql-gateway don't support kerberos

[ https://issues.apache.org/jira/browse/FLINK-31335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31335: --- Fix Version/s: 1.17.2 (was: 1.17.1) > using sql-gateway to submit job to

[jira] [Resolved] (FLINK-32001) SupportsRowLevelUpdate does not support returning only a part of the columns.

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

[GitHub] [flink-web] TanYuxin-tyx commented on a diff in pull request #649: Add Flink 1.16.2

TanYuxin-tyx commented on code in PR #649: URL: https://github.com/apache/flink-web/pull/649#discussion_r1198669733 ## docs/content/posts/2023-05-19-release-1.16.2.md: ## @@ -0,0 +1,215 @@ +--- +title: "Apache Flink 1.16.2 Release Announcement" +date:

[GitHub] [flink-web] TanYuxin-tyx commented on a diff in pull request #649: Add Flink 1.16.2

TanYuxin-tyx commented on code in PR #649: URL: https://github.com/apache/flink-web/pull/649#discussion_r1198669172 ## docs/content/posts/2023-05-19-release-1.16.2.md: ## @@ -0,0 +1,215 @@ +--- +title: "Apache Flink 1.16.2 Release Announcement" +date:

[jira] [Assigned] (FLINK-32001) SupportsRowLevelUpdate does not support returning only a part of the columns.

[ https://issues.apache.org/jira/browse/FLINK-32001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-32001: -- Assignee: Yuxia Luo > SupportsRowLevelUpdate does not support returning only a part of the

[jira] [Updated] (FLINK-32001) SupportsRowLevelUpdate does not support returning only a part of the columns.

[ https://issues.apache.org/jira/browse/FLINK-32001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32001: --- Fix Version/s: 1.18.0 1.17.1 > SupportsRowLevelUpdate does not support returning

[jira] [Assigned] (FLINK-32001) SupportsRowLevelUpdate does not support returning only a part of the columns.

[ https://issues.apache.org/jira/browse/FLINK-32001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-32001: -- Assignee: luoyuxia (was: Yuxia Luo) > SupportsRowLevelUpdate does not support returning

[jira] [Commented] (FLINK-30559) May get wrong result for `if` expression if it's string data type

[ https://issues.apache.org/jira/browse/FLINK-30559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724179#comment-17724179 ] Yun Tang commented on FLINK-30559: -- [~luoyuxia] This bug has been reported by many guys, can we make it

[GitHub] [flink] reswqa merged pull request #22600: [FLINK-32001][table] Row-level update should support returning partia…

reswqa merged PR #22600: URL: https://github.com/apache/flink/pull/22600 -- 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:

[jira] [Commented] (FLINK-30018) NPE error in generated StreamExecCalc

[ https://issues.apache.org/jira/browse/FLINK-30018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724178#comment-17724178 ] Yun Tang commented on FLINK-30018: -- I think this problem is the same as FLINK-30559. > NPE error in

[jira] [Commented] (FLINK-32112) Fix the deprecated state backend sample config in Chinese document

[ https://issues.apache.org/jira/browse/FLINK-32112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724176#comment-17724176 ] Weijie Guo commented on FLINK-32112: [~xmzhou] Please note that fix typo like this does not require

[jira] [Resolved] (FLINK-32112) Fix the deprecated state backend sample config in Chinese document

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

[jira] [Updated] (FLINK-32112) Fix the deprecated state backend sample config in Chinese document

[ https://issues.apache.org/jira/browse/FLINK-32112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32112: --- Fix Version/s: 1.18.0 1.17.1 > Fix the deprecated state backend sample config

[jira] [Assigned] (FLINK-32112) Fix the deprecated state backend sample config in Chinese document

[ https://issues.apache.org/jira/browse/FLINK-32112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-32112: -- Assignee: Xianming Zhou > Fix the deprecated state backend sample config in Chinese

[GitHub] [flink] WencongLiu commented on pull request #22341: [FLINK-27204] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

WencongLiu commented on PR #22341: URL: https://github.com/apache/flink/pull/22341#issuecomment-1554191565 @XComp I have made a round of changes. Please take a look at it when you have time.  -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] reswqa commented on pull request #22596: [FLINK-32112][docs] Fix the deprecated state backend sample config in Chinese document

reswqa commented on PR #22596: URL: https://github.com/apache/flink/pull/22596#issuecomment-1554190771 Merged in ab5af143. -- 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.

[GitHub] [flink] reswqa merged pull request #22605: [FLINK-32112][docs] Fix the deprecated state backend sample config in Chinese document

reswqa merged PR #22605: URL: https://github.com/apache/flink/pull/22605 -- 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 #22609: [FLINK-32129][fs-connector] Use string array in PartitionCommitInfo

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

[GitHub] [flink] FangYongs commented on pull request #22609: [FLINK-32129][fs-connector] Use string array in PartitionCommitInfo

FangYongs commented on PR #22609: URL: https://github.com/apache/flink/pull/22609#issuecomment-1554170886 Hi @libenchao Please help to review this PR when you are free, thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] Zakelly commented on a diff in pull request #22590: [FLINK-32071] Implement the snapshot manager for merged checkpoint files in TM

Zakelly commented on code in PR #22590: URL: https://github.com/apache/flink/pull/22590#discussion_r1198642459 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/merging/FileMergingCheckpointUtils.java: ## @@ -0,0 +1,87 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] FangYongs opened a new pull request, #22609: [FLINK-32129][fs-connector] Use string array in PartitionCommitInfo

FangYongs opened a new pull request, #22609: URL: https://github.com/apache/flink/pull/22609 ## What is the purpose of the change Use string array in PartitionCommitInfo to support `pipeline.generic-types` ## Brief change log - Use string array instead of string list

[GitHub] [flink] luoyuxia merged pull request #22525: [FLINK-32001][table] Row-level update should support returning partial columns

luoyuxia merged PR #22525: URL: https://github.com/apache/flink/pull/22525 -- 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] fredia commented on a diff in pull request #22590: [FLINK-32071] Implement the snapshot manager for merged checkpoint files in TM

fredia commented on code in PR #22590: URL: https://github.com/apache/flink/pull/22590#discussion_r1198501534 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/merging/FileMergingSnapshotManagerTest.java: ## @@ -0,0 +1,288 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-29542) Unload.md wrongly writes UNLOAD operation as LOAD operation

[ https://issues.apache.org/jira/browse/FLINK-29542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724156#comment-17724156 ] Lijie Wang commented on FLINK-29542: Fixed via master: 522fac5c1d0429621be5cac2d83b1e9ff8da106e

[jira] [Closed] (FLINK-29542) Unload.md wrongly writes UNLOAD operation as LOAD operation

[ https://issues.apache.org/jira/browse/FLINK-29542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang closed FLINK-29542. -- Fix Version/s: 1.18.0 1.17.1 1.16.3 Resolution: Fixed >

[GitHub] [flink] flinkbot commented on pull request #22608: [FLINK-31893][runtime] Introduce AdaptiveBatchScheduler failure enrichment/labeling

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

[GitHub] [flink] flinkbot commented on pull request #22607: [FLINK-32131][python] Support specifying hadoop config directory for HiveCatalog

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

[GitHub] [flink] pgaref opened a new pull request, #22608: [FLINK-31893][runtime] Introduce AdaptiveBatchScheduler failure enrichment/labeling

pgaref opened a new pull request, #22608: URL: https://github.com/apache/flink/pull/22608 https://issues.apache.org/jira/browse/FLINK-31893 * Label failures part of AdaptiveBatchScheduler#initializeVerticesIfPossible replacing failJob call with handleGlobalFailure on a unrecoverable

[GitHub] [flink] dianfu opened a new pull request, #22607: [FLINK-32131][python] Support specifying hadoop config directory for HiveCatalog

dianfu opened a new pull request, #22607: URL: https://github.com/apache/flink/pull/22607 … ## 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

[jira] [Closed] (FLINK-32103) RBAC flinkdeployments/finalizers missing for OpenShift Deployment

[ https://issues.apache.org/jira/browse/FLINK-32103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32103. -- Fix Version/s: kubernetes-operator-1.6.0 Assignee: James Busche Resolution: Fixed

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #600: FLINK-32103 Update RBAC for OpenShift Deployment

gyfora merged PR #600: URL: https://github.com/apache/flink-kubernetes-operator/pull/600 -- 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 merged pull request #20986: [hotfix][docs] Change LOAD to UNLOAD in Unload.md

wanglijie95 merged PR #20986: URL: https://github.com/apache/flink/pull/20986 -- 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: