[GitHub] [flink] snuyanzin commented on pull request #18604: [FLINK-25926][Connectors][JDBC] Update org.postgresql:postgresql to 42.3.3

2022-04-04 Thread GitBox
snuyanzin commented on PR #18604: URL: https://github.com/apache/flink/pull/18604#issuecomment-1088333227 Hi @MartijnVisser it seems there are at least 2 changes in pgjdbc which should be adapted to make tests happy... I have no idea how to propose changes to unchanged files with GitH

[jira] [Commented] (FLINK-27020) use hive dialect in SqlClient would thrown an error based on 1.15 version

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517254#comment-17517254 ] Martijn Visser commented on FLINK-27020: [~jingzhang] I think it's indeed a good

[jira] [Closed] (FLINK-27047) DispatcherResourceCleanupTest is unstable

2022-04-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27047. Resolution: Fixed master: 3eb762bbf3ae7fa1fe897300d4d12b3d22987e85 > DispatcherResourceCl

[GitHub] [flink] zentol merged pull request #19355: [FLINK-27047][tests] Remove timeouts

2022-04-04 Thread GitBox
zentol merged PR #19355: URL: https://github.com/apache/flink/pull/19355 -- 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] [Updated] (FLINK-27005) Bump CRD version to v1beta1

2022-04-04 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27005: --- Description: We should upgrade the CRD version to v1beta1 for both FlinkDeployment and FlinkSession

[jira] [Updated] (FLINK-27005) Bump CRD version to v1beta1

2022-04-04 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27005: --- Summary: Bump CRD version to v1beta1 (was: Bump CRD version to v1alpha2) > Bump CRD version to v1be

[GitHub] [flink] zentol commented on pull request #19354: [FLINK-27042][metrics] Fix instability of StreamTaskTest#testMailboxMetricsScheduling

2022-04-04 Thread GitBox
zentol commented on PR #19354: URL: https://github.com/apache/flink/pull/19354#issuecomment-1088324498 @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-24660) Allow setting KafkaSubscriber in KafkaSourceBuilder

2022-04-04 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517223#comment-17517223 ] Mason Chen commented on FLINK-24660: [~kkondamudi] [~dfontana] My apologies–my email

[jira] [Commented] (FLINK-24660) Allow setting KafkaSubscriber in KafkaSourceBuilder

2022-04-04 Thread Karthik Kondamudi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517214#comment-17517214 ] Karthik Kondamudi commented on FLINK-24660: --- [~mason6345] please let us know i

[jira] [Comment Edited] (FLINK-27020) use hive dialect in SqlClient would thrown an error based on 1.15 version

2022-04-04 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517203#comment-17517203 ] Jing Zhang edited comment on FLINK-27020 at 4/5/22 4:31 AM:

[jira] [Updated] (FLINK-27056) "pipeline.time-characteristic" should be deprecated and have EVENT_TIME as default value

2022-04-04 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-27056: -- Description: *Background* # pipeline.time-characteristic is the configuration option used to

[jira] [Created] (FLINK-27056) "pipeline.time-characteristic" should be deprecated and have EVENT_TIME as default value

2022-04-04 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-27056: - Summary: "pipeline.time-characteristic" should be deprecated and have EVENT_TIME as default value Key: FLINK-27056 URL: https://issues.apache.org/jira/browse/FLINK-27056

[jira] [Comment Edited] (FLINK-27020) use hive dialect in SqlClient would thrown an error based on 1.15 version

2022-04-04 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517203#comment-17517203 ] Jing Zhang edited comment on FLINK-27020 at 4/5/22 4:27 AM:

[jira] [Closed] (FLINK-27020) use hive dialect in SqlClient would thrown an error based on 1.15 version

2022-04-04 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang closed FLINK-27020. -- Resolution: Not A Problem > use hive dialect in SqlClient would thrown an error based on 1.15 version

[jira] [Commented] (FLINK-27020) use hive dialect in SqlClient would thrown an error based on 1.15 version

