[jira] [Commented] (FLINK-29200) Provide the way to delay the pod deletion for debugging purpose

2022-09-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605125#comment-17605125 ] Aitozi commented on FLINK-29200: Make sense, Closing it now > Provide the way to delay

[jira] [Closed] (FLINK-29200) Provide the way to delay the pod deletion for debugging purpose

2022-09-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-29200. -- Resolution: Won't Fix > Provide the way to delay the pod deletion for debugging purpose >

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

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

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

2022-09-14 Thread Tony Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605120#comment-17605120 ] Tony Zhu edited comment on FLINK-28902 at 9/15/22 5:39 AM: --- I

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

2022-09-14 Thread Tony Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605120#comment-17605120 ] Tony Zhu edited comment on FLINK-28902 at 9/15/22 5:38 AM: --- I

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

2022-09-14 Thread Tony Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605120#comment-17605120 ] Tony Zhu commented on FLINK-28902: -- I created this PR. Could you help review please >

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

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

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

2022-09-14 Thread GitBox
tonyzhu918 opened a new pull request, #20839: URL: https://github.com/apache/flink/pull/20839 ## What is the purpose of the change *rename FileSystemJobResultStoreTestInternal to FileSystemJobResultStoreTest and add Internal to test methods part* ## Brief change log

[jira] [Commented] (FLINK-29308) NoResourceAvailableException fails the batch job

2022-09-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605118#comment-17605118 ] Aitozi commented on FLINK-29308: cc [~xtsong] , [~wangyang0918] What do you think ? > N

[jira] [Updated] (FLINK-29308) NoResourceAvailableException fails the batch job

2022-09-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-29308: --- Description: When running batch job configured with the following restart strategy {code:java} restart-strat

[jira] [Created] (FLINK-29308) NoResourceAvailableException fails the batch job

2022-09-14 Thread Aitozi (Jira)
Aitozi created FLINK-29308: -- Summary: NoResourceAvailableException fails the batch job Key: FLINK-29308 URL: https://issues.apache.org/jira/browse/FLINK-29308 Project: Flink Issue Type: Improvement

[GitHub] [flink] harker2015 commented on a diff in pull request #20835: [FLINK-29287][tests] Rewrite sql-client packaging tests

2022-09-14 Thread GitBox
harker2015 commented on code in PR #20835: URL: https://github.com/apache/flink/pull/20835#discussion_r971531077 ## flink-test-utils-parent/flink-test-utils/src/test/java/org/apache/flink/packaging/PackagingTestUtilsTest.java: ## @@ -0,0 +1,134 @@ +/* + * Licensed to the Apache

[jira] [Created] (FLINK-29307) Fix timeInQueue in CheckpointRequestDecider

2022-09-14 Thread chenzihao (Jira)
chenzihao created FLINK-29307: - Summary: Fix timeInQueue in CheckpointRequestDecider Key: FLINK-29307 URL: https://issues.apache.org/jira/browse/FLINK-29307 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-29299) Fix the network memory size calculation issue in fine-grained resource mode

2022-09-14 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-29299: Issue Type: Bug (was: Improvement) > Fix the network memory size calculation issue in fine-graine

[GitHub] [flink] wsry merged pull request #20834: [FLINK-29299][network] Fix the network memory size calculation issue in fine-grained resource mode

2022-09-14 Thread GitBox
wsry merged PR #20834: URL: https://github.com/apache/flink/pull/20834 -- 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] chenyuzhi459 commented on pull request #20782: [FLINK-29195] Expose lastCompletedCheckpointId metric

2022-09-14 Thread GitBox
chenyuzhi459 commented on PR #20782: URL: https://github.com/apache/flink/pull/20782#issuecomment-1247479362 @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 comme

[GitHub] [flink] jinyius commented on pull request #20786: [hotfix] make ParquetProtoWriters.ParquetProtoWriterBuilder public

