[GitHub] [flink] yulei0824 commented on pull request #16645: [FLINK-23539][metrics-influxdb] InfluxDBReporter should filter charac…

yulei0824 commented on pull request #16645: URL: https://github.com/apache/flink/pull/16645#issuecomment-892250517 @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

[GitHub] [flink] flinkbot edited a comment on pull request #16638: [FLINK-23513] Remove legacy descriptors

flinkbot edited a comment on pull request #16638: URL: https://github.com/apache/flink/pull/16638#issuecomment-889186834 ## CI report: * a08a51997cb8a8b63ef73c096967e7060d35ba94 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16638: [FLINK-23513] Remove legacy descriptors

flinkbot edited a comment on pull request #16638: URL: https://github.com/apache/flink/pull/16638#issuecomment-889186834 ## CI report: * a08a51997cb8a8b63ef73c096967e7060d35ba94 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16695: [FLINK-21116][runtime] Harden DefaultDispatcherRunnerITCase#leaderCha…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * 67e73451c554e31d4d9986cf08fc100248a9bc73 Azure:

[GitHub] [flink] flinkbot commented on pull request #16695: [FLINK-21116][runtime] Harden DefaultDispatcherRunnerITCase#leaderCha…

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

[GitHub] [flink] flinkbot edited a comment on pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

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

[GitHub] [flink] flinkbot edited a comment on pull request #16679: [FLINK-23402][streaming-java] Simplify shuffle mode for batch execution

flinkbot edited a comment on pull request #16679: URL: https://github.com/apache/flink/pull/16679#issuecomment-891160011 ## CI report: * f8313d6515c5940623049ff4d26a78f215201572 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * 921d56fcaebe0ea44b81d459e617de336508abcc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16589: [FLINK-23541] Call StreamOperator#finish on EndOfData

flinkbot edited a comment on pull request #16589: URL: https://github.com/apache/flink/pull/16589#issuecomment-886429447 ## CI report: * 791a3f1825b2e2d5682c40e9b7e52a4cbc576429 UNKNOWN * a29a6115a578c543a9856a07d0ef58f79ebcc895 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * 67e73451c554e31d4d9986cf08fc100248a9bc73 Azure:

[GitHub] [flink] tweise commented on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-892162645 @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 specific

[jira] [Assigned] (FLINK-21116) DefaultDispatcherRunnerITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-21116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-21116: - Assignee: David Morávek > DefaultDispatcherRunnerITCase hangs on azure >

[GitHub] [flink] flinkbot edited a comment on pull request #16686: [FLINK-23599] Remove JobVertex#connectIdInput

flinkbot edited a comment on pull request #16686: URL: https://github.com/apache/flink/pull/16686#issuecomment-891705792 ## CI report: * f7b6b4f40bdbbe148be7b5d59dd1307e1af99e57 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16626: [FLINK-23498][table] Introduce a full PlannerConfiguration

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

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 356eac1b45f73fa1f32a9a3fe5650821015c08c6 Azure:

[GitHub] [flink] flinkbot commented on pull request #16695: [FLINK-21116][runtime] Harden DefaultDispatcherRunnerITCase#leaderCha…

flinkbot commented on pull request #16695: URL: https://github.com/apache/flink/pull/16695#issuecomment-892152551 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] dmvk commented on pull request #16695: [FLINK-21116][runtime] Harden DefaultDispatcherRunnerITCase#leaderCha…

dmvk commented on pull request #16695: URL: https://github.com/apache/flink/pull/16695#issuecomment-892152358 Also, during testing, I've seen a deadlock when giving up leadership (two threads competing for TestingLeaderElectionService lock, ... didn't save the thread dump  ). I wasn't

[jira] [Updated] (FLINK-21116) DefaultDispatcherRunnerITCase hangs on azure

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

[GitHub] [flink] dmvk opened a new pull request #16695: [FLINK-21116][runtime] Harden DefaultDispatcherRunnerITCase#leaderCha…