2022-04-04 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517203#comment-17517203 ] Jing Zhang commented on FLINK-27020: [~martijnvisser]Thanks a lot for reminding. It

[jira] [Created] (FLINK-27055) java.lang.ArrayIndexOutOfBoundsException in BinarySegmentUtils

2022-04-04 Thread Kenny Ma (Jira)
Kenny Ma created FLINK-27055: Summary: java.lang.ArrayIndexOutOfBoundsException in BinarySegmentUtils Key: FLINK-27055 URL: https://issues.apache.org/jira/browse/FLINK-27055 Project: Flink Issue

[jira] [Updated] (FLINK-25768) Python test BlinkBatchTableEnvironmentTests.test_explain_with_multi_sinks failed on azure

2022-04-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25768: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability) Pri

[jira] [Updated] (FLINK-11998) Flink Interactive Programming (Umbrella JIRA)

2022-04-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11998: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-depr

[jira] [Updated] (FLINK-21394) FLIP-164: Improve Schema Handling in Catalogs

2022-04-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21394: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-depr

[jira] [Updated] (FLINK-12047) State Processor API (previously named Savepoint Connector) to read / write / process savepoints

2022-04-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12047: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-depr

[GitHub] [flink] flinkbot commented on pull request #19357: [Flink-26011][test] ArchUnit test for formats test code

2022-04-04 Thread GitBox
flinkbot commented on PR #19357: URL: https://github.com/apache/flink/pull/19357#issuecomment-1088067086 ## CI report: * 79a4ada4f2d28eec373ac46ece7f8bd75fbcfa4e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] JingGe opened a new pull request, #19357: [Flink-26011][test] ArchUnit test for formats test code

2022-04-04 Thread GitBox
JingGe opened a new pull request, #19357: URL: https://github.com/apache/flink/pull/19357 ## What is the purpose of the change Develop ArchUnit tests for the test code of formats. ## Brief change log - Add ArchUnit tests for the test code of each format. - add archun

[jira] [Commented] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

2022-04-04 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517087#comment-17517087 ] Arvid Heise commented on FLINK-25916: - This looks like FLINK-24608 to me except this

[jira] [Updated] (FLINK-26663) Pod augmentation for the operator

2022-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26663: --- Labels: pull-request-available (was: ) > Pod augmentation for the operator > --

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #155: [FLINK-26663] Pod augmentation for the operator

2022-04-04 Thread GitBox
morhidi commented on PR #155: URL: https://github.com/apache/flink-kubernetes-operator/pull/155#issuecomment-1087956079 cc @wangyang0918 @gyfora @mbalassi -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[GitHub] [flink-kubernetes-operator] morhidi opened a new pull request, #155: [FLINK-26663] Pod augmentation for the operator

2022-04-04 Thread GitBox
morhidi opened a new pull request, #155: URL: https://github.com/apache/flink-kubernetes-operator/pull/155 - adding basic example and docs for pod augmentation using Helm + kustomize -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[jira] [Closed] (FLINK-26751) [FLIP-171] Kafka implementation of AsyncSinkBase

2022-04-04 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-26751. --- Resolution: Won't Fix As stated, with the current async sink design, it's not possible to implement

[GitHub] [flink] snuyanzin commented on pull request #19340: [FLINK-26961][BP-1.14][connectors][filesystems][formats] Update Jackson Databi…

2022-04-04 Thread GitBox
snuyanzin commented on PR #19340: URL: https://github.com/apache/flink/pull/19340#issuecomment-1087898371 @MartijnVisser thanks for the hint it looks it helped -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Created] (FLINK-27054) Elasticsearch SQL connector SSL issue

2022-04-04 Thread ricardo (Jira)
ricardo created FLINK-27054: --- Summary: Elasticsearch SQL connector SSL issue Key: FLINK-27054 URL: https://issues.apache.org/jira/browse/FLINK-27054 Project: Flink Issue Type: Bug Repor

[GitHub] [flink] MartijnVisser commented on pull request #19352: [FLINK-27044][Connectors][Hive] Drop support for Hive versions 1.*, 2.1.* and 2.2.* which are no longer supported by the Hive community

