[jira] [Issue Comment Deleted] (FLINK-22592) numBuffersInLocal is always zero when using unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-22592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xmarker updated FLINK-22592: Comment: was deleted (was: Could you assign this Jira to me?) > numBuffersInLocal is always zero when usi

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15869: [FLINK-22609][runtime] Generalize AllVerticesIterator.java

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

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

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

[jira] [Created] (FLINK-22610) The test-jar of flink-connector-kafka should include all test classes

LIU Xiao created FLINK-22610: Summary: The test-jar of flink-connector-kafka should include all test classes Key: FLINK-22610 URL: https://issues.apache.org/jira/browse/FLINK-22610 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15869: [FLINK-22609][runtime] Generalize AllVerticesIterator.java

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

[GitHub] [flink] flinkbot commented on pull request #15869: [FLINK-22609][runtime] Generalize AllVerticesIterator.java

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

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

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

[GitHub] [flink] flinkbot commented on pull request #15869: [FLINK-22609][runtime] Generalize AllVerticesIterator.java

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

[jira] [Updated] (FLINK-22609) Generalize AllVerticesIterator.java

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

[GitHub] [flink] RocMarshal opened a new pull request #15869: [FLINK-22609][runtime] Generalize AllVerticesIterator.java

RocMarshal opened a new pull request #15869: URL: https://github.com/apache/flink/pull/15869 ## What is the purpose of the change *Generalize AllVerticesIterator.java* ## Brief change log *Generalize AllVerticesIterator.java* - Code-Cleanup - org.ap

[jira] [Updated] (FLINK-22609) Generalize AllVerticesIterator.java

