[jira] [Commented] (FLINK-32244) flink-master-benchmarks-regression-check always fails since 2023.05.30

2023-06-01 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728565#comment-17728565 ] Lijie Wang commented on FLINK-32244: cc [~Yanfei Lei] > flink-master-benchmarks-regression-check

[jira] [Assigned] (FLINK-32244) flink-master-benchmarks-regression-check always fails since 2023.05.30

2023-06-01 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-32244: -- Assignee: Yanfei Lei > flink-master-benchmarks-regression-check always fails since

[GitHub] [flink] bvarghese1 commented on a diff in pull request #22629: [FLINK-31664][table] Add ARRAY_INTERSECT function

2023-06-01 Thread via GitHub
bvarghese1 commented on code in PR #22629: URL: https://github.com/apache/flink/pull/22629#discussion_r1213906988 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayIntersectFunction.java: ## @@ -0,0 +1,127 @@ +/* + * Licensed

[GitHub] [flink-connector-jdbc] WenDing-Y commented on pull request #49: [FLINK-32068] connector jdbc support clickhouse

2023-06-01 Thread via GitHub
WenDing-Y commented on PR #49: URL: https://github.com/apache/flink-connector-jdbc/pull/49#issuecomment-1573107357 What other tasks are needed for this PR to merge -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] zoltar9264 commented on a diff in pull request #22669: [FLINK-29913] fix shared state be discarded by mistake when maxConcurrentCheckpoint>1

2023-06-01 Thread via GitHub
zoltar9264 commented on code in PR #22669: URL: https://github.com/apache/flink/pull/22669#discussion_r1213882810 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksDBSnapshotStrategyBase.java: ## @@ -395,18

[GitHub] [flink] zoltar9264 commented on a diff in pull request #22669: [FLINK-29913] fix shared state be discarded by mistake when maxConcurrentCheckpoint>1

2023-06-01 Thread via GitHub
zoltar9264 commented on code in PR #22669: URL: https://github.com/apache/flink/pull/22669#discussion_r1213882810 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksDBSnapshotStrategyBase.java: ## @@ -395,18

[jira] [Commented] (FLINK-32227) Optimize code styles

2023-06-01 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728548#comment-17728548 ] Hangxiang Yu commented on FLINK-32227: -- Hi, [~zhihao song] Could you add more description about it?

[jira] [Commented] (FLINK-32244) flink-master-benchmarks-regression-check always fails since 2023.05.30

2023-06-01 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728541#comment-17728541 ] Lijie Wang commented on FLINK-32244: {code:java} [2023-06-01T11:38:20.703Z] Traceback (most recent

[jira] [Updated] (FLINK-32219) SQL client hangs when executing EXECUTE PLAN

2023-06-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-32219: Component/s: Table SQL / Client > SQL client hangs when executing EXECUTE PLAN >

[jira] [Commented] (FLINK-32241) UnsupportedFileSystemException when using the ABFS Hadoop driver for checkpointing in Flink 1.17

2023-06-01 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728537#comment-17728537 ] luoyuxia commented on FLINK-32241: -- Seems the root cause is similar to FLINK-30635? >

[GitHub] [flink] luoyuxia commented on a diff in pull request #21927: [FLINK-30966][table-planner] Optimize type inference for Character type and fix result type casting in IfCallGen

2023-06-01 Thread via GitHub
luoyuxia commented on code in PR #21927: URL: https://github.com/apache/flink/pull/21927#discussion_r1213054174 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/CalcITCase.scala: ## @@ -366,6 +366,50 @@ class CalcITCase extends

[jira] [Assigned] (FLINK-32245) NonDeterministicTests #testTemporalFunctionsInBatchMode failure masked due to incorrect test initialization

2023-06-01 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-32245: --- Assignee: Jane Chan > NonDeterministicTests #testTemporalFunctionsInBatchMode failure

[jira] [Updated] (FLINK-32245) NonDeterministicTests #testTemporalFunctionsInBatchMode failure masked due to incorrect test initialization

2023-06-01 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-32245: -- Description: After introducing FLINK-30006, the test case NonDeterministicTests

[jira] [Updated] (FLINK-32245) NonDeterministicTests #testTemporalFunctionsInBatchMode failure masked due to incorrect test initialization