2022-04-04 Thread GitBox
MartijnVisser commented on PR #19352: URL: https://github.com/apache/flink/pull/19352#issuecomment-1087786644 @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] snuyanzin commented on pull request #19340: [FLINK-26961][BP-1.14][connectors][filesystems][formats] Update Jackson Databi…

2022-04-04 Thread GitBox
snuyanzin commented on PR #19340: URL: https://github.com/apache/flink/pull/19340#issuecomment-1087715894 @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-26793) Flink Cassandra connector performance issue

2022-04-04 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516904#comment-17516904 ] Etienne Chauchot commented on FLINK-26793: -- [~bumblebee] in particular do you s

[GitHub] [flink] slinkydeveloper commented on pull request #19349: [FLINK-27043][table] Removing old csv format references

2022-04-04 Thread GitBox
slinkydeveloper commented on PR #19349: URL: https://github.com/apache/flink/pull/19349#issuecomment-1087657014 @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 co

[jira] [Commented] (FLINK-27031) ChangelogRescalingITCase.test failed due to IllegalStateException

2022-04-04 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516867#comment-17516867 ] Roman Khachatryan commented on FLINK-27031: --- The test fails reliably when resc

[jira] [Created] (FLINK-27053) IncrementalRemoteKeyedStateHandle.discardState swallows errors

2022-04-04 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-27053: - Summary: IncrementalRemoteKeyedStateHandle.discardState swallows errors Key: FLINK-27053 URL: https://issues.apache.org/jira/browse/FLINK-27053 Project: Flink

[jira] [Updated] (FLINK-27031) ChangelogRescalingITCase.test failed due to IllegalStateException

2022-04-04 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27031: -- Labels: (was: test-stability) > ChangelogRescalingITCase.test failed due to IllegalS

[jira] [Updated] (FLINK-27031) ChangelogRescalingITCase.test failed due to IllegalStateException

2022-04-04 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27031: -- Component/s: Runtime / Network > ChangelogRescalingITCase.test failed due to IllegalSt

[jira] [Updated] (FLINK-27031) ChangelogRescalingITCase.test failed due to IllegalStateException

2022-04-04 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27031: -- Affects Version/s: 1.15.0 > ChangelogRescalingITCase.test failed due to IllegalStateEx

[jira] [Created] (FLINK-27052) FsCompletedCheckpointStorageLocation.disposeStorageLocation doesn't expose errors properly (not processing the return value)

2022-04-04 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-27052: - Summary: FsCompletedCheckpointStorageLocation.disposeStorageLocation doesn't expose errors properly (not processing the return value) Key: FLINK-27052 URL: https://issues.apach

[GitHub] [flink] flinkbot commented on pull request #19356: [FLINK-26993][tests] Wait until checkpoint was actually triggered

2022-04-04 Thread GitBox
flinkbot commented on PR #19356: URL: https://github.com/apache/flink/pull/19356#issuecomment-1087584893 ## CI report: * a561e7d0e90e337b9d28f2b2abf9f0e8e8863515 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-27051) CompletedCheckpoint.DiscardObject.discard is not idempotent

2022-04-04 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-27051: - Summary: CompletedCheckpoint.DiscardObject.discard is not idempotent Key: FLINK-27051 URL: https://issues.apache.org/jira/browse/FLINK-27051 Project: Flink

[jira] [Closed] (FLINK-26884) Move Elasticsearch connector to external connector repository

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26884. -- Fix Version/s: 1.16.0 Release Note: The Elasticsearch connector has been copied from the F

[GitHub] [flink-connector-elasticsearch] MartijnVisser merged pull request #5: [Flink-26884] Copy elasticsearch connectors to the external repo

2022-04-04 Thread GitBox
MartijnVisser merged PR #5: URL: https://github.com/apache/flink-connector-elasticsearch/pull/5 -- 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-u

[GitHub] [flink] XComp commented on pull request #19351: [FLINK-27045][tests] Remove shared executor

