[jira] [Created] (FLINK-26575) Improve the info message when restoring keyed state backend

2022-03-10 Thread Yun Tang (Jira)
Yun Tang created FLINK-26575: Summary: Improve the info message when restoring keyed state backend Key: FLINK-26575 URL: https://issues.apache.org/jira/browse/FLINK-26575 Project: Flink Issue Ty

[GitHub] [flink] Myasuka opened a new pull request #19034: [FLINK-26575][checkpoint] Improve the info message when restoring keyed state backend

2022-03-10 Thread GitBox
Myasuka opened a new pull request #19034: URL: https://github.com/apache/flink/pull/19034 ## What is the purpose of the change Improve the info message when restoring keyed state backend to avoid too long message. From ~~~ 7183 [OverAggregate[4] -> Calc[5] -> Si

[jira] [Updated] (FLINK-26575) Improve the info message when restoring keyed state backend

2022-03-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26575: --- Labels: pull-request-available (was: ) > Improve the info message when restoring keyed stat

[GitHub] [flink] fapaul merged pull request #18996: [FLINK-26492][metric] deprecate umRecordsOutErrorsCounter

2022-03-10 Thread GitBox
fapaul merged pull request #18996: URL: https://github.com/apache/flink/pull/18996 -- 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

[jira] [Commented] (FLINK-26492) rename numRecordsOutErrors to numRecordsSendErrors in SinkWriterMetricGroup

2022-03-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504070#comment-17504070 ] Fabian Paul commented on FLINK-26492: - Merged in master: 29be5ce4be965cfeee32ddbdce1

[jira] [Resolved] (FLINK-26492) rename numRecordsOutErrors to numRecordsSendErrors in SinkWriterMetricGroup

2022-03-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-26492. - Resolution: Fixed > rename numRecordsOutErrors to numRecordsSendErrors in SinkWriterMetricGroup

[jira] [Closed] (FLINK-26492) rename numRecordsOutErrors to numRecordsSendErrors in SinkWriterMetricGroup

2022-03-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-26492. --- > rename numRecordsOutErrors to numRecordsSendErrors in SinkWriterMetricGroup > --

[GitHub] [flink] flinkbot edited a comment on pull request #18776: [FLINK-26151][streaming]Avoid inprogressfileRecoverable not be clean up after restoring the bucket

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #18776: URL: https://github.com/apache/flink/pull/18776#issuecomment-1040098864 ## CI report: * e7a42620acc196ee86d7d9b29cc53dbb5ae521c2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

2022-03-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26565: --- Component/s: Table SQL / API Table SQL / Planner Table SQL

[GitHub] [flink] flinkbot edited a comment on pull request #19008: [FLINK-26536] [python] Fix PyFlink RemoteKeyedStateBackend#merge_namespaces bugs

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19008: URL: https://github.com/apache/flink/pull/19008#issuecomment-1061583264 ## CI report: * 1b1d3595f0828f045964e58687d4a481c21ea843 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #19034: [FLINK-26575][checkpoint] Improve the info message when restoring keyed state backend

2022-03-10 Thread GitBox
flinkbot commented on pull request #19034: URL: https://github.com/apache/flink/pull/19034#issuecomment-1063770570 ## CI report: * 1ef4d30cde770fab2e50fe5398b673f6aa351968 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-26559) Support Customized Kubernetes Schedulers for Flink Kubernetes

2022-03-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504071#comment-17504071 ] Martijn Visser commented on FLINK-26559: [~bzhaoop] Will you create a FLIP on h

[jira] [Commented] (FLINK-26556) Refactoring MiniCluster and TestingMiniCluster

2022-03-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504072#comment-17504072 ] Martijn Visser commented on FLINK-26556: [~slinkydeveloper] Just pinging you bec

[jira] [Created] (FLINK-26576) The value of 'readerParallelism' passed to ContinuousFileMonitoringFunction is wrong

2022-03-10 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-26576: -- Summary: The value of 'readerParallelism' passed to ContinuousFileMonitoringFunction is wrong Key: FLINK-26576 URL: https://issues.apache.org/jira/browse/FLINK-26576 Proj