dmvk opened a new pull request #16695: URL: https://github.com/apache/flink/pull/16695 ## What is the purpose of the change Fixing a flaky test. Test could get stuck due to hard to reproduce memory-visibility issue in TestingnJobManagerRunnerFactory and race condition between job

[GitHub] [flink] flinkbot edited a comment on pull request #16693: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

flinkbot edited a comment on pull request #16693: URL: https://github.com/apache/flink/pull/16693#issuecomment-891870243 ## CI report: * f44a2c2b644a85c2685ad4cd65e820bc65c20b62 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16688: [FLINK-22773][coordination] Optimize the construction of pipelined regions

flinkbot edited a comment on pull request #16688: URL: https://github.com/apache/flink/pull/16688#issuecomment-891705944 ## CI report: * 43208da2eb35e121e75d68c5f291722155383f81 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window

flinkbot edited a comment on pull request #16669: URL: https://github.com/apache/flink/pull/16669#issuecomment-890847741 ## CI report: * 889dfbb1b28097728eea054580fa4e0e6bb61c22 UNKNOWN * d321514b562b86bf64ac9898203cb9a6a8a7a54c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * bd42c56eeb75dcfa6c53f278128476f7a6242518 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16523: [FLINK-23416][runtime] Don't log NoResourceAvailableException stacktrace

flinkbot edited a comment on pull request #16523: URL: https://github.com/apache/flink/pull/16523#issuecomment-881941982 ## CI report: * e8adb21af054acbbd4d17ed52b71787f6191a6cc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16694: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

flinkbot edited a comment on pull request #16694: URL: https://github.com/apache/flink/pull/16694#issuecomment-891870309 ## CI report: * 17de24375718fd602b26c77a8428b89ac8c8bb9d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16645: [FLINK-23539][metrics-influxdb] InfluxDBReporter should filter charac…

flinkbot edited a comment on pull request #16645: URL: https://github.com/apache/flink/pull/16645#issuecomment-889643808 ## CI report: * cbbae90ac287c25df1d73ca53c6ece3a1032bf7d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16598: [FLINK-23501][GCP PubSub] add table source API for GCP PubSub

flinkbot edited a comment on pull request #16598: URL: https://github.com/apache/flink/pull/16598#issuecomment-886655820 ## CI report: * ea804b7e9a1e7411605938da2e10f4bd95bfd883 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16691: [FLINK-16200][table] Introduce JSON_EXISTS to Table API & SQL

flinkbot edited a comment on pull request #16691: URL: https://github.com/apache/flink/pull/16691#issuecomment-891851095 ## CI report: * 04c6f36ee2417c8354cd73a207e7b15bc9973a64 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16692: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

flinkbot edited a comment on pull request #16692: URL: https://github.com/apache/flink/pull/16692#issuecomment-891870165 ## CI report: * dcebe54c19ee58530db300a6919e9c43589a6753 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window

flinkbot edited a comment on pull request #16669: URL: https://github.com/apache/flink/pull/16669#issuecomment-890847741 ## CI report: * ec53f59127ff25dc2e644ded5505d0e8a054e5ad Azure:

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

flinkbot edited a comment on pull request #16655: URL: https://github.com/apache/flink/pull/16655#issuecomment-890307289 ## CI report: * f655d73296654e3137f45a2b49445a9af6f04807 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

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

[GitHub] [flink] flinkbot edited a comment on pull request #16650: [FLINK-22405] [Table SQL / API] Support fixed-lengh chars in the Lead…

flinkbot edited a comment on pull request #16650: URL: https://github.com/apache/flink/pull/16650#issuecomment-889769193 ## CI report: * 6a29ac6e799567274b4583fd8c2924546d8185c8 UNKNOWN * c91747e1372a20f808195746aedacc6bdcc71c0c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16589: [FLINK-23541] Call StreamOperator#finish on EndOfData