2022-04-04 Thread GitBox
XComp commented on PR #19351: URL: https://github.com/apache/flink/pull/19351#issuecomment-1087575899 We might want to switch to a `ExecutorServiceResource` that takes care of shutting the thread pool down at the end of the test. -- This is an automated message from the Apache Git Service

[jira] [Updated] (FLINK-26993) CheckpointCoordinatorTest#testMinCheckpointPause

2022-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26993: --- Labels: pull-request-available (was: ) > CheckpointCoordinatorTest#testMinCheckpointPause >

[GitHub] [flink] zentol opened a new pull request, #19356: [FLINK-26993][tests] Wait until checkpoint was actually triggered

2022-04-04 Thread GitBox
zentol opened a new pull request, #19356: URL: https://github.com/apache/flink/pull/19356 This is a rather crude fix :/ -- 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 u

[GitHub] [flink] flinkbot commented on pull request #19355: [FLINK-27047][tests] Remove timeouts

2022-04-04 Thread GitBox
flinkbot commented on PR #19355: URL: https://github.com/apache/flink/pull/19355#issuecomment-1087567245 ## CI report: * 638d3a49aa3908cae9d83653a2f7442c1cb3c2ee UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-kubernetes-operator] SteNicholas commented on pull request #141: [FLINK-26894] Support custom validator implementations

2022-04-04 Thread GitBox
SteNicholas commented on PR #141: URL: https://github.com/apache/flink-kubernetes-operator/pull/141#issuecomment-1087565240 > @SteNicholas we have merged the session controller changes, I think it would be a good time to rebase this :) @gyfora I'm rebasing the main branch and updatin

[jira] [Updated] (FLINK-27047) DispatcherResourceCleanupTest is unstable

2022-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27047: --- Labels: pull-request-available test-stability (was: test-stability) > DispatcherResourceCle

[GitHub] [flink] zentol opened a new pull request, #19355: [FLINK-27047][tests] Remove timeouts

2022-04-04 Thread GitBox
zentol opened a new pull request, #19355: URL: https://github.com/apache/flink/pull/19355 There's no guarantee that the cleanup is initiated synchronously. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[jira] [Updated] (FLINK-27047) DispatcherResourceCleanupTest is unstable

2022-04-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-27047: -- Labels: test-stability (was: ) > DispatcherResourceCleanupTest is unstable >

[GitHub] [flink-connector-elasticsearch] MartijnVisser commented on pull request #4: [FLINK-26958][BuildSystem] Add Github Actions build for flink-connector-elasticsearch

2022-04-04 Thread GitBox
MartijnVisser commented on PR #4: URL: https://github.com/apache/flink-connector-elasticsearch/pull/4#issuecomment-1087551540 @zentol Thanks a lot for the feedback. I've reworked the pipeline; I've used https://github.com/apache/flink-connector-elasticsearch/pull/5 to verify it (you can se

[GitHub] [flink-connector-elasticsearch] MartijnVisser commented on a diff in pull request #4: [FLINK-26958][BuildSystem] Add Github Actions build for flink-connector-elasticsearch

2022-04-04 Thread GitBox
MartijnVisser commented on code in PR #4: URL: https://github.com/apache/flink-connector-elasticsearch/pull/4#discussion_r841729398 ## .github/workflows/ci.yml: ## @@ -0,0 +1,141 @@ + +# Licensed t

[GitHub] [flink-connector-elasticsearch] MartijnVisser commented on a diff in pull request #4: [FLINK-26958][BuildSystem] Add Github Actions build for flink-connector-elasticsearch

2022-04-04 Thread GitBox
MartijnVisser commented on code in PR #4: URL: https://github.com/apache/flink-connector-elasticsearch/pull/4#discussion_r841728690 ## .github/workflows/ci.yml: ## @@ -0,0 +1,141 @@ + +# Licensed t

[GitHub] [flink] flinkbot commented on pull request #19354: [FLINK-27042][metrics] Fix instability of StreamTaskTest#testMailboxMetricsScheduling