[GitHub] [flink] flinkbot edited a comment on pull request #19008: [FLINK-26536] [python] Fix PyFlink RemoteKeyedStateBackend#merge_namespaces bugs

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19008: URL: https://github.com/apache/flink/pull/19008#issuecomment-1061583264 ## CI report: * 1b1d3595f0828f045964e58687d4a481c21ea843 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19034: [FLINK-26575][checkpoint] Improve the info message when restoring keyed state backend

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19034: URL: https://github.com/apache/flink/pull/19034#issuecomment-1063770570 ## CI report: * 1ef4d30cde770fab2e50fe5398b673f6aa351968 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26576) The value of 'readerParallelism' passed to ContinuousFileMonitoringFunction is wrong

2022-03-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-26576: --- Description: In [StreamExecutionEnvironment#createFileInput |https://github.com/apache/flink/blob/m

[jira] [Commented] (FLINK-26322) Test FileSink compaction manually

2022-03-10 Thread Alexander Preuss (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504074#comment-17504074 ] Alexander Preuss commented on FLINK-26322: -- Hi guys, I tested against master wi

[jira] [Created] (FLINK-26577) Avoid state loss when switching to last-state upgrade mode

2022-03-10 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26577: -- Summary: Avoid state loss when switching to last-state upgrade mode Key: FLINK-26577 URL: https://issues.apache.org/jira/browse/FLINK-26577 Project: Flink Issue

[jira] [Commented] (FLINK-26577) Avoid state loss when switching to last-state upgrade mode

2022-03-10 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504076#comment-17504076 ] Gyula Fora commented on FLINK-26577: cc [~wangyang0918] [~thw] > Avoid state loss w

[GitHub] [flink] flinkbot edited a comment on pull request #19022: [FLINK-26550][checkpoint] Correct the information of checkpoint failure

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19022: URL: https://github.com/apache/flink/pull/19022#issuecomment-1062855606 ## CI report: * 550044071ad996fb80794d96e82123ed3ac68f2a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19032: [FLINK-26564] Fix the bug that CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests.

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19032: URL: https://github.com/apache/flink/pull/19032#issuecomment-1063628708 ## CI report: * ec989afd8ee329068a0d11ddb6ac039ea3cd1a88 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26576) The value of 'readerParallelism' passed to ContinuousFileMonitoringFunction is wrong

2022-03-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-26576: --- Description: In [StreamExecutionEnvironment#createFileInput |https://github.com/apache/flink/blob/m

[jira] [Updated] (FLINK-26418) Tests on flink-table-planner produce tmp_XXX dirs which are not cleaned up

2022-03-10 Thread Marios Trivyzas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marios Trivyzas updated FLINK-26418: Component/s: Runtime / Configuration (was: Table SQL / Planner) > Tes

[jira] (FLINK-26538) Ability to restart deployment w/o spec change

2022-03-10 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26538 ] Nicholas Jiang deleted comment on FLINK-26538: was (Author: nicholasjiang): >From the user perspective, most of the users desire to only a single operation >to restart deployment, the si

[jira] [Updated] (FLINK-26576) The value of 'readerParallelism' passed to ContinuousFileMonitoringFunction is wrong

2022-03-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-26576: --- Description: In [StreamExecutionEnvironment#createFileInput |https://github.com/apache/flink/blob/m

[jira] [Assigned] (FLINK-26571) Savepoint trigger/tracking improvements

2022-03-10 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26571: -- Assignee: Matyas Orhidi > Savepoint trigger/tracking improvements > -

[jira] [Updated] (FLINK-26576) The value of 'readerParallelism' passed to ContinuousFileMonitoringFunction is wrong

2022-03-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-26576: --- Affects Version/s: 1.14.3 1.13.6 1.15.0 > The value of

[GitHub] [flink] gaoyunhaii closed pull request #19030: [FLINK-26557][docs] Extend CsvFormat documentation

2022-03-10 Thread GitBox
gaoyunhaii closed pull request #19030: URL: https://github.com/apache/flink/pull/19030 -- 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-unsu

[jira] [Commented] (FLINK-26557) Extend CsvFormat documentation based on release-testing feedback

2022-03-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504081#comment-17504081 ] Yun Gao commented on FLINK-26557: - Merged on master via 22b025aaf370d8eac47778b69ec1798c

[jira] [Closed] (FLINK-26557) Extend CsvFormat documentation based on release-testing feedback

2022-03-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26557. --- Resolution: Fixed > Extend CsvFormat documentation based on release-testing feedback > -

[jira] [Commented] (FLINK-26311) Test CsvFormat

2022-03-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504082#comment-17504082 ] Yun Gao commented on FLINK-26311: - Very thanks [~afedulov] for the updating! The extende

[GitHub] [flink] slinkydeveloper commented on a change in pull request #19029: [FLINK-26418][runtime][test] Use java.io.tmpdir for tmpWorkingDir

2022-03-10 Thread GitBox
slinkydeveloper commented on a change in pull request #19029: URL: https://github.com/apache/flink/pull/19029#discussion_r823457633 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingTaskManagerRuntimeInfo.java ## @@ -38,7 +38,8 @@ public Testi

[jira] [Closed] (FLINK-26311) Test CsvFormat

2022-03-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26311. --- Resolution: Resolved > Test CsvFormat > -- > > Key: FLINK-26311 >

[jira] [Updated] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26568: -- Labels: test-stability (was: ) > BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlocki

[jira] [Commented] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504084#comment-17504084 ] Matthias Pohl commented on FLINK-26568: --- One error I could extract is the followin

[jira] [Updated] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26568: -- Component/s: Runtime / Coordination > BlockingShuffleITCase.testDeletePartitionFileOfBoundedBl

[jira] [Created] (FLINK-26578) Translate new Project Configuration section to Chinese

2022-03-10 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26578: -- Summary: Translate new Project Configuration section to Chinese Key: FLINK-26578 URL: https://issues.apache.org/jira/browse/FLINK-26578 Project: Flink Is

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #40: [FLINK-26567] FileStoreSourceSplitReader should deal with value count

2022-03-10 Thread GitBox
LadyForest commented on a change in pull request #40: URL: https://github.com/apache/flink-table-store/pull/40#discussion_r823462520 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitReaderTest.java ## @@

[jira] [Updated] (FLINK-26576) The value of 'readerParallelism' passed to ContinuousFileMonitoringFunction is wrong

2022-03-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-26576: --- Description: In [StreamExecutionEnvironment#createFileInput |https://github.com/apache/flink/blob/m

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #40: [FLINK-26567] FileStoreSourceSplitReader should deal with value count

2022-03-10 Thread GitBox
LadyForest commented on a change in pull request #40: URL: https://github.com/apache/flink-table-store/pull/40#discussion_r823462520 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitReaderTest.java ## @@

[jira] [Created] (FLINK-26579) The default source parallelism configuration in adaptive batch scheduling does not take effect

2022-03-10 Thread kangTwang (Jira)
kangTwang created FLINK-26579: - Summary: The default source parallelism configuration in adaptive batch scheduling does not take effect Key: FLINK-26579 URL: https://issues.apache.org/jira/browse/FLINK-26579

[jira] [Updated] (FLINK-26551) Make the legacy behavior disabled by default

2022-03-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26551: --- Component/s: Table SQL / Planner Table SQL / Runtime > Make the legacy beha

[GitHub] [flink] XComp merged pull request #19028: [FLINK-26555][runtime] Adds closing and flushing to OutputStream

2022-03-10 Thread GitBox
XComp merged pull request #19028: URL: https://github.com/apache/flink/pull/19028 -- 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.

[jira] [Closed] (FLINK-26558) Errors when reporting on Job status

2022-03-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-26558. Resolution: Duplicate > Errors when reporting on Job status >

[jira] [Resolved] (FLINK-26555) Missing close in FileSystemJobResultStore

2022-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-26555. --- Resolution: Fixed master: 281b8e744dd2f8677d41d9e97c9b8ceeeddff450 > Missing close in FileS

[jira] [Assigned] (FLINK-26572) Re-schedule reconcile more often until job is in ready state

2022-03-10 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26572: -- Assignee: Gyula Fora > Re-schedule reconcile more often until job is in ready state > ---

[jira] [Closed] (FLINK-25968) Possible class leaks in flink-table / sql modules

2022-03-10 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani closed FLINK-25968. --- Release Note: The leaks have been removed Resolution: Fixed > Possible class l

[jira] [Closed] (FLINK-25972) org.apache.calcite.rel.metadata.JaninoRelMetadataProvider#HANDLERS might cause class leaks

2022-03-10 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani closed FLINK-25972. --- Resolution: Not A Problem > org.apache.calcite.rel.metadata.JaninoRelMetadataProvide

[jira] [Commented] (FLINK-26552) Try to use @EnableKubernetesMockClient(crud = true) in controller test

2022-03-10 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504091#comment-17504091 ] Nicholas Jiang commented on FLINK-26552: [~gyfora], what problems did you meet?

[GitHub] [flink] gaoyunhaii commented on pull request #19032: [FLINK-26564] Fix the bug that CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests.

2022-03-10 Thread GitBox
gaoyunhaii commented on pull request #19032: URL: https://github.com/apache/flink/pull/19032#issuecomment-1063801624 @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 speci

[jira] [Updated] (FLINK-25968) Possible class leaks in flink-table / sql modules

2022-03-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25968: --- Release Note: (was: The leaks have been removed) > Possible class leaks in flink-table / s

[GitHub] [flink] flinkbot edited a comment on pull request #19032: [FLINK-26564] Fix the bug that CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests.

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19032: URL: https://github.com/apache/flink/pull/19032#issuecomment-1063628708 ## CI report: * ec989afd8ee329068a0d11ddb6ac039ea3cd1a88 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26451) Test GCS FileSystem w/ RecoverableWriter manually

2022-03-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504096#comment-17504096 ] Fabian Paul commented on FLINK-26451: - I tested checkpointing data to GCS and readin

[jira] [Updated] (FLINK-26451) Test GCS FileSystem w/ RecoverableWriter manually

2022-03-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26451: Affects Version/s: 1.15.0 > Test GCS FileSystem w/ RecoverableWriter manually > --

[jira] [Resolved] (FLINK-26451) Test GCS FileSystem w/ RecoverableWriter manually

2022-03-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-26451. - Resolution: Fixed > Test GCS FileSystem w/ RecoverableWriter manually >

[jira] [Closed] (FLINK-26451) Test GCS FileSystem w/ RecoverableWriter manually

2022-03-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-26451. --- > Test GCS FileSystem w/ RecoverableWriter manually > -

[jira] [Updated] (FLINK-26416) Release Testing: Sink V2 sanity checks

2022-03-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26416: Description: With the introduction of Sink V2, the operator model of the sink changed slightly th

[jira] [Commented] (FLINK-26416) Release Testing: Sink V2 sanity checks

2022-03-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504098#comment-17504098 ] Fabian Paul commented on FLINK-26416: - [~Jiangang] thanks for your findings. Can you

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * f8e0e8e66cbd7a4549e091ae743932d8610dd7b6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18993: [FLINK-26565][TABLE][TRIGGER]use later trigger for delay window when laterTrigger is not null

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #18993: URL: https://github.com/apache/flink/pull/18993#issuecomment-1060422581 ## CI report: * 27e11aaa18eddce327709f714cd0657911597536 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19032: [FLINK-26564] Fix the bug that CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests.

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19032: URL: https://github.com/apache/flink/pull/19032#issuecomment-1063628708 ## CI report: * ec989afd8ee329068a0d11ddb6ac039ea3cd1a88 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19025: [FLINK-26553][build] Configure scalafmt

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19025: URL: https://github.com/apache/flink/pull/19025#issuecomment-1063065558 ## CI report: * 9db9218ed9b912210dec03ecf02e2a2b0df17c57 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #40: [FLINK-26567] FileStoreSourceSplitReader should deal with value count

2022-03-10 Thread GitBox
LadyForest commented on a change in pull request #40: URL: https://github.com/apache/flink-table-store/pull/40#discussion_r823480245 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreReadImpl.java ## @@ -44,6 +44,7 @@

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #40: [FLINK-26567] FileStoreSourceSplitReader should deal with value count

2022-03-10 Thread GitBox
LadyForest commented on a change in pull request #40: URL: https://github.com/apache/flink-table-store/pull/40#discussion_r823480245 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreReadImpl.java ## @@ -44,6 +44,7 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 91a5a156671f5b97479e9b284678912ace3ac51d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19025: [FLINK-26553][build] Configure scalafmt

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19025: URL: https://github.com/apache/flink/pull/19025#issuecomment-1063065558 ## CI report: * 9db9218ed9b912210dec03ecf02e2a2b0df17c57 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568 ] Matthias Pohl deleted comment on FLINK-26568: --- was (Author: mapohl): One error I could extract is the following one: {code} org.apache.flink.runtime.jobmaster.ExecutionGraphException: The e

[jira] [Assigned] (FLINK-26445) Unified Sink cannot restore committer state

2022-03-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-26445: --- Assignee: Fabian Paul > Unified Sink cannot restore committer state > -

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #40: [FLINK-26567] FileStoreSourceSplitReader should deal with value count

2022-03-10 Thread GitBox
LadyForest commented on a change in pull request #40: URL: https://github.com/apache/flink-table-store/pull/40#discussion_r823462520 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitReaderTest.java ## @@

[GitHub] [flink] alpreu opened a new pull request #19035: [FLINK-26281][connectors/elasticsearch] setting default delivery guarantee to AT_LEAST_ONCE

2022-03-10 Thread GitBox
alpreu opened a new pull request #19035: URL: https://github.com/apache/flink/pull/19035 ## What is the purpose of the change The default delivery guarantee of the Elasticsearch sink should be AT_LEAST_ONCE as it was the case in 1.14 for upgradability/consistency reasons. Chin

[GitHub] [flink-table-store] JingsongLi merged pull request #40: [FLINK-26567] FileStoreSourceSplitReader should deal with value count

2022-03-10 Thread GitBox
JingsongLi merged pull request #40: URL: https://github.com/apache/flink-table-store/pull/40 -- 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: issue

[jira] [Updated] (FLINK-26281) Test Elasticsearch connector End2End

2022-03-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26281: --- Labels: pull-request-available release-testing (was: release-testing) > Test Elasticsearch

[jira] [Commented] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504105#comment-17504105 ] Matthias Pohl commented on FLINK-26568: --- Thanks to [~chesnay]: The stacktraces ind

[jira] [Closed] (FLINK-26567) FileStoreSourceSplitReader should deal with value count

2022-03-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26567. Resolution: Fixed master: 341dfe2ae0faf67944e5874d104942bd64d11341 > FileStoreSourceSplitReader s

[GitHub] [flink] flinkbot commented on pull request #19035: [FLINK-26281][connectors/elasticsearch] setting default delivery guarantee to AT_LEAST_ONCE

2022-03-10 Thread GitBox
flinkbot commented on pull request #19035: URL: https://github.com/apache/flink/pull/19035#issuecomment-1063817920 ## CI report: * 10cb63b99fd9289856226edc362077c2b97a2438 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] zentol commented on a change in pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-10 Thread GitBox
zentol commented on a change in pull request #18905: URL: https://github.com/apache/flink/pull/18905#discussion_r823487725 ## File path: flink-connectors/flink-connector-kinesis/pom.xml ## @@ -323,8 +323,10 @@ under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #19035: [FLINK-26281][connectors/elasticsearch] setting default delivery guarantee to AT_LEAST_ONCE

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19035: URL: https://github.com/apache/flink/pull/19035#issuecomment-1063817920 ## CI report: * 10cb63b99fd9289856226edc362077c2b97a2438 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504111#comment-17504111 ] Matthias Pohl commented on FLINK-26568: --- I grepped the logs (looking for {{The bas

[GitHub] [flink] JingGe commented on pull request #19024: [FLINK-26349][AvroParquet][test] add UT for reading reflect records from parquet file created with generic record schema.

2022-03-10 Thread GitBox
JingGe commented on pull request #19024: URL: https://github.com/apache/flink/pull/19024#issuecomment-1063829445 @dawidwys would you like to have a look at this PR and help merging it? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504112#comment-17504112 ] Matthias Pohl commented on FLINK-26568: --- I ran the test locally repeatedly (300 re

[jira] [Commented] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504116#comment-17504116 ] Matthias Pohl commented on FLINK-26568: --- [~pnowojski] may you have a look at it?

[jira] [Assigned] (FLINK-26194) Deprecate unused options in TableConfig

2022-03-10 Thread Marios Trivyzas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marios Trivyzas reassigned FLINK-26194: --- Assignee: Marios Trivyzas > Deprecate unused options in TableConfig > -

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2022-03-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504118#comment-17504118 ] Martijn Visser commented on FLINK-18356: Fork reuse has been renabled in master

[GitHub] [flink] flinkbot edited a comment on pull request #19033: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19033: URL: https://github.com/apache/flink/pull/19033#issuecomment-1063699541 ## CI report: * 7d1dbec66de54a97fb4a1a9a9304806bbe4da9af Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] MartijnVisser commented on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-10 Thread GitBox
MartijnVisser commented on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1063836218 @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 sp

[GitHub] [flink] MartijnVisser removed a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-10 Thread GitBox
MartijnVisser removed a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1063836218 @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 t

[jira] [Commented] (FLINK-26548) the source parallelism is not set correctly with AdaptiveBatchScheduler

2022-03-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504120#comment-17504120 ] Lijie Wang commented on FLINK-26548: Hi [~Leo Zhou] , thanks for trying it. -> and

[jira] [Assigned] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

2022-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-24538: - Assignee: Mika Naylor (was: xmarker) > ZooKeeperLeaderElectionTest.testLeaderShouldBeC

[jira] [Commented] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

2022-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504121#comment-17504121 ] Matthias Pohl commented on FLINK-24538: --- I re-assigned the issue to [~autophagy].

[GitHub] [flink] flinkbot edited a comment on pull request #19020: [FLINK-26551][table] Flip legacy casting to disable by default

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19020: URL: https://github.com/apache/flink/pull/19020#issuecomment-1062833750 ## CI report: * e16c14406fad0e2693e9e86f21ba3376e3ba743e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Comment Edited] (FLINK-26548) the source parallelism is not set correctly with AdaptiveBatchScheduler

2022-03-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504120#comment-17504120 ] Lijie Wang edited comment on FLINK-26548 at 3/10/22, 9:23 AM:

[jira] [Comment Edited] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504112#comment-17504112 ] Matthias Pohl edited comment on FLINK-26568 at 3/10/22, 9:24 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #19020: [FLINK-26551][table] Flip legacy casting to disable by default

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19020: URL: https://github.com/apache/flink/pull/19020#issuecomment-1062833750 ## CI report: * e16c14406fad0e2693e9e86f21ba3376e3ba743e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19032: [FLINK-26564] Fix the bug that CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests.

2022-03-10 Thread GitBox
flinkbot edited a comment on pull request #19032: URL: https://github.com/apache/flink/pull/19032#issuecomment-1063628708 ## CI report: * ec989afd8ee329068a0d11ddb6ac039ea3cd1a88 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-03-10 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504127#comment-17504127 ] Etienne Chauchot commented on FLINK-25771: -- Thanks [~mapohl] for raising this !

[GitHub] [flink-table-store] JingsongLi merged pull request #31: [FLINK-26293] Store log offsets in snapshot

2022-03-10 Thread GitBox
JingsongLi merged pull request #31: URL: https://github.com/apache/flink-table-store/pull/31 -- 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: issue

[GitHub] [flink] XComp merged pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-10 Thread GitBox
XComp merged pull request #18979: URL: https://github.com/apache/flink/pull/18979 -- 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] zentol commented on a change in pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-10 Thread GitBox
zentol commented on a change in pull request #18905: URL: https://github.com/apache/flink/pull/18905#discussion_r823500652 ## File path: flink-connectors/flink-sql-connector-aws-kinesis-streams/pom.xml ## @@ -36,6 +36,12 @@ org.apache.flink

[jira] [Resolved] (FLINK-26484) FileSystem.delete is not implemented consistently

2022-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-26484. --- Fix Version/s: 1.15.0 Resolution: Fixed master: 4907f5fb7033b1f918c4e721a1ccf95878f98

  1   2   3   4   5   6   7   8   >