[jira] [Resolved] (FLINK-29216) rows belong to update rowkind are transfered into delete and insert

2022-09-15 Thread Spongebob (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spongebob resolved FLINK-29216. --- Resolution: Not A Problem > rows belong to update rowkind are transfered into delete and insert > --

[GitHub] [flink] y0908105023 opened a new pull request, #20846: [FLINK-26943] [add date_add function support]

2022-09-15 Thread GitBox
y0908105023 opened a new pull request, #20846: URL: https://github.com/apache/flink/pull/20846 ## What is the purpose of the change *Add date_add sql function support* ## Brief change log *date_add* - *add sql function date_add to BuiltInFunction* - *also su

[GitHub] [flink] XComp commented on pull request #20839: [FLINK-28902][tests] rename FileSystemJobResultStoreTestInternal to FileSystemJobResultStoreTest and add Internal to test methods part

2022-09-15 Thread GitBox
XComp commented on PR #20839: URL: https://github.com/apache/flink/pull/20839#issuecomment-1248956464 @tonyzhu918 For the next time: You don't have to close PRs. Updating the corresponding branch is good enough. The benefit of using a single PR is to have all the discussion around code chan

[GitHub] [flink-ml] weibozhao opened a new pull request, #155: [FLINK-29318] Add Transformer for PolynomialExpansion

2022-09-15 Thread GitBox
weibozhao opened a new pull request, #155: URL: https://github.com/apache/flink-ml/pull/155 Add Transformer for PolynomialExpansion -- 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] [Updated] (FLINK-29318) Add Transformer for PolynomialExpansion

2022-09-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29318: --- Labels: pull-request-available (was: ) > Add Transformer for PolynomialExpansion >

[jira] [Created] (FLINK-29318) Add Transformer for PolynomialExpansion

2022-09-15 Thread weibo zhao (Jira)
weibo zhao created FLINK-29318: -- Summary: Add Transformer for PolynomialExpansion Key: FLINK-29318 URL: https://issues.apache.org/jira/browse/FLINK-29318 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-26043) Add periodic kerberos relogin to DelegationTokenManager

2022-09-15 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605597#comment-17605597 ] Rui Li commented on FLINK-26043: Got it, thanks [~gaborgsomogyi]! > Add periodic kerber

[GitHub] [flink] zjuwangg commented on a diff in pull request #20542: [FLINK-28910][Connectors/hbase]Fix potential data deletion while updating HBase rows

2022-09-15 Thread GitBox
zjuwangg commented on code in PR #20542: URL: https://github.com/apache/flink/pull/20542#discussion_r972576937 ## flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java: ## @@ -191,8 +195,10 @@ private void checkErr

[GitHub] [flink] flinkbot commented on pull request #20845: [FLINK-28902][tests] rename FileSystemJobResultStoreTestInternal to FileSystemJobResultStoreFileOperationsTest

2022-09-15 Thread GitBox
flinkbot commented on PR #20845: URL: https://github.com/apache/flink/pull/20845#issuecomment-1248870005 ## CI report: * 6cd73aa687093554dcf7115e1fb00ee19b4e59d1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-28902) FileSystemJobResultStoreTestInternal is a unit test that's not following the unit test naming convention

2022-09-15 Thread Tony Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605588#comment-17605588 ] Tony Zhu commented on FLINK-28902: -- Thanks for review. I created another PRĀ  [#20845|ht

[GitHub] [flink] tonyzhu918 commented on pull request #20839: [FLINK-28902][tests] rename FileSystemJobResultStoreTestInternal to FileSystemJobResultStoreTest and add Internal to test methods part

2022-09-15 Thread GitBox
tonyzhu918 commented on PR #20839: URL: https://github.com/apache/flink/pull/20839#issuecomment-1248866463 Thanks for review. I created another PR https://github.com/apache/flink/pull/20845 . -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] tonyzhu918 opened a new pull request, #20845: [FLINK-28902][tests] rename FileSystemJobResultStoreTestInternal to FileSystemJobResultStoreFileOperationsTest

2022-09-15 Thread GitBox
tonyzhu918 opened a new pull request, #20845: URL: https://github.com/apache/flink/pull/20845 ## What is the purpose of the change *rename FileSystemJobResultStoreTestInternal to FileSystemJobResultStoreFileOperationsTest* ## Brief change log - *rename File

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #368: [FLINK-29302] Add helm chart support for setting dns policy and config

2022-09-15 Thread GitBox
morhidi commented on PR #368: URL: https://github.com/apache/flink-kubernetes-operator/pull/368#issuecomment-1248864640 > @morhidi @mbalassi I see that the CI build failed. Looks like a temporary connection issue. Can we rerun the failed step? A simple force push, would do the trick too:

[GitHub] [flink] flinkbot commented on pull request #20844: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask

2022-09-15 Thread GitBox
flinkbot commented on PR #20844: URL: https://github.com/apache/flink/pull/20844#issuecomment-1248844509 ## CI report: * 43072aa7081746795b44485daa42cf683028623d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] sethsaperstein-lyft closed pull request #20843: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask

2022-09-15 Thread GitBox
sethsaperstein-lyft closed pull request #20843: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask URL: https://github.com/apache/flink/pull/20843 -- 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] sethsaperstein-lyft opened a new pull request, #20844: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask

2022-09-15 Thread GitBox
sethsaperstein-lyft opened a new pull request, #20844: URL: https://github.com/apache/flink/pull/20844 ## What is the purpose of the change This pull request updates the global watermark for subtasks marked idle, rather than waiting until the subtask is no longer idle. That way we avo

[GitHub] [flink] sethsaperstein-lyft commented on pull request #20843: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask

2022-09-15 Thread GitBox
sethsaperstein-lyft commented on PR #20843: URL: https://github.com/apache/flink/pull/20843#issuecomment-1248840904 @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 specifi

[jira] [Commented] (FLINK-12312) Temporarily disable CLI command for rescaling

2022-09-15 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605581#comment-17605581 ] Zhanghao Chen commented on FLINK-12312: --- [~gjy] the attached mail thread seems to

[GitHub] [flink] tonyzhu918 closed pull request #20839: [FLINK-28902][tests] rename FileSystemJobResultStoreTestInternal to FileSystemJobResultStoreTest and add Internal to test methods part

2022-09-15 Thread GitBox
tonyzhu918 closed pull request #20839: [FLINK-28902][tests] rename FileSystemJobResultStoreTestInternal to FileSystemJobResultStoreTest and add Internal to test methods part URL: https://github.com/apache/flink/pull/20839 -- This is an automated message from the Apache Git Service. To respon

[jira] [Created] (FLINK-29317) Add WebSocket in Dispatcher to support olap query submission and push results in session cluster

2022-09-15 Thread Shammon (Jira)
Shammon created FLINK-29317: --- Summary: Add WebSocket in Dispatcher to support olap query submission and push results in session cluster Key: FLINK-29317 URL: https://issues.apache.org/jira/browse/FLINK-29317

[jira] [Closed] (FLINK-27388) PulsarSourceEnumeratorTest#discoverPartitionsTriggersAssignments seems flaky

2022-09-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-27388. - Fix Version/s: 1.14.6 1.15.3 Resolution: Fixed https://github.com/apache/flink

[jira] [Closed] (FLINK-28934) Pulsar Source put all the splits to only one parallelism when using Exclusive subscription

2022-09-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-28934. - Fix Version/s: 1.16.0 1.14.6 1.15.3 Assignee: Yufan Sheng

[GitHub] [flink-kubernetes-operator] SteNicholas commented on pull request #368: [FLINK-29302] Add helm chart support for setting dns policy and config

2022-09-15 Thread GitBox
SteNicholas commented on PR #368: URL: https://github.com/apache/flink-kubernetes-operator/pull/368#issuecomment-1248816591 @joaoubaldo, you could reopen this pull request and the CI will be rerun. -- This is an automated message from the Apache Git Service. To respond to the message, ple

[jira] [Assigned] (FLINK-27388) PulsarSourceEnumeratorTest#discoverPartitionsTriggersAssignments seems flaky

2022-09-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-27388: - Assignee: Yufan Sheng > PulsarSourceEnumeratorTest#discoverPartitionsTriggersAssignments seems

[jira] [Closed] (FLINK-28084) Pulsar unordered reader should disable retry and delete reconsume logic.

2022-09-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-28084. - Fix Version/s: 1.14.6 1.15.3 Assignee: Yufan Sheng Resolution: Fixed

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

2022-09-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-27611. - > ConcurrentModificationException during Flink-Pulsar checkpoint notification >

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

2022-09-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-27611: -- Fix Version/s: 1.16.0 1.14.6 1.15.3 > ConcurrentModificationExce

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

2022-09-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-27611. --- Resolution: Fixed https://github.com/apache/flink/pull/20725 > ConcurrentModificationException duri

[jira] [Commented] (FLINK-27400) Pulsar connector subscribed the system topic when using the regex

2022-09-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605567#comment-17605567 ] Zili Chen commented on FLINK-27400: --- https://github.com/apache/flink/pull/20725 > Pul

[jira] [Closed] (FLINK-27400) Pulsar connector subscribed the system topic when using the regex

2022-09-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-27400. - Resolution: Fixed > Pulsar connector subscribed the system topic when using the regex >

[GitHub] [flink] tisonkun merged pull request #20801: [BK-1.14][FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

2022-09-15 Thread GitBox
tisonkun merged PR #20801: URL: https://github.com/apache/flink/pull/20801 -- 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.apac

[GitHub] [flink] tisonkun merged pull request #20793: [BK-1.15][FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

2022-09-15 Thread GitBox
tisonkun merged PR #20793: URL: https://github.com/apache/flink/pull/20793 -- 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.apac

[jira] [Assigned] (FLINK-28639) Preserve distributed consistency of OperatorEvents from subtasks to OperatorCoordinator

2022-09-15 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-28639: Assignee: Yunfeng Zhou > Preserve distributed consistency of OperatorEvents from subtasks to > O

[jira] [Updated] (FLINK-29314) AskTimeoutException for more than two partition with FileSource API on S3

2022-09-15 Thread Satyasheel Satyasheel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satyasheel Satyasheel updated FLINK-29314: -- Priority: Critical (was: Major) > AskTimeoutException for more than two parti

[GitHub] [flink] syhily commented on pull request #20793: [BK-1.15][FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

2022-09-15 Thread GitBox
syhily commented on PR #20793: URL: https://github.com/apache/flink/pull/20793#issuecomment-1248732838 @tisonkun Can we get this backport merged? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[GitHub] [flink] syhily commented on pull request #20801: [BK-1.14][FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

2022-09-15 Thread GitBox
syhily commented on PR #20801: URL: https://github.com/apache/flink/pull/20801#issuecomment-1248732789 @tisonkun Can we get this backport merged? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[GitHub] [flink] flinkbot commented on pull request #20843: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask

2022-09-15 Thread GitBox
flinkbot commented on PR #20843: URL: https://github.com/apache/flink/pull/20843#issuecomment-1248672279 ## CI report: * 43072aa7081746795b44485daa42cf683028623d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] sethsaperstein-lyft opened a new pull request, #20843: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask

2022-09-15 Thread GitBox
sethsaperstein-lyft opened a new pull request, #20843: URL: https://github.com/apache/flink/pull/20843 ## What is the purpose of the change This pull request updates the global watermark for subtasks marked idle, rather than waiting until the subtask is no longer idle. That way we avo

[GitHub] [flink] sethsaperstein-lyft closed pull request #20842: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask

2022-09-15 Thread GitBox
sethsaperstein-lyft closed pull request #20842: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask URL: https://github.com/apache/flink/pull/20842 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[jira] [Commented] (FLINK-14896) Kinesis connector doesn't shade jackson dependency

2022-09-15 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605536#comment-17605536 ] Danny Cranmer commented on FLINK-14896: --- Copy from Slack (https://apache-flink.sl

[jira] [Updated] (FLINK-29099) Deadlock for Single Subtask in Kinesis Consumer

2022-09-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29099: --- Labels: connector consumer kinesis pull-request-available (was: connector consumer kinesis)

[GitHub] [flink] sethsaperstein-lyft opened a new pull request, #20842: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask

2022-09-15 Thread GitBox
sethsaperstein-lyft opened a new pull request, #20842: URL: https://github.com/apache/flink/pull/20842 ## What is the purpose of the change This pull request updates the global watermark for subtasks marked idle, rather than waiting until the subtask is again. That way we avoid a dead

[jira] [Commented] (FLINK-27513) Update table walkthrough playground for 1.15

2022-09-15 Thread Roy Michael (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605530#comment-17605530 ] Roy Michael commented on FLINK-27513: - [~danderson] the PR is ready for review > Up

[jira] [Updated] (FLINK-27513) Update table walkthrough playground for 1.15

2022-09-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27513: --- Labels: pull-request-available starter (was: starter) > Update table walkthrough playground

[GitHub] [flink-playgrounds] roy-michael opened a new pull request, #35: [FLINK-27513][flink-playgrounds] Update table walkthrough playground for 1.15

2022-09-15 Thread GitBox
roy-michael opened a new pull request, #35: URL: https://github.com/apache/flink-playgrounds/pull/35 1. Change Flink version to 1.5.2 2. Use Scala free dependencies 3. Add dependency required for tests to run -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink-kubernetes-operator] joaoubaldo commented on pull request #368: [FLINK-29302] Add helm chart support for setting dns policy and config

2022-09-15 Thread GitBox
joaoubaldo commented on PR #368: URL: https://github.com/apache/flink-kubernetes-operator/pull/368#issuecomment-1248557757 @morhidi @mbalassi I see that the CI build failed. Looks like a temporary connection issue. Can we rerun the failed step? -- This is an automated message from the A

[GitHub] [flink] flinkbot commented on pull request #20841: [FLINK-29263] Remove Elasticsearch connector

2022-09-15 Thread GitBox
flinkbot commented on PR #20841: URL: https://github.com/apache/flink/pull/20841#issuecomment-1248331547 ## CI report: * ebea5bba350eee2ddd0c5c35cebc216fb1f8e168 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-29316) Replicate packaging tests

2022-09-15 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29316: Summary: Replicate packaging tests Key: FLINK-29316 URL: https://issues.apache.org/jira/browse/FLINK-29316 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-29263) Remove Elasticsearch connector from apache/flink repo

2022-09-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29263: --- Labels: pull-request-available (was: ) > Remove Elasticsearch connector from apache/flink r

[GitHub] [flink] zentol opened a new pull request, #20841: [FLINK-29263] Remove Elasticsearch connector

2022-09-15 Thread GitBox
zentol opened a new pull request, #20841: URL: https://github.com/apache/flink/pull/20841 The connector was moved to https://github.com/apache/flink-connector-elasticsearch/. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[jira] [Closed] (FLINK-27142) Decouple SQL client E2E test from Elasticsearch

2022-09-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27142. Fix Version/s: 1.17.0 Resolution: Fixed master: ef93bcace7086a152be239e3d48a2cea7f9

[GitHub] [flink] zentol merged pull request #19923: [FLINK-27142][test] Remove bash tests dependencies on the Elasticsearch connector

2022-09-15 Thread GitBox
zentol merged PR #19923: URL: https://github.com/apache/flink/pull/19923 -- 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-29314) AskTimeoutException for more than two partition with FileSource API on S3

2022-09-15 Thread Satyasheel Satyasheel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satyasheel Satyasheel updated FLINK-29314: -- Description: While using *FileSource.forRecordStreamFormat* api with a build o

[jira] [Commented] (FLINK-28891) Upgrade google-cloud-libraries-bom version to 25.0.0

2022-09-15 Thread Bilna (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605425#comment-17605425 ] Bilna commented on FLINK-28891: --- [~martijnvisser] I would love to contribute. But currentl

[jira] [Updated] (FLINK-29314) AskTimeoutException for more than two partition with FileSource API on S3

2022-09-15 Thread Satyasheel Satyasheel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satyasheel Satyasheel updated FLINK-29314: -- Description: While using *FileSource.forRecordStreamFormat* api with a build o

[GitHub] [flink] XComp commented on a diff in pull request #20839: [FLINK-28902][tests] rename FileSystemJobResultStoreTestInternal to FileSystemJobResultStoreTest and add Internal to test methods par

2022-09-15 Thread GitBox
XComp commented on code in PR #20839: URL: https://github.com/apache/flink/pull/20839#discussion_r972147862 ## flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStoreTest.java: ## @@ -62,11 +62,11 @@ public void setupTest() throws IOExcepti

[jira] [Updated] (FLINK-28902) FileSystemJobResultStoreTestInternal is a unit test that's not following the unit test naming convention

2022-09-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-28902: -- Summary: FileSystemJobResultStoreTestInternal is a unit test that's not following the unit tes

[jira] [Updated] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

2022-09-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29315: - Description: The test started failing 2 days ago on different branches. I suspect somet

[jira] [Commented] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

2022-09-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605422#comment-17605422 ] Chesnay Schepler commented on FLINK-29315: -- master: https://dev.azure.com/apach

[jira] [Created] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

2022-09-15 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29315: Summary: HDFSTest#testBlobServerRecovery fails on CI Key: FLINK-29315 URL: https://issues.apache.org/jira/browse/FLINK-29315 Project: Flink Issue Typ

[jira] [Updated] (FLINK-29314) AskTimeoutException for more than two partition with FileSource API on S3

2022-09-15 Thread Satyasheel Satyasheel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satyasheel Satyasheel updated FLINK-29314: -- Description: While using *FileSource.forRecordStreamFormat* api with a build o

[jira] [Created] (FLINK-29314) AskTimeoutException for more than two partition with FileSource API on S3

2022-09-15 Thread Satyasheel Satyasheel (Jira)
Satyasheel Satyasheel created FLINK-29314: - Summary: AskTimeoutException for more than two partition with FileSource API on S3 Key: FLINK-29314 URL: https://issues.apache.org/jira/browse/FLINK-29314

[jira] [Closed] (FLINK-29310) Setup license checks

2022-09-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29310. Resolution: Fixed main: 1fbdeacb1a31f33a6e532562339d3967e7d0cf4b > Setup license checks >

[GitHub] [flink-connector-elasticsearch] zentol merged pull request #37: [FLINK-29310][ci] Check licensing

2022-09-15 Thread GitBox
zentol merged PR #37: URL: https://github.com/apache/flink-connector-elasticsearch/pull/37 -- 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-unsubs

[GitHub] [flink-connector-elasticsearch] zentol commented on a diff in pull request #37: [FLINK-29310][ci] Check licensing

2022-09-15 Thread GitBox
zentol commented on code in PR #37: URL: https://github.com/apache/flink-connector-elasticsearch/pull/37#discussion_r972093380 ## .github/workflows/ci.yml: ## @@ -53,9 +56,20 @@ jobs: - name: Compile and test flink-connector-elasticsearch timeout-minutes: 20

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

2022-09-15 Thread Tommy Schnabel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605390#comment-17605390 ] Tommy Schnabel commented on FLINK-23886: Hi [~kphan102] and [~yunta] , we found

[GitHub] [flink-connector-elasticsearch] MartijnVisser commented on a diff in pull request #37: [FLINK-29310][ci] Check licensing

2022-09-15 Thread GitBox
MartijnVisser commented on code in PR #37: URL: https://github.com/apache/flink-connector-elasticsearch/pull/37#discussion_r972085632 ## .github/workflows/ci.yml: ## @@ -53,9 +56,20 @@ jobs: - name: Compile and test flink-connector-elasticsearch timeout-minutes:

[GitHub] [flink] MartijnVisser commented on pull request #19923: [FLINK-27142][test] Remove bash tests dependencies on the Elasticsearch connector

2022-09-15 Thread GitBox
MartijnVisser commented on PR #19923: URL: https://github.com/apache/flink/pull/19923#issuecomment-1248203364 Did a full `mvn clean` and a rebuild after, then the tests passed :/ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] lzshlzsh commented on pull request #20838: [FLINK-29306][shell] Fix the error detection of multiple flink-dist-*.jar for config.sh

2022-09-15 Thread GitBox
lzshlzsh commented on PR #20838: URL: https://github.com/apache/flink/pull/20838#issuecomment-1248197786 > Good spot. I've tested the change locally, by calling the function changes manually, and it appears to be working well now. > > I have added my approval, however there is a build

[jira] [Commented] (FLINK-29131) Kubernetes operator webhook can use hostPort

2022-09-15 Thread Dylan Meissner (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605379#comment-17605379 ] Dylan Meissner commented on FLINK-29131: I've abandoned my original approach due

[GitHub] [flink] lzshlzsh commented on pull request #20838: [FLINK-29306][shell] Fix the error detection of multiple flink-dist-*.jar for config.sh

2022-09-15 Thread GitBox
lzshlzsh commented on PR #20838: URL: https://github.com/apache/flink/pull/20838#issuecomment-1248188087 @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-29306) fail to check multiple flink-dist*.jar for config.sh

2022-09-15 Thread Rudi Kershaw (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605375#comment-17605375 ] Rudi Kershaw commented on FLINK-29306: -- [~LiuZeshan], this is a good spot. I've obv

[GitHub] [flink] flinkbot commented on pull request #20840: [FLINK-29309][streaming-java] Relax allow-client-job-configurations for Table API and parameters

2022-09-15 Thread GitBox
flinkbot commented on PR #20840: URL: https://github.com/apache/flink/pull/20840#issuecomment-1248160747 ## CI report: * 634a4cc19bbca8efa6651b6d6dd3828fa76955f3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29309) Relax allow-client-job-configurations for Table API and parameters

2022-09-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29309: --- Labels: pull-request-available (was: ) > Relax allow-client-job-configurations for Table AP

[GitHub] [flink] twalthr opened a new pull request, #20840: [FLINK-29309][streaming-java] Relax allow-client-job-configurations for Table API and parameters

2022-09-15 Thread GitBox
twalthr opened a new pull request, #20840: URL: https://github.com/apache/flink/pull/20840 ## What is the purpose of the change This is the second and hopefully last iteration on the `allow-client-job-configurations` feature. This PR makes sure that both Table API and DataStream API

[GitHub] [flink] MartijnVisser commented on a diff in pull request #19923: [FLINK-27142][test] Remove bash tests dependencies on the Elasticsearch connector

2022-09-15 Thread GitBox
MartijnVisser commented on code in PR #19923: URL: https://github.com/apache/flink/pull/19923#discussion_r972016370 ## flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java: ## @@ -0,0 +1,294 @@ +/* + * Licensed to the Apache Software Foundation (ASF) u

[jira] [Commented] (FLINK-26043) Add periodic kerberos relogin to DelegationTokenManager

2022-09-15 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605359#comment-17605359 ] Gabor Somogyi commented on FLINK-26043: --- That's right. > Add periodic kerberos re

[GitHub] [flink] zentol commented on pull request #19923: [FLINK-27142][test] Remove bash tests dependencies on the Elasticsearch connector

2022-09-15 Thread GitBox
zentol commented on PR #19923: URL: https://github.com/apache/flink/pull/19923#issuecomment-1248122566 What are the contents of `flink-end-to-end-tests/flink-sql-client-test/target/sql-jars`? -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] zentol commented on a diff in pull request #19923: [FLINK-27142][test] Remove bash tests dependencies on the Elasticsearch connector

2022-09-15 Thread GitBox
zentol commented on code in PR #19923: URL: https://github.com/apache/flink/pull/19923#discussion_r972002189 ## flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java: ## @@ -0,0 +1,294 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under on

[GitHub] [flink] MartijnVisser commented on pull request #19923: [FLINK-27142][test] Remove bash tests dependencies on the Elasticsearch connector

2022-09-15 Thread GitBox
MartijnVisser commented on PR #19923: URL: https://github.com/apache/flink/pull/19923#issuecomment-1248115906 > This could mean that the test module must be rebuilt via maven. Prior to running the test, I ran `mvn clean install -DskipTests -Dfast -Pskip-webui-build` on the entire proj

[GitHub] [flink] zentol commented on a diff in pull request #19923: [FLINK-27142][test] Remove bash tests dependencies on the Elasticsearch connector

2022-09-15 Thread GitBox
zentol commented on code in PR #19923: URL: https://github.com/apache/flink/pull/19923#discussion_r972000488 ## flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java: ## @@ -0,0 +1,294 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under on

[GitHub] [flink] zentol commented on pull request #19923: [FLINK-27142][test] Remove bash tests dependencies on the Elasticsearch connector

2022-09-15 Thread GitBox
zentol commented on PR #19923: URL: https://github.com/apache/flink/pull/19923#issuecomment-1248112619 > This could mean that the test module must be rebuilt via maven. Did you follow this suggestion? -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-29311) Unable to use http for Kinesis consumer when testing locally

2022-09-15 Thread Nicolas Pocock (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Pocock updated FLINK-29311: --- Description: I am attempting to run the StateFun docker image locally in a docker-compose s

[jira] [Updated] (FLINK-29311) Unable to use http for Kinesis consumer when testing locally

2022-09-15 Thread Nicolas Pocock (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Pocock updated FLINK-29311: --- Description: I am attempting to run the StateFun docker image locally in a docker-compose s

[jira] [Updated] (FLINK-29311) Unable to use http for Kinesis consumer when testing locally

2022-09-15 Thread Nicolas Pocock (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Pocock updated FLINK-29311: --- Description: I am attempting to run the StateFun docker image locally in a docker-compose s

[GitHub] [flink] MartijnVisser commented on a diff in pull request #19923: [FLINK-27142][test] Remove bash tests dependencies on the Elasticsearch connector

2022-09-15 Thread GitBox
MartijnVisser commented on code in PR #19923: URL: https://github.com/apache/flink/pull/19923#discussion_r971950916 ## flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java: ## @@ -0,0 +1,294 @@ +/* + * Licensed to the Apache Software Foundation (ASF) u

[jira] [Commented] (FLINK-26043) Add periodic kerberos relogin to DelegationTokenManager

2022-09-15 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605341#comment-17605341 ] Rui Li commented on FLINK-26043: I mean what if delegation token is disabled, i.e. {{se

[jira] [Commented] (FLINK-26043) Add periodic kerberos relogin to DelegationTokenManager

2022-09-15 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605326#comment-17605326 ] Gabor Somogyi commented on FLINK-26043: --- The kerberos token manager does the renew

[GitHub] [flink-web] XComp commented on a diff in pull request #569: Release Flink 1.14.6

2022-09-15 Thread GitBox
XComp commented on code in PR #569: URL: https://github.com/apache/flink-web/pull/569#discussion_r971946211 ## _posts/2022-09-08-release-1.14.6.md: ## @@ -0,0 +1,105 @@ +--- +layout: post +title: "Apache Flink 1.14.6 Release Announcement" +date: 2022-09-08T00:00:00.000Z +catego

[GitHub] [flink] tonyzhu918 commented on pull request #20839: [FLINK-28902][tests] rename FileSystemJobResultStoreTestInternal to FileSystemJobResultStoreTest and add Internal to test methods part

2022-09-15 Thread GitBox
tonyzhu918 commented on PR #20839: URL: https://github.com/apache/flink/pull/20839#issuecomment-1248061301 @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

[GitHub] [flink] zjuwangg commented on a diff in pull request #20542: [FLINK-28910][Connectors/hbase]Fix potential data deletion while updating HBase rows

2022-09-15 Thread GitBox
zjuwangg commented on code in PR #20542: URL: https://github.com/apache/flink/pull/20542#discussion_r971943575 ## flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java: ## @@ -191,8 +195,10 @@ private void checkErr

[GitHub] [flink] zjuwangg commented on a diff in pull request #20542: [FLINK-28910][Connectors/hbase]Fix potential data deletion while updating HBase rows

2022-09-15 Thread GitBox
zjuwangg commented on code in PR #20542: URL: https://github.com/apache/flink/pull/20542#discussion_r971943575 ## flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java: ## @@ -191,8 +195,10 @@ private void checkErr

[GitHub] [flink] zjuwangg commented on a diff in pull request #20542: [FLINK-28910][Connectors/hbase]Fix potential data deletion while updating HBase rows

2022-09-15 Thread GitBox
zjuwangg commented on code in PR #20542: URL: https://github.com/apache/flink/pull/20542#discussion_r971943575 ## flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java: ## @@ -191,8 +195,10 @@ private void checkErr

[GitHub] [flink-connector-elasticsearch] zentol commented on a diff in pull request #37: [FLINK-29310][ci] Check licensing

2022-09-15 Thread GitBox
zentol commented on code in PR #37: URL: https://github.com/apache/flink-connector-elasticsearch/pull/37#discussion_r971912006 ## pom.xml: ## @@ -51,6 +51,15 @@ under the License. + + + Review Comment:

[jira] [Commented] (FLINK-26043) Add periodic kerberos relogin to DelegationTokenManager

2022-09-15 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605315#comment-17605315 ] Rui Li commented on FLINK-26043: Hey [~gaborgsomogyi], just curious, does the periodical

[GitHub] [flink-connector-elasticsearch] zentol commented on a diff in pull request #37: [FLINK-29310][ci] Check licensing

2022-09-15 Thread GitBox
zentol commented on code in PR #37: URL: https://github.com/apache/flink-connector-elasticsearch/pull/37#discussion_r971912006 ## pom.xml: ## @@ -51,6 +51,15 @@ under the License. + + + Review Comment:

[jira] [Updated] (FLINK-29310) Setup license checks

2022-09-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29310: --- Labels: pull-request-available (was: ) > Setup license checks > > >

[GitHub] [flink-connector-elasticsearch] zentol opened a new pull request, #37: [FLINK-29310][ci] Check licensing

2022-09-15 Thread GitBox
zentol opened a new pull request, #37: URL: https://github.com/apache/flink-connector-elasticsearch/pull/37 Runs the NoticeFileChecker on CI. Additionally changes CI logging to output to the console, since otherwise we don't see any license checker output. -- This is an automated m

[jira] [Closed] (FLINK-17969) Enhance Flink (Task) logging to include job name as context diagnostic information

2022-09-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-17969. Resolution: Won't Fix > Enhance Flink (Task) logging to include job name as context diagno

[jira] [Resolved] (FLINK-28341) Fix comment in BytesKeyNormalizationUtil.java

2022-09-15 Thread shen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shen resolved FLINK-28341. -- Fix Version/s: 1.17.0 Resolution: Fixed > Fix comment in BytesKeyNormalizationUtil.java > -

  1   2   >