[jira] [Updated] (FLINK-22791) HybridSource user documentation

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22791: - Component/s: Documentation > HybridSource user documentation > ---

[GitHub] [flink] flinkbot commented on pull request #16869: [runtime] fix packge import mode for DefaultLeaderRetrievalService

2021-08-17 Thread GitBox
flinkbot commented on pull request #16869: URL: https://github.com/apache/flink/pull/16869#issuecomment-900832930 ## CI report: * c9d650fd898ee818953858fa1954bda4b5f1fce2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16745: [FLINK-22246]when use HiveCatalog create table , can't set Table owne…

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16745: URL: https://github.com/apache/flink/pull/16745#issuecomment-894632163 ## CI report: * 8012720d8036bdae16feaafed425f3024dfc14f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16683: [FLINK-23846][docs]improve PushGatewayReporter config description

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16683: URL: https://github.com/apache/flink/pull/16683#issuecomment-891515480 ## CI report: * 63aa6e2f3c05fac9150399fe2a9c519cbe3e1d1e UNKNOWN * a51a065dc64d6b495ff12761b4babb117529da2b Azure:

[jira] [Updated] (FLINK-23834) Test StreamTableEnvironment batch mode manually

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23834: - Priority: Blocker (was: Major) > Test StreamTableEnvironment batch mode manually >

[GitHub] [flink] wsry commented on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

2021-08-17 Thread GitBox
wsry commented on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900828858 > One last question: > > What if we move the change to `releaseInternal`, like this. In this way, we do not need for refacotring or changing fail(). WDYT? > > ```

[jira] [Created] (FLINK-23851) AggregationsITCase.testDistinctAfterAggregate fails due to AskTimeoutException

2021-08-17 Thread Xintong Song (Jira)
Xintong Song created FLINK-23851: Summary: AggregationsITCase.testDistinctAfterAggregate fails due to AskTimeoutException Key: FLINK-23851 URL: https://issues.apache.org/jira/browse/FLINK-23851

[GitHub] [flink] wsry commented on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

2021-08-17 Thread GitBox
wsry commented on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900827949 > @wsry thanks for your changes. They look correct for me but I have a couple of notices. First of all, I suggest splitting this one commit into two: the first one with the

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400800#comment-17400800 ] Xintong Song commented on FLINK-23848: --

[jira] [Commented] (FLINK-23829) SavepointITCase JVM crash on azure

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400799#comment-17400799 ] Xintong Song commented on FLINK-23829: --

[GitHub] [flink] flinkbot commented on pull request #16869: fix packge import mode for DefaultLeaderRetrievalService

2021-08-17 Thread GitBox
flinkbot commented on pull request #16869: URL: https://github.com/apache/flink/pull/16869#issuecomment-900825384 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #16823: [FLINK-23845][docs]improve PushGatewayReporter config:deleteOnShutdown de…

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16823: URL: https://github.com/apache/flink/pull/16823#issuecomment-898865990 ## CI report: * 656fc2a8cd23e86b8abf656d80593e4df7c2e8a5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16629: [FLINK-23847][connectors][kafka] improve error message when valueDeseriali…

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16629: URL: https://github.com/apache/flink/pull/16629#issuecomment-888753020 ## CI report: * a3f89c52f22638b58005b76670229e2952d6bf83 Azure:

[GitHub] [flink] wangjunyou opened a new pull request #16869: fix packge import mode for DefaultLeaderRetrievalService

2021-08-17 Thread GitBox
wangjunyou opened a new pull request #16869: URL: https://github.com/apache/flink/pull/16869 ## What is the purpose of the change *Modify import method, static import Preconditions.checkState to DefaultLeaderRetrievalService.java* ## Brief change log -

[GitHub] [flink] flinkbot edited a comment on pull request #14893: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #14893: URL: https://github.com/apache/flink/pull/14893#issuecomment-774815157 ## CI report: * 521b6d5ad32becde67f8477258633b1e1a1ac59b Azure:

[jira] [Comment Edited] (FLINK-23727) Skip null values in SimpleStringSchema#deserialize

2021-08-17 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400787#comment-17400787 ] Paul Lin edited comment on FLINK-23727 at 8/18/21, 5:13 AM: [~paul8263] WRT

[jira] [Commented] (FLINK-23727) Skip null values in SimpleStringSchema#deserialize

2021-08-17 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400787#comment-17400787 ] Paul Lin commented on FLINK-23727: -- [~paul8263] WRT solutions, I've considered adding a flag as you

[jira] [Commented] (FLINK-21200) User defined functions refuse to accept multi-set arguments without type hints

2021-08-17 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400784#comment-17400784 ] Timo Walther commented on FLINK-21200: -- [~Kenyore] This issue has rather low priority. The current

[GitHub] [flink] flinkbot edited a comment on pull request #14893: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #14893: URL: https://github.com/apache/flink/pull/14893#issuecomment-774815157 ## CI report: * 521b6d5ad32becde67f8477258633b1e1a1ac59b Azure:

[GitHub] [flink] lgo commented on pull request #14893: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

2021-08-17 Thread GitBox
lgo commented on pull request #14893: URL: https://github.com/apache/flink/pull/14893#issuecomment-900806314 I merged in `master` to resolve conflicts and want to thaw this change because the RocksDB version was bumped to a version where this operation is stable. -- This is an

[jira] [Commented] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange

2021-08-17 Thread Joey Pereira (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400773#comment-17400773 ] Joey Pereira commented on FLINK-21321: -- [~yunta] would you be open merging this change now because

[jira] [Commented] (FLINK-23727) Skip null values in SimpleStringSchema#deserialize

2021-08-17 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400771#comment-17400771 ] Yao Zhang commented on FLINK-23727: --- Hi [~Paul Lin], I encountered the same issue with very early

[GitHub] [flink] curcur edited a comment on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

2021-08-17 Thread GitBox
curcur edited a comment on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900799942 One last question: What if we move the change to `releaseInternal`, like this. In this way, we do not need for refacotring or changing fail(). WDYT? ```