2022-04-04 Thread GitBox
flinkbot commented on PR #19354: URL: https://github.com/apache/flink/pull/19354#issuecomment-1087547817 ## CI report: * d5f62428a57f77e2484ed2b5b1e06adee4744a3f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-connector-elasticsearch] MartijnVisser commented on a diff in pull request #4: [FLINK-26958][BuildSystem] Add Github Actions build for flink-connector-elasticsearch

2022-04-04 Thread GitBox
MartijnVisser commented on code in PR #4: URL: https://github.com/apache/flink-connector-elasticsearch/pull/4#discussion_r841728337 ## .github/workflows/ci.yml: ## @@ -0,0 +1,141 @@ + +# Licensed t

[GitHub] [flink-connector-elasticsearch] MartijnVisser commented on a diff in pull request #4: [FLINK-26958][BuildSystem] Add Github Actions build for flink-connector-elasticsearch

2022-04-04 Thread GitBox
MartijnVisser commented on code in PR #4: URL: https://github.com/apache/flink-connector-elasticsearch/pull/4#discussion_r841724628 ## .github/workflows/ci.yml: ## @@ -0,0 +1,141 @@ + +# Licensed t

[GitHub] [flink-connector-elasticsearch] MartijnVisser commented on a diff in pull request #4: [FLINK-26958][BuildSystem] Add Github Actions build for flink-connector-elasticsearch

2022-04-04 Thread GitBox
MartijnVisser commented on code in PR #4: URL: https://github.com/apache/flink-connector-elasticsearch/pull/4#discussion_r841720418 ## .github/workflows/ci.yml: ## @@ -0,0 +1,141 @@ + +# Licensed t

[GitHub] [flink] flinkbot commented on pull request #19353: [FLINK-27050][runtime] Removes default RpcSystem instance

2022-04-04 Thread GitBox
flinkbot commented on PR #19353: URL: https://github.com/apache/flink/pull/19353#issuecomment-1087537918 ## CI report: * a942ecbc4be8adf0ee037228ad9ebc697b7e6080 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27042) StreamTaskTest#testMailboxMetricsScheduling is unstable

2022-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27042: --- Labels: pull-request-available (was: ) > StreamTaskTest#testMailboxMetricsScheduling is uns

[GitHub] [flink] smattheis opened a new pull request, #19354: [FLINK-27042] Fix instability of StreamTaskTest#testMailboxMetricsScheduling

2022-04-04 Thread GitBox
smattheis opened a new pull request, #19354: URL: https://github.com/apache/flink/pull/19354 ## What is the purpose of the change * Fix instability of StreamTaskTest#testMailboxMetricsScheduling ## Brief change log * Remove assertion for latency me

[GitHub] [flink] metaswirl commented on a diff in pull request #19263: [FLINK-21585][metrics] Add options for in-/excluding metrics

2022-04-04 Thread GitBox
metaswirl commented on code in PR #19263: URL: https://github.com/apache/flink/pull/19263#discussion_r841714252 ## flink-runtime/src/test/java/org/apache/flink/runtime/metrics/filter/DefaultMetricFilterTest.java: ## @@ -0,0 +1,192 @@ +/* + * Licensed to the Apache Software Found

[GitHub] [flink] flinkbot commented on pull request #19352: [FLINK-27044][Connectors][Hive] Drop support for Hive versions 1.*, 2.1.* and 2.2.* which are no longer supported by the Hive community

2022-04-04 Thread GitBox
flinkbot commented on PR #19352: URL: https://github.com/apache/flink/pull/19352#issuecomment-1087529382 ## CI report: * a07227dc89ff583ffe9cae0264e518aea73409a6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27050) TestingDispatcher.Builder instantiates a RPCSystem without shutting it down

2022-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27050: --- Labels: pull-request-available test-stability (was: test-stability) > TestingDispatcher.Bui

[GitHub] [flink] XComp opened a new pull request, #19353: [FLINK-27050][runtime] Removes default RpcSystem instance