flinkbot edited a comment on pull request #16589: URL: https://github.com/apache/flink/pull/16589#issuecomment-886429447 ## CI report: * 791a3f1825b2e2d5682c40e9b7e52a4cbc576429 UNKNOWN * a29a6115a578c543a9856a07d0ef58f79ebcc895 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * 67e73451c554e31d4d9986cf08fc100248a9bc73 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * 014925a112fb27200e11defad7d698a2f13c2c8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

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

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 9e31e0e4c49c6becf89876017d3bb6e4581b9939 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

flinkbot edited a comment on pull request #16582: URL: https://github.com/apache/flink/pull/16582#issuecomment-885598535 ## CI report: * dfdcff9fa15faf486afdb0ddd62c775f6dd61f3b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

flinkbot edited a comment on pull request #16465: URL: https://github.com/apache/flink/pull/16465#issuecomment-878076127 ## CI report: * 4fb87e1eedfd547c18b9a07cc52779b6c0ac39cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16463: [FLINK-23272][web] Add custom netty HTTP request inbound/outbound handlers

flinkbot edited a comment on pull request #16463: URL: https://github.com/apache/flink/pull/16463#issuecomment-878058026 ## CI report: * 53b99a4a2bedce5cb69659c7235babdc127a580d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * 67e73451c554e31d4d9986cf08fc100248a9bc73 Azure:

[jira] [Updated] (FLINK-23607) Cleanup unnecessary dependencies in dstl pom.xml

