[GitHub] [flink] flinkbot edited a comment on pull request #15499: [FLINK-22127][network] Enrich error message of read buffer request timeout to tell the user how to solve the problem when using sort-

flinkbot edited a comment on pull request #15499: URL: https://github.com/apache/flink/pull/15499#issuecomment-814647050 ## CI report: * 87b826d246f4e396c92dabfa7510607f1b77e6c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[jira] [Resolved] (FLINK-22172) Fix the bug of shared resource among Python Operators of the same slot is not released

[ https://issues.apache.org/jira/browse/FLINK-22172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-22172. -- Resolution: Fixed Merged into master 023568b83d971b439468d680bddc66d584c6f7c4 Merged into

[GitHub] [flink] HuangXingBo closed pull request #15537: [FLINK-22172][python] Fix the bug of shared resource among Python Operators of the same slot is not released

HuangXingBo closed pull request #15537: URL: https://github.com/apache/flink/pull/15537 -- 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 #15554: [FLINK-20816][tests] Fix race condition in NotifyCheckpointAbortedITCase.

flinkbot edited a comment on pull request #15554: URL: https://github.com/apache/flink/pull/15554#issuecomment-816848735 ## CI report: * 82a466cec422d0e523440a0943ab4a4f9ae135b4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

flinkbot edited a comment on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550 ## CI report: * 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN * f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15487: [FLINK-15571][connector] [POC] Redis Stream connector for Flink

flinkbot edited a comment on pull request #15487: URL: https://github.com/apache/flink/pull/15487#issuecomment-813369782 ## CI report: * 5f3ad56f5b166d855b4d7e75a8e9bc01d465b0ec Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15553: [FLINK-22069] Reduce various logging issues

flinkbot edited a comment on pull request #15553: URL: https://github.com/apache/flink/pull/15553#issuecomment-816736380 ## CI report: * 101152d2c0e272d1e3a1d049d5b596d2af2f7fb2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15552: [FLINK-22184][client] Shutdown client outside of netty thread

flinkbot edited a comment on pull request #15552: URL: https://github.com/apache/flink/pull/15552#issuecomment-816736265 ## CI report: * 2c4afb90df12ef1dd27ea6a49b99be8841aefab4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

flinkbot edited a comment on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550 ## CI report: * 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN * f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15551: [FLINK-22151][table] Implement type inference for agg functions

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

[GitHub] [flink] flinkbot edited a comment on pull request #15554: [FLINK-20816][tests] Fix race condition in NotifyCheckpointAbortedITCase.

flinkbot edited a comment on pull request #15554: URL: https://github.com/apache/flink/pull/15554#issuecomment-816848735 ## CI report: * 82a466cec422d0e523440a0943ab4a4f9ae135b4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15487: [FLINK-15571][connector] [POC] Redis Stream connector for Flink

flinkbot edited a comment on pull request #15487: URL: https://github.com/apache/flink/pull/15487#issuecomment-813369782 ## CI report: * ff679da8f952446a289835f73ef3ff90ce3cfa91 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15155: [FLINK-21660][table-api-java][hive] Stop using is_generic to differen…

flinkbot edited a comment on pull request #15155: URL: https://github.com/apache/flink/pull/15155#issuecomment-79675 ## CI report: * 3985c48c6c4c43ea8d7c9fd924ee91d8c1608ae7 Azure:

[GitHub] [flink] flinkbot commented on pull request #15554: [FLINK-20816][tests] Fix race condition in NotifyCheckpointAbortedITCase.

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

[GitHub] [flink] flinkbot edited a comment on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

flinkbot edited a comment on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550 ## CI report: * 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN * f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #15554: [FLINK-20816][tests] Fix race condition in NotifyCheckpointAbortedITCase.

flinkbot commented on pull request #15554: URL: https://github.com/apache/flink/pull/15554#issuecomment-816845283 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-20816) NotifyCheckpointAbortedITCase failed due to timeout

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

[GitHub] [flink] AHeise opened a new pull request #15554: [FLINK-20816][tests] Fix race condition in NotifyCheckpointAbortedITCase.

AHeise opened a new pull request #15554: URL: https://github.com/apache/flink/pull/15554 ## What is the purpose of the change `NotifyCheckpointAbortedITCase` implicitly assumes that abortion of chk-1 happens before sync phase of chk-2. If abortion is late, the mail that

[GitHub] [flink] flinkbot edited a comment on pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

flinkbot edited a comment on pull request #15550: URL: https://github.com/apache/flink/pull/15550#issuecomment-816683015 ## CI report: * aa5b840d171126cc36ad16906cd0c30d3ebdce6f Azure:

[GitHub] [flink] YuvalItzchakov edited a comment on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

YuvalItzchakov edited a comment on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-816832991 @fsk119 All fixes are done except the one for removing `PushFilterIntoTableSourceScanRule`, not sure I understood what you meant there. -- This is an automated

[GitHub] [flink] YuvalItzchakov commented on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

YuvalItzchakov commented on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-816832991 All fixes are done except the one for removing `PushFilterIntoTableSourceScanRule`, not sure I understood what you meant there. -- This is an automated message from

[jira] [Assigned] (FLINK-21859) Batch job fails due to "Could not mark slot 61a637e3977c58a0e6b73533c419297d active"

[ https://issues.apache.org/jira/browse/FLINK-21859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-21859: - Assignee: Till Rohrmann > Batch job fails due to "Could not mark slot

[jira] [Commented] (FLINK-21859) Batch job fails due to "Could not mark slot 61a637e3977c58a0e6b73533c419297d active"

[ https://issues.apache.org/jira/browse/FLINK-21859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318138#comment-17318138 ] Till Rohrmann commented on FLINK-21859: --- What I cannot really explain is why we immediately after

[jira] [Updated] (FLINK-21859) Batch job fails due to "Could not mark slot 61a637e3977c58a0e6b73533c419297d active"

[ https://issues.apache.org/jira/browse/FLINK-21859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21859: -- Priority: Critical (was: Major) > Batch job fails due to "Could not mark slot

[GitHub] [flink] flinkbot edited a comment on pull request #15487: [FLINK-15571][connector] [POC] Redis Stream connector for Flink

flinkbot edited a comment on pull request #15487: URL: https://github.com/apache/flink/pull/15487#issuecomment-813369782 ## CI report: * 6e2259531f24b18f9553d50b83aaf2f4840c8ae7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[jira] [Commented] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318134#comment-17318134 ] Arvid Heise commented on FLINK-20816: - I found the root cause: the test assumes implicitly that

[GitHub] [flink] YuvalItzchakov commented on a change in pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

YuvalItzchakov commented on a change in pull request #15307: URL: https://github.com/apache/flink/pull/15307#discussion_r610781390 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala ## @@

[GitHub] [flink] YuvalItzchakov commented on a change in pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

YuvalItzchakov commented on a change in pull request #15307: URL: https://github.com/apache/flink/pull/15307#discussion_r610781390 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala ## @@

[jira] [Commented] (FLINK-21859) Batch job fails due to "Could not mark slot 61a637e3977c58a0e6b73533c419297d active"

[ https://issues.apache.org/jira/browse/FLINK-21859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318123#comment-17318123 ] Till Rohrmann commented on FLINK-21859: --- >From the logs it looks as if the {{TaskManager}} offers

[GitHub] [flink] flinkbot edited a comment on pull request #15495: [FLINK-21305][table-planner-blink] Fix Cumulative and Hopping window should accumulate late events belonging to the cleaned slice

flinkbot edited a comment on pull request #15495: URL: https://github.com/apache/flink/pull/15495#issuecomment-814224111 ## CI report: * b9658ea5c6365f7041eaa9d4ebba7032bb3759c1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15487: [FLINK-15571][connector] [POC] Redis Stream connector for Flink

flinkbot edited a comment on pull request #15487: URL: https://github.com/apache/flink/pull/15487#issuecomment-813369782 ## CI report: * 6e2259531f24b18f9553d50b83aaf2f4840c8ae7 Azure:

[jira] [Updated] (FLINK-22185) Add k8s example to flink-statefun-playground

[ https://issues.apache.org/jira/browse/FLINK-22185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22185: --- Labels: pull-request-available (was: ) > Add k8s example to flink-statefun-playground >

[GitHub] [flink-statefun-playground] igalshilman opened a new pull request #11: [FLINK-22185] Add k8s example

igalshilman opened a new pull request #11: URL: https://github.com/apache/flink-statefun-playground/pull/11 This PR adds an already pre-configured, ready to `kubectl apply` k8s example. copied from README.md: --- # Kubernetes Example ##

[jira] [Updated] (FLINK-22185) Add k8s example to flink-statefun-playground

[ https://issues.apache.org/jira/browse/FLINK-22185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-22185: - Description: Add a simple pre-configured example for the playground, that demonstrates a

[jira] [Created] (FLINK-22185) Add k8s example to flink-statefun-playground

Igal Shilman created FLINK-22185: Summary: Add k8s example to flink-statefun-playground Key: FLINK-22185 URL: https://issues.apache.org/jira/browse/FLINK-22185 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #15547: [FLINK-22015][table-planner-blink] Exclude IS NULL from SEARCH operators

flinkbot edited a comment on pull request #15547: URL: https://github.com/apache/flink/pull/15547#issuecomment-816538871 ## CI report: * 14808493846d0a096cf51484c030fd564f3e3da0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15549: [FLINK-20761][hive] Escape the location path when creating input splits

flinkbot edited a comment on pull request #15549: URL: https://github.com/apache/flink/pull/15549#issuecomment-816597084 ## CI report: * 6bc0d4aa007b6fe629822142a3e6eb1d6c6fe7d9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15519: [FLINK-22120] Remove duplicate code in generated code for map get

flinkbot edited a comment on pull request #15519: URL: https://github.com/apache/flink/pull/15519#issuecomment-815409179 ## CI report: * f4c660ad4e60a753513f4759dee39363fa86ebeb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15489: [FLINK-22106][table-planner-blink] Result type of GeneratedExpression in StringCallGen should be compatible with their definition in

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

[jira] [Commented] (FLINK-22069) Check Log Pollution for 1.13 release

[ https://issues.apache.org/jira/browse/FLINK-22069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318099#comment-17318099 ] Stephan Ewen commented on FLINK-22069: -- Random log exception when tasks finish after a checkpoint

[GitHub] [flink] rkhachatryan commented on a change in pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

rkhachatryan commented on a change in pull request #15550: URL: https://github.com/apache/flink/pull/15550#discussion_r610733665 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -932,9 +932,9 @@ public void

[jira] [Commented] (FLINK-22181) SourceNAryInputChainingITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318091#comment-17318091 ] Stephan Ewen commented on FLINK-22181: -- At this point, I would expect they all have a similar root

[jira] [Commented] (FLINK-22069) Check Log Pollution for 1.13 release

[ https://issues.apache.org/jira/browse/FLINK-22069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318090#comment-17318090 ] Stephan Ewen commented on FLINK-22069: -- When checkpoints are being skipped because not all sources

[GitHub] [flink] rkhachatryan commented on a change in pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

rkhachatryan commented on a change in pull request #15550: URL: https://github.com/apache/flink/pull/15550#discussion_r610724355 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterStopWithSavepointITCase.java ## @@ -384,24 +380,28 @@ protected

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] kezhuw commented on a change in pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

kezhuw commented on a change in pull request #15550: URL: https://github.com/apache/flink/pull/15550#discussion_r610720272 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -932,9 +932,9 @@ public void

[GitHub] [flink] dawidwys commented on a change in pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

dawidwys commented on a change in pull request #15550: URL: https://github.com/apache/flink/pull/15550#discussion_r610713471 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterStopWithSavepointITCase.java ## @@ -384,24 +380,28 @@ protected

[GitHub] [flink] dawidwys commented on a change in pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

dawidwys commented on a change in pull request #15550: URL: https://github.com/apache/flink/pull/15550#discussion_r610713471 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterStopWithSavepointITCase.java ## @@ -384,24 +380,28 @@ protected

[GitHub] [flink] dawidwys commented on a change in pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

dawidwys commented on a change in pull request #15550: URL: https://github.com/apache/flink/pull/15550#discussion_r610715281 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -932,9 +932,9 @@ public void

[GitHub] [flink] dawidwys commented on a change in pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

dawidwys commented on a change in pull request #15550: URL: https://github.com/apache/flink/pull/15550#discussion_r610715281 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -932,9 +932,9 @@ public void

[GitHub] [flink] dawidwys commented on a change in pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

dawidwys commented on a change in pull request #15550: URL: https://github.com/apache/flink/pull/15550#discussion_r610715281 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -932,9 +932,9 @@ public void

[GitHub] [flink] dawidwys commented on a change in pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

dawidwys commented on a change in pull request #15550: URL: https://github.com/apache/flink/pull/15550#discussion_r610713471 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterStopWithSavepointITCase.java ## @@ -384,24 +380,28 @@ protected

[jira] [Commented] (FLINK-20432) SQLClientSchemaRegistryITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318069#comment-17318069 ] Dawid Wysakowicz commented on FLINK-20432: -- Probably transient ssl error when reaching docker

[jira] [Updated] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22085: - Priority: Blocker (was: Critical) > KafkaSourceLegacyITCase hangs/fails on azure >

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318067#comment-17318067 ] Dawid Wysakowicz commented on FLINK-22085: --

[GitHub] [flink] flinkbot edited a comment on pull request #15553: [FLINK-22069] Reduce various logging issues

flinkbot edited a comment on pull request #15553: URL: https://github.com/apache/flink/pull/15553#issuecomment-816736380 ## CI report: * 101152d2c0e272d1e3a1d049d5b596d2af2f7fb2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15544: [FLINK-17371][table-runtime] Open testDefaultDecimalCasting case in DecimalTypeTest

flinkbot edited a comment on pull request #15544: URL: https://github.com/apache/flink/pull/15544#issuecomment-816526265 ## CI report: * 11559ea2ac7fd1ae2a135fd2e5189ec1a4e30372 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15552: [FLINK-22184][client] Shutdown client outside of netty thread

flinkbot edited a comment on pull request #15552: URL: https://github.com/apache/flink/pull/15552#issuecomment-816736265 ## CI report: * 2c4afb90df12ef1dd27ea6a49b99be8841aefab4 Azure:

[GitHub] [flink] flinkbot commented on pull request #15553: [FLINK-22069] Reduce various logging issues

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

[GitHub] [flink] flinkbot commented on pull request #15552: [FLINK-22184][client] Shutdown client outside of netty thread

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

rkhachatryan commented on a change in pull request #15550: URL: https://github.com/apache/flink/pull/15550#discussion_r610676693 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -932,9 +932,9 @@ public void

[GitHub] [flink] flinkbot commented on pull request #15553: [FLINK-22069] Reduce various logging issues

flinkbot commented on pull request #15553: URL: https://github.com/apache/flink/pull/15553#issuecomment-816728271 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 #15552: [FLINK-22184][client] Shutdown client outside of netty thread

flinkbot commented on pull request #15552: URL: https://github.com/apache/flink/pull/15552#issuecomment-816728297 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-22069) Check Log Pollution for 1.13 release

[ https://issues.apache.org/jira/browse/FLINK-22069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22069: --- Labels: pull-request-available (was: ) > Check Log Pollution for 1.13 release >

[jira] [Updated] (FLINK-22184) Rest client shutdown on failure runs in netty thread

[ https://issues.apache.org/jira/browse/FLINK-22184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22184: --- Labels: pull-request-available (was: ) > Rest client shutdown on failure runs in netty

[GitHub] [flink] zentol opened a new pull request #15553: [FLINK-22069] Reduce various logging issues

zentol opened a new pull request #15553: URL: https://github.com/apache/flink/pull/15553 A collection of various issues around logging. Each commit is self-contained and addresses a separate issue. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] zentol opened a new pull request #15552: [FLINK-22184][client] Shutdown client outside of netty thread

zentol opened a new pull request #15552: URL: https://github.com/apache/flink/pull/15552 If the future returned by `clusterClient.submitJob()` fails, then this failure is executed by a netty thread. This then causes `.whenComplete((ignored1, ignored2) -> clusterClient.close())` to also be

[GitHub] [flink] flinkbot edited a comment on pull request #15551: [FLINK-22151][table] Implement type inference for agg functions

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

[GitHub] [flink] flinkbot edited a comment on pull request #15534: [FLINK-22104][sql-client] Fix unstable SqlClientTest.testExecuteSqlFile

flinkbot edited a comment on pull request #15534: URL: https://github.com/apache/flink/pull/15534#issuecomment-816392253 ## CI report: * f0f37cfe199dc670e8908b05a7df7ace8c2ecfd4 UNKNOWN * 4333c907fd2b5bd8953853e0af21ef51bcdf1810 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15519: [FLINK-22120] Remove duplicate code in generated code for map get

flinkbot edited a comment on pull request #15519: URL: https://github.com/apache/flink/pull/15519#issuecomment-815409179 ## CI report: * aad685a974e0f542d911900db42361aade6fb299 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15487: [FLINK-15571][connector] [POC] Redis Stream connector for Flink

flinkbot edited a comment on pull request #15487: URL: https://github.com/apache/flink/pull/15487#issuecomment-813369782 ## CI report: * 6e2259531f24b18f9553d50b83aaf2f4840c8ae7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15155: [FLINK-21660][table-api-java][hive] Stop using is_generic to differen…

flinkbot edited a comment on pull request #15155: URL: https://github.com/apache/flink/pull/15155#issuecomment-79675 ## CI report: * c0ee0ff10082a0299df061aea1e893c7a6471b9a Azure:

[jira] [Created] (FLINK-22184) Rest client shutdown on failure runs in netty thread

Chesnay Schepler created FLINK-22184: Summary: Rest client shutdown on failure runs in netty thread Key: FLINK-22184 URL: https://issues.apache.org/jira/browse/FLINK-22184 Project: Flink

[GitHub] [flink] zentol merged pull request #15532: Add missed parenthesis into doc demo code.

zentol merged pull request #15532: URL: https://github.com/apache/flink/pull/15532 -- 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, please

[jira] [Updated] (FLINK-22183) Update Website copyright footer

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

[GitHub] [flink-web] zentol opened a new pull request #432: [FLINK-22183] Update copyright to 2014-2021

zentol opened a new pull request #432: URL: https://github.com/apache/flink-web/pull/432 -- 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,

[jira] [Created] (FLINK-22183) Update Website copyright footer

Chesnay Schepler created FLINK-22183: Summary: Update Website copyright footer Key: FLINK-22183 URL: https://issues.apache.org/jira/browse/FLINK-22183 Project: Flink Issue Type: Task

[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=17318000#comment-17318000 ] Till Rohrmann commented on FLINK-22014: --- In the logs, I couldn't find anything suspicious. It

[jira] [Comment Edited] (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=17318000#comment-17318000 ] Till Rohrmann edited comment on FLINK-22014 at 4/9/21, 1:51 PM: In the

[jira] [Closed] (FLINK-22116) Setup .asf.yaml in flink-web

[ https://issues.apache.org/jira/browse/FLINK-22116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-22116. Resolution: Fixed asf-site: f810b35f138691e4a32356469399035b173497bd > Setup .asf.yaml

[GitHub] [flink-web] zentol merged pull request #431: [FLINK-22116] Setup .asf.yaml for publishing

zentol merged pull request #431: URL: https://github.com/apache/flink-web/pull/431 -- 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, please

[GitHub] [flink] flinkbot edited a comment on pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

flinkbot edited a comment on pull request #15550: URL: https://github.com/apache/flink/pull/15550#issuecomment-816683015 ## CI report: * aa5b840d171126cc36ad16906cd0c30d3ebdce6f Azure:

[GitHub] [flink] flinkbot commented on pull request #15551: [FLINK-22151][table] Implement type inference for agg functions

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

[GitHub] [flink] flinkbot edited a comment on pull request #15487: [FLINK-15571][connector] [POC] Redis Stream connector for Flink

flinkbot edited a comment on pull request #15487: URL: https://github.com/apache/flink/pull/15487#issuecomment-813369782 ## CI report: * 6e2259531f24b18f9553d50b83aaf2f4840c8ae7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15155: [FLINK-21660][table-api-java][hive] Stop using is_generic to differen…

flinkbot edited a comment on pull request #15155: URL: https://github.com/apache/flink/pull/15155#issuecomment-79675 ## CI report: * c0ee0ff10082a0299df061aea1e893c7a6471b9a Azure:

[jira] [Updated] (FLINK-22182) Incorrect round when dividing decimals

[ https://issues.apache.org/jira/browse/FLINK-22182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated FLINK-22182: --- Summary: Incorrect round when dividing decimals (was: Incorrect round when dividing two

[jira] [Created] (FLINK-22182) Incorrect round when dividing two decimals

Maciej Bryński created FLINK-22182: -- Summary: Incorrect round when dividing two decimals Key: FLINK-22182 URL: https://issues.apache.org/jira/browse/FLINK-22182 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

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

[GitHub] [flink] flinkbot edited a comment on pull request #15548: [FLINK-22082][planner] Nested projection push down doesn't work for d…

flinkbot edited a comment on pull request #15548: URL: https://github.com/apache/flink/pull/15548#issuecomment-816538966 ## CI report: * a327bfd95662ad081f6a586518e9236c1bd65c86 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15545: [FLINK-22167][table-planner] Partial insert not works when complex fields reorder

flinkbot edited a comment on pull request #15545: URL: https://github.com/apache/flink/pull/15545#issuecomment-816526358 ## CI report: * 55e3eb5247e7f6c44ef4e6bef04c34c8fc6af348 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15544: [FLINK-17371][table-runtime] Open testDefaultDecimalCasting case in DecimalTypeTest

flinkbot edited a comment on pull request #15544: URL: https://github.com/apache/flink/pull/15544#issuecomment-816526265 ## CI report: * 6e5e37fd1ca4bc3bbccf95e3d18c1810311b6b9a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15541: [FLINK-20230][table] FileSystemOutputFormat should delete file using FileSystemFactory

flinkbot edited a comment on pull request #15541: URL: https://github.com/apache/flink/pull/15541#issuecomment-816513346 ## CI report: * a6a4fd6154c8e0a1bcab47e499e31f58c6ba62ce Azure:

[GitHub] [flink] flinkbot commented on pull request #15551: [FLINK-22151][table] Implement type inference for agg functions

flinkbot commented on pull request #15551: URL: https://github.com/apache/flink/pull/15551#issuecomment-816682127 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-22181) SourceNAryInputChainingITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22181: - Component/s: API / DataStream > SourceNAryInputChainingITCase hangs on azure >

[jira] [Commented] (FLINK-22181) SourceNAryInputChainingITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317982#comment-17317982 ] Dawid Wysakowicz commented on FLINK-22181: -- Could it be the same issue as in FLINK-22129 ?

  1   2   3   4   >