2022-09-14 Thread GitBox
jinyius commented on PR #20786: URL: https://github.com/apache/flink/pull/20786#issuecomment-1247345215 ping -- 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,

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

2022-09-14 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604983#comment-17604983 ] Alexander Fedulov commented on FLINK-14896: --- [~danny.cranmer] could you addres

[jira] [Closed] (FLINK-29303) Add DockerImageVersions

2022-09-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29303. Resolution: Fixed main: 861b6fc53079a407714a5815cdc45e083226393e > Add DockerImageVersion

[GitHub] [flink-connector-elasticsearch] zentol merged pull request #33: [FLINK-29303][tests] Add DockerImageVersions

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

[jira] [Closed] (FLINK-29301) Publish java-ci-tools

2022-09-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29301. Resolution: Fixed master: 2d6fa8876a66679c21743c506d7b8f3c5692f7bc..bb23cf7b2f69fef0264e0

[GitHub] [flink] zentol merged pull request #20836: [FLINK-29301] Publish flink-ci-tools

2022-09-14 Thread GitBox
zentol merged PR #20836: URL: https://github.com/apache/flink/pull/20836 -- 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] zentol commented on pull request #20837: [FLINK-29305][tests] UpsertTestSinkWriter creates parent directories

2022-09-14 Thread GitBox
zentol commented on PR #20837: URL: https://github.com/apache/flink/pull/20837#issuecomment-1247292644 @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

[GitHub] [flink] alpinegizmo commented on a diff in pull request #20836: [FLINK-29301] Publish flink-ci-tools

2022-09-14 Thread GitBox
alpinegizmo commented on code in PR #20836: URL: https://github.com/apache/flink/pull/20836#discussion_r971266850 ## tools/ci/flink-ci-tools/src/main/java/org/apache/flink/tools/ci/licensecheck/NoticeFileChecker.java: ## @@ -62,6 +62,10 @@ public class NoticeFileChecker { p

[GitHub] [flink] zentol commented on pull request #20836: [FLINK-29301] Publish flink-ci-tools

2022-09-14 Thread GitBox
zentol commented on PR #20836: URL: https://github.com/apache/flink/pull/20836#issuecomment-1247258952 We don't really have tests for NoticeChecker, however one can infer the correctness from the logging output on CI: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=41

[GitHub] [flink] zentol commented on pull request #20837: [FLINK-29305][tests] UpsertTestSinkWriter creates parent directories

2022-09-14 Thread GitBox
zentol commented on PR #20837: URL: https://github.com/apache/flink/pull/20837#issuecomment-1247252769 @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] [Resolved] (FLINK-28937) Add doc for SqlGateway

2022-09-14 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-28937. Resolution: Duplicate > Add doc for SqlGateway > -- > >

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

2022-09-14 Thread Khoa Phan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604923#comment-17604923 ] Khoa Phan commented on FLINK-23886: --- I also received this error in version 1.15.2. Not

[GitHub] [flink] alpinegizmo commented on pull request #20836: [FLINK-29301] Publish flink-ci-tools

2022-09-14 Thread GitBox
alpinegizmo commented on PR #20836: URL: https://github.com/apache/flink/pull/20836#issuecomment-1247158004 Overall the code in licensecheck/NoticeFileChecker.java is complex enough that I'm wondering how we know for sure that it works. Are there tests somewhere? -- This is an automated

[GitHub] [flink] RyanSkraba commented on a diff in pull request #20835: [FLINK-29287][tests] Rewrite sql-client packaging tests

2022-09-14 Thread GitBox
RyanSkraba commented on code in PR #20835: URL: https://github.com/apache/flink/pull/20835#discussion_r971112886 ## flink-test-utils-parent/flink-test-utils/src/test/java/org/apache/flink/packaging/PackagingTestUtilsTest.java: ## @@ -0,0 +1,138 @@ +/* + * Licensed to the Apache

[jira] [Comment Edited] (FLINK-18647) How to handle processing time timers with bounded input

