[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

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * 3f89d29a4cee4917ff8087e16ab35c5d1274220c Azure:

[GitHub] [flink] tzulitai opened a new pull request #12209: [FLINK-17520] [core] Extend CompositeTypeSerializerSnapshot to support migration

2020-05-18 Thread GitBox
tzulitai opened a new pull request #12209: URL: https://github.com/apache/flink/pull/12209 ## What is the purpose of the change Previously, the abstraction provided by `CompositeTypeSerializerSnapshot` only allows a mismatch in the outer configuration of composite serializers to be

[GitHub] [flink] flinkbot edited a comment on pull request #12205: [FLINK-17780][checkpointing] Add task name to log statements of ChannelStateWriter.

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12205: URL: https://github.com/apache/flink/pull/12205#issuecomment-629865234 ## CI report: * 95793199f3be07aaf21dcefd2f7c7f8998be683d Azure:

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109915#comment-17109915 ] Robert Metzger commented on FLINK-12030:

[GitHub] [flink] zentol merged pull request #12207: [hotfix][doc] Fix broken link in the native Kubernetes document

2020-05-18 Thread GitBox
zentol merged pull request #12207: URL: https://github.com/apache/flink/pull/12207 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

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109916#comment-17109916 ] Robert Metzger commented on FLINK-17768:

[GitHub] [flink] wanglijie95 commented on a change in pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

2020-05-18 Thread GitBox
wanglijie95 commented on a change in pull request #12181: URL: https://github.com/apache/flink/pull/12181#discussion_r426389591 ## File path: flink-core/src/test/java/org/apache/flink/core/fs/SafetyNetCloseableRegistryTest.java ## @@ -198,4 +211,27 @@ public void

[GitHub] [flink] pnowojski commented on a change in pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

2020-05-18 Thread GitBox
pnowojski commented on a change in pull request #8693: URL: https://github.com/apache/flink/pull/8693#discussion_r426378044 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java ## @@ -38,4 +38,12 @@ * @throws Exception

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109926#comment-17109926 ] Robert Metzger commented on FLINK-17768:

[GitHub] [flink-web] yangjf2019 commented on pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

2020-05-18 Thread GitBox
yangjf2019 commented on pull request #268: URL: https://github.com/apache/flink-web/pull/268#issuecomment-629972237 Hi, @klion26 thank you for your help, I will continue to work hard. This is an automated message from the

[jira] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109935#comment-17109935 ] Robert Metzger commented on FLINK-17730:

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109934#comment-17109934 ] Robert Metzger commented on FLINK-16947:

[jira] [Commented] (FLINK-17787) BucketStateSerializerTest fails on output mismatch

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109940#comment-17109940 ] Robert Metzger commented on FLINK-17787: This was probably resolved through

[jira] [Closed] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-05-18 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15670. -- Resolution: Fixed Merged to master as 03f5d54b99..78b7c71d83 > Provide a Kafka Source/Sink

[GitHub] [flink] pnowojski commented on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

2020-05-18 Thread GitBox
pnowojski commented on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-629984389 LGTM, private azure test passed % end to end tests timeout, but this couldn't be possibly caused by the latest update - previous version differed only in a java doc and was

[GitHub] [flink] pnowojski merged pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

2020-05-18 Thread GitBox
pnowojski merged pull request #11725: URL: https://github.com/apache/flink/pull/11725 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Commented] (FLINK-17789) DelegatingConfiguration should remove prefix instead of add prefix in toMap

2020-05-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109957#comment-17109957 ] Chesnay Schepler commented on FLINK-17789: -- I disagree. The current behavior is simple; take an

[GitHub] [flink] pnowojski commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

2020-05-18 Thread GitBox
pnowojski commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r426411404 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[]

[GitHub] [flink] pnowojski commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

2020-05-18 Thread GitBox
pnowojski commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r426411404 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[]

[GitHub] [flink] GJL opened a new pull request #12210: [FLINK-17792][tests] Catch and log exception if jstack fails

2020-05-18 Thread GitBox
GJL opened a new pull request #12210: URL: https://github.com/apache/flink/pull/12210 ## What is the purpose of the change *This catches and logs exceptions thrown when invoking jstack. jstack can fail if the JVM process that we want to sample exits while or before we invoke

[jira] [Updated] (FLINK-17792) Failing to invoking jstack on TM processes should not fail Jepsen Tests

2020-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17792: --- Labels: pull-request-available (was: ) > Failing to invoking jstack on TM processes should

[jira] [Commented] (FLINK-17789) DelegatingConfiguration should remove prefix instead of add prefix in toMap

2020-05-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109970#comment-17109970 ] Jingsong Lee commented on FLINK-17789: -- Hi [~chesnay], thanks for quick response. > an option

[GitHub] [flink] JingsongLi opened a new pull request #12212: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-18 Thread GitBox
JingsongLi opened a new pull request #12212: URL: https://github.com/apache/flink/pull/12212 ## What is the purpose of the change Fs connector should use FLIP-122 format options style. Like: ``` create table t (...) with ( 'connector'='filesystem', 'path'='...',

[jira] [Updated] (FLINK-17790) flink-connector-kafka-base does not compile on Java11

2020-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17790: --- Labels: pull-request-available (was: ) > flink-connector-kafka-base does not compile on

[GitHub] [flink] zentol opened a new pull request #12211: [FLINK-17790][kafka] Fix JDK 11 compile error

2020-05-18 Thread GitBox
zentol opened a new pull request #12211: URL: https://github.com/apache/flink/pull/12211 `initializePartitioner` returns a `FlinkKafkaPartitioner`, without any generic parameter, as a result of which the type of the Optional is not well-defined.

[GitHub] [flink] flinkbot commented on pull request #12212: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-18 Thread GitBox
flinkbot commented on pull request #12212: URL: https://github.com/apache/flink/pull/12212#issuecomment-630001771 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

[jira] [Assigned] (FLINK-17763) No log files when starting scala-shell

2020-05-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-17763: Assignee: Chesnay Schepler > No log files when starting scala-shell >

[GitHub] [flink] tillrohrmann commented on a change in pull request #11987: [hotfix] Show hostname in failure error message

2020-05-18 Thread GitBox
tillrohrmann commented on a change in pull request #11987: URL: https://github.com/apache/flink/pull/11987#discussion_r426428629 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ## @@ -1568,7 +1568,7 @@ private boolean

[jira] [Updated] (FLINK-17787) BucketStateSerializerTest fails on output mismatch

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17787: --- Component/s: Tests > BucketStateSerializerTest fails on output mismatch >

[jira] [Updated] (FLINK-17787) BucketStateSerializerTest fails on output mismatch

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17787: --- Labels: test-stability (was: ) > BucketStateSerializerTest fails on output mismatch >

[jira] [Created] (FLINK-17787) BucketStateSerializerTest fails on output mismatch

2020-05-18 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17787: -- Summary: BucketStateSerializerTest fails on output mismatch Key: FLINK-17787 URL: https://issues.apache.org/jira/browse/FLINK-17787 Project: Flink Issue

[GitHub] [flink] yangyichao-mango removed a comment on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

2020-05-18 Thread GitBox
yangyichao-mango removed a comment on pull request #12196: URL: https://github.com/apache/flink/pull/12196#issuecomment-629932386 > @yangyichao-mango thanks for your contribution. could you please share the result after execute `sh docs/check_links.sh` here (you have to execute `sh

[GitHub] [flink] yangyichao-mango removed a comment on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

2020-05-18 Thread GitBox
yangyichao-mango removed a comment on pull request #12196: URL: https://github.com/apache/flink/pull/12196#issuecomment-629932483 > @yangyichao-mango thanks for your contribution. could you please share the result after execute `sh docs/check_links.sh` here (you have to execute `sh

[GitHub] [flink] flinkbot edited a comment on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-628151415 ## CI report: * 449b8494248924ab0c9a4a5187458933902a13a3 Azure:

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109925#comment-17109925 ] Robert Metzger commented on FLINK-12030:

[GitHub] [flink] flinkbot commented on pull request #12209: [FLINK-17520] [core] Extend CompositeTypeSerializerSnapshot to support migration

2020-05-18 Thread GitBox
flinkbot commented on pull request #12209: URL: https://github.com/apache/flink/pull/12209#issuecomment-629971018 ## CI report: * c91cdd32db0464d8b60d0efc0763078388a15daf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-17787) BucketStateSerializerTest fails on output mismatch

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109931#comment-17109931 ] Robert Metzger commented on FLINK-17787:

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109932#comment-17109932 ] Robert Metzger commented on FLINK-12030:

[jira] [Commented] (FLINK-5763) Make savepoints self-contained and relocatable

2020-05-18 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109933#comment-17109933 ] Congxian Qiu(klion26) commented on FLINK-5763: -- Add a release note. > Make savepoints

[jira] [Updated] (FLINK-5763) Make savepoints self-contained and relocatable

2020-05-18 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-5763: - Release Note: After FLINK-5763, we made savepoint self-contained and relocatable

[GitHub] [flink] zentol commented on a change in pull request #12138: [FLINK-16611] [datadog-metrics] Make number of metrics per request configurable

2020-05-18 Thread GitBox
zentol commented on a change in pull request #12138: URL: https://github.com/apache/flink/pull/12138#discussion_r426394581 ## File path: flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java ## @@ -157,6 +181,11 @@ private

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109928#comment-17109928 ] Robert Metzger commented on FLINK-16572:

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

2020-05-18 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109939#comment-17109939 ] Piotr Nowojski commented on FLINK-17768: Test disabled on master via {{591aebcdd9}} >

[jira] [Created] (FLINK-17790) flink-connector-kafka-base does not compile on Java11

2020-05-18 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17790: -- Summary: flink-connector-kafka-base does not compile on Java11 Key: FLINK-17790 URL: https://issues.apache.org/jira/browse/FLINK-17790 Project: Flink

[jira] [Updated] (FLINK-17791) Combine collecting sink and iterator to support collecting query results under all execution and network environments

2020-05-18 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-17791: Labels: pull-request-available (was: ) > Combine collecting sink and iterator to support

[GitHub] [flink] dawidwys commented on a change in pull request #12201: [hotfix] Remove raw class usages in Configuration.

2020-05-18 Thread GitBox
dawidwys commented on a change in pull request #12201: URL: https://github.com/apache/flink/pull/12201#discussion_r426407452 ## File path: flink-core/src/main/java/org/apache/flink/configuration/Configuration.java ## @@ -909,12 +909,10 @@ private void

[GitHub] [flink] dawidwys commented on a change in pull request #12201: [hotfix] Remove raw class usages in Configuration.

2020-05-18 Thread GitBox
dawidwys commented on a change in pull request #12201: URL: https://github.com/apache/flink/pull/12201#discussion_r426407452 ## File path: flink-core/src/main/java/org/apache/flink/configuration/Configuration.java ## @@ -909,12 +909,10 @@ private void

[jira] [Assigned] (FLINK-17790) flink-connector-kafka-base does not compile on Java11

2020-05-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-17790: Assignee: Chesnay Schepler > flink-connector-kafka-base does not compile on

[jira] [Reopened] (FLINK-17595) JobExceptionsInfo. ExecutionExceptionInfo miss getter method

2020-05-18 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reopened FLINK-17595: -- > JobExceptionsInfo. ExecutionExceptionInfo miss getter method >

[GitHub] [flink] flinkbot edited a comment on pull request #12209: [FLINK-17520] [core] Extend CompositeTypeSerializerSnapshot to support migration

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12209: URL: https://github.com/apache/flink/pull/12209#issuecomment-629971018 ## CI report: * c91cdd32db0464d8b60d0efc0763078388a15daf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12202: [FLINK-17791][table][streaming] Support collecting query results under all execution and network environments

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12202: URL: https://github.com/apache/flink/pull/12202#issuecomment-629806443 ## CI report: * 9385209a72fa1314e604a3998a149d93a12617d9 UNKNOWN * 1b46780c0bf016a524a379cec83d120563ddcb9d Azure:

[jira] [Commented] (FLINK-17527) kubernetes-session.sh uses log4j-console.properties

2020-05-18 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109953#comment-17109953 ] Yang Wang commented on FLINK-17527: --- [~trohrmann] If you agree, i will rename

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595 ## CI report: * 9a73076f072352ba5539bf558f90a94572fb6c36 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12186: URL: https://github.com/apache/flink/pull/12186#issuecomment-629492236 ## CI report: * f512eeef60f86107d945f975b1ca8dead57db9c4 Azure:

[jira] [Closed] (FLINK-17595) JobExceptionsInfo. ExecutionExceptionInfo miss getter method

2020-05-18 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-17595. Resolution: Won't Do > JobExceptionsInfo. ExecutionExceptionInfo miss getter method >

[jira] [Updated] (FLINK-17595) JobExceptionsInfo. ExecutionExceptionInfo miss getter method

2020-05-18 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-17595: - Fix Version/s: (was: 1.11.0) > JobExceptionsInfo. ExecutionExceptionInfo miss getter method >

[GitHub] [flink] flinkbot edited a comment on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-628151415 ## CI report: * 449b8494248924ab0c9a4a5187458933902a13a3 Azure:

[GitHub] [flink] rmetzger merged pull request #12175: [FLINK-17692] Keep yarn.classpath in target folder to not pollute local builds

2020-05-18 Thread GitBox
rmetzger merged pull request #12175: URL: https://github.com/apache/flink/pull/12175 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Closed] (FLINK-17692) "flink-end-to-end-tests/test-scripts/hadoop/yarn.classpath" present after building Flink

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-17692. -- Fix Version/s: 1.11.0 Resolution: Fixed Fixed in

[GitHub] [flink] flinkbot commented on pull request #12210: [FLINK-17792][tests] Catch and log exception if jstack fails

2020-05-18 Thread GitBox
flinkbot commented on pull request #12210: URL: https://github.com/apache/flink/pull/12210#issuecomment-629996745 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

[jira] [Updated] (FLINK-17626) Migrate format properties to new FLIP-122

2020-05-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17626: - Priority: Critical (was: Major) > Migrate format properties to new FLIP-122 >

[GitHub] [flink] GJL commented on a change in pull request #12204: [FLINK-17777][tests] Set HADOOP_CLASSPATH for Mesos TaskManagers

2020-05-18 Thread GitBox
GJL commented on a change in pull request #12204: URL: https://github.com/apache/flink/pull/12204#discussion_r426424405 ## File path: flink-jepsen/src/jepsen/flink/db.clj ## @@ -327,9 +327,14 @@ :delay 4000)] (info "Submitted Flink

[jira] [Updated] (FLINK-17763) No log files when starting scala-shell

2020-05-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17763: - Affects Version/s: (was: 1.11.0) 1.9.2

[jira] [Updated] (FLINK-17763) No log files when starting scala-shell

2020-05-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17763: - Fix Version/s: 1.9.4 1.10.2 1.11.0 > No log files

[GitHub] [flink] flinkbot commented on pull request #12213: Revert "[FLINK-13827][script] shell variable should be escaped"

2020-05-18 Thread GitBox
flinkbot commented on pull request #12213: URL: https://github.com/apache/flink/pull/12213#issuecomment-630006554 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

[jira] [Updated] (FLINK-17071) Kubernetes session CLI logging output is either misleading or concerning

2020-05-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17071: - Parent: FLINK-15856 Issue Type: Sub-task (was: Bug) > Kubernetes session CLI

[GitHub] [flink] zentol merged pull request #11839: [FLINK-17166][dist] Modify the log4j-console.properties to also output logs into the files for WebUI

2020-05-18 Thread GitBox
zentol merged pull request #11839: URL: https://github.com/apache/flink/pull/11839 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

[jira] [Updated] (FLINK-17520) Extend CompositeTypeSerializerSnapshot to allow composite serializers to signal migration based on outer configuration

2020-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17520: --- Labels: pull-request-available (was: ) > Extend CompositeTypeSerializerSnapshot to allow

[jira] [Closed] (FLINK-17166) Modify the log4j-console.properties to also output logs into the files for WebUI

2020-05-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-17166. Resolution: Fixed master: a06bb9ee38c18211d8832ff21952c19d59ee9a61 > Modify the

[jira] [Commented] (FLINK-17787) BucketStateSerializerTest fails on output mismatch

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109918#comment-17109918 ] Robert Metzger commented on FLINK-17787:

[jira] [Updated] (FLINK-17787) BucketStateSerializerTest fails on output mismatch

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17787: --- Priority: Blocker (was: Major) > BucketStateSerializerTest fails on output mismatch >

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109920#comment-17109920 ] Robert Metzger commented on FLINK-17768:

[GitHub] [flink] pnowojski commented on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

2020-05-18 Thread GitBox
pnowojski commented on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-629969390 There is a test failure: ``` SubtaskCheckpointCoordinatorTest.testNotifyCheckpointAbortedDuringAsyncPhase:195 » IllegalArgument ```

[GitHub] [flink] leonardBang commented on pull request #12176: [FLINK-17029][jdbc]Introduce a new JDBC connector with new property keys

2020-05-18 Thread GitBox
leonardBang commented on pull request #12176: URL: https://github.com/apache/flink/pull/12176#issuecomment-629969292 Thanks for the awesome review!@wuchong This is an automated message from the Apache Git Service. To respond

[jira] [Created] (FLINK-17791) Combine collecting sink and iterator to support collecting query results under all execution and network environments

2020-05-18 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-17791: --- Summary: Combine collecting sink and iterator to support collecting query results under all execution and network environments Key: FLINK-17791 URL:

[GitHub] [flink] leonardBang commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

2020-05-18 Thread GitBox
leonardBang commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426404152 ## File path:

[jira] [Comment Edited] (FLINK-17789) DelegatingConfiguration should remove prefix instead of add prefix in toMap

2020-05-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109957#comment-17109957 ] Chesnay Schepler edited comment on FLINK-17789 at 5/18/20, 7:09 AM:

[jira] [Created] (FLINK-17792) Failing to invoking jstack on TM processes should not fail Jepsen Tests

2020-05-18 Thread Gary Yao (Jira)
Gary Yao created FLINK-17792: Summary: Failing to invoking jstack on TM processes should not fail Jepsen Tests Key: FLINK-17792 URL: https://issues.apache.org/jira/browse/FLINK-17792 Project: Flink

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

2020-05-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109971#comment-17109971 ] Chesnay Schepler commented on FLINK-16478: -- Creating as custom DSL per logging backend sounds

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-05-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109971#comment-17109971 ] Chesnay Schepler edited comment on FLINK-16478 at 5/18/20, 7:22 AM:

[jira] [Updated] (FLINK-17626) Migrate format properties to new FLIP-122

2020-05-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17626: - Parent: (was: FLINK-14256) Issue Type: Bug (was: Sub-task) > Migrate format

[jira] [Commented] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container

2020-05-18 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109973#comment-17109973 ] Andrey Zagrebin commented on FLINK-17077: - When you say copying flink-conf.yaml to another path,

[jira] [Updated] (FLINK-17626) Fs connector should use FLIP-122 format options style

2020-05-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17626: - Summary: Fs connector should use FLIP-122 format options style (was: Migrate format properties

[GitHub] [flink] flinkbot commented on pull request #12211: [FLINK-17790][kafka] Fix JDK 11 compile error

2020-05-18 Thread GitBox
flinkbot commented on pull request #12211: URL: https://github.com/apache/flink/pull/12211#issuecomment-63482 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] zentol opened a new pull request #12213: Revert "[FLINK-13827][script] shell variable should be escaped"

2020-05-18 Thread GitBox
zentol opened a new pull request #12213: URL: https://github.com/apache/flink/pull/12213 This reverts commit 865cc4c7a39f7aa610a02cc4a0f41424edcd6279. The addition of quotes means that the log settings are passed as a single argument, rendering it ineffective.

[GitHub] [flink] wxplovecc commented on pull request #12035: [FLINK-17569][FileSystemsems]support ViewFileSystem when wait lease revoke of hadoop filesystem

2020-05-18 Thread GitBox
wxplovecc commented on pull request #12035: URL: https://github.com/apache/flink/pull/12035#issuecomment-630006157 @StephanEwen Ok, I will try to add a test This is an automated message from the Apache Git Service. To

[GitHub] [flink] godfreyhe commented on a change in pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

2020-05-18 Thread GitBox
godfreyhe commented on a change in pull request #12188: URL: https://github.com/apache/flink/pull/12188#discussion_r426428163 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -34,24 +61,130 @@ private

[jira] [Assigned] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

2020-05-18 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17768: Assignee: Zhijiang (was: Piotr Nowojski) >

[GitHub] [flink] flinkbot commented on pull request #12209: [FLINK-17520] [core] Extend CompositeTypeSerializerSnapshot to support migration

2020-05-18 Thread GitBox
flinkbot commented on pull request #12209: URL: https://github.com/apache/flink/pull/12209#issuecomment-629966084 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

[jira] [Commented] (FLINK-9992) FsStorageLocationReferenceTest#testEncodeAndDecode failed in Travis CI

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109923#comment-17109923 ] Robert Metzger commented on FLINK-9992: --- CI

[jira] [Reopened] (FLINK-9992) FsStorageLocationReferenceTest#testEncodeAndDecode failed in Travis CI

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-9992: --- > FsStorageLocationReferenceTest#testEncodeAndDecode failed in Travis CI >

[jira] [Created] (FLINK-17788) scala shell in yarn mode is broken

2020-05-18 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-17788: -- Summary: scala shell in yarn mode is broken Key: FLINK-17788 URL: https://issues.apache.org/jira/browse/FLINK-17788 Project: Flink Issue Type: Bug

[GitHub] [flink] AHeise commented on pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

2020-05-18 Thread GitBox
AHeise commented on pull request #12186: URL: https://github.com/apache/flink/pull/12186#issuecomment-629970819 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Assigned] (FLINK-17787) BucketStateSerializerTest fails on output mismatch

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-17787: -- Assignee: Aljoscha Krettek > BucketStateSerializerTest fails on output mismatch >

[jira] [Resolved] (FLINK-17787) BucketStateSerializerTest fails on output mismatch

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-17787. Resolution: Fixed Yep:

[jira] [Created] (FLINK-17789) DelegatingConfiguration should remove prefix instead of add prefix in toMap

2020-05-18 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17789: Summary: DelegatingConfiguration should remove prefix instead of add prefix in toMap Key: FLINK-17789 URL: https://issues.apache.org/jira/browse/FLINK-17789 Project:

[jira] [Updated] (FLINK-16383) KafkaProducerExactlyOnceITCase.testExactlyOnceRegularSink fails with "The producer has already been closed"

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-16383: --- Summary: KafkaProducerExactlyOnceITCase.testExactlyOnceRegularSink fails with "The producer

[GitHub] [flink] wanglijie95 commented on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

2020-05-18 Thread GitBox
wanglijie95 commented on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-629992918 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

2020-05-18 Thread Timo Walther (Jira)
Timo Walther created FLINK-17793: Summary: Replace TableSchema with dedicated CatalogSchema Key: FLINK-17793 URL: https://issues.apache.org/jira/browse/FLINK-17793 Project: Flink Issue Type:

[GitHub] [flink] godfreyhe commented on a change in pull request #12202: [FLINK-17791][table][streaming] Support collecting query results under all execution and network environments

2020-05-18 Thread GitBox
godfreyhe commented on a change in pull request #12202: URL: https://github.com/apache/flink/pull/12202#discussion_r426364305 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java ## @@ -219,6 +219,22 @@

  1   2   3   4   5   6   7   8   9   >