2022-04-04 Thread GitBox
XComp opened a new pull request, #19353: URL: https://github.com/apache/flink/pull/19353 ## What is the purpose of the change Having a default RpcSystem in TestingDispatcher.Builder caused threads being spawned without cleanup. Instead, we should rely on the RpcSystem ins

[GitHub] [flink] metaswirl commented on a diff in pull request #19272: [FLINK-26710] fix TestLoggerResource

2022-04-04 Thread GitBox
metaswirl commented on code in PR #19272: URL: https://github.com/apache/flink/pull/19272#discussion_r841709790 ## flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/testutils/logging/TestLoggerResourceTest.java: ## @@ -0,0 +1,119 @@ +/* + * Licensed t

[GitHub] [flink] metaswirl commented on a diff in pull request #19272: [FLINK-26710] fix TestLoggerResource

2022-04-04 Thread GitBox
metaswirl commented on code in PR #19272: URL: https://github.com/apache/flink/pull/19272#discussion_r841709315 ## flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/testutils/logging/TestLoggerResourceTest.java: ## @@ -0,0 +1,119 @@ +/* + * Licensed t

[GitHub] [flink] metaswirl commented on a diff in pull request #19272: [FLINK-26710] fix TestLoggerResource

2022-04-04 Thread GitBox
metaswirl commented on code in PR #19272: URL: https://github.com/apache/flink/pull/19272#discussion_r841708284 ## flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/testutils/logging/TestLoggerResourceTest.java: ## @@ -0,0 +1,119 @@ +/* + * Licensed t

[jira] [Updated] (FLINK-27044) Drop support for Hive versions 1.*, 2.1.* and 2.2.*

2022-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27044: --- Labels: pull-request-available (was: ) > Drop support for Hive versions 1.*, 2.1.* and 2.2.

[jira] [Assigned] (FLINK-27044) Drop support for Hive versions 1.*, 2.1.* and 2.2.*

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-27044: -- Assignee: Martijn Visser > Drop support for Hive versions 1.*, 2.1.* and 2.2.* > ---

[GitHub] [flink] MartijnVisser opened a new pull request, #19352: [FLINK-27044][Connectors][Hive] Drop support for Hive versions 1.*, 2.1.* and 2.2.* which are no longer supported by the Hive communit

2022-04-04 Thread GitBox
MartijnVisser opened a new pull request, #19352: URL: https://github.com/apache/flink/pull/19352 ## What is the purpose of the change This PR drops support for 3 versions of Hive: * All Hive 1.* support * All Hive 2.1.* support * All Hive 2.2.* support That means th

[GitHub] [flink] slinkydeveloper commented on pull request #19349: [FLINK-27043][table] Removing old csv format references

2022-04-04 Thread GitBox
slinkydeveloper commented on PR #19349: URL: https://github.com/apache/flink/pull/19349#issuecomment-1087514912 @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 co

[jira] [Commented] (FLINK-27050) TestingDispatcher.Builder instantiates a RPCSystem without shutting it down

2022-04-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516795#comment-17516795 ] Matthias Pohl commented on FLINK-27050: --- This was introduced by {{9cac58227d2c28e7

[jira] [Created] (FLINK-27050) TestingDispatcher.Builder instantiates a RPCSystem without shutting it down

2022-04-04 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-27050: - Summary: TestingDispatcher.Builder instantiates a RPCSystem without shutting it down Key: FLINK-27050 URL: https://issues.apache.org/jira/browse/FLINK-27050 Project

[jira] [Assigned] (FLINK-27050) TestingDispatcher.Builder instantiates a RPCSystem without shutting it down

2022-04-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-27050: - Assignee: Matthias Pohl > TestingDispatcher.Builder instantiates a RPCSystem without sh

[GitHub] [flink] DefuLi commented on pull request #19344: [hotfix] Modify spelling error in IOUtils.java

2022-04-04 Thread GitBox
DefuLi commented on PR #19344: URL: https://github.com/apache/flink/pull/19344#issuecomment-1087505636 @MartijnVisser ok, 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 above to go to the specific com

