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

[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 loggingFallback(FallbackK

[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 loggingFallback(FallbackK

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

[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&focusedCommentId=17109953#comment-17109953 ] Yang Wang commented on FLINK-17527: --- [~trohrmann] If you agree, i will rename {{log4j-

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

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

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

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

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

[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&focusedCommentId=17109957#comment-17109957 ] Chesnay Schepler commented on FLINK-17789: -- I disagree. The current behavior is

[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&focusedCommentId=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

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

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

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

[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 https://github.com/apache/flink/commi

[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, ple

[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] 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 jstack.

[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&focusedCommentId=17109970#comment-17109970 ] Jingsong Lee commented on FLINK-17789: -- Hi [~chesnay], thanks for quick response.

[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&focusedCommentId=17109971#comment-17109971 ] Chesnay Schepler edited comment on FLINK-16478 at 5/18/20, 7:22 AM: --

[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&focusedCommentId=17109971#comment-17109971 ] Chesnay Schepler commented on FLINK-16478: -- Creating as custom DSL per logging

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563 ## CI report: * f11005c6596ecf41efd898ba324374948b2eb8cb Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

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

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

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

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

[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&focusedCommentId=17109973#comment-17109973 ] Andrey Zagrebin commented on FLINK-17077: - When you say copying flink-conf.yaml

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

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

[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-17626) Fs connector should use FLIP-122 format options style

2020-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17626: --- Labels: pull-request-available (was: ) > Fs connector should use FLIP-122 format options st

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

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

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

[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&focusedCommentId=17109980#comment-17109980 ] Robert Metzger commented on FLINK-17730: In FLINK-17336, we introduced a timeout

[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_r426426306 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliClientTest.java ## @@ -90,9 +92,9 @@ public void testFail

[jira] [Updated] (FLINK-17167) Extend entry point script and docs with history server mode

2020-05-18 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-17167: Parent: (was: FLINK-17160) Issue Type: Improvement (was: Sub-task) > Extend e

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

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

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

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

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

[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) > UnalignedCheckpointITCase.shouldPerformUnalignedCheck

[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&focusedCommentId=1711#comment-1711 ] Chesnay Schepler commented on FLINK-17789: -- I'd argue that the behavior of {{De

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

2020-05-18 Thread GitBox
rmetzger commented on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-630013296 Note: changes merged through this PR broke master: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=1686&view=results ---

[GitHub] [flink] wuchong commented on pull request #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

2020-05-18 Thread GitBox
wuchong commented on pull request #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-630014046 Passed: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=1680&view=results Merging...

[GitHub] [flink] wuchong merged pull request #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

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

[GitHub] [flink] flinkbot edited a comment on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-542518065 ## CI report: * 40f0f8f733b268c3ddcf2864313b3ec67fe3757c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?

[jira] [Closed] (FLINK-17703) Default execution command fails due 'benchmark' profile being inactive

2020-05-18 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17703. --- Resolution: Fixed Fixed in [https://github.com/dataArtisans/flink-benchmarks] (master) via 8de66eda

[jira] [Commented] (FLINK-16160) Schema#proctime and Schema#rowtime don't work in TableEnvironment#connect code path

2020-05-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110012#comment-17110012 ] Jark Wu commented on FLINK-16160: - Fixed in - master (1.11.0): 0d9c46ea97e337acfcef932

[GitHub] [flink] flinkbot edited a comment on pull request #12103: [FLINK-16998][core] Add a changeflag to Row

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12103: URL: https://github.com/apache/flink/pull/12103#issuecomment-627456433 ## CI report: * 05ab513e7a7aed7481001668eecddf26b8fd05cb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2020-05-18 Thread Eui Heo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110019#comment-17110019 ] Eui Heo commented on FLINK-17077: - In either case, flink-conf.yaml is mounted only with

[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&focusedCommentId=17110018#comment-17110018 ] Jingsong Lee commented on FLINK-17789: -- If there is an option = ConfigOptions.key("

[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-630018919 ## CI report: * 439f4f136e73eebb6c424f7f706ab91655516ed3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] tillrohrmann closed pull request #11987: [hotfix] Show hostname in failure error message

2020-05-18 Thread GitBox
tillrohrmann closed pull request #11987: URL: https://github.com/apache/flink/pull/11987 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 g

[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-630018809 ## CI report: * 35a0b961d4d1a1dbb7485ff847c7b5e2a5068c80 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

[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-630019128 ## CI report: * 74c9e440c684f255faa2075c12e4438590631dae UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[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-630019032 ## CI report: * 0ec02542ed4721376e60ea71090cbb335885e6b0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Closed] (FLINK-17348) Expose metric group to ascendingTimestampExtractor

2020-05-18 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17348. Fix Version/s: 1.11.0 Resolution: Fixed This was added in the new interfaces of FLI

[jira] [Assigned] (FLINK-17348) Expose metric group to ascendingTimestampExtractor

2020-05-18 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17348: Assignee: Aljoscha Krettek > Expose metric group to ascendingTimestampExtractor >

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

2020-05-18 Thread GitBox
rmetzger commented on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-630021791 Change has been reverted https://github.com/apache/flink/commit/bf58725e7ad80f276a458007a2d5b890d8ffc4f5 This

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

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-15670: I reverted the change in https://github.com/apache/flink/commit/bf58725e7ad80f276a458007a2d5b

[GitHub] [flink] aljoscha commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

2020-05-18 Thread GitBox
aljoscha commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-630022206 No hard feeling, I hope! 😃 I managed to make my version of the test also work, by allowing relative paths for the local filesystem: https://github.com/aljoscha/flink/com

[GitHub] [flink-docker] wangxiyuan opened a new pull request #23: [FLINK-14241][test]Add arm64 support for docker e2e test

2020-05-18 Thread GitBox
wangxiyuan opened a new pull request #23: URL: https://github.com/apache/flink-docker/pull/23 The docker image `openjdk:8-jre` only works for amd64. When running test on arm64, use `arm64v8/openjdk:8-jre` instead. Thi

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

2020-05-18 Thread GitBox
curcur commented on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-630025655 It is because of commit of unifying the watermark Strategy committed last night... This is an automated message

[GitHub] [flink] wangyang0918 opened a new pull request #12214: [FLINK-17618][flink-dist] Update the outdated comments in log4j2 configuration files

2020-05-18 Thread GitBox
wangyang0918 opened a new pull request #12214: URL: https://github.com/apache/flink/pull/12214 When we upgrade the log4j to log4j2, there are some residual log4j logger configuration in the comments. Just like following, log4j.properties and log4j-console.properties ```

[jira] [Updated] (FLINK-17618) Update the outdated comments in the log4j properties files

2020-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17618: --- Labels: pull-request-available (was: ) > Update the outdated comments in the log4j properti

[GitHub] [flink] guoweiM commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

2020-05-18 Thread GitBox
guoweiM commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-630028998 NP This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] wangyang0918 commented on pull request #12214: [FLINK-17618][flink-dist] Update the outdated comments in log4j2 configuration files

2020-05-18 Thread GitBox
wangyang0918 commented on pull request #12214: URL: https://github.com/apache/flink/pull/12214#issuecomment-630029338 cc @zentol Could you have a look? When i update the `flink-console.sh`, i find this issue. This is an auto

[GitHub] [flink] flinkbot edited a comment on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-542518065 ## CI report: * 40f0f8f733b268c3ddcf2864313b3ec67fe3757c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?

[GitHub] [flink] flinkbot commented on pull request #12214: [FLINK-17618][flink-dist] Update the outdated comments in log4j2 configuration files

2020-05-18 Thread GitBox
flinkbot commented on pull request #12214: URL: https://github.com/apache/flink/pull/12214#issuecomment-630030778 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-17565) Bump fabric8 version from 4.5.2 to 4.9.1

2020-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17565: --- Labels: pull-request-available (was: ) > Bump fabric8 version from 4.5.2 to 4.9.1 > ---

[GitHub] [flink] zhengcanbin opened a new pull request #12215: [FLINK-17565][k8s] Bump fabric8 version from 4.5.2 to 4.9.1

2020-05-18 Thread GitBox
zhengcanbin opened a new pull request #12215: URL: https://github.com/apache/flink/pull/12215 ## What is the purpose of the change Bump fabric8 kubernetes-client from 4.5.2 to 4.7.1. It fixes the issue of [FLINK-17566](https://issues.apache.org/jira/browse/FLINK-17566).

[GitHub] [flink] flinkbot edited a comment on pull request #12103: [FLINK-16998][core] Add a changeflag to Row

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12103: URL: https://github.com/apache/flink/pull/12103#issuecomment-627456433 ## CI report: * 05ab513e7a7aed7481001668eecddf26b8fd05cb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[GitHub] [flink] flinkbot edited a comment on pull request #12197: [FLINK-17357][table-planner-blink] add 'DROP catalog' DDL to blink pl…

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12197: URL: https://github.com/apache/flink/pull/12197#issuecomment-629768433 ## CI report: * 15cb31fea013766318c482cd266aa294b9df225b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12139: [FLINK-16076] Translate "Queryable State" page into Chinese

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12139: URL: https://github.com/apache/flink/pull/12139#issuecomment-628360660 ## CI report: * b02e502fa3bb3ae57d4678d23868cad20d51caca Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12210: URL: https://github.com/apache/flink/pull/12210#issuecomment-630018809 ## CI report: * 35a0b961d4d1a1dbb7485ff847c7b5e2a5068c80 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12204: [FLINK-17777][tests] Set HADOOP_CLASSPATH for Mesos TaskManagers

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12204: URL: https://github.com/apache/flink/pull/12204#issuecomment-629847515 ## CI report: * 097ac2b06f10900c435115c24e699c5328ee3227 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12211: URL: https://github.com/apache/flink/pull/12211#issuecomment-630018919 ## CI report: * 439f4f136e73eebb6c424f7f706ab91655516ed3 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12212: URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032 ## CI report: * 0ec02542ed4721376e60ea71090cbb335885e6b0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12213: URL: https://github.com/apache/flink/pull/12213#issuecomment-630019128 ## CI report: * 74c9e440c684f255faa2075c12e4438590631dae Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Issue Comment Deleted] (FLINK-17384) support read hbase conf dir from flink.conf just like hadoop_conf

2020-05-18 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-17384: - Comment: was deleted (was: Hi [~liyu],  I have committed my code, but the log is below, which is not re

[GitHub] [flink] aljoscha commented on a change in pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

2020-05-18 Thread GitBox
aljoscha commented on a change in pull request #12132: URL: https://github.com/apache/flink/pull/12132#discussion_r426448856 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/filesystem/TestUtils.java ## @@ -414,4 +419,50 @@ public

  1   2   3   4   5   6   7   8   9   >