[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=17402054#comment-17402054 ] Yun Gao commented on FLINK-23772: - Since currently it seems this issue should not exist, I'll close the

[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=17402052#comment-17402052 ] Yun Gao commented on FLINK-23772: - [~pnowojski] and I have some offline discussion on this issue:

[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=17402047#comment-17402047 ] Yun Gao commented on FLINK-2491: The following bug fixes are tacked by FLINK-23883. > Support

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

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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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=17402041#comment-17402041 ] Yun Gao commented on FLINK-23512: - Fixed via

[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

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

[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

[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

[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

[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

[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=17402037#comment-17402037 ] JING ZHANG edited comment on FLINK-23886 at 8/20/21, 5:26 AM: -- User

[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=17402037#comment-17402037 ] JING ZHANG commented on FLINK-23886: User mailist:

[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=17402030#comment-17402030 ] Caizhi Weng commented on FLINK-23885: - I've looked a bit into this issue and found that this is

[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

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

[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

[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

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

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

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

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

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

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

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

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

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

[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

[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

[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

[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

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

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

[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

[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

[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

[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

[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

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

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

[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

[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

[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

[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

[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

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

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

[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=17400241#comment-17400241 ] Jingsong Lee edited comment on FLINK-23420 at 8/20/21, 3:29 AM: master:

[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=17402007#comment-17402007 ] Xintong Song commented on FLINK-23848: --

[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=17402005#comment-17402005 ] Xintong Song commented on FLINK-23525: --

[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=17402006#comment-17402006 ] Xintong Song commented on FLINK-23848: --

[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=17402004#comment-17402004 ] Xintong Song commented on FLINK-23525: --

[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=17402003#comment-17402003 ] Xintong Song commented on FLINK-22889: --

[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

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

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

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

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

[jira] [Commented] (FLINK-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401995#comment-17401995 ] Xintong Song commented on FLINK-23493: --

[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_r692628992 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporterOptions.java ##

[jira] [Reopened] (FLINK-23724) Network buffer leak when ResultPartition is released (failover)

[ https://issues.apache.org/jira/browse/FLINK-23724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reopened FLINK-23724: -- > Network buffer leak when ResultPartition is released (failover) >

[jira] [Commented] (FLINK-23724) Network buffer leak when ResultPartition is released (failover)

[ https://issues.apache.org/jira/browse/FLINK-23724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401993#comment-17401993 ] Yuan Mei commented on FLINK-23724: -- [~kevin.cyj], would you please also backport this to 1.13 as well,

[GitHub] [flink] fsk119 closed pull request #13446: [FLINK-18779][table sql/planner]Support the SupportsFilterPushDown for LookupTableSource

fsk119 closed pull request #13446: URL: https://github.com/apache/flink/pull/13446 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Resolved] (FLINK-23724) Network buffer leak when ResultPartition is released (failover)

[ https://issues.apache.org/jira/browse/FLINK-23724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei resolved FLINK-23724. -- Resolution: Fixed merged commit 

[GitHub] [flink] curcur commented on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

curcur commented on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-902397136 Thanks @wsry and @akalash -- 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] curcur merged pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

curcur merged pull request #16844: URL: https://github.com/apache/flink/pull/16844 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-23879) Benchmark are not compiling

[ https://issues.apache.org/jira/browse/FLINK-23879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401986#comment-17401986 ] Zhu Zhu commented on FLINK-23879: - cc [~arvid] [~dwysakowicz] > Benchmark are not compiling >

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

tsreaper commented on a change in pull request #16823: URL: https://github.com/apache/flink/pull/16823#discussion_r692625950 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporterOptions.java ## @@

[jira] [Updated] (FLINK-23868) JobExecutionResult printed even if suppressSysout is on

[ https://issues.apache.org/jira/browse/FLINK-23868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-23868: - Summary: JobExecutionResult printed even if suppressSysout is on (was: JobExecutionResult printed

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

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

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

  1   2   3   4   5   >