[GitHub] [flink] flinkbot edited a comment on pull request #16744: [FLINK-23208] let late processing timers fired immediately

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

[jira] [Commented] (FLINK-16504) Add a AWS DynamoDB sink

[ https://issues.apache.org/jira/browse/FLINK-16504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395129#comment-17395129 ] Yuri Gusev commented on FLINK-16504: Unfortunately don't have rights to assign to my

[GitHub] [flink] flinkbot edited a comment on pull request #16743: [FLINK-23645][Table SQL / Client] Fix SqlClient doesn't response correctly to Signal.INT

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

[GitHub] [flink] flinkbot edited a comment on pull request #16590: [FLINK-19554][connector/testing-framework] Connector Testing Framework

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

[GitHub] [flink] flinkbot edited a comment on pull request #16590: [FLINK-19554][connector/testing-framework] Connector Testing Framework

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

[GitHub] [flink] flinkbot edited a comment on pull request #16744: [FLINK-23208] let late processing timers fired immediately

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

[GitHub] [flink] flinkbot edited a comment on pull request #16644: [FLINK-23551][Connectors/ORC] Bump ORC to 1.6.9

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

[jira] [Comment Edited] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly

[ https://issues.apache.org/jira/browse/FLINK-22246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395045#comment-17395045 ] Bo Cui edited comment on FLINK-22246 at 8/7/21, 3:43 AM: - [~liru

[GitHub] [flink] cshuo commented on a change in pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window

cshuo commented on a change in pull request #16669: URL: https://github.com/apache/flink/pull/16669#discussion_r684576306 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalWindowAggregate.scala

[GitHub] [flink] flinkbot commented on pull request #16744: [FLINK-23208] let late processing timers fired immediately

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

[GitHub] [flink] flinkbot edited a comment on pull request #16644: [FLINK-23551][Connectors/ORC] Bump ORC to 1.6.9

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

[GitHub] [flink] flinkbot edited a comment on pull request #16743: [FLINK-23645][Table SQL / Client] Fix SqlClient doesn't response correctly to Signal.INT

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

[GitHub] [flink] flinkbot commented on pull request #16744: [FLINK-23208] let late processing timers fired immediately

flinkbot commented on pull request #16744: URL: https://github.com/apache/flink/pull/16744#issuecomment-894593957 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] Jiayi-Liao edited a comment on pull request #16744: [FLINK-23208] let late processing timers fired immediately

Jiayi-Liao edited a comment on pull request #16744: URL: https://github.com/apache/flink/pull/16744#issuecomment-894593088 @pnowojski To make the change pass the CI, I have to modify `TestProcessingTimeService.setCurrentTime(long)` which may affect a lot of tests. (Try `InternalTimerServi

[GitHub] [flink] Jiayi-Liao commented on pull request #16744: [FLINK-23208] let late processing timers fired immediately

Jiayi-Liao commented on pull request #16744: URL: https://github.com/apache/flink/pull/16744#issuecomment-894593088 @pnowojski To make the change pass the CI, I have to modify `TestProcessingTimeService.setCurrentTime(long)` which may affect a lot of unit tests. I tried to correct

[GitHub] [flink] Jiayi-Liao opened a new pull request #16744: [FLINK-23208] let late processing timers fired immediately

Jiayi-Liao opened a new pull request #16744: URL: https://github.com/apache/flink/pull/16744 ## What is the purpose of the change Currently late timers need to wait 1ms at least to be fired which may decrease the whole job's throughput. (see benchmarks in https://github.com/apache/f

[GitHub] [flink] syhily commented on a change in pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

syhily commented on a change in pull request #15304: URL: https://github.com/apache/flink/pull/15304#discussion_r684570817 ## File path: flink-connectors/flink-connector-pulsar/pom.xml ## @@ -0,0 +1,162 @@ + + +http://maven.apache.org/POM/4.0.0"; +xmlns:xsi="htt

[jira] [Assigned] (FLINK-23672) Add smoke-e2e-java for Java SDK smoke test

[ https://issues.apache.org/jira/browse/FLINK-23672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-23672: --- Assignee: Evans Ye > Add smoke-e2e-java for Java SDK smoke test > -

[jira] [Commented] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly

[ https://issues.apache.org/jira/browse/FLINK-22246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395045#comment-17395045 ] Bo Cui commented on FLINK-22246: [~lirui] Why dont you need real user? authentication re

[GitHub] [flink] flinkbot edited a comment on pull request #16743: [FLINK-23645][Table SQL / Client] Fix SqlClient doesn't response correctly to Signal.INT

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

[jira] [Commented] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly

[ https://issues.apache.org/jira/browse/FLINK-22246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395044#comment-17395044 ] Bo Cui commented on FLINK-22246: yes, we can use sessionstate. but i wouldn't recommend

[jira] [Updated] (FLINK-13203) [proper fix] Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-13203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13203: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am th

[jira] [Updated] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22059: --- Labels: auto-deprioritized-major auto-unassigned stale-assigned (was: auto-deprioritized-ma

[jira] [Updated] (FLINK-9925) ClientTest.testSimpleRequests fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9925: -- Labels: stale-critical test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[GitHub] [flink] AHeise commented on a change in pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

AHeise commented on a change in pull request #15304: URL: https://github.com/apache/flink/pull/15304#discussion_r684403885 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicMetadata.java ## @@ -0,

[GitHub] [flink] flinkbot edited a comment on pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

flinkbot edited a comment on pull request #16620: URL: https://github.com/apache/flink/pull/16620#issuecomment-888120908 ## CI report: * 12c0dbb7a1359053f4804910f58f06434e542dad UNKNOWN * 9855605eb69ba78b8fc5b7bb02f0529221c9521e Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] pnowojski commented on a change in pull request #16726: FLINK-23454 The upstream sends the buffer of the right size for unicast case

pnowojski commented on a change in pull request #16726: URL: https://github.com/apache/flink/pull/16726#discussion_r684452732 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -450,6 +454,16 @@ public int g

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

[jira] [Updated] (FLINK-23672) Add smoke-e2e-java for Java SDK smoke test

[ https://issues.apache.org/jira/browse/FLINK-23672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23672: --- Labels: pull-request-available (was: ) > Add smoke-e2e-java for Java SDK smoke test > -

[GitHub] [flink-statefun] evans-ye opened a new pull request #248: [FLINK-23672] Add smoke-e2e-java for Java SDK smoke test

evans-ye opened a new pull request #248: URL: https://github.com/apache/flink-statefun/pull/248 WIP. I'll add more description here. -- 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] [Issue Comment Deleted] (FLINK-22902) Port KafkaSink to FLIP-143

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22902: Comment: was deleted (was: Merged into master as 801dd688789921277b0a03d76b7cc707dc1010f0..871948

[jira] [Commented] (FLINK-23124) Implement exactly-once Kafka Sink

[ https://issues.apache.org/jira/browse/FLINK-23124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394937#comment-17394937 ] Arvid Heise commented on FLINK-23124: - Merged into master as 801dd688789921277b0a03

[jira] [Resolved] (FLINK-23124) Implement exactly-once Kafka Sink

[ https://issues.apache.org/jira/browse/FLINK-23124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23124. - Fix Version/s: 1.14.0 Resolution: Fixed > Implement exactly-once Kafka Sink > ---

[jira] [Resolved] (FLINK-23123) Implement at-least-once Kafka Sink

[ https://issues.apache.org/jira/browse/FLINK-23123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23123. - Fix Version/s: 1.14.0 Resolution: Fixed > Implement at-least-once Kafka Sink > --

[jira] [Reopened] (FLINK-22902) Port KafkaSink to FLIP-143

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reopened FLINK-22902: - > Port KafkaSink to FLIP-143 > -- > > Key: FLINK-22902 >

[jira] [Updated] (FLINK-22902) Port KafkaSink to FLIP-143

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22902: Release Note: KafkaSink supersedes FlinkKafkaProducer and provides efficient exactly-once and at-l

[jira] [Updated] (FLINK-22902) Port KafkaSink to FLIP-143

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22902: Affects Version/s: 1.14.0 > Port KafkaSink to FLIP-143 > -- > >

[jira] [Resolved] (FLINK-22902) Port KafkaSink to FLIP-143

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22902. - Resolution: Fixed Merged into master as 801dd688789921277b0a03d76b7cc707dc1010f0..8719481c3b44d

[GitHub] [flink] AHeise merged pull request #16676: [FLINK-22902] Port KafkaSink to FLIP-143

AHeise merged pull request #16676: URL: https://github.com/apache/flink/pull/16676 -- 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-unsubscr

[GitHub] [flink] flinkbot edited a comment on pull request #16742: [FLINK-23626] [Runtime / Metrics] Migrate all TaskMG instantiations to factory method

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

[GitHub] [flink] flinkbot edited a comment on pull request #16720: [FLINK-23507] Use IP address of a kubernetes node when constructing node port connection string for the REST gateway.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16637: [FLINK-23189][checkpoint]Count and fail the task when the disk is error on JobManager

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

[GitHub] [flink] flinkbot edited a comment on pull request #16590: [FLINK-19554][connector/testing-framework] Connector Testing Framework

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

[jira] [Created] (FLINK-23672) Add smoke-e2e-java for Java SDK smoke test

Evans Ye created FLINK-23672: Summary: Add smoke-e2e-java for Java SDK smoke test Key: FLINK-23672 URL: https://issues.apache.org/jira/browse/FLINK-23672 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #16700: [FLINK-22606][hive] Simplify the usage of SessionState

flinkbot edited a comment on pull request #16700: URL: https://github.com/apache/flink/pull/16700#issuecomment-892453171 ## CI report: * a7302fab5aa4ec1eae859d9e4542516799d05b6a Azure: [FAILURE](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: * 0fd6c57783b7dee619945551d94490442b77af0a UNKNOWN * 5f636910791eb5ddaa6b9b210c3a4b3230fc60bd UNKNOWN * 96995fe1f26d7a08e91308409d2c66ec32ec

[GitHub] [flink] flinkbot edited a comment on pull request #16590: [FLINK-19554][connector/testing-framework] Connector Testing Framework

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

[jira] [Updated] (FLINK-23451) FLIP-183: Dynamic buffer size adjustment (Buffer debloat)

[ https://issues.apache.org/jira/browse/FLINK-23451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23451: --- Component/s: Runtime / Network > FLIP-183: Dynamic buffer size adjustment (Buffer debloat) >

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * d79db15ab05c86dcd82fe88dc7247fd413f5c0bf UNKNOWN * adf2f29416eaf6f819cbb2a7944ecec4c1be0eb2 Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

[jira] [Updated] (FLINK-23459) New metrics for dynamic buffer size

[ https://issues.apache.org/jira/browse/FLINK-23459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23459: --- Component/s: Runtime / Network Runtime / Metrics > New metrics for dynamic

[jira] [Updated] (FLINK-23451) FLIP-183: Dynamic buffer size adjustment (Buffer debloat)

[ https://issues.apache.org/jira/browse/FLINK-23451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23451: --- Fix Version/s: 1.14.0 > FLIP-183: Dynamic buffer size adjustment (Buffer debloat) >

[jira] [Closed] (FLINK-23459) New metrics for dynamic buffer size

[ https://issues.apache.org/jira/browse/FLINK-23459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23459. -- Fix Version/s: 1.14.0 Resolution: Fixed Scoped was narrowed down to not present detaile

[jira] [Commented] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394886#comment-17394886 ] Piotr Nowojski commented on FLINK-23556: https://dev.azure.com/apache-flink/apac

[jira] [Updated] (FLINK-21004) test_process_mode_boot.py test hangs

[ https://issues.apache.org/jira/browse/FLINK-21004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21004: --- Priority: Critical (was: Minor) > test_process_mode_boot.py test hangs > --

[GitHub] [flink] flinkbot edited a comment on pull request #16708: [FLINK-23192][table] Move connector & format options to consistent packages

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

[jira] [Updated] (FLINK-23666) Flaky test: SQLClientSchemaRegistryITCase.testWriting

[ https://issues.apache.org/jira/browse/FLINK-23666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23666: --- Priority: Critical (was: Major) > Flaky test: SQLClientSchemaRegistryITCase.testWriting > -

[GitHub] [flink] pnowojski merged pull request #16713: [FLINK-23408][task] Add metrics for buffer debloating

pnowojski merged pull request #16713: URL: https://github.com/apache/flink/pull/16713 -- 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-unsub

[jira] [Commented] (FLINK-21004) test_process_mode_boot.py test hangs

[ https://issues.apache.org/jira/browse/FLINK-21004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394892#comment-17394892 ] Piotr Nowojski commented on FLINK-21004: maybe related as well https://dev.azure

[jira] [Commented] (FLINK-23666) Flaky test: SQLClientSchemaRegistryITCase.testWriting

[ https://issues.apache.org/jira/browse/FLINK-23666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394885#comment-17394885 ] Piotr Nowojski commented on FLINK-23666: another instance https://dev.azure.com

[jira] [Closed] (FLINK-23666) Flaky test: SQLClientSchemaRegistryITCase.testWriting

[ https://issues.apache.org/jira/browse/FLINK-23666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23666. -- Resolution: Duplicate > Flaky test: SQLClientSchemaRegistryITCase.testWriting > --

[jira] [Assigned] (FLINK-23560) Performance regression on 29.07.2021

[ https://issues.apache.org/jira/browse/FLINK-23560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-23560: -- Assignee: Anton Kalashnikov (was: Piotr Nowojski) > Performance regression on 29.07.

[GitHub] [flink] flinkbot edited a comment on pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

flinkbot edited a comment on pull request #16620: URL: https://github.com/apache/flink/pull/16620#issuecomment-888120908 ## CI report: * 12c0dbb7a1359053f4804910f58f06434e542dad UNKNOWN * 9855605eb69ba78b8fc5b7bb02f0529221c9521e Azure: [PENDING](https://dev.azure.com/apache-fl

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

[GitHub] [flink] flinkbot edited a comment on pull request #16743: [FLINK-23645][Table SQL / Client] Fix SqlClient doesn't response correctly to Signal.INT

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

[GitHub] [flink] flinkbot edited a comment on pull request #16740: [FLINK-23614][table-planner] The resulting scale of TRUNCATE(DECIMAL,…

flinkbot edited a comment on pull request #16740: URL: https://github.com/apache/flink/pull/16740#issuecomment-894176423 ## CI report: * aceb2a25e00797b20ed5e3356f168ea12df0a8de Azure: [FAILURE](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: * 0fd6c57783b7dee619945551d94490442b77af0a UNKNOWN * 5f636910791eb5ddaa6b9b210c3a4b3230fc60bd UNKNOWN * 96995fe1f26d7a08e91308409d2c66ec32ec

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

[GitHub] [flink] flinkbot edited a comment on pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

flinkbot edited a comment on pull request #16620: URL: https://github.com/apache/flink/pull/16620#issuecomment-888120908 ## CI report: * 12c0dbb7a1359053f4804910f58f06434e542dad UNKNOWN * 9855605eb69ba78b8fc5b7bb02f0529221c9521e Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] PatrickRen commented on pull request #16551: [FLINK-23255][test] Introduce JUnit 5 dependencies

PatrickRen commented on pull request #16551: URL: https://github.com/apache/flink/pull/16551#issuecomment-894343427 @AHeise Thanks again for the review! I made a rebase to sync with the latest master. I manually ran CI twice in my own AZP project, one with the JUnit 5 dependencies[

[jira] [Reopened] (FLINK-23560) Performance regression on 29.07.2021

[ https://issues.apache.org/jira/browse/FLINK-23560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-23560: The issue in http://codespeed.dak8s.net:8000/timeline/?ben=sortedTwoInput&env=2 http://codesp

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

beyond1920 commented on pull request #16620: URL: https://github.com/apache/flink/pull/16620#issuecomment-894332563 @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 specif

[GitHub] [flink] beyond1920 commented on pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window

beyond1920 commented on pull request #16669: URL: https://github.com/apache/flink/pull/16669#issuecomment-894332189 @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 specif

[jira] [Commented] (FLINK-23272) FLIP-181: Custom netty HTTP request inbound/outbound handlers

[ https://issues.apache.org/jira/browse/FLINK-23272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394817#comment-17394817 ] Gabor Somogyi commented on FLINK-23272: --- The handlers has been added in https://g

[GitHub] [flink] flinkbot edited a comment on pull request #16739: [FLINK-23247][table-planner] Materialize attribute fields of regular join's inputs.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16741: [FLINK-23662][rpc][akka] Port all Scala code to Java

flinkbot edited a comment on pull request #16741: URL: https://github.com/apache/flink/pull/16741#issuecomment-894188972 ## CI report: * 4182d8f3b326218058f9d0a5675b22d7a3e22154 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: * 889dfbb1b28097728eea054580fa4e0e6bb61c22 UNKNOWN * 26a9f1ad70ba1a7f1231bdc8cd8b62fef6510472 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16742: [FLINK-23626] [Runtime / Metrics] Migrate all TaskMG instantiations to factory method

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

[GitHub] [flink] flinkbot edited a comment on pull request #16720: [FLINK-23507] Use IP address of a kubernetes node when constructing node port connection string for the REST gateway.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16637: [FLINK-23189][checkpoint]Count and fail the task when the disk is error on JobManager

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

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

StephanEwen edited a comment on pull request #16655: URL: https://github.com/apache/flink/pull/16655#issuecomment-894305960 Thanks for the discussion and digging out the corner cases to check. I was wondering is a very simple rule could actually be good enough here: *You can only

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

StephanEwen commented on pull request #16655: URL: https://github.com/apache/flink/pull/16655#issuecomment-894305960 Thanks for the discussion and digging out the corner cases to check. I was wondering is a very simple rule could actually be good enough here: *You can only change

[jira] [Commented] (FLINK-23671) Failed to inference type in correlate

[ https://issues.apache.org/jira/browse/FLINK-23671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394805#comment-17394805 ] Timo Walther commented on FLINK-23671: -- How is {{func111}} defined? > Failed to in

[GitHub] [flink] asfgit closed pull request #16463: [FLINK-23272][web] Add custom netty HTTP request inbound/outbound handlers

asfgit closed pull request #16463: URL: https://github.com/apache/flink/pull/16463 -- 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-unsubscr

[GitHub] [flink] flinkbot edited a comment on pull request #16742: [FLINK-23626] [Runtime / Metrics] Migrate all TaskMG instantiations to factory method

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

[GitHub] [flink] flinkbot edited a comment on pull request #16738: [FLINK-23661][build] Fix protobuf plugin proxy issue

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

[GitHub] [flink] flinkbot edited a comment on pull request #16720: [FLINK-23507] Use IP address of a kubernetes node when constructing node port connection string for the REST gateway.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16637: [FLINK-23189][checkpoint]Count and fail the task when the disk is error on JobManager

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

[jira] [Closed] (FLINK-23669) Avoid using Scala >= 2.12.8 in Flink Training exercises

[ https://issues.apache.org/jira/browse/FLINK-23669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-23669. --- Resolution: Fixed Merged on master via 1704fd959122aa197b48803441338c1fb0470091 > Avoid using Scala

[jira] [Closed] (FLINK-23667) Fix training exercises IDE setup description for Scala

[ https://issues.apache.org/jira/browse/FLINK-23667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-23667. --- Resolution: Fixed Merged on master via 08f5bf4d93d241f58d67148dc3e054a2325b64a0 > Fix training exer

[GitHub] [flink-training] NicoK merged pull request #32: [FLINK-23669] avoid using Scala >= 2.12.8 when setting up an IDE

NicoK merged pull request #32: URL: https://github.com/apache/flink-training/pull/32 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #16735: [FLINK-21090][DRAFT] ITCase for final checkpoints

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

[GitHub] [flink] flinkbot edited a comment on pull request #16734: [FLINK-23408] Waiting for final checkpoint completed before finishing a task

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

[GitHub] [flink] flinkbot edited a comment on pull request #16731: [FLINK-23612][table-runtime] Fix compile exception for ROUND function with some numeric input arguments

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

[GitHub] [flink] flinkbot edited a comment on pull request #16736: [FLINK-23658][metrics][jmx] Cleanup code

flinkbot edited a comment on pull request #16736: URL: https://github.com/apache/flink/pull/16736#issuecomment-894157145 ## CI report: * f8e52dd6e12b808f0bc5b4a7a6e1a42c726bc72a 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: * 0fd6c57783b7dee619945551d94490442b77af0a UNKNOWN * 5f636910791eb5ddaa6b9b210c3a4b3230fc60bd UNKNOWN * 055d0fd83c72f141a1bd2d8a4bc0e30bf637

[GitHub] [flink-training] NicoK merged pull request #33: [FLINK-23667] fix code formatting IDE instructions

NicoK merged pull request #33: URL: https://github.com/apache/flink-training/pull/33 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #16637: [FLINK-23189][checkpoint]Count and fail the task when the disk is error on JobManager

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

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

  1   2   3   4   >