2023-06-01 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-32245: -- Description: The test case NonDeterministicTests #testTemporalFunctionsInBatchMode has been

[jira] [Created] (FLINK-32245) NonDeterministicTests #testTemporalFunctionsInBatchMode failure masked due to incorrect test initialization

2023-06-01 Thread Jane Chan (Jira)
Jane Chan created FLINK-32245: - Summary: NonDeterministicTests #testTemporalFunctionsInBatchMode failure masked due to incorrect test initialization Key: FLINK-32245 URL:

[GitHub] [flink] jiaoqingbo commented on pull request #22694: [FLINK-32223][runtime][security] Add Hive delegation token support

2023-06-01 Thread via GitHub
jiaoqingbo commented on PR #22694: URL: https://github.com/apache/flink/pull/22694#issuecomment-1573036547 > Is there an ETA to have an external Hive connector? +1 on having this in the connector module. I also found this problem yesterday, I am moving this part of code to hive

[jira] [Created] (FLINK-32244) flink-master-benchmarks-regression-check always fails since 2023.05.30

2023-06-01 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-32244: -- Summary: flink-master-benchmarks-regression-check always fails since 2023.05.30 Key: FLINK-32244 URL: https://issues.apache.org/jira/browse/FLINK-32244 Project: Flink

[GitHub] [flink] jiaoqingbo commented on a diff in pull request #22694: [FLINK-32223][runtime][security] Add Hive delegation token support

2023-06-01 Thread via GitHub
jiaoqingbo commented on code in PR #22694: URL: https://github.com/apache/flink/pull/22694#discussion_r1213844896 ## flink-runtime/src/main/java/org/apache/flink/runtime/security/token/hadoop/HiveDelegationTokenProvider.java: ## @@ -0,0 +1,177 @@ +/* + * Licensed to the Apache

[jira] [Created] (FLINK-32243) Bump okhttp version to 4.11.0

2023-06-01 Thread ConradJam (Jira)
ConradJam created FLINK-32243: - Summary: Bump okhttp version to 4.11.0 Key: FLINK-32243 URL: https://issues.apache.org/jira/browse/FLINK-32243 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on pull request #22700: [DO NOT MERGE] [WIP] Remove all Kafka connector code from main repo

2023-06-01 Thread via GitHub
flinkbot commented on PR #22700: URL: https://github.com/apache/flink/pull/22700#issuecomment-1572875068 ## CI report: * 342a89176bdf5d3650629bfc4e401641c9ba65ef UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] tzulitai opened a new pull request, #22700: [DO NOT MERGE] [WIP] Remove all Kafka connector code from main repo

2023-06-01 Thread via GitHub
tzulitai opened a new pull request, #22700: URL: https://github.com/apache/flink/pull/22700 This is WIP, DO NOT MERGE! -- 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

[jira] [Updated] (FLINK-31747) Externalize debezium from flink-json

2023-06-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31747: --- Labels: pull-request-available (was: ) > Externalize debezium from flink-json >

[GitHub] [flink-connector-kafka] tzulitai commented on pull request #31: [FLINK-31747] Remove Confluent Avro formats from externalized Kafka connector repo

2023-06-01 Thread via GitHub
tzulitai commented on PR #31: URL: https://github.com/apache/flink-connector-kafka/pull/31#issuecomment-1572721547 cc @mas-chen @twalthr for 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

[GitHub] [flink-connector-kafka] tzulitai opened a new pull request, #31: [FLINK-31747] Remove Confluent Avro formats from externalized Kafka connector repo

2023-06-01 Thread via GitHub
tzulitai opened a new pull request, #31: URL: https://github.com/apache/flink-connector-kafka/pull/31 This PR removes again the Confluent Avro related formats from the externalized Kafka connector repo. This was a result of a discussion with @twalthr. The formats will remain in the

[jira] [Closed] (FLINK-25162) Flink : Connectors : Hive fails with VectorizedRowBatch not found

2023-06-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25162. Resolution: Fixed master: 686bc00fd48f09b35a81a1588a2f2bc094f47c40 > Flink : Connectors

[GitHub] [flink] zentol merged pull request #22699: [FLINK-25162][hive] Fix Java 17 compile issue

2023-06-01 Thread via GitHub
zentol merged PR #22699: URL: https://github.com/apache/flink/pull/22699 -- 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-32230) Deadlock in AWS Kinesis Data Streams AsyncSink connector