[ https://issues.apache.org/jira/browse/FLINK-23607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23607: -- Description: - check whether some dependencies (i.e. flink-streaming-java, shaded

[jira] [Created] (FLINK-23607) Cleanup unnecessary dependencies in dstl pom.xml

Roman Khachatryan created FLINK-23607: - Summary: Cleanup unnecessary dependencies in dstl pom.xml Key: FLINK-23607 URL: https://issues.apache.org/jira/browse/FLINK-23607 Project: Flink

[GitHub] [flink] akalash commented on pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

akalash commented on pull request #16653: URL: https://github.com/apache/flink/pull/16653#issuecomment-892037605 @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 specific

[GitHub] [flink] tweise commented on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-892037152 @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 specific

[GitHub] [flink] flinkbot edited a comment on pull request #16676: [FLINK-22902] Port KafkaSink to FLIP-143

flinkbot edited a comment on pull request #16676: URL: https://github.com/apache/flink/pull/16676#issuecomment-890987522 ## CI report: * a4a37916fdd2d49a7682b2d90da22e5ed398eae5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16674: [FLINK-23587][deployment] Set Deployment's Annotation when using kubernetes

flinkbot edited a comment on pull request #16674: URL: https://github.com/apache/flink/pull/16674#issuecomment-890963322 ## CI report: * 425e513893d86249eb9efe3d380a88bb36fd2878 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16656: [BP-1.13][FLINK-23183][connectors/rabbitmq] Fix ACKs for redelivered messages in RMQSource and add IT

flinkbot edited a comment on pull request #16656: URL: https://github.com/apache/flink/pull/16656#issuecomment-890328762 ## CI report: * d9c8855972035f368788474001fdd488d8ea347c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * 014925a112fb27200e11defad7d698a2f13c2c8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 9e31e0e4c49c6becf89876017d3bb6e4581b9939 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16599: [FLINK-23479][table-planner] Fix the unstable test cases about json plan

flinkbot edited a comment on pull request #16599: URL: https://github.com/apache/flink/pull/16599#issuecomment-886750468 ## CI report: * 770b177feb77709640e01f6410fbed386daac997 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16589: [FLINK-23541] Call StreamOperator#finish on EndOfData

flinkbot edited a comment on pull request #16589: URL: https://github.com/apache/flink/pull/16589#issuecomment-886429447 ## CI report: * 791a3f1825b2e2d5682c40e9b7e52a4cbc576429 UNKNOWN * a29a6115a578c543a9856a07d0ef58f79ebcc895 UNKNOWN *

[GitHub] [flink] dawidwys commented on pull request #16589: [FLINK-23541] Call StreamOperator#finish on EndOfData

dawidwys commented on pull request #16589: URL: https://github.com/apache/flink/pull/16589#issuecomment-892018298 @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] [Comment Edited] (FLINK-23593) Performance regression on 15.07.2021

[ https://issues.apache.org/jira/browse/FLINK-23593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392423#comment-17392423 ] Piotr Nowojski edited comment on FLINK-23593 at 8/3/21, 4:59 PM: -

[jira] [Comment Edited] (FLINK-23593) Performance regression on 15.07.2021

[ https://issues.apache.org/jira/browse/FLINK-23593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392423#comment-17392423 ] Piotr Nowojski edited comment on FLINK-23593 at 8/3/21, 4:59 PM: -

[jira] [Comment Edited] (FLINK-23593) Performance regression on 15.07.2021

[ https://issues.apache.org/jira/browse/FLINK-23593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392423#comment-17392423 ] Piotr Nowojski edited comment on FLINK-23593 at 8/3/21, 4:58 PM: -

[jira] [Comment Edited] (FLINK-23593) Performance regression on 15.07.2021

[ https://issues.apache.org/jira/browse/FLINK-23593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392423#comment-17392423 ] Piotr Nowojski edited comment on FLINK-23593 at 8/3/21, 4:58 PM: -

[jira] [Commented] (FLINK-23593) Performance regression on 15.07.2021

[ https://issues.apache.org/jira/browse/FLINK-23593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392423#comment-17392423 ] Piotr Nowojski commented on FLINK-23593: Because of

[GitHub] [flink] flinkbot edited a comment on pull request #16679: [FLINK-23402][streaming-java] Simplify shuffle mode for batch execution

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

[GitHub] [flink] flinkbot edited a comment on pull request #16690: [FLINK-23492][runtime][backport] harden testCachedStatsCleanedAfterCleanupInterval

flinkbot edited a comment on pull request #16690: URL: https://github.com/apache/flink/pull/16690#issuecomment-891731210 ## CI report: * a39758db36ffcc29ac2876cc54164227d5eb84fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16652: [FLINK-22483][flink-runtime] Remove CompletedCheckpointStore#recover(…

flinkbot edited a comment on pull request #16652: URL: https://github.com/apache/flink/pull/16652#issuecomment-889863499 ## CI report: * bec31db7e5954054997b68fc2eaceb3556ea7200 UNKNOWN * b564f54f0618507fbdaf78ab7db2fe5c569d85cc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 9e31e0e4c49c6becf89876017d3bb6e4581b9939 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16589: [FLINK-23541] Call StreamOperator#finish on EndOfData

flinkbot edited a comment on pull request #16589: URL: https://github.com/apache/flink/pull/16589#issuecomment-886429447 ## CI report: * 791a3f1825b2e2d5682c40e9b7e52a4cbc576429 UNKNOWN * a29a6115a578c543a9856a07d0ef58f79ebcc895 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16630: [FLINK-23531][table]Allow skip all change log for row-time deduplicate mini-batch

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

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * 67e73451c554e31d4d9986cf08fc100248a9bc73 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 4dcee9f07135401160aae3f0d01bd480630f808f UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16679: [FLINK-23402][streaming-java] Simplify shuffle mode for batch execution

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

[GitHub] [flink] flinkbot edited a comment on pull request #16685: [FLINK-23279][tests] Randomly use Changelog Backend in tests

flinkbot edited a comment on pull request #16685: URL: https://github.com/apache/flink/pull/16685#issuecomment-891687869 ## CI report: * 32807f9693e4b834d8f89b0e109d72679de33add Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window

flinkbot edited a comment on pull request #16669: URL: https://github.com/apache/flink/pull/16669#issuecomment-890847741 ## CI report: * d64b410bf3ec0d97369c1daf60a27fd13bb9cc72 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

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

[GitHub] [flink] flinkbot edited a comment on pull request #16626: [FLINK-23498][table] Introduce a full PlannerConfiguration

flinkbot edited a comment on pull request #16626: URL: https://github.com/apache/flink/pull/16626#issuecomment-888274470 ## CI report: * bf044e098e62eea002a7e5c47ae0e8747f5b9cff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16551: [FLINK-23255][test] Introduce JUnit 5 dependencies

flinkbot edited a comment on pull request #16551: URL: https://github.com/apache/flink/pull/16551#issuecomment-883977463 ## CI report: * eb42585ca68ef7aae24b240d55098c829c50c283 Azure:

[GitHub] [flink] pnowojski commented on pull request #16628: [FLINK-23453][streaming] Created the buffer size calculator for the ability to automatically change the buffer size based on the throughput

pnowojski commented on pull request #16628: URL: https://github.com/apache/flink/pull/16628#issuecomment-891958262 Thanks for the update. Could you maybe squash the commits before the final pass? -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #16686: [FLINK-23599] Remove JobVertex#connectIdInput

flinkbot edited a comment on pull request #16686: URL: https://github.com/apache/flink/pull/16686#issuecomment-891705792 ## CI report: * f7b6b4f40bdbbe148be7b5d59dd1307e1af99e57 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16689: [FLINK-21290][table-planner] Support project push down for window TVF.

flinkbot edited a comment on pull request #16689: URL: https://github.com/apache/flink/pull/16689#issuecomment-891706045 ## CI report: * c4d0e9cdfb13e7ad24f2631629eea291bf47ed60 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16676: [FLINK-22902] Port KafkaSink to FLIP-143

flinkbot edited a comment on pull request #16676: URL: https://github.com/apache/flink/pull/16676#issuecomment-890987522 ## CI report: * 6287ea41e01d215a3974dca0ae037537a7f3d4bb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window

flinkbot edited a comment on pull request #16669: URL: https://github.com/apache/flink/pull/16669#issuecomment-890847741 ## CI report: * d64b410bf3ec0d97369c1daf60a27fd13bb9cc72 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16654: [FLINK-23492][runtime] harden testCachedStatsCleanedAfterCleanupInterval

flinkbot edited a comment on pull request #16654: URL: https://github.com/apache/flink/pull/16654#issuecomment-890035133 ## CI report: * 540883274c16e5b0c97f93674fc2d24c14f26c7d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16688: [FLINK-22773][coordination] Optimize the construction of pipelined regions

flinkbot edited a comment on pull request #16688: URL: https://github.com/apache/flink/pull/16688#issuecomment-891705944 ## CI report: * 43208da2eb35e121e75d68c5f291722155383f81 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16652: [FLINK-22483][flink-runtime] Remove CompletedCheckpointStore#recover(…

flinkbot edited a comment on pull request #16652: URL: https://github.com/apache/flink/pull/16652#issuecomment-889863499 ## CI report: * bec31db7e5954054997b68fc2eaceb3556ea7200 UNKNOWN * c9149e8af1cdef4b615c7c83a3dc69054ddbdaae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16636: [FLINK-23529] Add Flink 1.13 MigrationVersion

flinkbot edited a comment on pull request #16636: URL: https://github.com/apache/flink/pull/16636#issuecomment-889045676 ## CI report: * 46332f2c7aa2e4d4b6489f94eccdd866fbea79f1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16626: [FLINK-23498][table] Introduce a full PlannerConfiguration

flinkbot edited a comment on pull request #16626: URL: https://github.com/apache/flink/pull/16626#issuecomment-888274470 ## CI report: * b7a07005f53c491bbd2eb9437c479ef31581bf2a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16523: [FLINK-23416][runtime] Don't log NoResourceAvailableException stacktrace

flinkbot edited a comment on pull request #16523: URL: https://github.com/apache/flink/pull/16523#issuecomment-881941982 ## CI report: * ae9a98b727dba02d7aa7e9ff8f58cde9d75f8598 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16463: [FLINK-23272][web] Add custom netty HTTP request inbound/outbound handlers

flinkbot edited a comment on pull request #16463: URL: https://github.com/apache/flink/pull/16463#issuecomment-878058026 ## CI report: * 758e058554d003959bb42ca3988a306389e1b9d3 Azure:

[GitHub] [flink] zhuzhurk commented on a change in pull request #16679: [FLINK-23402][streaming-java] Simplify shuffle mode for batch execution

zhuzhurk commented on a change in pull request #16679: URL: https://github.com/apache/flink/pull/16679#discussion_r681877463 ## File path: flink-core/src/main/java/org/apache/flink/api/common/BatchShuffleMode.java ## @@ -41,7 +41,7 @@ * to run upstream and downstream tasks

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 4dcee9f07135401160aae3f0d01bd480630f808f UNKNOWN *

[jira] [Commented] (FLINK-23317) Only keep the latest checkpoint in CompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-23317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392363#comment-17392363 ] Till Rohrmann commented on FLINK-23317: --- I am not sure whether this improvement justifies the

[GitHub] [flink] gaborgsomogyi edited a comment on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

gaborgsomogyi edited a comment on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-891938008 As I see this is not solving 2 major issues which belongs to this area: * DTs not re-obtained which makes workloads fail after 7 days, please see

[GitHub] [flink] gaborgsomogyi edited a comment on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

gaborgsomogyi edited a comment on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-891938008 As I see this is not solving 2 major issues which belongs to this area: * DTs not re-obtained which makes workloads fail after 7 days (I don't thing renew worth

[GitHub] [flink] gaborgsomogyi edited a comment on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

gaborgsomogyi edited a comment on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-891938008 As I see this is not solving 2 major issues which belongs to this area: * DTs not re-obtained which makes workloads fail after 7 days (I don't thing renew worth

[GitHub] [flink] gaborgsomogyi commented on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

gaborgsomogyi commented on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-891938008 As I see this is not solving 2 major issues which belongs to this area: * DTs not re-obtained which makes workloads fail after 7 days (I don't thing renew worth the

[GitHub] [flink] twalthr commented on a change in pull request #16679: [FLINK-23402][streaming-java] Simplify shuffle mode for batch execution

twalthr commented on a change in pull request #16679: URL: https://github.com/apache/flink/pull/16679#discussion_r681864349 ## File path: flink-core/src/main/java/org/apache/flink/api/common/BatchShuffleMode.java ## @@ -41,7 +41,7 @@ * to run upstream and downstream tasks

[GitHub] [flink] godfreyhe commented on a change in pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

godfreyhe commented on a change in pull request #16620: URL: https://github.com/apache/flink/pull/16620#discussion_r681731759 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.java ## @@ -128,32

[GitHub] [flink] flinkbot edited a comment on pull request #16688: [FLINK-22773][coordination] Optimize the construction of pipelined regions

flinkbot edited a comment on pull request #16688: URL: https://github.com/apache/flink/pull/16688#issuecomment-891705944 ## CI report: * 43208da2eb35e121e75d68c5f291722155383f81 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16686: [FLINK-23599] Remove JobVertex#connectIdInput

flinkbot edited a comment on pull request #16686: URL: https://github.com/apache/flink/pull/16686#issuecomment-891705792 ## CI report: * f7b6b4f40bdbbe148be7b5d59dd1307e1af99e57 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16676: [FLINK-22902] Port KafkaSink to FLIP-143

flinkbot edited a comment on pull request #16676: URL: https://github.com/apache/flink/pull/16676#issuecomment-890987522 ## CI report: * 6287ea41e01d215a3974dca0ae037537a7f3d4bb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window

flinkbot edited a comment on pull request #16669: URL: https://github.com/apache/flink/pull/16669#issuecomment-890847741 ## CI report: * d64b410bf3ec0d97369c1daf60a27fd13bb9cc72 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * 014925a112fb27200e11defad7d698a2f13c2c8f Azure:

<    1   2   3   4   5   6   7   >