[jira] [Created] (FLINK-23850) Test Kafka table connector with new runtime provider

2021-08-17 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-23850: - Summary: Test Kafka table connector with new runtime provider Key: FLINK-23850 URL: https://issues.apache.org/jira/browse/FLINK-23850 Project: Flink Issue

[GitHub] [flink] curcur edited a comment on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

2021-08-17 Thread GitBox
curcur edited a comment on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900799942 One last question: What if we move the change to `releaseInternal`, like this. In this way, we do not need for refacotring or changing fail(). WDYT? ```

[GitHub] [flink] curcur commented on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

2021-08-17 Thread GitBox
curcur commented on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900799942 One last question: What if we move the change to `releaseInternal`, like this. In this way, we do not need for refacotring or changing fail(). WDYT? ```

[GitHub] [flink] curcur commented on a change in pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

2021-08-17 Thread GitBox
curcur commented on a change in pull request #16844: URL: https://github.com/apache/flink/pull/16844#discussion_r690885852 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -1182,7 +1186,10 @@ void

[GitHub] [flink] curcur commented on a change in pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

2021-08-17 Thread GitBox
curcur commented on a change in pull request #16844: URL: https://github.com/apache/flink/pull/16844#discussion_r690885852 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -1182,7 +1186,10 @@ void

[GitHub] [flink] curcur edited a comment on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

