[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 * d326abc93378bb3c4b53616e7717c409d987

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 * c679fefa6bc59735ea1fb7f3ed6a5cd74685

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17392423#comment-17392423 ] Piotr Nowojski commented on FLINK-23593: Because of https://issues.apache.org/ji

[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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=17392423#comment-17392423 ] Piotr Nowojski edited comment on FLINK-23593 at 8/3/21, 4:59 PM: -

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

[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 * c679fefa6bc59735ea1fb7f3ed6a5cd74685

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[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

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

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

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [PENDING](https://dev.azure.com/apache-fl

[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 * c679fefa6bc59735ea1fb7f3ed6a5cd74685

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [SUCCESS](https://dev.azure.com/apache-fl

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

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

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

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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] 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 c

[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: [PENDING](https://dev.azure.com/apache-fl

[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 * c679fefa6bc59735ea1fb7f3ed6a5cd74685

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20845) Drop support for Scala 2.11

[ https://issues.apache.org/jira/browse/FLINK-20845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392621#comment-17392621 ] Nick Burkard commented on FLINK-20845: -- [~eloisant] I just rebased and pushed to th

[GitHub] [flink] flinkbot edited a comment on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

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

[jira] [Commented] (FLINK-23096) HiveParser could not attach the sessionstate of hive

[ https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392631#comment-17392631 ] luoyuxia commented on FLINK-23096: -- [~leexu]  Actual, path.getFileSystem with return Hd

[jira] [Created] (FLINK-23608) org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory

张祥兵 created FLINK-23608: --- Summary: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory Key: FLINK-23608 URL: https://

[GitHub] [flink] xintongsong commented on pull request #16640: [FLINK-22891][runtime] Using CompletableFuture to sync the scheduling…

xintongsong commented on pull request #16640: URL: https://github.com/apache/flink/pull/16640#issuecomment-892296368 @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 speci

[jira] [Commented] (FLINK-23590) StreamTaskTest#testProcessWithUnAvailableInput is flaky

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

[GitHub] [flink] xintongsong commented on pull request #16636: [FLINK-23529] Add Flink 1.13 MigrationVersion

xintongsong commented on pull request #16636: URL: https://github.com/apache/flink/pull/16636#issuecomment-892296492 @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 speci

[GitHub] [flink] flinkbot edited a comment on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

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

[jira] [Commented] (FLINK-18184) Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory'

[ https://issues.apache.org/jira/browse/FLINK-18184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392638#comment-17392638 ] 张祥兵 commented on FLINK-18184: - Caused by: org.apache.flink.table.api.NoMatchingTableFactoryE

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16640: [FLINK-22891][runtime] Using CompletableFuture to sync the scheduling…

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

[jira] [Created] (FLINK-23609) Codeine error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)"

xiaojin.wy created FLINK-23609: -- Summary: Codeine error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)" Key: FLINK-23609 URL: https://issues.apache.org/jira/browse/FLINK-23609 Project

[jira] [Updated] (FLINK-23609) Codegen error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)"

[ https://issues.apache.org/jira/browse/FLINK-23609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-23609: --- Summary: Codegen error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)" (was: Co

[jira] [Updated] (FLINK-23609) Codegen error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)"

[ https://issues.apache.org/jira/browse/FLINK-23609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-23609: --- Environment: (was: java.lang.NumberFormatException: Infinite or NaN at java.math.BigDeci

[jira] [Updated] (FLINK-23609) Codegen error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)"

[ https://issues.apache.org/jira/browse/FLINK-23609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-23609: --- Description: {code:java} CREATE TABLE database5_t2 ( `c0` DECIMAL ) WITH ( 'connector' = 'filesy

[GitHub] [flink] tsreaper commented on pull request #16636: [FLINK-23529] Add Flink 1.13 MigrationVersion

tsreaper commented on pull request #16636: URL: https://github.com/apache/flink/pull/16636#issuecomment-892305767 > @flinkbot run azure It already succeeded in https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=21395&view=results -- This is an automated message

[GitHub] [flink] wsry commented on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

wsry commented on pull request #16465: URL: https://github.com/apache/flink/pull/16465#issuecomment-892306109 Rebased master and squashed fixup commits. -- 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

[jira] [Closed] (FLINK-23608) org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory

[ https://issues.apache.org/jira/browse/FLINK-23608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23608. --- Resolution: Not A Problem Please use English in JIRA. Regarding your exception stack, there is no kafka fa

[GitHub] [flink] wangyang0918 commented on a change in pull request #16674: [FLINK-23587][deployment] Set Deployment's Annotation when using kubernetes

wangyang0918 commented on a change in pull request #16674: URL: https://github.com/apache/flink/pull/16674#discussion_r682236420 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesJobManagerFactoryTest.java ## @@ -170,12 +177,

[GitHub] [flink] KarlManong commented on a change in pull request #16674: [FLINK-23587][deployment] Set Deployment's Annotation when using kubernetes

KarlManong commented on a change in pull request #16674: URL: https://github.com/apache/flink/pull/16674#discussion_r682237085 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesJobManagerFactoryTest.java ## @@ -170,12 +177,9

[GitHub] [flink] xintongsong commented on pull request #16636: [FLINK-23529] Add Flink 1.13 MigrationVersion

xintongsong commented on pull request #16636: URL: https://github.com/apache/flink/pull/16636#issuecomment-892309511 Thanks, @tsreaper. Merging this. -- 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

[jira] [Commented] (FLINK-23608) org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory

[ https://issues.apache.org/jira/browse/FLINK-23608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392651#comment-17392651 ] 张祥兵 commented on FLINK-23608: - [~jark] I use IDAE to run my job, and after packaging, report

[GitHub] [flink] xintongsong closed pull request #16636: [FLINK-23529] Add Flink 1.13 MigrationVersion

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

[GitHub] [flink] zhuzhurk closed pull request #16686: [FLINK-23599] Remove JobVertex#connectIdInput

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

[jira] [Closed] (FLINK-23599) Remove JobVertex#connectIdInput

[ https://issues.apache.org/jira/browse/FLINK-23599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-23599. --- Resolution: Done Done via ec9ff1ee5e33529260d6a3adfad4b0b34efde55e > Remove JobVertex#connectIdInput >

[jira] [Assigned] (FLINK-22767) Optimize the initialization of LocalInputPreferredSlotSharingStrategy

[ https://issues.apache.org/jira/browse/FLINK-22767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-22767: --- Assignee: Zhilong Hong > Optimize the initialization of LocalInputPreferredSlotSharingStrategy > --

<    1   2   3   4   5   6   >