[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=17516795#comment-17516795 ] Matthias Pohl commented on FLINK-27050: --- This was introduced by

[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

[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.* >

[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

[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

[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

[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

[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

[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:

[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=17516904#comment-17516904 ] Etienne Chauchot commented on FLINK-26793: -- [~bumblebee] in particular do you see in Flink logs

[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

[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

[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-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

[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

[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

[jira] [Assigned] (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 reassigned FLINK-27031: - Assignee: Roman Khachatryan > ChangelogRescalingITCase.test failed due to

[GitHub] [flink] MartijnVisser opened a new pull request, #19348: [FLINK-25797][BP 1.15][Docs] Translate datastream/formats/parquet.md page into Chinese

2022-04-04 Thread GitBox
MartijnVisser opened a new pull request, #19348: URL: https://github.com/apache/flink/pull/19348 Unchanged backport of https://github.com/apache/flink/pull/18646 -- 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] [Commented] (FLINK-25738) Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors"

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516662#comment-17516662 ] Martijn Visser commented on FLINK-25738: [~RocMarshal] I was still waiting on a backport for

[GitHub] [flink] dmvk merged pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

2022-04-04 Thread GitBox
dmvk merged PR #18664: URL: https://github.com/apache/flink/pull/18664 -- 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-26999) Introduce ClickHouse Connector

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516675#comment-17516675 ] Martijn Visser commented on FLINK-26999: [~monster#12] [~RocMarshal] Thanks for the FLIP and the

[jira] [Commented] (FLINK-8929) "UnknownTaskExecutorException: No TaskExecutor registered" when having tab open for taskmanager that does not exist (anymore)

2022-04-04 Thread Doug (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516690#comment-17516690 ] Doug commented on FLINK-8929: - We are also facing same issue. Anybody found solution on it ?        ERROR

[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=17516696#comment-17516696 ] Martijn Visser commented on FLINK-27020: [~jingzhang] Have you changed the planner to the old

[jira] [Commented] (FLINK-27011) Add state access examples of Python DataStream API

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516701#comment-17516701 ] Martijn Visser commented on FLINK-27011: [~dianfu] Will these examples also be validated during

[GitHub] [flink] zentol merged pull request #19346: [FLINK-27034][gcp][tests] Use testcontainers

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

[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] 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:

[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

[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=17516867#comment-17516867 ] Roman Khachatryan commented on FLINK-27031: --- The test fails reliably when rescaling from 1 to

[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) >

[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

[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:

[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

[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

[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`

[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

[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] 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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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) >

[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`

[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

[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

[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

[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

[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

[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

[jira] [Created] (FLINK-27043) Remove CSV connector test usages

2022-04-04 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-27043: --- Summary: Remove CSV connector test usages Key: FLINK-27043 URL: https://issues.apache.org/jira/browse/FLINK-27043 Project: Flink Issue Type:

[jira] [Commented] (FLINK-27025) Cannot read parquet file, after putting the jar in the right place with right permissions

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516694#comment-17516694 ] Martijn Visser commented on FLINK-27025: [~marsupialtail] Based on your attachment you're trying

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

2022-04-04 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-27042: - Assignee: Sebastian Mattheis > StreamTaskTest#testMailboxMetricsScheduling is

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

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516706#comment-17516706 ] Martijn Visser commented on FLINK-27010: I don't think this is a good idea. I think the SQL

[GitHub] [flink] zentol merged pull request #19342: [FLINK-27027] Get rid of oddly named mvn-${sys mvn.forkNumber}.log files

2022-04-04 Thread GitBox
zentol merged PR #19342: URL: https://github.com/apache/flink/pull/19342 -- 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-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=17516768#comment-17516768 ] David Morávek commented on FLINK-25897: --- asf-site: 16607c8e4ec87382b9dfa411c75b6f229f7e0f4f >

[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:

[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

[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

[GitHub] [flink] ZhangChaoming commented on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

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

[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=17516661#comment-17516661 ] Roman Khachatryan commented on FLINK-27031: --- Sure [~mapohl], I'll take a look. >

[GitHub] [flink] gaborgsomogyi commented on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

2022-04-04 Thread GitBox
gaborgsomogyi commented on PR #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1087223293 @dmvk thanks for the review and taking care! New PRs are on the way... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Resolved] (FLINK-25907) Add pluggable delegation token manager

2022-04-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-25907. --- Resolution: Fixed > Add pluggable delegation token manager >

[GitHub] [flink] MartijnVisser merged pull request #19339: [FLINK-26961][BP-1.15][connectors][filesystems][formats] Update Jackson Databi…

2022-04-04 Thread GitBox
MartijnVisser merged PR #19339: URL: https://github.com/apache/flink/pull/19339 -- 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] Humbedooh commented on pull request #19348: [FLINK-25797][BP 1.15][Docs] Translate datastream/formats/parquet.md page into Chinese

2022-04-04 Thread GitBox
Humbedooh commented on PR #19348: URL: https://github.com/apache/flink/pull/19348#issuecomment-1087259265 testing why mails are going to the wrong place, ignore me please -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Closed] (FLINK-27026) Upgrade checkstyle plugin

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

[GitHub] [flink] zentol merged pull request #19343: [FLINK-27026][build] Upgrade checkstyle plugin

2022-04-04 Thread GitBox
zentol merged PR #19343: URL: https://github.com/apache/flink/pull/19343 -- 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] [Closed] (FLINK-27034) Use testcontainers for google cloud pubsub e2e test

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

[jira] [Created] (FLINK-27045) Remove shared TestingUtils executor

2022-04-04 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27045: Summary: Remove shared TestingUtils executor Key: FLINK-27045 URL: https://issues.apache.org/jira/browse/FLINK-27045 Project: Flink Issue Type:

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516747#comment-17516747 ] Francesco Guardiani commented on FLINK-26760: - Ok just checked the TPC-DS spec: > Comment:

[jira] [Comment Edited] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516747#comment-17516747 ] Francesco Guardiani edited comment on FLINK-26760 at 4/4/22 11:04 AM:

[GitHub] [flink] morhidi commented on pull request #18933: [FLINK-26368] [kafka] Add setProperty method to KafkaSinkBuilder

2022-04-04 Thread GitBox
morhidi commented on PR #18933: URL: https://github.com/apache/flink/pull/18933#issuecomment-1087455138 +1 LGTM, way more elegant than it was before, thanks for contributing ! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[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

[GitHub] [flink-table-store] JingsongLi merged pull request #72: [FLINK-26899] Introduce write/query table document for table store

2022-04-04 Thread GitBox
JingsongLi merged PR #72: URL: https://github.com/apache/flink-table-store/pull/72 -- 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-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516656#comment-17516656 ] Martijn Visser commented on FLINK-26760: [~wanglijie95] Can you open a ticket for that

[jira] [Closed] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26524. -- Resolution: Cannot Reproduce > Elasticsearch (v5.3.3) sink end-to-end test >

[GitHub] [flink] MartijnVisser commented on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

2022-04-04 Thread GitBox
MartijnVisser commented on PR #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-1087209729 > slink @slinkydeveloper Can you help with the review? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] zentol commented on pull request #19342: [FLINK-27027] Get rid of oddly named mvn-${sys mvn.forkNumber}.log files

2022-04-04 Thread GitBox
zentol commented on PR #19342: URL: https://github.com/apache/flink/pull/19342#issuecomment-1087315513 > We don't know where this separate log is coming from, do we? Not entirely; I think it's a case of certain classes being loaded outside of a fork. -- This is an automated

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516717#comment-17516717 ] Timo Walther commented on FLINK-26760: -- UTF-8 is the default within the engine but I don't know why

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

2022-04-04 Thread GitBox
matriv commented on code in PR #504: URL: https://github.com/apache/flink-web/pull/504#discussion_r841553926 ## q/gradle-quickstart.sh: ## @@ -169,17 +168,23 @@ dependencies { // Compile-time dependencies that should NOT be part of the // shadow jar and are provided

[GitHub] [flink] twalthr commented on a diff in pull request #19087: [FLINK-26467][table-planner] Compile RowDataToStringConverter lazily

2022-04-04 Thread GitBox
twalthr commented on code in PR #19087: URL: https://github.com/apache/flink/pull/19087#discussion_r841582266 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/RowDataToStringConverterImpl.java: ## @@ -51,9 +53,18 @@ public

[jira] [Assigned] (FLINK-27048) Add ArchUnit tests for Elasticsearch to only depend on public API

2022-04-04 Thread Alexander Preuss (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Preuss reassigned FLINK-27048: Assignee: Alexander Preuss > Add ArchUnit tests for Elasticsearch to only depend

[jira] [Created] (FLINK-27048) Add ArchUnit tests for Elasticsearch to only depend on public API

2022-04-04 Thread Alexander Preuss (Jira)
Alexander Preuss created FLINK-27048: Summary: Add ArchUnit tests for Elasticsearch to only depend on public API Key: FLINK-27048 URL: https://issues.apache.org/jira/browse/FLINK-27048 Project:

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

2022-04-04 Thread GitBox
MartijnVisser commented on PR #19340: URL: https://github.com/apache/flink/pull/19340#issuecomment-1087452950 Ah I assumed it was a broken test  To resolve that we need to have a look at

[GitHub] [flink] ZhangChaoming commented on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-04-04 Thread GitBox
ZhangChaoming commented on PR #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1087202410 @RocMarshal OK -- 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-26952) Remove old CSV connector

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516655#comment-17516655 ] Martijn Visser commented on FLINK-26952: [~wanglijie95] I think removing the old connector isn't

[jira] [Commented] (FLINK-26978) Flink-SQL cannot display Timestamp time correctly.

2022-04-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516673#comment-17516673 ] Timo Walther commented on FLINK-26978: -- [~CharlieX47] can you check this with the latest master?

[jira] [Closed] (FLINK-27027) Get rid of oddly named mvn-${sys mvn.forkNumber}.log files

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

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516708#comment-17516708 ] Francesco Guardiani commented on FLINK-26760: - Another incident: I'm trying to convert our

[jira] [Updated] (FLINK-27045) Remove shared TestingUtils executor

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

[GitHub] [flink] zentol opened a new pull request, #19351: [FLINK-27045][tests] Remove shared executor

2022-04-04 Thread GitBox
zentol opened a new pull request, #19351: URL: https://github.com/apache/flink/pull/19351 Sharing an executor can lead to surprising behaviors, especially since the ownership of the executor isn't well-defined. -- This is an automated message from the Apache Git Service. To respond to

  1   2   >