2021-08-17 Thread GitBox
curcur edited a comment on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900796934 Synced up offline. Thanks Yingjie @wsry for the explanation! I am fine with the change. Please add three comments/explanations either in the code or in this PR (I

[GitHub] [flink] curcur commented on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

2021-08-17 Thread GitBox
curcur commented on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900796934 Thanks Yingjie @wsry for the explanation! I am fine with the change. Please add three comments/explanations either in the code or in this PR (I will also comment inline).

[jira] [Commented] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400767#comment-17400767 ] Xintong Song commented on FLINK-23525: --

[jira] [Commented] (FLINK-23796) UnalignedCheckpointRescaleITCase JVM crash on Azure

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400766#comment-17400766 ] Xintong Song commented on FLINK-23796: --

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400764#comment-17400764 ] Xintong Song commented on FLINK-22889: --

[jira] [Created] (FLINK-23849) Support react to the node decommissioning change state on yarn and do graceful restart

2021-08-17 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-23849: --- Summary: Support react to the node decommissioning change state on yarn and do graceful restart Key: FLINK-23849 URL: https://issues.apache.org/jira/browse/FLINK-23849

[jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400763#comment-17400763 ] Xintong Song commented on FLINK-23828: --

[jira] [Updated] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23828: - Priority: Critical (was: Major) > KafkaSourceITCase.testIdleReader fails on azure >

[jira] [Commented] (FLINK-23351) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails due to "too few watermarks emitted" on azure

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400762#comment-17400762 ] Xintong Song commented on FLINK-23351: --

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400761#comment-17400761 ] Xintong Song commented on FLINK-22198: --

[jira] [Commented] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400760#comment-17400760 ] Xintong Song commented on FLINK-23525: --

[jira] [Commented] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400759#comment-17400759 ] Xintong Song commented on FLINK-23525: --

[jira] [Commented] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400758#comment-17400758 ] Xintong Song commented on FLINK-23525: --

[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400755#comment-17400755 ] Xintong Song commented on FLINK-22387: --

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400752#comment-17400752 ] Xintong Song commented on FLINK-23848: --

[jira] [Commented] (FLINK-23697) flink standalone Isolation is poor, why not do as spark does

2021-08-17 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400753#comment-17400753 ] jackylau commented on FLINK-23697: -- hi [~trohrmann], could we support this in the feature ? > flink

[jira] [Updated] (FLINK-23848) PulsarSourceITCase is failed on Azure

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23848: - Labels: test-stability (was: ) > PulsarSourceITCase is failed on Azure >

[jira] [Updated] (FLINK-23848) PulsarSourceITCase is failed on Azure

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23848: - Affects Version/s: 1.14.0 > PulsarSourceITCase is failed on Azure >

[jira] [Updated] (FLINK-23848) PulsarSourceITCase is failed on Azure

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23848: - Issue Type: Bug (was: Improvement) > PulsarSourceITCase is failed on Azure >

[jira] [Updated] (FLINK-23848) PulsarSourceITCase is failed on Azure

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23848: - Fix Version/s: 1.14.0 > PulsarSourceITCase is failed on Azure >

[GitHub] [flink] flinkbot edited a comment on pull request #16860: [FLINK-22198][connector/kafka] Redirect KafkaContainer output to log4j and print debug log if test hangs

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16860: URL: https://github.com/apache/flink/pull/16860#issuecomment-900154319 ## CI report: * d6bfdd97c618e764305515917075f97a38ebcd32 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16851: [FLINK-23776][streaming] Fix handling of timestamp-less records in Source metrics.

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16851: URL: https://github.com/apache/flink/pull/16851#issuecomment-899772155 ## CI report: * 2178ac743f87edaf1792db765a0fc0b5b058c66e Azure:

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

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16740: URL: https://github.com/apache/flink/pull/16740#issuecomment-894176423 ## CI report: * 56b337596cb3b2db4fe3d4aa985b4ce8851102ba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16683: [FLINK-23846][docs]improve PushGatewayReporter config description

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16683: URL: https://github.com/apache/flink/pull/16683#issuecomment-891515480 ## CI report: * 3b3f16a9694732d6211a63d324d4bb579933fe87 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16629: [FLINK-23847][connectors][kafka] improve error message when valueDeseriali…

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16629: URL: https://github.com/apache/flink/pull/16629#issuecomment-888753020 ## CI report: * cabb650967f9a523bca917ae6409398e5c6ccd2a Azure:

[jira] [Commented] (FLINK-17104) Support registering custom JobStatusListeners from config

2021-08-17 Thread Wenhao Ji (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400743#comment-17400743 ] Wenhao Ji commented on FLINK-17104: --- It has been a while since I opened the discussion about this

[GitHub] [flink] wsry commented on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

2021-08-17 Thread GitBox
wsry commented on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900783119 > Thanks @wsry for fixing up! But I have a small concern about this change. > > 1. It is necessary to recycle BufferBuilder in the BufferWritingResultPartition#close method,

[GitHub] [flink] flinkbot edited a comment on pull request #16860: [FLINK-22198][connector/kafka] Redirect KafkaContainer output to log4j and print debug log if test hangs

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16860: URL: https://github.com/apache/flink/pull/16860#issuecomment-900154319 ## CI report: * d6bfdd97c618e764305515917075f97a38ebcd32 Azure:

[jira] [Updated] (FLINK-23847) [Kafka] Error msg are obscure when KafkaConsumer init, valueDeserializer is null

2021-08-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23847: --- Labels: pull-request-available (was: ) > [Kafka] Error msg are obscure when KafkaConsumer

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

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16740: URL: https://github.com/apache/flink/pull/16740#issuecomment-894176423 ## CI report: * 56b337596cb3b2db4fe3d4aa985b4ce8851102ba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16683: [FLINK-23846][docs]improve PushGatewayReporter config description

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16683: URL: https://github.com/apache/flink/pull/16683#issuecomment-891515480 ## CI report: * 3b3f16a9694732d6211a63d324d4bb579933fe87 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16629: [FLINK-23847][connectors][kafka] improve error message when valueDeseriali…

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16629: URL: https://github.com/apache/flink/pull/16629#issuecomment-888753020 ## CI report: * cabb650967f9a523bca917ae6409398e5c6ccd2a Azure:

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-08-17 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400730#comment-17400730 ] Huang Xingbo commented on FLINK-23493: --

[jira] [Commented] (FLINK-23749) Testing Window Join

2021-08-17 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400728#comment-17400728 ] lixiaobao commented on FLINK-23749: --- Can you assign this issue to me? I'd like to working on this

[jira] [Commented] (FLINK-23837) Differences between documentation and implementation for taskmanager.memory.network.max

2021-08-17 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400726#comment-17400726 ] Yao Zhang commented on FLINK-23837: --- Hi all, I looked into the default flink-conf.yml file:

[jira] [Commented] (FLINK-23813) DeleteExecutor NPE

2021-08-17 Thread Junning Liang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400727#comment-17400727 ] Junning Liang commented on FLINK-23813: --- hi, [~roman_khachatryan]. this is the deepest

[jira] [Updated] (FLINK-23813) DeleteExecutor NPE

2021-08-17 Thread Junning Liang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junning Liang updated FLINK-23813: -- Attachment: image-2021-08-18-10-49-43-941.png > DeleteExecutor NPE > -- > >

[GitHub] [flink] wsry commented on a change in pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

2021-08-17 Thread GitBox
wsry commented on a change in pull request #16844: URL: https://github.com/apache/flink/pull/16844#discussion_r690859332 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -972,24 +972,28 @@ private void releaseResources() {

[jira] [Commented] (FLINK-16154) Translate "Operator/Join" into Chinese

2021-08-17 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400720#comment-17400720 ] lixiaobao commented on FLINK-16154: --- Ok,I will translate other page,tks > Translate "Operator/Join"

[GitHub] [flink] lirui-apache commented on pull request #16745: [FLINK-22246]when use HiveCatalog create table , can't set Table owne…

2021-08-17 Thread GitBox
lirui-apache commented on pull request #16745: URL: https://github.com/apache/flink/pull/16745#issuecomment-900769304 > > Could you post links to the authentication design you mentioned? I tried with hive 2.3.6 and found this is actually allowed. For example, in a kerberized env, you can

[GitHub] [flink] wsry commented on a change in pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

2021-08-17 Thread GitBox
wsry commented on a change in pull request #16844: URL: https://github.com/apache/flink/pull/16844#discussion_r690857837 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartition.java ## @@ -250,15 +250,20 @@ public void

[jira] [Commented] (FLINK-16154) Translate "Operator/Join" into Chinese

2021-08-17 Thread Wenzhong Duan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400719#comment-17400719 ] Wenzhong Duan commented on FLINK-16154: --- Hi [~q977734161], the translations are already done. But

[jira] [Issue Comment Deleted] (FLINK-16154) Translate "Operator/Join" into Chinese

2021-08-17 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16154: Comment: was deleted (was: Hi [~q977734161] Very thanks, I see there is already an PR open, so let's

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

2021-08-17 Thread GitBox
paul8263 commented on pull request #16740: URL: https://github.com/apache/flink/pull/16740#issuecomment-900766636 Hi @tsreaper , I solved the conflicts in 9296b4e. When I ran the unit tests I encountered an error: org.apache.flink.changelog.fs.FsStateChangelogStorageFactory in

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

2021-08-17 Thread GitBox
paul8263 removed a comment on pull request #16740: URL: https://github.com/apache/flink/pull/16740#issuecomment-900766636 Hi @tsreaper , I solved the conflicts in 9296b4e. When I ran the unit tests I encountered an error: org.apache.flink.changelog.fs.FsStateChangelogStorageFactory

[GitHub] [flink] wuchong commented on pull request #16852: [FLINK-13636][docs-zh]Translate the "Flink DataStream API Programming Guide" page into Chinese

2021-08-17 Thread GitBox
wuchong commented on pull request #16852: URL: https://github.com/apache/flink/pull/16852#issuecomment-900766528 cc @RocMarshal , do you have time to review this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Closed] (FLINK-23844) Fix spelling mistakes for "async"

2021-08-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23844. --- Fix Version/s: 1.14.0 Assignee: wuguihu Resolution: Fixed Fixed in master:

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

2021-08-17 Thread GitBox
paul8263 commented on pull request #16740: URL: https://github.com/apache/flink/pull/16740#issuecomment-900766227 Hi @tsreaper , I solved the conflicts in 9296b4e. When I ran the unit tests I encountered an error: org.apache.flink.changelog.fs.FsStateChangelogStorageFactory in

[GitHub] [flink] wuchong merged pull request #16868: [FLINK-23844]Fix spelling mistakes for "async"

2021-08-17 Thread GitBox
wuchong merged pull request #16868: URL: https://github.com/apache/flink/pull/16868 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #16823: [FLINK-23845][docs]improve PushGatewayReporter config:deleteOnShutdown de…

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16823: URL: https://github.com/apache/flink/pull/16823#issuecomment-898865990 ## CI report: * 3ca95e2c4af83ecc4125f4c86747b7006cc41961 Azure:

[jira] [Created] (FLINK-23848) PulsarSourceITCase is failed on Azure

2021-08-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-23848: --- Summary: PulsarSourceITCase is failed on Azure Key: FLINK-23848 URL: https://issues.apache.org/jira/browse/FLINK-23848 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #16745: [FLINK-22246]when use HiveCatalog create table , can't set Table owne…

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16745: URL: https://github.com/apache/flink/pull/16745#issuecomment-894632163 ## CI report: * ec30ee61c2adc94b71eede27342a6e4a42a23e56 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16683: [FLINK-23846][docs]improve PushGatewayReporter config description

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16683: URL: https://github.com/apache/flink/pull/16683#issuecomment-891515480 ## CI report: * 3b3f16a9694732d6211a63d324d4bb579933fe87 Azure:

[jira] [Commented] (FLINK-16154) Translate "Operator/Join" into Chinese

2021-08-17 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400715#comment-17400715 ] Yun Gao commented on FLINK-16154: - Hi [~q977734161] Very thanks, I see there is already an PR open, so

[GitHub] [flink] gaoyunhaii commented on pull request #14858: [FLINK-16154] Translate "Operator/Join" into Chinese

2021-08-17 Thread GitBox
gaoyunhaii commented on pull request #14858: URL: https://github.com/apache/flink/pull/14858#issuecomment-900764728 Hi @dijkwxyz sorry for the very late reply, do you want to still work on this PR~? -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Assigned] (FLINK-16152) Translate "Operator/index" into Chinese

2021-08-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16152: --- Assignee: wuguihu > Translate "Operator/index" into Chinese >

[jira] [Updated] (FLINK-23847) [Kafka] Error msg are obscure when KafkaConsumer init, valueDeserializer is null

2021-08-17 Thread camilesing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] camilesing updated FLINK-23847: --- Component/s: (was: Documentation) Connectors / Kafka > [Kafka] Error msg are

[GitHub] [flink] gaoyunhaii commented on pull request #14819: [FLINK-16152] Translate "Operator/index" into Chinese

2021-08-17 Thread GitBox
gaoyunhaii commented on pull request #14819: URL: https://github.com/apache/flink/pull/14819#issuecomment-900764458 Hi @dijkwxyz sorry for the very late reply, do you want to still work on this PR~? -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-23847) [Kafka] Error msg are obscure when KafkaConsumer init, valueDeserializer is null

2021-08-17 Thread camilesing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] camilesing updated FLINK-23847: --- Summary: [Kafka] Error msg are obscure when KafkaConsumer init, valueDeserializer is null (was:

[jira] [Created] (FLINK-23847) [DOCS] Error msg are obscure when KafkaConsumer init, valueDeserializer is null

2021-08-17 Thread camilesing (Jira)
camilesing created FLINK-23847: -- Summary: [DOCS] Error msg are obscure when KafkaConsumer init, valueDeserializer is null Key: FLINK-23847 URL: https://issues.apache.org/jira/browse/FLINK-23847 Project:

[GitHub] [flink] xintongsong commented on a change in pull request #16860: [FLINK-22198][connector/kafka] Redirect KafkaContainer output to log4j and print debug log if test hangs

2021-08-17 Thread GitBox
xintongsong commented on a change in pull request #16860: URL: https://github.com/apache/flink/pull/16860#discussion_r690849889 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestBase.java ## @@

[jira] [Updated] (FLINK-23846) [DOCS]PushGatewayReporter config description obscure

2021-08-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23846: --- Labels: pull-request-available (was: ) > [DOCS]PushGatewayReporter config description

[GitHub] [flink] camilesing commented on pull request #16683: [FLINK-23846][docs]improve PushGatewayReporter config description

2021-08-17 Thread GitBox
camilesing commented on pull request #16683: URL: https://github.com/apache/flink/pull/16683#issuecomment-900760531 @infoverload thx your comment, I've done what you said -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Comment Edited] (FLINK-16154) Translate "Operator/Join" into Chinese

2021-08-17 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400712#comment-17400712 ] lixiaobao edited comment on FLINK-16154 at 8/18/21, 2:14 AM: - Hi

[jira] [Commented] (FLINK-16154) Translate "Operator/Join" into Chinese

2021-08-17 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400712#comment-17400712 ] lixiaobao commented on FLINK-16154: --- Hi Jark Wu , I find this page is not translated. can you assign

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

2021-08-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400706#comment-17400706 ] Xintong Song commented on FLINK-23556: -- Thanks for the updates, [~bgeng777]. Do you need a review

[jira] [Created] (FLINK-23846) [DOCS]PushGatewayReporter config description obscure

2021-08-17 Thread camilesing (Jira)
camilesing created FLINK-23846: -- Summary: [DOCS]PushGatewayReporter config description obscure Key: FLINK-23846 URL: https://issues.apache.org/jira/browse/FLINK-23846 Project: Flink Issue Type:

[jira] [Updated] (FLINK-23845) [DOCS]PushGateway metrics group not delete when job shutdown

2021-08-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23845: --- Labels: pull-request-available (was: ) > [DOCS]PushGateway metrics group not delete when

[GitHub] [flink] flinkbot edited a comment on pull request #16823: [FLINK-23845][docs]improve PushGatewayReporter config:deleteOnShutdown de…

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16823: URL: https://github.com/apache/flink/pull/16823#issuecomment-898865990 ## CI report: * 3ca95e2c4af83ecc4125f4c86747b7006cc41961 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16745: [FLINK-22246]when use HiveCatalog create table , can't set Table owne…

2021-08-17 Thread GitBox
flinkbot edited a comment on pull request #16745: URL: https://github.com/apache/flink/pull/16745#issuecomment-894632163 ## CI report: * ec30ee61c2adc94b71eede27342a6e4a42a23e56 Azure:

[jira] [Commented] (FLINK-23845) [DOCS]PushGateway metrics group not delete when job shutdown

2021-08-17 Thread camilesing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400702#comment-17400702 ] camilesing commented on FLINK-23845: https://github.com/apache/flink/pull/16823 > [DOCS]PushGateway

[GitHub] [flink] cuibo01 commented on pull request #16745: [FLINK-22246]when use HiveCatalog create table , can't set Table owne…

2021-08-17 Thread GitBox
cuibo01 commented on pull request #16745: URL: https://github.com/apache/flink/pull/16745#issuecomment-900743034 > Could you post links to the authentication design you mentioned? I tried with hive 2.3.6 and found this is actually allowed. For example, in a kerberized env, you can kinit

  1   2   3   4   5   >