[ https://issues.apache.org/jira/browse/FLINK-22609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-22609: Summary: Generalize AllVerticesIterator.java (was: Generify AllVerticesIterator.java) > Generali

[GitHub] [flink] flinkbot edited a comment on pull request #15868: [hotfix][docs] Fixed broken image link

flinkbot edited a comment on pull request #15868: URL: https://github.com/apache/flink/pull/15868#issuecomment-835521924 ## CI report: * 7f73637a20db8ef7a2bf05b7c74acf9c3a5291e6 UNKNOWN * 19f2a534a9ff61a1e9d611d7b8106ccc6082a398 Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

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

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

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

[GitHub] [flink] mans2singh commented on pull request #15868: [hotfix][docs] Fixed broken image link

mans2singh commented on pull request #15868: URL: https://github.com/apache/flink/pull/15868#issuecomment-835601829 Hi @wuchong @leonardBang @tisonkun - Can you please review this fix for broken image links ? Thanks -- This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (FLINK-22609) Generify AllVerticesIterator.java

[ https://issues.apache.org/jira/browse/FLINK-22609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-22609: Labels: (was: easyfix) > Generify AllVerticesIterator.java > - >

[jira] [Updated] (FLINK-22609) Generify AllVerticesIterator.java

[ https://issues.apache.org/jira/browse/FLINK-22609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-22609: Description: * Code-Cleanup * org.apache.flink.runtime.executiongraph.AllVerticesIterator &  org.

[jira] [Updated] (FLINK-22609) Generify AllVerticesIterator.java

[ https://issues.apache.org/jira/browse/FLINK-22609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-22609: Description: * Code-Cleanup * org.apache.flink.runtime.executiongraph. > Generify AllVerticesIte

[jira] [Created] (FLINK-22609) Generify AllVerticesIterator.java

Roc Marshal created FLINK-22609: --- Summary: Generify AllVerticesIterator.java Key: FLINK-22609 URL: https://issues.apache.org/jira/browse/FLINK-22609 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #15868: [hotfix][docs] Fixed broken image link

flinkbot edited a comment on pull request #15868: URL: https://github.com/apache/flink/pull/15868#issuecomment-835521924 ## CI report: * 7f73637a20db8ef7a2bf05b7c74acf9c3a5291e6 UNKNOWN * 19f2a534a9ff61a1e9d611d7b8106ccc6082a398 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] sjwiesman commented on pull request #15865: [hotfix][docs] Fix all broken images

sjwiesman commented on pull request #15865: URL: https://github.com/apache/flink/pull/15865#issuecomment-835535187 Thanks for opening this, I’ll take a closer look on Monday. Unfortunately there isn’t a great way to automate this process. The migration was done via a custom tool I wrote an

[GitHub] [flink] flinkbot edited a comment on pull request #15868: [hotfix][docs] Fixed broken image link

flinkbot edited a comment on pull request #15868: URL: https://github.com/apache/flink/pull/15868#issuecomment-835521924 ## CI report: * 7f73637a20db8ef7a2bf05b7c74acf9c3a5291e6 UNKNOWN * 19f2a534a9ff61a1e9d611d7b8106ccc6082a398 UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot commented on pull request #15868: [hotfix][docs] Fixed broken image link

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

[GitHub] [flink] flinkbot commented on pull request #15868: [hotfix][docs] Fixed broken image link

flinkbot commented on pull request #15868: URL: https://github.com/apache/flink/pull/15868#issuecomment-835512215 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] mans2singh opened a new pull request #15868: [hotfix][docs] Fixed broken image link

mans2singh opened a new pull request #15868: URL: https://github.com/apache/flink/pull/15868 ## What is the purpose of the change * Fix broken image link ## Brief change log * Corrected image link in sources ## Verifying this change This change is a trivial

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

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

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

flinkbot edited a comment on pull request #15863: URL: https://github.com/apache/flink/pull/15863#issuecomment-835141646 ## CI report: * 2797442019f2dc8158bfa637951611c320fd47c6 UNKNOWN * 5de494c61f361b7dd93ef2b458a8f05f1e21cad3 Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

flinkbot edited a comment on pull request #15863: URL: https://github.com/apache/flink/pull/15863#issuecomment-835141646 ## CI report: * dfa8666885781c837f964b00e4e08a3af35019a4 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

lincoln-lil commented on pull request #15863: URL: https://github.com/apache/flink/pull/15863#issuecomment-835339872 Two phase window aggregate currently not covered by harness test, I'll add one later. -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] flinkbot edited a comment on pull request #15864: [FLINK-22559][table-planner] The consumed DataType of ExecSink should only consider physical columns

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

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

[jira] [Commented] (FLINK-22559) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch

[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341297#comment-17341297 ] Timo Walther commented on FLINK-22559: -- Thanks for looking into this [~Leonard Xu].

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

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

[GitHub] [flink] Shawn-Hx edited a comment on pull request #15865: [hotfix][docs] Fix all broken images

Shawn-Hx edited a comment on pull request #15865: URL: https://github.com/apache/flink/pull/15865#issuecomment-835278202 Thanks @xintongsong . Before migrating Flink docs from Jekyll to Hugo, I have changed the link format in all markdown files in FLINK-20298. The link format in J

[GitHub] [flink] Shawn-Hx commented on pull request #15865: [hotfix][docs] Fix all broken images

Shawn-Hx commented on pull request #15865: URL: https://github.com/apache/flink/pull/15865#issuecomment-835278202 Thanks @xintongsong . Before migrating Flink docs from Jekyll to Hugo, I have changed the link format in all markdown files in FLINK-20298. The link format in Jekyll l

[GitHub] [flink] flinkbot edited a comment on pull request #15865: [hotfix][docs] Fix all broken images

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

[GitHub] [flink] flinkbot edited a comment on pull request #15866: [FLINK-22562][docs-zh]Translate recent updates to backpressure and ch…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15867: [FLINK-22607][examples] Update deprecated forms of assignTimestampsAndWatermarks

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

[GitHub] [flink] xintongsong commented on pull request #15865: [hotfix][docs] Fix all broken images

xintongsong commented on pull request #15865: URL: https://github.com/apache/flink/pull/15865#issuecomment-835253957 Thanks @Shawn-Hx, I'll take a look. A quick question, how did you locate these broken images? Did you just manually go through all the pages, or is there an automatic

[jira] [Updated] (FLINK-21160) ValueDeserializerWrapper throws NullPointerException when getProducedType is invoked

[ https://issues.apache.org/jira/browse/FLINK-21160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-21160: -- Affects Version/s: (was: 1.13.0) > ValueDeserializerWrapper throws NullPointerException wh

[jira] [Updated] (FLINK-21160) ValueDeserializerWrapper throws NullPointerException when getProducedType is invoked

[ https://issues.apache.org/jira/browse/FLINK-21160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-21160: -- Fix Version/s: 1.13.0 > ValueDeserializerWrapper throws NullPointerException when getProducedT

[jira] [Updated] (FLINK-21160) ValueDeserializerWrapper throws NullPointerException when getProducedType is invoked

[ https://issues.apache.org/jira/browse/FLINK-21160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-21160: -- Affects Version/s: 1.13.0 1.12.3 > ValueDeserializerWrapper throws Null

[jira] [Closed] (FLINK-20553) Add end-to-end test case for new Kafka source

[ https://issues.apache.org/jira/browse/FLINK-20553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-20553. - Resolution: Duplicate > Add end-to-end test case for new Kafka source >

[GitHub] [flink] flinkbot edited a comment on pull request #15867: [FLINK-22607][examples] Update deprecated forms of assignTimestampsAndWatermarks

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

[jira] [Commented] (FLINK-20553) Add end-to-end test case for new Kafka source

[ https://issues.apache.org/jira/browse/FLINK-20553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341254#comment-17341254 ] Qingsheng Ren commented on FLINK-20553: --- Duplicated to FLINK-20655 > Add end-to-e

[GitHub] [flink] flinkbot commented on pull request #15867: [FLINK-22607][examples] Update deprecated forms of assignTimestampsAndWatermarks

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

[jira] [Created] (FLINK-22608) Flink Kryo deserialize read wrong bytes

Si Chen created FLINK-22608: --- Summary: Flink Kryo deserialize read wrong bytes Key: FLINK-22608 URL: https://issues.apache.org/jira/browse/FLINK-22608 Project: Flink Issue Type: Bug Compo

[jira] [Commented] (FLINK-11793) Make KafkaProducer more resilient to Kafka Broker Failures

[ https://issues.apache.org/jira/browse/FLINK-11793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341247#comment-17341247 ] Qingsheng Ren commented on FLINK-11793: --- According to [the documentation of Kafka

[GitHub] [flink] flinkbot edited a comment on pull request #15864: [FLINK-22559][table-planner] The consumed DataType of ExecSink should only consider physical columns

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

[GitHub] [flink] flinkbot edited a comment on pull request #15865: [hotfix][docs] Fix all broken images

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

[GitHub] [flink] flinkbot edited a comment on pull request #15866: [FLINK-22562][docs-zh]Translate recent updates to backpressure and ch…

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

[GitHub] [flink] flinkbot commented on pull request #15867: [FLINK-22607][examples] Update deprecated forms of assignTimestampsAndWatermarks

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

[jira] [Updated] (FLINK-22607) Examples use deprecated AscendingTimestampExtractor

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

[GitHub] [flink] Al-assad opened a new pull request #15867: [FLINK-22607][examples] Update deprecated forms of assignTimestampsAndWatermarks

Al-assad opened a new pull request #15867: URL: https://github.com/apache/flink/pull/15867 ## What is the purpose of the change The usage of `assignTimestampsAndWatermarks ` in the example code is no longer recommended, so update it to the latest usage form and keep it c

[GitHub] [flink] flinkbot commented on pull request #15866: [FLINK-22562][docs-zh]Translate recent updates to backpressure and ch…

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

[GitHub] [flink] flinkbot commented on pull request #15865: [hotfix][docs] Fix all broken images

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

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

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

[GitHub] [flink] flinkbot commented on pull request #15864: [FLINK-22559][table-planner] The consumed DataType of ExecSink should only consider physical columns

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

[GitHub] [flink] Shawn-Hx commented on pull request #15865: [hotfix][docs] Fix all broken images

Shawn-Hx commented on pull request #15865: URL: https://github.com/apache/flink/pull/15865#issuecomment-835205705 Hi, @xintongsong, @sjwiesman I find several broken images in docs and fix them. PTAL :) -- This is an automated message from the Apache Git Service. To respond to the mess

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

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

[jira] [Updated] (FLINK-22607) Examples use deprecated AscendingTimestampExtractor

[ https://issues.apache.org/jira/browse/FLINK-22607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Al-assad updated FLINK-22607: - Description: The streaming examples  [TopSpeedWindowing|https://github.com/apache/flink/blob/master/flin

[jira] [Created] (FLINK-22607) Examples use deprecated AscendingTimestampExtractor

Al-assad created FLINK-22607: Summary: Examples use deprecated AscendingTimestampExtractor Key: FLINK-22607 URL: https://issues.apache.org/jira/browse/FLINK-22607 Project: Flink Issue Type: Impro

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

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

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

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

[jira] [Created] (FLINK-22606) Simplify the usage of SessionState

Rui Li created FLINK-22606: -- Summary: Simplify the usage of SessionState Key: FLINK-22606 URL: https://issues.apache.org/jira/browse/FLINK-22606 Project: Flink Issue Type: Sub-task Compone

[GitHub] [flink] 95chenjz commented on pull request #15866: [FLINK-22562][docs-zh]Translate recent updates to backpressure and ch…

95chenjz commented on pull request #15866: URL: https://github.com/apache/flink/pull/15866#issuecomment-835195077 cc @wuchong @pnowojski. Could you review my PR when you're free? Looking for your feedback. Thanks. -- This is an automated message from the Apache Git Service. To respond to

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

[ https://issues.apache.org/jira/browse/FLINK-22598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Al-assad updated FLINK-22598: - Summary: Examples use deprecated method of writeAsText (was: Examples use deprecated forms of writeAsTe

[GitHub] [flink] flinkbot commented on pull request #15866: [FLINK-22562][docs-zh]Translate recent updates to backpressure and ch…

flinkbot commented on pull request #15866: URL: https://github.com/apache/flink/pull/15866#issuecomment-835191363 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 #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

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

[jira] [Updated] (FLINK-22562) Translate recent updates to backpressure and checkpointing docs

[ https://issues.apache.org/jira/browse/FLINK-22562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22562: --- Labels: pull-request-available (was: ) > Translate recent updates to backpressure and check

[GitHub] [flink] 95chenjz opened a new pull request #15866: [FLINK-22562][docs-zh]Translate recent updates to backpressure and ch…

95chenjz opened a new pull request #15866: URL: https://github.com/apache/flink/pull/15866 …eckpointing docs ## What is the purpose of the change Translate recent updates to backpressure and checkpointing docs ## Brief change log Update 'flink/docs/con

[GitHub] [flink] flinkbot commented on pull request #15865: [hotfix][docs] Fix all broken images

flinkbot commented on pull request #15865: URL: https://github.com/apache/flink/pull/15865#issuecomment-835189145 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] Shawn-Hx opened a new pull request #15865: [hotfix][docs] Fix all broken images

Shawn-Hx opened a new pull request #15865: URL: https://github.com/apache/flink/pull/15865 ## What is the purpose of the change Fix all broken images after migrating to Hugo. ## Brief change log ## Verifying this change This change is a trivial rework / co

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

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

[GitHub] [flink] flinkbot commented on pull request #15864: [FLINK-22559][table-planner] The consumed DataType of ExecSink should only consider physical columns

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

[jira] [Commented] (FLINK-22491) JdbcBatchingOutputFormat checks size of buffer in TableBufferReducedStatementExecutor

[ https://issues.apache.org/jira/browse/FLINK-22491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341232#comment-17341232 ] Leon Hao commented on FLINK-22491: -- will anyone review this? > JdbcBatchingOutputForma

[jira] [Updated] (FLINK-22559) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch

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

[GitHub] [flink] leonardBang opened a new pull request #15864: [FLINK-22559][table-planner] The consumed DataType of ExecSink should only consider physical columns

leonardBang opened a new pull request #15864: URL: https://github.com/apache/flink/pull/15864 ## What is the purpose of the change * This pull request fix the unstable test `UpsertKafkaTableITCase#testKafkaSourceSinkWithKeyAndFullValue` due to the consumed DataType of ExecSink has c

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

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

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

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

[GitHub] [flink] lirui-apache commented on pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

lirui-apache commented on pull request #15712: URL: https://github.com/apache/flink/pull/15712#issuecomment-835173991 Hi @hehuiyuan , I mean you could include the parquet file in your PR, and use it in the test. The file should contain minimum data that is sufficient to reproduce the issue

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

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

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

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

[jira] [Updated] (FLINK-22559) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch

[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22559: --- Affects Version/s: (was: 1.13.0) 1.13.1 > UpsertKafkaTableITCase.testKafk

[jira] [Closed] (FLINK-18762) Make network buffers per incoming/outgoing channel can be configured separately

[ https://issues.apache.org/jira/browse/FLINK-18762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-18762. --- Resolution: Won't Fix > Make network buffers per incoming/outgoing channel can be configured > sepa

[jira] [Commented] (FLINK-18762) Make network buffers per incoming/outgoing channel can be configured separately

[ https://issues.apache.org/jira/browse/FLINK-18762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341214#comment-17341214 ] Yingjie Cao commented on FLINK-18762: - This ticket is not needed, so closing it. >

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

[ https://issues.apache.org/jira/browse/FLINK-22604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22604: Assignee: lincoln lee > NPE on bundle close when task failover after a failed task open >

[jira] [Commented] (FLINK-22559) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch

[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341211#comment-17341211 ] Leonard Xu commented on FLINK-22559: The reason is the primary key indices is wrong

[GitHub] [flink] hehuiyuan commented on pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

hehuiyuan commented on pull request #15712: URL: https://github.com/apache/flink/pull/15712#issuecomment-835159159 > @hehuiyuan Could you share the parquet file you use to reproduce the issue? Hive client execute the sql is ok, then read it by flink. ``` INSERT INTO TABLE sear