2023-06-01 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728452#comment-17728452 ] Ahmed Hamdy commented on FLINK-32230: - Hi [~antoniovespoli] thanks for reporting the issue. I will

[jira] [Closed] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

2023-06-01 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31974. -- Fix Version/s: 1.18.0 1.17.2 Resolution: Fixed > JobManager crashes after

[jira] [Comment Edited] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

2023-06-01 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728363#comment-17728363 ] Weijie Guo edited comment on FLINK-31974 at 6/1/23 6:12 PM: master(1.18) via

[GitHub] [flink] reswqa merged pull request #22698: [BP-1.17][FLINK-31974] Do not crash jobmanager on Kubernetes clien…

2023-06-01 Thread via GitHub
reswqa merged PR #22698: URL: https://github.com/apache/flink/pull/22698 -- 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] pgaref commented on pull request #22643: [FLINK-31894][runtime] ExceptionHistory and REST API failure label integration

2023-06-01 Thread via GitHub
pgaref commented on PR #22643: URL: https://github.com/apache/flink/pull/22643#issuecomment-157247 >  good job; let's just get rid of the separate FailureLabel class as discussed offline Thanks much @dmvk ! Updated :) -- This is an automated message from the Apache Git

[jira] [Updated] (FLINK-32242) Datadog HTTP Reporter produces a huge outgoing traffic and CPU overhead