[jira] [Comment Edited] (FLINK-26957) FileSystemJobResultStore calls flush on an already closed OutputStream

2022-04-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516784#comment-17516784 ] Matthias Pohl edited comment on FLINK-26957 at 4/4/22 12:34 PM: --

[jira] [Resolved] (FLINK-26957) FileSystemJobResultStore calls flush on an already closed OutputStream

2022-04-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-26957. --- Resolution: Fixed master: * c50b0706237114adec195b84202b969a148ccece * caa296b813b8a719910f4

[GitHub] [flink] XComp merged pull request #19345: [FLINK-26957][BP-1.15][runtime] Removes flush in FileSystemJobResultStore.createDirtyResultInternal

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

[GitHub] [flink] XComp commented on pull request #19345: [FLINK-26957][BP-1.15][runtime] Removes flush in FileSystemJobResultStore.createDirtyResultInternal

2022-04-04 Thread GitBox
XComp commented on PR #19345: URL: https://github.com/apache/flink/pull/19345#issuecomment-1087496890 Merging the PR since the CI passed and the parent PR was approved. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[GitHub] [flink] XComp merged pull request #19304: [FLINK-26957][runtime] Removes flush in FileSystemJobResultStore.createDirtyResultInternal

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

[GitHub] [flink] XComp commented on pull request #19304: [FLINK-26957][runtime] Removes flush in FileSystemJobResultStore.createDirtyResultInternal

2022-04-04 Thread GitBox
XComp commented on PR #19304: URL: https://github.com/apache/flink/pull/19304#issuecomment-1087496375 I'm gonna merge. I only dropped on commit. -- 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 th

[jira] [Commented] (FLINK-27010) Support setting sql client args via flink conf