2022-09-14 Thread Divye Kapoor (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604879#comment-17604879 ] Divye Kapoor edited comment on FLINK-18647 at 9/14/22 5:55 PM: ---

[jira] [Comment Edited] (FLINK-18647) How to handle processing time timers with bounded input

2022-09-14 Thread Divye Kapoor (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604879#comment-17604879 ] Divye Kapoor edited comment on FLINK-18647 at 9/14/22 5:54 PM: ---

[jira] [Commented] (FLINK-18647) How to handle processing time timers with bounded input

2022-09-14 Thread Divye Kapoor (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604879#comment-17604879 ] Divye Kapoor commented on FLINK-18647: -- Here are 3 usecases to solve as part of add

[GitHub] [flink] zentol commented on pull request #20827: [backport][FLINK-28733][scripts] jobmanager.sh supports dynamic parameters

2022-09-14 Thread GitBox
zentol commented on PR #20827: URL: https://github.com/apache/flink/pull/20827#issuecomment-1247089618 rebase the PR. _You_ can also push into #20716; there's no need to create a separate PR. -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Commented] (FLINK-29306) fail to check multiple flink-dist*.jar for config.sh

2022-09-14 Thread LiuZeshan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604870#comment-17604870 ] LiuZeshan commented on FLINK-29306: --- [~rudi.kershaw] would you please to have a look ?

[GitHub] [flink] flinkbot commented on pull request #20838: [FLINK-29306][shell] Fix the error detection of multiple flink-dist-*…

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

[jira] [Updated] (FLINK-29306) fail to check multiple flink-dist*.jar for config.sh

2022-09-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29306: --- Labels: pull-request-available (was: ) > fail to check multiple flink-dist*.jar for config.

[GitHub] [flink] lzshlzsh opened a new pull request, #20838: [FLINK-29306][shell] Fix the error detection of multiple flink-dist-*…

2022-09-14 Thread GitBox
lzshlzsh opened a new pull request, #20838: URL: https://github.com/apache/flink/pull/20838 ## What is the purpose of the change The following shell command always make FLINK_DIST_COUNT=1 `FLINK_DIST_COUNT="$(echo "$FLINK_DIST" | wc -l)" ` and the following condition wil

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #365: [FLINK-29257] Clarify description of SAVEPOINT upgrade mode

2022-09-14 Thread GitBox
gyfora commented on code in PR #365: URL: https://github.com/apache/flink-kubernetes-operator/pull/365#discussion_r971089439 ## docs/content/docs/custom-resource/job-management.md: ## @@ -98,8 +98,8 @@ The `upgradeMode` setting controls both the stop and restore mechanisms as

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #365: [FLINK-29257] Clarify description of SAVEPOINT upgrade mode

2022-09-14 Thread GitBox
mxm commented on code in PR #365: URL: https://github.com/apache/flink-kubernetes-operator/pull/365#discussion_r971055611 ## docs/content/docs/custom-resource/job-management.md: ## @@ -98,8 +98,8 @@ The `upgradeMode` setting controls both the stop and restore mechanisms as det

[jira] [Updated] (FLINK-29305) UpsertTestSinkWriter fails if parent of output file does not exist

2022-09-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29305: --- Labels: pull-request-available (was: ) > UpsertTestSinkWriter fails if parent of output fil

[GitHub] [flink] flinkbot commented on pull request #20837: [FLINK-29305][tests] UpsertTestSinkWriter creates parent directories

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

[jira] [Updated] (FLINK-29306) fail to check multiple flink-dist*.jar for config.sh

2022-09-14 Thread LiuZeshan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-29306: -- Description: The following shell command always make FLINK_DIST_COUNT=1 ([config.sh|https://github.co

[jira] [Created] (FLINK-29306) fail to check multiple flink-dist*.jar for config.sh

2022-09-14 Thread LiuZeshan (Jira)
LiuZeshan created FLINK-29306: - Summary: fail to check multiple flink-dist*.jar for config.sh Key: FLINK-29306 URL: https://issues.apache.org/jira/browse/FLINK-29306 Project: Flink Issue Type: Bu

[jira] [Closed] (FLINK-29206) Default Flink configuration contains irrelevant settings

2022-09-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29206. -- Resolution: Won't Fix This is an intentional design , and configs never overlap. The user shouldn’t n

[jira] [Created] (FLINK-29305) UpsertTestSinkWriter fails if parent of output file does not exist

2022-09-14 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29305: Summary: UpsertTestSinkWriter fails if parent of output file does not exist Key: FLINK-29305 URL: https://issues.apache.org/jira/browse/FLINK-29305 Project: F

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

2022-09-14 Thread GitBox
zentol commented on PR #19923: URL: https://github.com/apache/flink/pull/19923#issuecomment-1247032078 Rebased and fixed all the issue I could find. -- 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 t

[GitHub] [flink-kubernetes-operator] mxm commented on pull request #365: [FLINK-29257] Clarify description of SAVEPOINT upgrade mode

2022-09-14 Thread GitBox
mxm commented on PR #365: URL: https://github.com/apache/flink-kubernetes-operator/pull/365#issuecomment-1247029744 Updated. -- 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-kubernetes-operator] mxm commented on a diff in pull request #365: [FLINK-29257] Clarify description of SAVEPOINT upgrade mode

2022-09-14 Thread GitBox
mxm commented on code in PR #365: URL: https://github.com/apache/flink-kubernetes-operator/pull/365#discussion_r971055611 ## docs/content/docs/custom-resource/job-management.md: ## @@ -98,8 +98,8 @@ The `upgradeMode` setting controls both the stop and restore mechanisms as det

[jira] [Commented] (FLINK-29258) Add SAVEPOINT_ONLY upgrade mode

2022-09-14 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604835#comment-17604835 ] Maximilian Michels commented on FLINK-29258: That's good to know but how doe

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

2022-09-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-27142: Assignee: Chesnay Schepler > Decouple SQL client E2E test from Elasticsearch > --

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #367: [FLINK-29283] Remove hardcoded apiVersion from operator unit test

2022-09-14 Thread GitBox
gyfora commented on PR #367: URL: https://github.com/apache/flink-kubernetes-operator/pull/367#issuecomment-1247020197 Later if we feel like it we can parameterize these tests when new versions come around that change the serialization logic -- This is an automated message from the Apac

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #367: [FLINK-29283] Remove hardcoded apiVersion from operator unit test

2022-09-14 Thread GitBox
gyfora commented on PR #367: URL: https://github.com/apache/flink-kubernetes-operator/pull/367#issuecomment-1247019482 Having hard coded versions serve as a basic form of backward compatibility test . I think we should not change these. -- This is an automated message from the Apache Git

[jira] [Comment Edited] (FLINK-29288) Can't start a job with a jar in the system classpath

2022-09-14 Thread Yaroslav Tkachenko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603817#comment-17603817 ] Yaroslav Tkachenko edited comment on FLINK-29288 at 9/14/22 4:13 PM: -

[jira] [Created] (FLINK-29304) Set timeout on CI

2022-09-14 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29304: Summary: Set timeout on CI Key: FLINK-29304 URL: https://issues.apache.org/jira/browse/FLINK-29304 Project: Flink Issue Type: Technical Debt

[jira] [Closed] (FLINK-29285) Publish TestUtils#getResource

2022-09-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29285. Resolution: Fixed master: 469049a4359aea40f083bb2b7e4fbc1f86b65ce9 1.16: b1a2a5c2d2a9d8e2c

[jira] [Closed] (FLINK-29282) Decouple Quickstart E2E test from Elasticsearch

2022-09-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29282. Resolution: Fixed master: db98322472cb65ca0358ec1cce7f9ef737198189 > Decouple Quickstart

[GitHub] [flink] zentol merged pull request #20825: [FLINK-29282][tests] Decouple Quickstart E2E test from Elasticsearch

2022-09-14 Thread GitBox
zentol merged PR #20825: URL: https://github.com/apache/flink/pull/20825 -- 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] zentol merged pull request #20828: [FLINK-29285][tests] Move TestUtils#getResource

2022-09-14 Thread GitBox
zentol merged PR #20828: URL: https://github.com/apache/flink/pull/20828 -- 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] [Closed] (FLINK-29101) PipelinedRegionSchedulingStrategy benchmark shows performance degradation

2022-09-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29101. Resolution: Fixed - master (1.17): c0165a8a7e3ccc6e82df7a30c67497a10e281153 - release-1.16: eefeb6

[GitHub] [flink] xintongsong closed pull request #20739: [FLINK-29101] PipelinedRegionSchedulingStrategy benchmark shows performance degradation

2022-09-14 Thread GitBox
xintongsong closed pull request #20739: [FLINK-29101] PipelinedRegionSchedulingStrategy benchmark shows performance degradation URL: https://github.com/apache/flink/pull/20739 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[jira] [Commented] (FLINK-29283) Remove hardcoded apiVersion from operator unit test

2022-09-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-29283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604772#comment-17604772 ] Márton Balassi commented on FLINK-29283: Thanks, in the meantime there is a PR o

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

2022-09-14 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-27513: -- Assignee: Roy Michael > Update table walkthrough playground for 1.15 > --

[jira] [Assigned] (FLINK-27512) Update pyflink walkthrough playground for 1.15

2022-09-14 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-27512: -- Assignee: Roy Michael > Update pyflink walkthrough playground for 1.15 >

[jira] [Commented] (FLINK-29283) Remove hardcoded apiVersion from operator unit test

2022-09-14 Thread Tony Garrard (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604758#comment-17604758 ] Tony Garrard commented on FLINK-29283: -- Absolutely, assign it to me > Remove hardc

[jira] [Assigned] (FLINK-27511) Update operations playground for 1.15

2022-09-14 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-27511: -- Assignee: Roy Michael > Update operations playground for 1.15 > -

[jira] [Commented] (FLINK-27510) update playgrounds for Flink 1.15

2022-09-14 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604756#comment-17604756 ] David Anderson commented on FLINK-27510: [~roy.m...@gmail.com] Thank you! I'm as

[jira] [Assigned] (FLINK-27510) update playgrounds for Flink 1.15

2022-09-14 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-27510: -- Assignee: Roy Michael > update playgrounds for Flink 1.15 > -

[GitHub] [flink] xintongsong commented on pull request #20739: [FLINK-29101] PipelinedRegionSchedulingStrategy benchmark shows performance degradation

2022-09-14 Thread GitBox
xintongsong commented on PR #20739: URL: https://github.com/apache/flink/pull/20739#issuecomment-1246825185 @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 commen

[GitHub] [flink] lincoln-lil commented on pull request #20679: [FLINK-28738][table-planner] Adds a user doc about the determinism in streaming

2022-09-14 Thread GitBox
lincoln-lil commented on PR #20679: URL: https://github.com/apache/flink/pull/20679#issuecomment-1246820673 @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 commen

[GitHub] [flink] chenyuzhi459 commented on a diff in pull request #20782: [FLINK-29195] Expose lastCompletedCheckpointId metric

2022-09-14 Thread GitBox
chenyuzhi459 commented on code in PR #20782: URL: https://github.com/apache/flink/pull/20782#discussion_r970826122 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java: ## @@ -327,6 +327,9 @@ public void reportIncompleteStats( stati

[GitHub] [flink] chenyuzhi459 commented on pull request #20782: [FLINK-29195] Expose lastCompletedCheckpointId metric

2022-09-14 Thread GitBox
chenyuzhi459 commented on PR #20782: URL: https://github.com/apache/flink/pull/20782#issuecomment-1246783052 @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 comme

[GitHub] [flink] tweise commented on pull request #20485: [FLINK-28853][connector-base] Add FLIP-217 support for watermark alignment of source splits

2022-09-14 Thread GitBox
tweise commented on PR #20485: URL: https://github.com/apache/flink/pull/20485#issuecomment-1246779270 Exciting to see this make the finish line! This was a long awaited feature (we implemented alignment for the Kinesis source ~4 years ago). Let's see how it holds up in production use cases

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

2022-09-14 Thread GitBox
morhidi commented on PR #368: URL: https://github.com/apache/flink-kubernetes-operator/pull/368#issuecomment-1246752865 +1 from me. cc @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 to go to t

[GitHub] [flink] dawidwys commented on pull request #20485: [FLINK-28853][connector-base] Add FLIP-217 support for watermark alignment of source splits

2022-09-14 Thread GitBox
dawidwys commented on PR #20485: URL: https://github.com/apache/flink/pull/20485#issuecomment-1246745732 Thank you for taking over! @mxm -- 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 speci

[jira] [Updated] (FLINK-29303) Add DockerImageVersions

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

[GitHub] [flink-connector-elasticsearch] zentol opened a new pull request, #33: [FLINK-29303][tests] Add DockerImageVersions

2022-09-14 Thread GitBox
zentol opened a new pull request, #33: URL: https://github.com/apache/flink-connector-elasticsearch/pull/33 We need this to be decoupled from Flink. -- 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 t

[jira] [Created] (FLINK-29303) Add DockerImageVersions

2022-09-14 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29303: Summary: Add DockerImageVersions Key: FLINK-29303 URL: https://issues.apache.org/jira/browse/FLINK-29303 Project: Flink Issue Type: Sub-task

[jira] [Resolved] (FLINK-28853) FLIP-217 Support watermark alignment of source splits

2022-09-14 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-28853. Resolution: Fixed Implemented as of 0612a997ddcc791ee54f500fbf1299ce04987679. > F

[jira] [Assigned] (FLINK-28853) FLIP-217 Support watermark alignment of source splits

2022-09-14 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-28853: -- Assignee: Maximilian Michels (was: Sebastian Mattheis) > FLIP-217 Support wa

[GitHub] [flink] mxm commented on pull request #20485: [FLINK-28853][connector-base] Add FLIP-217 support for watermark alignment of source splits

2022-09-14 Thread GitBox
mxm commented on PR #20485: URL: https://github.com/apache/flink/pull/20485#issuecomment-1246726404 Thank you everyone! -- 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] mxm merged pull request #20485: [FLINK-28853][connector-base] Add FLIP-217 support for watermark alignment of source splits

2022-09-14 Thread GitBox
mxm merged PR #20485: URL: https://github.com/apache/flink/pull/20485 -- 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.or

[jira] [Closed] (FLINK-29251) Send CREATED status and Cancel event via FlinkResourceListener

2022-09-14 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise closed FLINK-29251. Resolution: Fixed > Send CREATED status and Cancel event via FlinkResourceListener > -

[jira] [Updated] (FLINK-29287) Add PackagingTestUtils

2022-09-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29287: - Priority: Blocker (was: Major) > Add PackagingTestUtils > -- > >

[jira] [Updated] (FLINK-29285) Publish TestUtils#getResource

2022-09-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29285: - Priority: Blocker (was: Major) > Publish TestUtils#getResource > --

[jira] [Updated] (FLINK-29301) Publish java-ci-tools

2022-09-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29301: - Priority: Blocker (was: Major) > Publish java-ci-tools > - > >

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

2022-09-14 Thread GitBox
joaoubaldo commented on PR #368: URL: https://github.com/apache/flink-kubernetes-operator/pull/368#issuecomment-1246691933 @morhidi I don't know of a use case that requires different DNS settings for each of these containers. Since these are Pod level attributes, the webhook container will

[GitHub] [flink-kubernetes-operator] tweise merged pull request #366: [FLINK-29251] Send CREATED status and Cancel event via FlinkResourceListener

2022-09-14 Thread GitBox
tweise merged PR #366: URL: https://github.com/apache/flink-kubernetes-operator/pull/366 -- 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

[GitHub] [flink] flinkbot commented on pull request #20836: [FLINK-29301] Publish flink-ci-tools

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

[jira] [Updated] (FLINK-29301) Publish java-ci-tools

2022-09-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29301: --- Labels: pull-request-available (was: ) > Publish java-ci-tools > - > >

[GitHub] [flink] zentol opened a new pull request, #20836: [FLINK-29301] Publish flink-ci-tools

2022-09-14 Thread GitBox
zentol opened a new pull request, #20836: URL: https://github.com/apache/flink/pull/20836 Publish the `java-ci-tools` (after renaming them to flink-ci-tools) so that external connectors can also use it for license checks etc. Additionally fixes a few issues about resources and modules

[GitHub] [flink] mhv666 commented on pull request #20343: [FLINK-25916][connector-kafka] Using upsert-kafka with a flush buffer…

2022-09-14 Thread GitBox
mhv666 commented on PR #20343: URL: https://github.com/apache/flink/pull/20343#issuecomment-1246679458 @paul8263 I'm currently facing this issue, do you know when it will be merge it? thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log

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

2022-09-14 Thread GitBox
morhidi commented on PR #368: URL: https://github.com/apache/flink-kubernetes-operator/pull/368#issuecomment-1246677686 LGTM. qq: Will the webhook container ever need such setting? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

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

2022-09-14 Thread Marti (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604055#comment-17604055 ] Marti commented on FLINK-25916: --- Hi all, do you know when this MR will be merged? I'm cur

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #262: [FLINK-28810] Introduce write.skip-compaction to skip compaction on write

2022-09-14 Thread GitBox
SteNicholas commented on code in PR #262: URL: https://github.com/apache/flink-table-store/pull/262#discussion_r970712169 ## flink-table-store-core/src/test/java/org/apache/flink/table/store/table/FileStoreTableTestBase.java: ## @@ -175,6 +181,40 @@ public void testReadFilter()

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #262: [FLINK-28810] Introduce write.skip-compaction to skip compaction on write

2022-09-14 Thread GitBox
SteNicholas commented on code in PR #262: URL: https://github.com/apache/flink-table-store/pull/262#discussion_r970710912 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/data/AppendOnlyCompactManager.java: ## @@ -58,10 +59,9 @@ public AppendOnlyCompactM

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #262: [FLINK-28810] Introduce write.skip-compaction to skip compaction on write

2022-09-14 Thread GitBox
SteNicholas commented on code in PR #262: URL: https://github.com/apache/flink-table-store/pull/262#discussion_r970709006 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/compact/CompactManager.java: ## @@ -40,14 +42,28 @@ public CompactManager(ExecutorS

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #262: [FLINK-28810] Introduce write.skip-compaction to skip compaction on write

2022-09-14 Thread GitBox
SteNicholas commented on code in PR #262: URL: https://github.com/apache/flink-table-store/pull/262#discussion_r970707701 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/data/AppendOnlyWriter.java: ## @@ -160,37 +158,19 @@ public List close() throws Exc

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #262: [FLINK-28810] Introduce write.skip-compaction to skip compaction on write

2022-09-14 Thread GitBox
SteNicholas commented on code in PR #262: URL: https://github.com/apache/flink-table-store/pull/262#discussion_r970707138 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/compact/CompactManager.java: ## @@ -40,14 +42,28 @@ public CompactManager(ExecutorS

[GitHub] [flink] SmirAlex commented on a diff in pull request #20734: [FLINK-29093][table] Fix InternalCompilerException in LookupJoinITCase + reset resource counter before each test

2022-09-14 Thread GitBox
SmirAlex commented on code in PR #20734: URL: https://github.com/apache/flink/pull/20734#discussion_r970670535 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/fullcache/LookupFullCache.java: ## @@ -72,6 +72,13 @@ public sync

  1   2   >