[GitHub] [flink] flinkbot commented on pull request #15863: [FLINK-22604] [table-runtime-blink] fix NPE on bundle close when task failover after a failed task open

flinkbot commented on pull request #15863: URL: https://github.com/apache/flink/pull/15863#issuecomment-835125709 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

[jira] [Updated] (FLINK-22604) NPE on bundle close when task failover after a failed task open

[ https://issues.apache.org/jira/browse/FLINK-22604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22604: --- Labels: pull-request-available (was: ) > NPE on bundle close when task failover after a

[GitHub] [flink] lincoln-lil opened a new pull request #15863: [FLINK-22604] [table-runtime-blink] fix NPE on bundle close when task failover after a failed task open

lincoln-lil opened a new pull request #15863: URL: https://github.com/apache/flink/pull/15863 ## What is the purpose of the change fix NPE on bundle close when task failover after a failed task open and add case for current sql harness tests. ## Brief change log - add

[jira] [Created] (FLINK-22604) NPE on bundle close when task failover after a failed task open

lincoln lee created FLINK-22604: --- Summary: NPE on bundle close when task failover after a failed task open Key: FLINK-22604 URL: https://issues.apache.org/jira/browse/FLINK-22604 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15821: [FLINK-21911][table] Add built-in greatest/least functions support

flinkbot edited a comment on pull request #15821: URL: https://github.com/apache/flink/pull/15821#issuecomment-830427889 ## CI report: * d1194f2f42e3ebc045947b818fe5a5fd85729028 Azure:

[GitHub] [flink] flinkbot commented on pull request #15862: [FLINK-22355][docs] Fix simple task manager memory model image

flinkbot commented on pull request #15862: URL: https://github.com/apache/flink/pull/15862#issuecomment-835116609 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

[jira] [Updated] (FLINK-22355) Simple Task Manager Memory Model image does not show up

[ https://issues.apache.org/jira/browse/FLINK-22355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22355: --- Labels: pull-request-available stale-critical starter (was: stale-critical starter) >

[GitHub] [flink] Shawn-Hx opened a new pull request #15862: [FLINK-22355][docs] Fix simple task manager memory model image

Shawn-Hx opened a new pull request #15862: URL: https://github.com/apache/flink/pull/15862 ## What is the purpose of the change Fix the broken image in https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/memory/mem_setup_tm/ ## Verifying this change

[GitHub] [flink] flinkbot edited a comment on pull request #15860: [FLINK-22598][examples] Update deprecated forms of writeAsText in examples

flinkbot edited a comment on pull request #15860: URL: https://github.com/apache/flink/pull/15860#issuecomment-835080766 ## CI report: * 3b42ff5c62b287157d954cfdc3258def7a258c67 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.0 due to CVEs

flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * d0a13db504e21e3afddc768f09c9b99337785ab5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

flinkbot edited a comment on pull request #15848: URL: https://github.com/apache/flink/pull/15848#issuecomment-833490569 ## CI report: * 99a21fd00339a5c0f0700c493095c745ac1935c0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15858: [WIP][FLINK-22067][tests] Wait for vertices to using API

flinkbot edited a comment on pull request #15858: URL: https://github.com/apache/flink/pull/15858#issuecomment-834799316 ## CI report: * 16e61d4169ad70214e2d8a503e100ac566b6800e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15860: [FLINK-22598][examples] Update deprecated forms of writeAsText in examples

flinkbot edited a comment on pull request #15860: URL: https://github.com/apache/flink/pull/15860#issuecomment-835080766 ## CI report: * 3b42ff5c62b287157d954cfdc3258def7a258c67 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.0 due to CVEs

flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * d0a13db504e21e3afddc768f09c9b99337785ab5 Azure:

[jira] [Commented] (FLINK-22587) Support aggregations in batch mode with DataStream API

[ https://issues.apache.org/jira/browse/FLINK-22587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341174#comment-17341174 ] Yun Gao commented on FLINK-22587: - Hi [~echauchot] very thanks for reporting this issue ! I tried the

[GitHub] [flink] lqjack commented on pull request #15812: remove slotpoolImpl

lqjack commented on pull request #15812: URL: https://github.com/apache/flink/pull/15812#issuecomment-835089041 @tillrohrmann fix related issues.the changes for ENABLE_DECLARATIVE_RESOURCE_MANAGEMENT and ResourceManagerGateway.requestSlot I need confirm. -- This is an automated message

[GitHub] [flink] flinkbot commented on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.0 due to CVEs

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

[GitHub] [flink] flinkbot commented on pull request #15860: [FLINK-22598][examples] Update deprecated forms of writeAsText in examples

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

[GitHub] [flink] flinkbot edited a comment on pull request #15479: [FLINK-19606][table-runtime-blink] Introduce StreamExecWindowJoin and window join it cases

flinkbot edited a comment on pull request #15479: URL: https://github.com/apache/flink/pull/15479#issuecomment-812344008 ## CI report: * 1b562e2eec41f48d9ac9b4e7591240b6c8d99e61 Azure:

[jira] [Created] (FLINK-22603) The digest can be produced by SourceAbilitySpec

Jingsong Lee created FLINK-22603: Summary: The digest can be produced by SourceAbilitySpec Key: FLINK-22603 URL: https://issues.apache.org/jira/browse/FLINK-22603 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.0 due to CVEs

flinkbot commented on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835059779 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

[jira] [Closed] (FLINK-22536) Promote the critical log in FineGrainedSlotManager to INFO level

[ https://issues.apache.org/jira/browse/FLINK-22536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-22536. Fix Version/s: 1.14.0 Resolution: Done Merged via - master (1.14):

[jira] [Updated] (FLINK-22602) Upgrade parquet to 1.12.0 due to CVEs

[ https://issues.apache.org/jira/browse/FLINK-22602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22602: --- Labels: pull-request-available (was: ) > Upgrade parquet to 1.12.0 due to CVEs >

[GitHub] [flink] cuibo01 opened a new pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.0 due to CVEs

cuibo01 opened a new pull request #15861: URL: https://github.com/apache/flink/pull/15861 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] flinkbot edited a comment on pull request #15859: [FLINK-22525][table-api] Fix gmt format in Flink from GMT-8:00 to GMT-08:00

flinkbot edited a comment on pull request #15859: URL: https://github.com/apache/flink/pull/15859#issuecomment-835044237 ## CI report: * dbea27529825c987d5b908eb8c9622a9665790fd Azure:

[jira] [Created] (FLINK-22602) Upgrade parquet to 1.12.0 due to CVEs

Bo Cui created FLINK-22602: -- Summary: Upgrade parquet to 1.12.0 due to CVEs Key: FLINK-22602 URL: https://issues.apache.org/jira/browse/FLINK-22602 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-22600) TableSourceTable: extraDigests should be consistent with abilitySpecs

[ https://issues.apache.org/jira/browse/FLINK-22600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22600: - Issue Type: Improvement (was: Bug) > TableSourceTable: extraDigests should be consistent with

[jira] [Updated] (FLINK-22601) PushWatermarkIntoScan should produce digest created by Expression

[ https://issues.apache.org/jira/browse/FLINK-22601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22601: - Issue Type: Improvement (was: Bug) > PushWatermarkIntoScan should produce digest created by

[GitHub] [flink] xintongsong closed pull request #15850: [FLINK-22536][runtime] Promote the critical log in FineGrainedSlotMan…

xintongsong closed pull request #15850: URL: https://github.com/apache/flink/pull/15850 -- 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. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15479: [FLINK-19606][table-runtime-blink] Introduce StreamExecWindowJoin and window join it cases

flinkbot edited a comment on pull request #15479: URL: https://github.com/apache/flink/pull/15479#issuecomment-812344008 ## CI report: * 1b562e2eec41f48d9ac9b4e7591240b6c8d99e61 Azure:

[jira] [Updated] (FLINK-22601) PushWatermarkIntoScan should produce digest created by Expression

[ https://issues.apache.org/jira/browse/FLINK-22601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22601: - Component/s: Table SQL / Planner > PushWatermarkIntoScan should produce digest created by

[jira] [Created] (FLINK-22601) PushWatermarkIntoScan should produce digest created by Expression

Jingsong Lee created FLINK-22601: Summary: PushWatermarkIntoScan should produce digest created by Expression Key: FLINK-22601 URL: https://issues.apache.org/jira/browse/FLINK-22601 Project: Flink

[jira] [Updated] (FLINK-22598) Examples use deprecated forms of writeAsText

[ https://issues.apache.org/jira/browse/FLINK-22598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22598: --- Labels: pull-request-available pull-requests-available (was: pull-requests-available) >

[GitHub] [flink] flinkbot commented on pull request #15860: [FLINK-22598][examples] Update deprecated forms of writeAsText in examples

flinkbot commented on pull request #15860: URL: https://github.com/apache/flink/pull/15860#issuecomment-835055045 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

[jira] [Created] (FLINK-22600) TableSourceTable: extraDigests should be consistent with abilitySpecs

Jingsong Lee created FLINK-22600: Summary: TableSourceTable: extraDigests should be consistent with abilitySpecs Key: FLINK-22600 URL: https://issues.apache.org/jira/browse/FLINK-22600 Project: Flink

[jira] [Updated] (FLINK-22598) Examples use deprecated forms of writeAsText

[ https://issues.apache.org/jira/browse/FLINK-22598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Al-assad updated FLINK-22598: - Labels: pull-requests-available (was: pull-request-available) > Examples use deprecated forms of

[jira] [Updated] (FLINK-22598) Examples use deprecated forms of writeAsText

[ https://issues.apache.org/jira/browse/FLINK-22598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22598: --- Labels: pull-request-available (was: ) > Examples use deprecated forms of writeAsText >

[GitHub] [flink] Al-assad opened a new pull request #15860: [FLINK-22598][examples] Update deprecated forms of writeAsText in examples

Al-assad opened a new pull request #15860: URL: https://github.com/apache/flink/pull/15860 ## What is the purpose of the change The `writeAsText` usage of the examples is no longer recommended, so update to the latest usage. This PR only updates DataStream examples.

[jira] [Comment Edited] (FLINK-22551) checkpoints: strange behaviour

[ https://issues.apache.org/jira/browse/FLINK-22551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341114#comment-17341114 ] buom edited comment on FLINK-22551 at 5/8/21, 3:34 AM: --- [~HunterHunter] The logic

[jira] [Commented] (FLINK-22551) checkpoints: strange behaviour

[ https://issues.apache.org/jira/browse/FLINK-22551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341114#comment-17341114 ] buom commented on FLINK-22551: -- [~HunterHunter] The logic is wrong in cases 2 & 3 - there is no text

[jira] [Created] (FLINK-22599) Point to `client.timeout` in error messages where it is used for rpc timeout

Xintong Song created FLINK-22599: Summary: Point to `client.timeout` in error messages where it is used for rpc timeout Key: FLINK-22599 URL: https://issues.apache.org/jira/browse/FLINK-22599

[jira] [Commented] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341113#comment-17341113 ] Yang Wang commented on FLINK-22014: --- [~trohrmann] Do you mean that you could reproduce the issue

[GitHub] [flink] flinkbot commented on pull request #15859: [FLINK-22525][table-api] Fix gmt format in Flink from GMT-8:00 to GMT-08:00

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

[GitHub] [flink] flinkbot edited a comment on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

flinkbot edited a comment on pull request #15848: URL: https://github.com/apache/flink/pull/15848#issuecomment-833490569 ## CI report: * 99a21fd00339a5c0f0700c493095c745ac1935c0 Azure:

[jira] [Updated] (FLINK-22598) Examples use deprecated forms of writeAsText

[ https://issues.apache.org/jira/browse/FLINK-22598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Al-assad updated FLINK-22598: - Description: The DataStream examples at

[jira] [Updated] (FLINK-22598) Examples use deprecated forms of writeAsText

[ https://issues.apache.org/jira/browse/FLINK-22598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Al-assad updated FLINK-22598: - Description:   The DataStream examples at

[jira] [Updated] (FLINK-22598) Examples use deprecated forms of writeAsText

[ https://issues.apache.org/jira/browse/FLINK-22598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Al-assad updated FLINK-22598: - Description:   The DataStream examples at

[jira] [Assigned] (FLINK-22586) Improve precision derivation for decimal arithmetics

[ https://issues.apache.org/jira/browse/FLINK-22586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22586: Assignee: Shuo Cheng > Improve precision derivation for decimal arithmetics >

[GitHub] [flink] beyond1920 commented on pull request #15479: [FLINK-19606][table-runtime-blink] Introduce StreamExecWindowJoin and window join it cases

beyond1920 commented on pull request #15479: URL: https://github.com/apache/flink/pull/15479#issuecomment-835038080 @JingsongLi Thanks for reminding me, I've rebased, please have a look, thanks. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] godfreyhe commented on a change in pull request #14894: [FLINK-20895][flink-table-planner-blink] support local aggregate push down in blink planner

godfreyhe commented on a change in pull request #14894: URL: https://github.com/apache/flink/pull/14894#discussion_r628689039 ## File path:

[GitHub] [flink] JingsongLi edited a comment on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

JingsongLi edited a comment on pull request #15848: URL: https://github.com/apache/flink/pull/15848#issuecomment-835035689 HIVE: https://issues.apache.org/jira/browse/HIVE-15331 SPARK: https://issues.apache.org/jira/browse/SPARK-22036 -- This is an automated message from the Apache

[GitHub] [flink] godfreyhe commented on a change in pull request #14894: [FLINK-20895][flink-table-planner-blink] support local aggregate push down in blink planner

godfreyhe commented on a change in pull request #14894: URL: https://github.com/apache/flink/pull/14894#discussion_r628668576 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/abilities/source/AggregatePushDownSpec.java ##

[GitHub] [flink] JingsongLi commented on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

JingsongLi commented on pull request #15848: URL: https://github.com/apache/flink/pull/15848#issuecomment-835035689 HIVE: https://issues.apache.org/jira/browse/HIVE-15331 SPARK: https://github.com/apache/spark/pull/20023 -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-22598) Examples use deprecated forms of writeAsText

[ https://issues.apache.org/jira/browse/FLINK-22598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Al-assad updated FLINK-22598: - Description: The DataStream examples at

[jira] [Updated] (FLINK-22598) Examples use deprecated forms of writeAsText

[ https://issues.apache.org/jira/browse/FLINK-22598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Al-assad updated FLINK-22598: - Description: The DataStream examples at

[jira] [Assigned] (FLINK-22355) Simple Task Manager Memory Model image does not show up

[ https://issues.apache.org/jira/browse/FLINK-22355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22355: Assignee: Xiao Chen > Simple Task Manager Memory Model image does not show up >

[jira] [Assigned] (FLINK-22355) Simple Task Manager Memory Model image does not show up

[ https://issues.apache.org/jira/browse/FLINK-22355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22355: Assignee: Xiao Huang (was: Xiao Chen) > Simple Task Manager Memory Model image does not

[jira] [Commented] (FLINK-22355) Simple Task Manager Memory Model image does not show up

[ https://issues.apache.org/jira/browse/FLINK-22355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341108#comment-17341108 ] Xintong Song commented on FLINK-22355: -- [~ShawnHx], you're assigned. > Simple Task Manager Memory

[GitHub] [flink] JingsongLi commented on pull request #15479: [FLINK-19606][table-runtime-blink] Introduce StreamExecWindowJoin and window join it cases

JingsongLi commented on pull request #15479: URL: https://github.com/apache/flink/pull/15479#issuecomment-835031017 Can you rebase? -- 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

[jira] [Updated] (FLINK-22598) Examples use deprecated forms of writeAsText

[ https://issues.apache.org/jira/browse/FLINK-22598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Al-assad updated FLINK-22598: - Description: The DataStream examples at

[jira] [Created] (FLINK-22598) Examples use deprecated forms of writeAsText

Al-assad created FLINK-22598: Summary: Examples use deprecated forms of writeAsText Key: FLINK-22598 URL: https://issues.apache.org/jira/browse/FLINK-22598 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

flinkbot edited a comment on pull request #15848: URL: https://github.com/apache/flink/pull/15848#issuecomment-833490569 ## CI report: * 99a21fd00339a5c0f0700c493095c745ac1935c0 Azure:

[GitHub] [flink] flinkbot commented on pull request #15859: [FLINK-22525][table-api] Fix gmt format in Flink from GMT-8:00 to GMT-08:00

flinkbot commented on pull request #15859: URL: https://github.com/apache/flink/pull/15859#issuecomment-835001500 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

[jira] [Updated] (FLINK-22525) The zone id in exception message should be GMT+08:00 instead of GMT+8:00

[ https://issues.apache.org/jira/browse/FLINK-22525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22525: --- Labels: pull-request-available (was: ) > The zone id in exception message should be

[GitHub] [flink] leonardBang opened a new pull request #15859: [FLINK-22525][table-api] Fix gmt format in Flink from GMT-8:00 to GMT-08:00

leonardBang opened a new pull request #15859: URL: https://github.com/apache/flink/pull/15859 ## What is the purpose of the change * The format 'GMT-8:00' is invalid to **java.time.ZoneId**, this pull request fix the gmt format in flink doc and code from GMT-8:00 to GMT-08:00.

[jira] [Commented] (FLINK-22355) Simple Task Manager Memory Model image does not show up

[ https://issues.apache.org/jira/browse/FLINK-22355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341101#comment-17341101 ] Xiao Huang commented on FLINK-22355: Hi, [~dwysakowicz]. I'm willing to fix this. Could you assign

[GitHub] [flink] cshuo commented on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

cshuo commented on pull request #15848: URL: https://github.com/apache/flink/pull/15848#issuecomment-834993513 @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] [Closed] (FLINK-22505) Limit the precision of Resource

[ https://issues.apache.org/jira/browse/FLINK-22505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-22505. Fix Version/s: 1.14.0 Resolution: Fixed Fixed via - master (1.14):

[GitHub] [flink] JingsongLi merged pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

JingsongLi merged pull request #15760: URL: https://github.com/apache/flink/pull/15760 -- 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. For queries about this service,

[GitHub] [flink] xintongsong closed pull request #15815: [FLINK-22505][core] Limit the scale of Resource to 8

xintongsong closed pull request #15815: URL: https://github.com/apache/flink/pull/15815 -- 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. For queries about this service,

[GitHub] [flink] JingsongLi commented on a change in pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

JingsongLi commented on a change in pull request #15760: URL: https://github.com/apache/flink/pull/15760#discussion_r628676415 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/window/WindowJoinOperator.java ## @@

[GitHub] [flink] KarmaGYZ commented on pull request #15815: [FLINK-22505][core] Limit the scale of Resource to 8

KarmaGYZ commented on pull request #15815: URL: https://github.com/apache/flink/pull/15815#issuecomment-834973543 Failure caused by the existing issue FLINK-22595. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-22595) RocksDBStateBackendWindowITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341098#comment-17341098 ] Yangze Guo commented on FLINK-22595:

[jira] [Commented] (FLINK-21095) Remove legacy slotmanagement profile

[ https://issues.apache.org/jira/browse/FLINK-21095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341097#comment-17341097 ] Yangze Guo commented on FLINK-21095: Hi, [~chesnay] and [~trohrmann]. Does this mean we want to

[GitHub] [flink] cshuo commented on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

cshuo commented on pull request #15848: URL: https://github.com/apache/flink/pull/15848#issuecomment-834964547 @JingsongLi -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Updated] (FLINK-22589) There are quite a few Python classes doesn't appear in the Python docs

[ https://issues.apache.org/jira/browse/FLINK-22589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22589: Fix Version/s: 1.14.0 > There are quite a few Python classes doesn't appear in the Python docs >

[jira] [Reopened] (FLINK-22393) Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-22393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianzhang Chen reopened FLINK-22393: > Translate the page of "Execution Mode (Batch/Streaming)" into Chinese >

[jira] [Comment Edited] (FLINK-22393) Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-22393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341083#comment-17341083 ] Jianzhang Chen edited comment on FLINK-22393 at 5/8/21, 12:40 AM: -- Hi

[jira] [Resolved] (FLINK-22393) Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-22393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianzhang Chen resolved FLINK-22393. Resolution: Done Ready for PR merge. > Translate the page of "Execution Mode

[GitHub] [flink] flinkbot edited a comment on pull request #15821: [FLINK-21911][table] Add built-in greatest/least functions support

flinkbot edited a comment on pull request #15821: URL: https://github.com/apache/flink/pull/15821#issuecomment-830427889 ## CI report: * 8e75fa3fca772e2550b17564e77e0eca97251238 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15812: remove slotpoolImpl

flinkbot edited a comment on pull request #15812: URL: https://github.com/apache/flink/pull/15812#issuecomment-829441551 ## CI report: * 138ef072ee69fd18736d215afae07834a993c9d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15821: [FLINK-21911][table] Add built-in greatest/least functions support

flinkbot edited a comment on pull request #15821: URL: https://github.com/apache/flink/pull/15821#issuecomment-830427889 ## CI report: * 8e75fa3fca772e2550b17564e77e0eca97251238 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15858: [WIP][FLINK-22067][tests] Wait for vertices to using API

flinkbot edited a comment on pull request #15858: URL: https://github.com/apache/flink/pull/15858#issuecomment-834799316 ## CI report: * 16e61d4169ad70214e2d8a503e100ac566b6800e Azure:

[jira] [Updated] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22067: --- Labels: auto-deprioritized-critical pull-request-available test-stability (was:

[GitHub] [flink] flinkbot commented on pull request #15858: [WIP][FLINK-22067][tests] Wait for vertices to using API

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

[GitHub] [flink] flinkbot commented on pull request #15858: [WIP][FLINK-22481][tests] Wait for vertices to using API

flinkbot commented on pull request #15858: URL: https://github.com/apache/flink/pull/15858#issuecomment-834789807 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

[jira] [Commented] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341037#comment-17341037 ] Roman Khachatryan commented on FLINK-22067: --- I think the issue is caused by

[jira] [Updated] (FLINK-22481) RocksDBStateBackendWindowITCase times out on Azure

[ https://issues.apache.org/jira/browse/FLINK-22481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22481: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] rkhachatryan opened a new pull request #15858: [WIP][FLINK-22481][tests] Wait for vertices to using API

rkhachatryan opened a new pull request #15858: URL: https://github.com/apache/flink/pull/15858 ## What is the purpose of the change Showcase the usage of API instead of latches to wait for vertices to start. This should prevent bugs when not all tasks are running at the time of

[GitHub] [flink] flinkbot edited a comment on pull request #15837: [FLINK-22537][docs] Add documentation how to interact with DataStream API

flinkbot edited a comment on pull request #15837: URL: https://github.com/apache/flink/pull/15837#issuecomment-832649922 ## CI report: * 4186d304f132555a8337ff9c1de35c26c5936258 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15789: [FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources

flinkbot edited a comment on pull request #15789: URL: https://github.com/apache/flink/pull/15789#issuecomment-827996694 ## CI report: * 4c5180310bf76e96f2665bf53531eccb1fa86421 UNKNOWN * 0deea5791e8fbe396429f62da52dedeb3670a2b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15856: [BP-1.13][FLINK-22577][tests] Harden KubernetesLeaderElectionAndRetrievalITCase

flinkbot edited a comment on pull request #15856: URL: https://github.com/apache/flink/pull/15856#issuecomment-834546697 ## CI report: * 3d5fdc5188805817e8c8f81501b72769c3938956 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15854: [BP-1.12][FLINK-22597] Make JobMaster restartable

flinkbot edited a comment on pull request #15854: URL: https://github.com/apache/flink/pull/15854#issuecomment-834546252 ## CI report: * 8066fe2dbbdd378c63b30fd9afb81349320a5adf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15853: [FLINK-22566][test] Adds NodeManager log extraction to YARN-related e2e tests

flinkbot edited a comment on pull request #15853: URL: https://github.com/apache/flink/pull/15853#issuecomment-834546066 ## CI report: * 093542c6114bc04e7954c90ce47098685d8c88f6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15849: [FLINK-22577][tests] Harden KubernetesLeaderElectionAndRetrievalITCase

flinkbot edited a comment on pull request #15849: URL: https://github.com/apache/flink/pull/15849#issuecomment-833559648 ## CI report: * 07aac793a06614501d9e0a60efe9b7e17ade9699 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15857: [BP-1.12][FLINK-22577][tests] Harden KubernetesLeaderElectionAndRetrievalITCase

flinkbot edited a comment on pull request #15857: URL: https://github.com/apache/flink/pull/15857#issuecomment-834546877 ## CI report: * bc6b84b7d48a3dfced7dbd9ec721a9ddeb46b3e9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15789: [FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources

flinkbot edited a comment on pull request #15789: URL: https://github.com/apache/flink/pull/15789#issuecomment-827996694 ## CI report: * 4c5180310bf76e96f2665bf53531eccb1fa86421 UNKNOWN * ec5676afadc1218d866524a516eee92924ccee45 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15812: remove slotpoolImpl

flinkbot edited a comment on pull request #15812: URL: https://github.com/apache/flink/pull/15812#issuecomment-829441551 ## CI report: * 086cab27ec50c4742cf96d0735f6242d3d4612e9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15852: [FLINK-22596][checkpoints] Active timeout is not triggered if there were no barriers

flinkbot edited a comment on pull request #15852: URL: https://github.com/apache/flink/pull/15852#issuecomment-834516673 ## CI report: * 918871ae4db2875d001a7c91102f0ebadf91c4d8 UNKNOWN * a824e690bc361bd9196c22cdd98c3b625f2272c1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15855: [BP-1.11][FLINK-22597] Make JobMaster restartable

flinkbot edited a comment on pull request #15855: URL: https://github.com/apache/flink/pull/15855#issuecomment-834546533 ## CI report: * 0c8a0bf0eeaa1e915841975b6402a67bedb6bb56 Azure:

  1   2   3   4   >