2023-06-01 Thread Mathieu DESPRIEE (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mathieu DESPRIEE updated FLINK-32242: - Description: We're running a relatively small flink cluster (7 task-managers, 8 cores)

[jira] [Updated] (FLINK-32242) Datadog HTTP Reporter produces a huge outgoing traffic and CPU overhead

2023-06-01 Thread Mathieu DESPRIEE (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mathieu DESPRIEE updated FLINK-32242: - Description: We're running a relatively small flink cluster (7 task-managers * 8 cores)

[jira] [Commented] (FLINK-32242) Datadog HTTP Reporter produces a huge outgoing traffic and CPU overhead

2023-06-01 Thread Yaroslav Tkachenko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728421#comment-17728421 ] Yaroslav Tkachenko commented on FLINK-32242: This is not surprising. I've already tried to

[jira] [Updated] (FLINK-32242) Datadog HTTP Reporter produces a huge outgoing traffic and CPU overhead

2023-06-01 Thread Mathieu DESPRIEE (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mathieu DESPRIEE updated FLINK-32242: - Attachment: (was: image-2023-06-01-17-42-56-305.png) > Datadog HTTP Reporter

[jira] [Updated] (FLINK-32242) Datadog HTTP Reporter produces a huge outgoing traffic and CPU overhead

2023-06-01 Thread Mathieu DESPRIEE (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mathieu DESPRIEE updated FLINK-32242: - Description: We're running a relatively small flink cluster (7 task-managers, 8 cores)

[jira] [Created] (FLINK-32242) Datadog HTTP Reporter produces a huge outgoing traffic and CPU overhead

2023-06-01 Thread Mathieu DESPRIEE (Jira)
Mathieu DESPRIEE created FLINK-32242: Summary: Datadog HTTP Reporter produces a huge outgoing traffic and CPU overhead Key: FLINK-32242 URL: https://issues.apache.org/jira/browse/FLINK-32242

[GitHub] [flink] twalthr commented on a diff in pull request #22558: [FLINK-28744][table] Upgrade Calcite to 1.31.0

2023-06-01 Thread via GitHub
twalthr commented on code in PR #22558: URL: https://github.com/apache/flink/pull/22558#discussion_r1213151859 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CastFunctionITCase.java: ## @@ -1132,22 +1132,14 @@ private static List

[GitHub] [flink] Ivan0626 closed pull request #14344: [docs] fix typos in Basic Concepts documentation

2023-06-01 Thread via GitHub
Ivan0626 closed pull request #14344: [docs] fix typos in Basic Concepts documentation URL: https://github.com/apache/flink/pull/14344 -- 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

[jira] [Commented] (FLINK-32241) UnsupportedFileSystemException when using the ABFS Hadoop driver for checkpointing in Flink 1.17

2023-06-01 Thread Steve Loughran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728393#comment-17728393 ] Steve Loughran commented on FLINK-32241: this is odd as the buffer to disk code is derived from

[GitHub] [flink] flinkbot commented on pull request #22699: [FLINK-25162][hive] Fix Java 17 compile issue

2023-06-01 Thread via GitHub
flinkbot commented on PR #22699: URL: https://github.com/apache/flink/pull/22699#issuecomment-1572215204 ## CI report: * a2c761c6a1253f214468ba1a0a2feb5e122b1a15 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-25162) Flink : Connectors : Hive fails with VectorizedRowBatch not found

2023-06-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25162: --- Labels: pull-request-available (was: ) > Flink : Connectors : Hive fails with

[jira] [Updated] (FLINK-25162) Flink : Connectors : Hive fails with VectorizedRowBatch not found

2023-06-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25162: - Fix Version/s: 1.18.0 > Flink : Connectors : Hive fails with VectorizedRowBatch not

[GitHub] [flink] zentol opened a new pull request, #22699: [FLINK-25162][hive] Fix Java 17 compile issue

2023-06-01 Thread via GitHub
zentol opened a new pull request, #22699: URL: https://github.com/apache/flink/pull/22699 Witness! The strangest Java 17 fix to date! Java 17 apparently does more things with the signatures of called methods, requiring compile-time access to all returned types. Since orc-nohive isn't

[jira] [Commented] (FLINK-25162) Flink : Connectors : Hive fails with VectorizedRowBatch not found

2023-06-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728388#comment-17728388 ] Chesnay Schepler commented on FLINK-25162: -- It seems that Java 17 requires it because, while

[jira] [Assigned] (FLINK-25162) Flink : Connectors : Hive fails with VectorizedRowBatch not found

2023-06-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-25162: Assignee: Chesnay Schepler > Flink : Connectors : Hive fails with

[GitHub] [flink-kubernetes-operator] ottomata commented on pull request #604: [FLINK-32041] - Allow operator to manage leases when using watchNamespaces

2023-06-01 Thread via GitHub
ottomata commented on PR #604: URL: https://github.com/apache/flink-kubernetes-operator/pull/604#issuecomment-1572161935 Thanks @gyfora ! QQ: how long do you think it will take for this to make it into a release? I ask just for our own 'fork'. We'd prefer to apply these changes

[jira] [Commented] (FLINK-25162) Flink : Connectors : Hive fails with VectorizedRowBatch not found

2023-06-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728383#comment-17728383 ] Chesnay Schepler commented on FLINK-25162: -- The weird thing is that it _should_ fail. The class

[GitHub] [flink] gaborgsomogyi commented on pull request #22694: [FLINK-32223][runtime][security] Add Hive delegation token support

2023-06-01 Thread via GitHub
gaborgsomogyi commented on PR #22694: URL: https://github.com/apache/flink/pull/22694#issuecomment-1572081353 Is there an ETA to have an external Hive connector? +1 on having this in the connector module. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] pvary commented on a diff in pull request #22694: [FLINK-32223][runtime][security] Add Hive delegation token support

2023-06-01 Thread via GitHub
pvary commented on code in PR #22694: URL: https://github.com/apache/flink/pull/22694#discussion_r1213177848 ## flink-runtime/src/main/java/org/apache/flink/runtime/security/token/hadoop/HiveDelegationTokenProvider.java: ## @@ -0,0 +1,177 @@ +/* + * Licensed to the Apache

[GitHub] [flink] pvary commented on a diff in pull request #22694: [FLINK-32223][runtime][security] Add Hive delegation token support

2023-06-01 Thread via GitHub
pvary commented on code in PR #22694: URL: https://github.com/apache/flink/pull/22694#discussion_r1213175818 ## flink-runtime/src/main/java/org/apache/flink/runtime/security/token/hadoop/HiveDelegationTokenProvider.java: ## @@ -0,0 +1,177 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-31856) Add support for Opensearch Connector REST client customization

2023-06-01 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728371#comment-17728371 ] Andriy Redko commented on FLINK-31856: -- [~mhjtrifork] we have a pull request opened, mind give it a

[jira] [Commented] (FLINK-32237) add jackson-module-kotlin to Jackson packages that get shaded

2023-06-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728369#comment-17728369 ] Martijn Visser commented on FLINK-32237: You should use shaded if you're building something in

[jira] [Created] (FLINK-32241) UnsupportedFileSystemException when using the ABFS Hadoop driver for checkpointing in Flink 1.17

2023-06-01 Thread Anton Ippolitov (Jira)
Anton Ippolitov created FLINK-32241: --- Summary: UnsupportedFileSystemException when using the ABFS Hadoop driver for checkpointing in Flink 1.17 Key: FLINK-32241 URL:

[GitHub] [flink] reswqa commented on pull request #22698: [BP-1.17][FLINK-31974] Do not crash jobmanager on Kubernetes clien…

2023-06-01 Thread via GitHub
reswqa commented on PR #22698: URL: https://github.com/apache/flink/pull/22698#issuecomment-1572058319 I made a small change to the testing assertions. Because `FlinkFutureAssertion` was not introduced on branch 1.17. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot commented on pull request #22698: [FLINK-31974][kubernetes] Do not crash jobmanager on Kubernetes clien…

2023-06-01 Thread via GitHub
flinkbot commented on PR #22698: URL: https://github.com/apache/flink/pull/22698#issuecomment-1572049730 ## CI report: * a5ee085c25e4703783a4ee30f80cd4938730b7d4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

2023-06-01 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728363#comment-17728363 ] Weijie Guo commented on FLINK-31974: master(1.18) via 3b9f7cf8ffcd357f252f62dee62d26dbc6a76e91.

[jira] [Closed] (FLINK-32237) add jackson-module-kotlin to Jackson packages that get shaded

2023-06-01 Thread Samael Bate (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samael Bate closed FLINK-32237. --- Resolution: Not A Problem > add jackson-module-kotlin to Jackson packages that get shaded >

[GitHub] [flink] reswqa opened a new pull request, #22698: [FLINK-31974][kubernetes] Do not crash jobmanager on Kubernetes clien…

2023-06-01 Thread via GitHub
reswqa opened a new pull request, #22698: URL: https://github.com/apache/flink/pull/22698 Backport FLINK-31974 to release-1.17 branch. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Commented] (FLINK-32237) add jackson-module-kotlin to Jackson packages that get shaded

2023-06-01 Thread Samael Bate (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728362#comment-17728362 ] Samael Bate commented on FLINK-32237: - I was under the impression that users should make use of the

[GitHub] [flink] reswqa merged pull request #22693: [FLINK-31974] Do not crash jobmanager on Kubernetes client errors

2023-06-01 Thread via GitHub
reswqa merged PR #22693: URL: https://github.com/apache/flink/pull/22693 -- 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] [Created] (FLINK-32240) Update Flink client to 1.17.1

2023-06-01 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-32240: -- Summary: Update Flink client to 1.17.1 Key: FLINK-32240 URL: https://issues.apache.org/jira/browse/FLINK-32240 Project: Flink Issue Type: Improvement

[GitHub] [flink] mbalassi merged pull request #22508: trivial word dedup

2023-06-01 Thread via GitHub
mbalassi merged PR #22508: URL: https://github.com/apache/flink/pull/22508 -- 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] [Created] (FLINK-32239) Unify TestJvmProcess and TestProcessBuilder

2023-06-01 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-32239: Summary: Unify TestJvmProcess and TestProcessBuilder Key: FLINK-32239 URL: https://issues.apache.org/jira/browse/FLINK-32239 Project: Flink Issue

[jira] [Updated] (FLINK-32239) Unify TestJvmProcess and TestProcessBuilder

2023-06-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-32239: - Priority: Minor (was: Major) > Unify TestJvmProcess and TestProcessBuilder >

[jira] [Updated] (FLINK-32239) Unify TestJvmProcess and TestProcessBuilder

2023-06-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-32239: - Labels: starter (was: ) > Unify TestJvmProcess and TestProcessBuilder >

[jira] [Assigned] (FLINK-21883) Introduce cooldown period into adaptive scheduler

2023-06-01 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot reassigned FLINK-21883: Assignee: Etienne Chauchot > Introduce cooldown period into adaptive scheduler >

[GitHub] [flink] flinkbot commented on pull request #22697: [FLINK-32238][ci] Stable libssl download

2023-06-01 Thread via GitHub
flinkbot commented on PR #22697: URL: https://github.com/apache/flink/pull/22697#issuecomment-1571958741 ## CI report: * bf6910828de8a628affed5d68ea6c048086b7f72 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32238) Stable approach for installing libssl

2023-06-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32238: --- Labels: pull-request-available (was: ) > Stable approach for installing libssl >

[GitHub] [flink] luoyuxia commented on a diff in pull request #21927: [FLINK-30966][table-planner] Optimize type inference for Character type and fix result type casting in IfCallGen

2023-06-01 Thread via GitHub
luoyuxia commented on code in PR #21927: URL: https://github.com/apache/flink/pull/21927#discussion_r1213012657 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/type/LeastRestrictiveOrDefaultReturnTypeInference.java: ## @@ -56,7 +57,7 @@

[jira] [Created] (FLINK-32238) Stable approach for installing libssl

2023-06-01 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-32238: Summary: Stable approach for installing libssl Key: FLINK-32238 URL: https://issues.apache.org/jira/browse/FLINK-32238 Project: Flink Issue Type:

[jira] [Updated] (FLINK-32231) libssl not found when running CI

2023-06-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-32231: - Issue Type: Technical Debt (was: Bug) > libssl not found when running CI >

[jira] [Closed] (FLINK-31407) Upgrade Fabric8 version to 6.5.0

2023-06-01 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-31407. -- Resolution: Fixed > Upgrade Fabric8 version to 6.5.0 > > >

[jira] [Closed] (FLINK-32041) flink-kubernetes-operator RoleBinding for Leases not created in correct namespace when using watchNamespaces

2023-06-01 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32041. -- Fix Version/s: kubernetes-operator-1.6.0 Resolution: Fixed merged to main

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #604: [FLINK-32041] - Allow operator to manage leases when using watchNamespaces

2023-06-01 Thread via GitHub
gyfora merged PR #604: URL: https://github.com/apache/flink-kubernetes-operator/pull/604 -- 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-32237) add jackson-module-kotlin to Jackson packages that get shaded

2023-06-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728313#comment-17728313 ] Martijn Visser commented on FLINK-32237: [~singingbush] Why wouldn't you use Jackson directly

[GitHub] [flink] reswqa commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

2023-06-01 Thread via GitHub
reswqa commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1212863225 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClient.java: ## @@ -80,13 +107,23 @@ public void

[GitHub] [flink] flinkbot commented on pull request #22696: [FLINK-32234][table] Support execute truncate table statement

2023-06-01 Thread via GitHub
flinkbot commented on PR #22696: URL: https://github.com/apache/flink/pull/22696#issuecomment-1571759894 ## CI report: * 72ab2d0cc77f50104268b3a5de4b81ee7bc0bf3f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32234) Support execute truncate table statement

2023-06-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32234: --- Labels: pull-request-available (was: ) > Support execute truncate table statement >

[GitHub] [flink] luoyuxia opened a new pull request, #22696: [FLINK-32234][table] Support execute truncate table statement

2023-06-01 Thread via GitHub
luoyuxia opened a new pull request, #22696: URL: https://github.com/apache/flink/pull/22696 ## 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

[jira] [Updated] (FLINK-32237) add jackson-module-kotlin to Jackson packages that get shaded

2023-06-01 Thread Samael Bate (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samael Bate updated FLINK-32237: Description: Because of the shaded Jackson packages having their package names prefixed, such as 

[jira] [Created] (FLINK-32237) add jackson-module-kotlin to Jackson packages that get shaded

2023-06-01 Thread Samael Bate (Jira)
Samael Bate created FLINK-32237: --- Summary: add jackson-module-kotlin to Jackson packages that get shaded Key: FLINK-32237 URL: https://issues.apache.org/jira/browse/FLINK-32237 Project: Flink

[jira] [Updated] (FLINK-30480) Add benchmarks for adaptive batch scheduler

2023-06-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30480: Fix Version/s: 1.18.0 > Add benchmarks for adaptive batch scheduler >

[GitHub] [flink] flinkbot commented on pull request #22695: [FLINK-32236][yarn][tests] Ease allow-list regex

2023-06-01 Thread via GitHub
flinkbot commented on PR #22695: URL: https://github.com/apache/flink/pull/22695#issuecomment-1571697288 ## CI report: * 5e1e6232a4a7b346acfcda6d677b1a789038205e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32236) Ease YarnTestBase allowlist address regex

2023-06-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32236: --- Labels: pull-request-available (was: ) > Ease YarnTestBase allowlist address regex >

[jira] [Created] (FLINK-32236) Ease YarnTestBase allowlist address regex

2023-06-01 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-32236: Summary: Ease YarnTestBase allowlist address regex Key: FLINK-32236 URL: https://issues.apache.org/jira/browse/FLINK-32236 Project: Flink Issue

[GitHub] [flink] reswqa commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

2023-06-01 Thread via GitHub
reswqa commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1212861475 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClient.java: ## @@ -100,26 +137,95 @@ public

[GitHub] [flink] WencongLiu commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

2023-06-01 Thread via GitHub
WencongLiu commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1212845100 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/EndOfSegmentEvent.java: ## @@ -0,0 +1,64 @@ +/* + * Licensed to the Apache Software

[jira] [Closed] (FLINK-32226) RestClusterClient leaks jobgraph file if submission fails

2023-06-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-32226. Resolution: Fixed master: d90a72da2fd601ca4e2a46700e91ec5b348de2ad 1.17:

[GitHub] [flink] zentol merged pull request #22685: [FLINK-32226][client] Cleanup jobgraph file on submission failure

2023-06-01 Thread via GitHub
zentol merged PR #22685: URL: https://github.com/apache/flink/pull/22685 -- 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 pull request #22672: [BP-1.17][FLINK-32023][API / DataStream] Add config execution.buffer-…

2023-06-01 Thread via GitHub
reswqa commented on PR #22672: URL: https://github.com/apache/flink/pull/22672#issuecomment-1571637071 @Myracle It seems that there are compilation error, would you mind taking a look again. -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Assigned] (FLINK-32213) Add get off heap buffer in memory segment

2023-06-01 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-32213: -- Assignee: Fang Yong > Add get off heap buffer in memory segment >

[GitHub] [flink] flinkbot commented on pull request #22694: [FLINK-32223][runtime][security] Add Hive delegation token support

2023-06-01 Thread via GitHub
flinkbot commented on PR #22694: URL: https://github.com/apache/flink/pull/22694#issuecomment-1571630624 ## CI report: * df978216dfef3a994dfe37268a3a04d60d1bb963 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] gyfora commented on a diff in pull request #22693: [FLINK-31974] Do not crash jobmanager on Kubernetes client errors

2023-06-01 Thread via GitHub
gyfora commented on code in PR #22693: URL: https://github.com/apache/flink/pull/22693#discussion_r1212819836 ## flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriverTest.java: ## @@ -223,6 +225,27 @@ void testFatalHandleError() throws

[GitHub] [flink] reswqa commented on a diff in pull request #22675: [FLINK-32213][core] Add get off heap buffer in segment

2023-06-01 Thread via GitHub
reswqa commented on code in PR #22675: URL: https://github.com/apache/flink/pull/22675#discussion_r1212813169 ## flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java: ## @@ -279,6 +279,21 @@ public byte[] getArray() { } } +/** + *

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

2023-06-01 Thread via GitHub
WencongLiu commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1212817671 ## flink-runtime/src/test/java/org/apache/flink/runtime/testutils/TestingJobResultStore.java: ## @@ -80,33 +82,65 @@ private TestingJobResultStore( }

[jira] [Updated] (FLINK-32223) Add Hive delegation token support

2023-06-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32223: --- Labels: pull-request-available (was: ) > Add Hive delegation token support >

[GitHub] [flink] jiaoqingbo opened a new pull request, #22694: [FLINK-32223][runtime][security] Add Hive delegation token support

2023-06-01 Thread via GitHub
jiaoqingbo opened a new pull request, #22694: URL: https://github.com/apache/flink/pull/22694 ## What is the purpose of the change Add Hive delegation token support ## Brief change log Add HiveDelegationTokenProvider Add HiveDelegationTokenReceiver Add

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

2023-06-01 Thread via GitHub
TanYuxin-tyx commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1212512688 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/EndOfSegmentEvent.java: ## @@ -0,0 +1,64 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

2023-06-01 Thread via GitHub
TanYuxin-tyx commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1212512688 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/EndOfSegmentEvent.java: ## @@ -0,0 +1,64 @@ +/* + * Licensed to the Apache Software

  1   2   >