[jira] [Assigned] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-23828: Assignee: Qingsheng Ren > KafkaSourceITCase.testIdleReader fails on azure > -

[jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402073#comment-17402073 ] Qingsheng Ren commented on FLINK-23828: --- Thanks [~xtsong] for raising this. I'll t

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate from tslint to eslint and add stylint for less

flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * af560fe451589fb80db581734a32b5e0c3b692c6 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #16892: [hotfix][docs] Update IDE Setup guide

flinkbot edited a comment on pull request #16892: URL: https://github.com/apache/flink/pull/16892#issuecomment-901662389 ## CI report: * 633beaef501b7e5db6e66be1ec3e2912920ec795 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16858: [FLINK-16202][table] Support JSON_QUERY

flinkbot edited a comment on pull request #16858: URL: https://github.com/apache/flink/pull/16858#issuecomment-900113536 ## CI report: * 0b642eed264b40b200fc67959bfae8c7f755673c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 76f71f0f595cd67186d4d7bb3c17737c568f72e7 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402069#comment-17402069 ] Qingsheng Ren commented on FLINK-22198: --- [~jark] The default value is 7 days. The

[jira] [Updated] (FLINK-23882) Documentation of TIMESTAMP WITH TIME ZONE should state that it is currently not supported by Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-23882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-23882: Component/s: Table SQL / API > Documentation of TIMESTAMP WITH TIME ZONE should state that it is currently

[jira] [Comment Edited] (FLINK-23814) Test FLIP-143 KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400938#comment-17400938 ] Hang Ruan edited comment on FLINK-23814 at 8/20/21, 6:24 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #16892: [hotfix][docs] Update IDE Setup guide

flinkbot edited a comment on pull request #16892: URL: https://github.com/apache/flink/pull/16892#issuecomment-901662389 ## CI report: * 633beaef501b7e5db6e66be1ec3e2912920ec795 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16900: [FLINK-23877][connector/pulsar] Provide an embedded pulsar broker for testing.

flinkbot edited a comment on pull request #16900: URL: https://github.com/apache/flink/pull/16900#issuecomment-902199681 ## CI report: * db84a292597428f82df1688e87787a6cc2591cfd Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16858: [FLINK-16202][table] Support JSON_QUERY

flinkbot edited a comment on pull request #16858: URL: https://github.com/apache/flink/pull/16858#issuecomment-900113536 ## CI report: * 0b642eed264b40b200fc67959bfae8c7f755673c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 76f71f0f595cd67186d4d7bb3c17737c568f72e7 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] zhuzhurk commented on a change in pull request #16724: [FLINK-23172][docs] Fix broken links to Task Failure Recovery page on Configuration page

zhuzhurk commented on a change in pull request #16724: URL: https://github.com/apache/flink/pull/16724#discussion_r692687726 ## File path: flink-core/src/main/java/org/apache/flink/configuration/RestartStrategyOptions.java ## @@ -63,21 +63,21 @@

[jira] [Closed] (FLINK-23772) Double check if non-keyed FullyFinishedOperatorState can be mixed up with non finished OperatorState on recovery

[ https://issues.apache.org/jira/browse/FLINK-23772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-23772. --- Resolution: Not A Problem > Double check if non-keyed FullyFinishedOperatorState can be mixed up with non >

[jira] [Commented] (FLINK-23772) Double check if non-keyed FullyFinishedOperatorState can be mixed up with non finished OperatorState on recovery

[ https://issues.apache.org/jira/browse/FLINK-23772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402054#comment-17402054 ] Yun Gao commented on FLINK-23772: - Since currently it seems this issue should not exist,

[jira] [Commented] (FLINK-23772) Double check if non-keyed FullyFinishedOperatorState can be mixed up with non finished OperatorState on recovery

[ https://issues.apache.org/jira/browse/FLINK-23772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402052#comment-17402052 ] Yun Gao commented on FLINK-23772: - [~pnowojski] and I have some offline discussion on th

[jira] [Commented] (FLINK-2491) Support Checkpoints After Tasks Finished

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402047#comment-17402047 ] Yun Gao commented on FLINK-2491: The following bug fixes are tacked by FLINK-23883. > Su

[GitHub] [flink] flinkbot edited a comment on pull request #16900: [FLINK-23877][connector/pulsar] Provide an embedded pulsar broker for testing.

flinkbot edited a comment on pull request #16900: URL: https://github.com/apache/flink/pull/16900#issuecomment-902199681 ## CI report: * db84a292597428f82df1688e87787a6cc2591cfd Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16901: [BP-1.13][FLINK-23813][connectors/jdbc] Update delete executor in TableJdbcUpsertOutputFormat

flinkbot edited a comment on pull request #16901: URL: https://github.com/apache/flink/pull/16901#issuecomment-902295949 ## CI report: * c2528e12299a1210dea2ba3a36afc6bd9517bf58 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-23808) Bypass operators when advanceToEndOfEventTime for both legacy and new source tasks

[ https://issues.apache.org/jira/browse/FLINK-23808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23808: Parent: FLINK-23883 Issue Type: Sub-task (was: Bug) > Bypass operators when advanceToEndOfEventTi

[jira] [Updated] (FLINK-23815) Follow-up code improvement regarding final checkpoint.

[ https://issues.apache.org/jira/browse/FLINK-23815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23815: Parent: FLINK-23883 Issue Type: Sub-task (was: Bug) > Follow-up code improvement regarding final

[jira] [Updated] (FLINK-23772) Double check if non-keyed FullyFinishedOperatorState can be mixed up with non finished OperatorState on recovery

[ https://issues.apache.org/jira/browse/FLINK-23772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23772: Parent: FLINK-23883 Issue Type: Sub-task (was: Bug) > Double check if non-keyed FullyFinishedOper

[jira] [Updated] (FLINK-23809) Respect the finished flag when extracting operator states due to skip in-flight data

[ https://issues.apache.org/jira/browse/FLINK-23809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23809: Parent: FLINK-23883 Issue Type: Sub-task (was: Bug) > Respect the finished flag when extracting o

[jira] [Updated] (FLINK-23809) Respect the finished flag when extracting operator states due to skip in-flight data

[ https://issues.apache.org/jira/browse/FLINK-23809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23809: Parent: (was: FLINK-2491) Issue Type: Bug (was: Sub-task) > Respect the finished flag when ex

[jira] [Updated] (FLINK-23815) Follow-up code improvement regarding final checkpoint.

[ https://issues.apache.org/jira/browse/FLINK-23815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23815: Parent: (was: FLINK-2491) Issue Type: Bug (was: Sub-task) > Follow-up code improvement regard

[jira] [Updated] (FLINK-23808) Bypass operators when advanceToEndOfEventTime for both legacy and new source tasks

[ https://issues.apache.org/jira/browse/FLINK-23808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23808: Parent: (was: FLINK-2491) Issue Type: Bug (was: Sub-task) > Bypass operators when advanceToEn

[jira] [Updated] (FLINK-23772) Double check if non-keyed FullyFinishedOperatorState can be mixed up with non finished OperatorState on recovery

[ https://issues.apache.org/jira/browse/FLINK-23772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23772: Parent: (was: FLINK-2491) Issue Type: Bug (was: Sub-task) > Double check if non-keyed FullyFi

[jira] [Updated] (FLINK-23770) FLIP-147: Unable to recover after source fully finished

[ https://issues.apache.org/jira/browse/FLINK-23770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23770: Parent: FLINK-23883 Issue Type: Sub-task (was: Bug) > FLIP-147: Unable to recover after source fu

[jira] [Updated] (FLINK-23770) FLIP-147: Unable to recover after source fully finished

[ https://issues.apache.org/jira/browse/FLINK-23770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23770: Parent: (was: FLINK-2491) Issue Type: Bug (was: Sub-task) > FLIP-147: Unable to recover after

[GitHub] [flink] Airblader commented on pull request #16892: [hotfix][docs] Update IDE Setup guide

Airblader commented on pull request #16892: URL: https://github.com/apache/flink/pull/16892#issuecomment-902444746 Thanks for your review @infoverload and @dianfu. I've updated the PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-23430) Take snapshots for operator coordinators which all corresponding tasks finished

[ https://issues.apache.org/jira/browse/FLINK-23430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23430: Parent: FLINK-23883 Issue Type: Sub-task (was: Bug) > Take snapshots for operator coordinators wh

[jira] [Updated] (FLINK-23430) Take snapshots for operator coordinators which all corresponding tasks finished

[ https://issues.apache.org/jira/browse/FLINK-23430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23430: Parent: (was: FLINK-2491) Issue Type: Bug (was: Sub-task) > Take snapshots for operator coord

[jira] [Commented] (FLINK-23512) Check for illegal modifications of JobGraph with partially finished operators

[ https://issues.apache.org/jira/browse/FLINK-23512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402041#comment-17402041 ] Yun Gao commented on FLINK-23512: - Fixed via c4e9a0b7471af56078014ee82b4c78d6b76ee976..

[jira] [Closed] (FLINK-23512) Check for illegal modifications of JobGraph with partially finished operators

[ https://issues.apache.org/jira/browse/FLINK-23512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-23512. --- > Check for illegal modifications of JobGraph with partially finished operators > --

[jira] [Resolved] (FLINK-23512) Check for illegal modifications of JobGraph with partially finished operators

[ https://issues.apache.org/jira/browse/FLINK-23512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao resolved FLINK-23512. - Resolution: Fixed > Check for illegal modifications of JobGraph with partially finished operators >

[GitHub] [flink] Airblader commented on a change in pull request #16892: [hotfix][docs] Update IDE Setup guide

Airblader commented on a change in pull request #16892: URL: https://github.com/apache/flink/pull/16892#discussion_r692677978 ## File path: docs/content/docs/flinkDev/ide_setup.md ## @@ -39,7 +39,7 @@ command line first (`mvn clean package -DskipTests`) as it might be your IDE

[GitHub] [flink] gaoyunhaii closed pull request #16655: [FLINK-23512][runtime][checkpoint] Check for illegal modifications of JobGraph with partially finished operators

gaoyunhaii closed pull request #16655: URL: https://github.com/apache/flink/pull/16655 -- 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] [Updated] (FLINK-23886) An exception is thrown out when recover job timers from savepoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23886: --- Description: A user report the bug in the [mailist|http://mail-archives.apache.org/mod_mbox/flink-u

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

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23886: --- Description: A user report the bug in the [mailist|[http://mail-archives.apache.org/mod_mbox/flink-

[GitHub] [flink] Airblader commented on a change in pull request #16902: [FLINK-23113][runtime-web] Migrate from tslint to eslint and add stylint for less

Airblader commented on a change in pull request #16902: URL: https://github.com/apache/flink/pull/16902#discussion_r692672356 ## File path: flink-runtime-web/web-dashboard/src/app/interfaces/safe-any.ts ## @@ -0,0 +1,2 @@ +// eslint-disable-next-line @typescript-eslint/no-expli

[GitHub] [flink] gaoyunhaii commented on pull request #16655: [FLINK-23512][runtime][checkpoint] Check for illegal modifications of JobGraph with partially finished operators

gaoyunhaii commented on pull request #16655: URL: https://github.com/apache/flink/pull/16655#issuecomment-902442312 Very thanks @StephanEwen for the review! I'll merging the code~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[jira] [Comment Edited] (FLINK-23886) An exception is thrown out when recover job timers from savepoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402037#comment-17402037 ] JING ZHANG edited comment on FLINK-23886 at 8/20/21, 5:26 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402037#comment-17402037 ] JING ZHANG commented on FLINK-23886: User mailist: [http://mail-archives.apache.org

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

JING ZHANG created FLINK-23886: -- Summary: An exception is thrown out when recover job timers from savepoint file Key: FLINK-23886 URL: https://issues.apache.org/jira/browse/FLINK-23886 Project: Flink

[jira] [Assigned] (FLINK-23884) Fix the concurrent problem between triggering savepoint with drain and finish

[ https://issues.apache.org/jira/browse/FLINK-23884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-23884: --- Assignee: Yun Gao > Fix the concurrent problem between triggering savepoint with drain and finish >

[jira] [Commented] (FLINK-23885) DataStream#map(int value -> row value).getType() produces a generic type info of row instead of row type info

[ https://issues.apache.org/jira/browse/FLINK-23885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402030#comment-17402030 ] Caizhi Weng commented on FLINK-23885: - I've looked a bit into this issue and found t

[jira] [Updated] (FLINK-23885) DataStream#map(int value -> row value).getType() produces a generic type info of row instead of row type info

[ https://issues.apache.org/jira/browse/FLINK-23885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-23885: Component/s: API / DataStream > DataStream#map(int value -> row value).getType() produces a generi

[jira] [Created] (FLINK-23885) DataStream#map(int value -> row value).getType() produces a generic type info of row instead of row type info

Caizhi Weng created FLINK-23885: --- Summary: DataStream#map(int value -> row value).getType() produces a generic type info of row instead of row type info Key: FLINK-23885 URL: https://issues.apache.org/jira/browse/FL

[jira] [Updated] (FLINK-23885) DataStream#map(int value -> row value).getType() produces a generic type info of row instead of row type info

[ https://issues.apache.org/jira/browse/FLINK-23885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-23885: Affects Version/s: 1.14.0 > DataStream#map(int value -> row value).getType() produces a generic >

[jira] [Created] (FLINK-23884) Fix the concurrent problem between triggering savepoint with drain and finish

Yun Gao created FLINK-23884: --- Summary: Fix the concurrent problem between triggering savepoint with drain and finish Key: FLINK-23884 URL: https://issues.apache.org/jira/browse/FLINK-23884 Project: Flink

[GitHub] [flink] syhily removed a comment on pull request #16900: [FLINK-23877][connector/pulsar] Provide an embedded pulsar broker for testing.

syhily removed a comment on pull request #16900: URL: https://github.com/apache/flink/pull/16900#issuecomment-902382011 @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

[jira] [Updated] (FLINK-23883) Following bug fix and code improvement for FLIP-147

[ https://issues.apache.org/jira/browse/FLINK-23883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23883: Description: This issue is an umbrella issue to tracking the remaining bug fix and code improvement for FL

[jira] [Created] (FLINK-23883) Following bug fix and code improvement for FLIP-147

Yun Gao created FLINK-23883: --- Summary: Following bug fix and code improvement for FLIP-147 Key: FLINK-23883 URL: https://issues.apache.org/jira/browse/FLINK-23883 Project: Flink Issue Type: Improve

[GitHub] [flink] curcur commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

curcur commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r692662790 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/materializer/PeriodicMaterializer.java ## @

[GitHub] [flink] flinkbot edited a comment on pull request #16864: [FLINK-23556][tests] Make SQLClientSchemaRegistryITCase more stable

flinkbot edited a comment on pull request #16864: URL: https://github.com/apache/flink/pull/16864#issuecomment-900421523 ## CI report: * f9c7e403998ee1ba89b02abb9874fc7f18ac3362 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-23882) Documentation of TIMESTAMP WITH TIME ZONE should state that it is currently not supported by Flink SQL

Caizhi Weng created FLINK-23882: --- Summary: Documentation of TIMESTAMP WITH TIME ZONE should state that it is currently not supported by Flink SQL Key: FLINK-23882 URL: https://issues.apache.org/jira/browse/FLINK-238

[GitHub] [flink] flinkbot edited a comment on pull request #14395: [FLINK-16491][formats] Add compression support for ParquetAvroWriters

flinkbot edited a comment on pull request #14395: URL: https://github.com/apache/flink/pull/14395#issuecomment-745744218 ## CI report: * 416c2011bc57e4a94cf46df69f6a31d424393b3c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16903: [FLINK-23579][table-runtime] Fix compile exception in hash functions with varbinary arguments

flinkbot edited a comment on pull request #16903: URL: https://github.com/apache/flink/pull/16903#issuecomment-902413870 ## CI report: * e93c0efc434c26b15fe2a01821928d1a41075b87 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16904: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released (cherry-pick)

flinkbot edited a comment on pull request #16904: URL: https://github.com/apache/flink/pull/16904#issuecomment-902413906 ## CI report: * a12b477748275355e13f56c9daa866959b7ed7b8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate from tslint to eslint and add stylint for less

flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * af560fe451589fb80db581734a32b5e0c3b692c6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16823: [FLINK-23845][docs]improve PushGatewayReporter config:deleteOnShutdown de…

flinkbot edited a comment on pull request #16823: URL: https://github.com/apache/flink/pull/16823#issuecomment-898865990 ## CI report: * 656fc2a8cd23e86b8abf656d80593e4df7c2e8a5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14395: [FLINK-16491][formats] Add compression support for ParquetAvroWriters

flinkbot edited a comment on pull request #14395: URL: https://github.com/apache/flink/pull/14395#issuecomment-745744218 ## CI report: * 416c2011bc57e4a94cf46df69f6a31d424393b3c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] curcur commented on a change in pull request #16898: [FLINK-23876][docs] Update JDBC XA Sink docs

curcur commented on a change in pull request #16898: URL: https://github.com/apache/flink/pull/16898#discussion_r692642345 ## File path: docs/content/docs/connectors/datastream/jdbc.md ## @@ -32,14 +32,6 @@ To use it, add the following dependency to your project (along with yo

[GitHub] [flink] curcur commented on pull request #16898: [FLINK-23876][docs] Update JDBC XA Sink docs

curcur commented on pull request #16898: URL: https://github.com/apache/flink/pull/16898#issuecomment-902419376 Thanks @rkhachatryan ! LGTM -- 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] flinkbot commented on pull request #16904: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released (cherry-pick)

flinkbot commented on pull request #16904: URL: https://github.com/apache/flink/pull/16904#issuecomment-902413906 ## CI report: * a12b477748275355e13f56c9daa866959b7ed7b8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #16903: [FLINK-23579][table-runtime] Fix compile exception in hash functions with varbinary arguments

flinkbot commented on pull request #16903: URL: https://github.com/apache/flink/pull/16903#issuecomment-902413870 ## CI report: * e93c0efc434c26b15fe2a01821928d1a41075b87 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate from tslint to eslint and add stylint for less

flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * af560fe451589fb80db581734a32b5e0c3b692c6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16823: [FLINK-23845][docs]improve PushGatewayReporter config:deleteOnShutdown de…

flinkbot edited a comment on pull request #16823: URL: https://github.com/apache/flink/pull/16823#issuecomment-898865990 ## CI report: * 656fc2a8cd23e86b8abf656d80593e4df7c2e8a5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Issue Comment Deleted] (FLINK-18295) Remove the hack logics of result consumers

[ https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18295: Comment: was deleted (was: This issue was marked "stale-assigned" and has not received an update in 7 day

[jira] [Issue Comment Deleted] (FLINK-18295) Remove the hack logics of result consumers

[ https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18295: Comment: was deleted (was: This issue was labeled "stale-major" 7 ago and has not received any updates so

[jira] [Issue Comment Deleted] (FLINK-18295) Remove the hack logics of result consumers

[ https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18295: Comment: was deleted (was: This issue is assigned but has not received an update in 7 days so it has been

[jira] [Issue Comment Deleted] (FLINK-18295) Remove the hack logics of result consumers

[ https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18295: Comment: was deleted (was: I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help

[jira] [Updated] (FLINK-18295) Remove the hack logics of result consumers

[ https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18295: Priority: Major (was: Minor) > Remove the hack logics of result consumers > -

[jira] [Updated] (FLINK-18295) Remove the hack logics of result consumers

[ https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18295: Labels: (was: auto-deprioritized-major auto-unassigned) > Remove the hack logics of result consumers > -

[GitHub] [flink] yangjunhan commented on pull request #16902: [FLINK-23113][runtime-web] Migrate from tslint to eslint and add stylint for less

yangjunhan commented on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902407214 Please note, this PR also covers _"Address vulnerabilities in Flink UI"_ [FLINK-23114](https://issues.apache.org/jira/browse/FLINK-23114). -- This is an automated message f

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate from tslint to eslint and add stylint for less

flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * af560fe451589fb80db581734a32b5e0c3b692c6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16823: [FLINK-23845][docs]improve PushGatewayReporter config:deleteOnShutdown de…

flinkbot edited a comment on pull request #16823: URL: https://github.com/apache/flink/pull/16823#issuecomment-898865990 ## CI report: * 656fc2a8cd23e86b8abf656d80593e4df7c2e8a5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16904: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released (cherry-pick)

flinkbot commented on pull request #16904: URL: https://github.com/apache/flink/pull/16904#issuecomment-902405412 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] flinkbot commented on pull request #16903: [FLINK-23579][table-runtime] Fix compile exception in hash functions with varbinary arguments

flinkbot commented on pull request #16903: URL: https://github.com/apache/flink/pull/16903#issuecomment-902405426 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] camilesing edited a comment on pull request #16823: [FLINK-23845][docs]improve PushGatewayReporter config:deleteOnShutdown de…

camilesing edited a comment on pull request #16823: URL: https://github.com/apache/flink/pull/16823#issuecomment-902405089 @tsreaper got it -- 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

[GitHub] [flink] camilesing commented on pull request #16823: [FLINK-23845][docs]improve PushGatewayReporter config:deleteOnShutdown de…

camilesing commented on pull request #16823: URL: https://github.com/apache/flink/pull/16823#issuecomment-902405089 @tsreaper got it -- 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

[GitHub] [flink] wangyang0918 commented on pull request #16086: [FLINK-22585] Add deprecated message when -m yarn-cluster is used

wangyang0918 commented on pull request #16086: URL: https://github.com/apache/flink/pull/16086#issuecomment-902404968 @tillrohrmann Thanks for the comments. I will keep an eye on this PR and help with reviewing once the comments are addressed. BTW, since we do not take any concrete behavio

[GitHub] [flink] camilesing commented on a change in pull request #16823: [FLINK-23845][docs]improve PushGatewayReporter config:deleteOnShutdown de…

camilesing commented on a change in pull request #16823: URL: https://github.com/apache/flink/pull/16823#discussion_r692636809 ## File path: docs/layouts/shortcodes/generated/prometheus_push_gateway_reporter_configuration.html ## @@ -12,7 +12,7 @@ deleteOnShutdown

[GitHub] [flink] JingsongLi merged pull request #16893: [FLINK-23579][table-runtime] Fix compile exception in hash functions with varbinary arguments

JingsongLi merged pull request #16893: URL: https://github.com/apache/flink/pull/16893 -- 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] [Closed] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-23420. Resolution: Fixed > sql stream mode lag function java.lang.NullPointerException >

[jira] [Comment Edited] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400241#comment-17400241 ] Jingsong Lee edited comment on FLINK-23420 at 8/20/21, 3:29 AM: --

[jira] [Updated] (FLINK-23848) PulsarSourceITCase is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23848: - Priority: Blocker (was: Critical) > PulsarSourceITCase is failed on Azure > ---

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402007#comment-17402007 ] Xintong Song commented on FLINK-23848: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402005#comment-17402005 ] Xintong Song commented on FLINK-23525: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402006#comment-17402006 ] Xintong Song commented on FLINK-23848: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22889: - Priority: Blocker (was: Critical) > JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure >

[jira] [Commented] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402004#comment-17402004 ] Xintong Song commented on FLINK-23525: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402003#comment-17402003 ] Xintong Song commented on FLINK-22889: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-23881) SemiJoinITCase.testExistsWithOver4 fails with "failed to fetch next result"

Xintong Song created FLINK-23881: Summary: SemiJoinITCase.testExistsWithOver4 fails with "failed to fetch next result" Key: FLINK-23881 URL: https://issues.apache.org/jira/browse/FLINK-23881 Project:

[GitHub] [flink] wsry opened a new pull request #16904: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released (cherry-pick)

wsry opened a new pull request #16904: URL: https://github.com/apache/flink/pull/16904 ## What is the purpose of the change This patch fixes the network buffer leak when ResultPartition is released by closing all BufferBuilders. ## Brief change log - All BufferBuilder

[GitHub] [flink] JingsongLi merged pull request #16873: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

JingsongLi merged pull request #16873: URL: https://github.com/apache/flink/pull/16873 -- 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] [Created] (FLINK-23880) WindowAggregateITCase.testCascadeEventTimeTumbleWindowWithOffset fail with Artificial Failure

Xintong Song created FLINK-23880: Summary: WindowAggregateITCase.testCascadeEventTimeTumbleWindowWithOffset fail with Artificial Failure Key: FLINK-23880 URL: https://issues.apache.org/jira/browse/FLINK-23880

[GitHub] [flink] tsreaper opened a new pull request #16903: [FLINK-23579][table-runtime] Fix compile exception in hash functions with varbinary arguments

tsreaper opened a new pull request #16903: URL: https://github.com/apache/flink/pull/16903 (This PR is cherry-picked from #16718) ## What is the purpose of the change Currently hash functions like `MD5`, `SHA2`, etc. fails to compile if the argument is a varbinary value. This

[GitHub] [flink] tsreaper commented on pull request #16823: [FLINK-23845][docs]improve PushGatewayReporter config:deleteOnShutdown de…

tsreaper commented on pull request #16823: URL: https://github.com/apache/flink/pull/16823#issuecomment-902400444 Also please don't squash commits and force-push them, as it will be hard for reviewers to see what is changed. The committer who merges this commit will squash them for you.

  1   2   3   4   5   >