2022-04-04 Thread Moses (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516780#comment-17516780 ] Moses commented on FLINK-27010: --- [~martijnvisser] +1 > Support setting sql client args vi

[GitHub] [flink] XComp commented on a diff in pull request #19304: [FLINK-26957][runtime] Removes flush in FileSystemJobResultStore.createDirtyResultInternal

2022-04-04 Thread GitBox
XComp commented on code in PR #19304: URL: https://github.com/apache/flink/pull/19304#discussion_r841681923 ## flink-core/src/test/java/org/apache/flink/core/fs/FileSystemBehaviorTestSuite.java: ## @@ -263,6 +266,21 @@ public void testMkdirsFailsWithExistingParentFile() throws

[GitHub] [flink-kubernetes-operator] MartijnVisser commented on pull request #154: [hotfix] Change email/repository notifications to match with Flink Core settings

2022-04-04 Thread GitBox
MartijnVisser commented on PR #154: URL: https://github.com/apache/flink-kubernetes-operator/pull/154#issuecomment-1087493977 > Dank. You're welcome :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[GitHub] [flink] metaswirl commented on a diff in pull request #19272: [FLINK-26710] fix TestLoggerResource

2022-04-04 Thread GitBox
metaswirl commented on code in PR #19272: URL: https://github.com/apache/flink/pull/19272#discussion_r841677959 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/logging/TestLoggerResource.java: ## @@ -43,52 +52,125 @@ private fina

[GitHub] [flink] MartijnVisser merged pull request #19344: [hotfix] Modify spelling error in IOUtils.java

2022-04-04 Thread GitBox
MartijnVisser merged PR #19344: URL: https://github.com/apache/flink/pull/19344 -- 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

[GitHub] [flink] matriv commented on a diff in pull request #18609: [FLINK-25897][docs] Update gradle quickstart quide to gradle 7.3.3

2022-04-04 Thread GitBox
matriv commented on code in PR #18609: URL: https://github.com/apache/flink/pull/18609#discussion_r841673533 ## docs/content/docs/dev/datastream/project-configuration.md: ## @@ -372,19 +358,18 @@ dependencies { // Compile-time dependencies that should NOT be part of the

[GitHub] [flink] metaswirl commented on a diff in pull request #19272: [FLINK-26710] fix TestLoggerResource

2022-04-04 Thread GitBox
metaswirl commented on code in PR #19272: URL: https://github.com/apache/flink/pull/19272#discussion_r841673414 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/logging/TestLoggerResource.java: ## @@ -43,52 +52,125 @@ private fina

[GitHub] [flink] dannycranmer commented on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

2022-04-04 Thread GitBox
dannycranmer commented on PR #17360: URL: https://github.com/apache/flink/pull/17360#issuecomment-1087483377 @MartijnVisser we do not have capacity to pick it up right now. If we do not hear back from @jherico then we could potentially pick it up sometime before the 1.16 release -- This

[GitHub] [flink] metaswirl commented on a diff in pull request #19272: [FLINK-26710] fix TestLoggerResource

2022-04-04 Thread GitBox
metaswirl commented on code in PR #19272: URL: https://github.com/apache/flink/pull/19272#discussion_r841670907 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/logging/TestLoggerResource.java: ## @@ -43,52 +52,125 @@ private fina

[GitHub] [flink-connector-elasticsearch] JingGe closed pull request #2: [Flink-26884][draft] move elasticsearch connectors to the external repo

2022-04-04 Thread GitBox
JingGe closed pull request #2: [Flink-26884][draft] move elasticsearch connectors to the external repo URL: https://github.com/apache/flink-connector-elasticsearch/pull/2 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [flink-connector-elasticsearch] JingGe commented on pull request #2: [Flink-26884][draft] move elasticsearch connectors to the external repo

2022-04-04 Thread GitBox
JingGe commented on PR #2: URL: https://github.com/apache/flink-connector-elasticsearch/pull/2#issuecomment-1087480666 please refer to the new PR: #5 -- 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 g

[GitHub] [flink] dmvk commented on a diff in pull request #19304: [FLINK-26957][runtime] Removes flush in FileSystemJobResultStore.createDirtyResultInternal

2022-04-04 Thread GitBox
dmvk commented on code in PR #19304: URL: https://github.com/apache/flink/pull/19304#discussion_r841664758 ## flink-core/src/test/java/org/apache/flink/core/fs/FileSystemBehaviorTestSuite.java: ## @@ -263,6 +266,21 @@ public void testMkdirsFailsWithExistingParentFile() throws E

[jira] [Closed] (FLINK-26712) Metadata keys should not conflict with physical columns

2022-04-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-26712. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 0097b5a6faed4a2b146dca81f4d92e08c5

[jira] [Commented] (FLINK-25897) Update project configuration gradle doc to 7.x version

2022-04-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516768#comment-17516768 ] David Morávek commented on FLINK-25897: --- asf-site: 16607c8e4ec87382b9dfa411c75b6f2

[GitHub] [flink-web] dmvk merged pull request #504: [FLINK-25897] Update gradle quickstart to gradle 7.3.3

2022-04-04 Thread GitBox
dmvk merged PR #504: URL: https://github.com/apache/flink-web/pull/504 -- 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.o

[GitHub] [flink-statefun] FilKarnicki commented on a diff in pull request #309: [FLINK-26570][statefun] Remote module configuration interpolation

2022-04-04 Thread GitBox
FilKarnicki commented on code in PR #309: URL: https://github.com/apache/flink-statefun/pull/309#discussion_r841660248 ## docs/content/docs/modules/overview.md: ## @@ -61,3 +61,36 @@ spec: A module YAML file can contain multiple YAML documents, separated by `---`, each repre

[jira] [Commented] (FLINK-27041) KafkaSource in batch mode failing on 0 messages in any topic partition

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516766#comment-17516766 ] Martijn Visser commented on FLINK-27041: [~renqs] Can you have a look? > KafkaS

[jira] [Updated] (FLINK-26368) Add setProperty method to KafkaSinkBuilder

2022-04-04 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26368: --- Fix Version/s: 1.16.0 > Add setProperty method to KafkaSinkBuilder > ---

  1   2   >