[jira] [Commented] (FLINK-19004) Fail to call Hive percentile function together with distinct aggregate call

2020-08-20 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181194#comment-17181194 ] Rui Li commented on FLINK-19004: It seems the {{MIN}} is introduced during

[jira] [Commented] (FLINK-18850) Add late records dropped metric for row time over windows

2020-08-20 Thread ZhuShang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181190#comment-17181190 ] ZhuShang commented on FLINK-18850: -- sorry,i get it. > Add late records dropped metric for row time

[GitHub] [flink] danny0405 commented on a change in pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

2020-08-20 Thread GitBox
danny0405 commented on a change in pull request #13050: URL: https://github.com/apache/flink/pull/13050#discussion_r473975682 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/Expander.java ## @@ -0,0 +1,126 @@ +/* + *

[GitHub] [flink] xccui commented on a change in pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

2020-08-20 Thread GitBox
xccui commented on a change in pull request #13089: URL: https://github.com/apache/flink/pull/13089#discussion_r473944845 ## File path: docs/try-flink/local_installation.zh.md ## @@ -26,36 +26,35 @@ under the License. {% if site.version contains "SNAPSHOT" %} - NOTE:

[GitHub] [flink] flinkbot edited a comment on pull request #13208: [FLINK-18676] [FileSystem] Bump s3 aws version

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13208: URL: https://github.com/apache/flink/pull/13208#issuecomment-677651717 ## CI report: * 3c1d30e68c960e1009b93d51582053ccf67ceb37 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 72e7dcb66f3a2c6eda4899d51ddd6420d2d5822b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13207: [FLINK-18952][python][docs] Add 10 minutes to DataStream API documentation

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13207: URL: https://github.com/apache/flink/pull/13207#issuecomment-677643498 ## CI report: * 371eaa2083054d66ef256a9a0ef7a90e116fee0d Azure:

[GitHub] [flink] flinkbot commented on pull request #13208: [FLINK-18676] [FileSystem] Bump s3 aws version

2020-08-20 Thread GitBox
flinkbot commented on pull request #13208: URL: https://github.com/apache/flink/pull/13208#issuecomment-677651717 ## CI report: * 3c1d30e68c960e1009b93d51582053ccf67ceb37 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-18850) Add late records dropped metric for row time over windows

2020-08-20 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181158#comment-17181158 ] Benchao Li commented on FLINK-18850: [~ZhuShang] Seems that you misunderstand this issue. What I

[jira] [Created] (FLINK-19006) project transformation does not support conversion to Tuple25 type

2020-08-20 Thread ming li (Jira)
ming li created FLINK-19006: --- Summary: project transformation does not support conversion to Tuple25 type Key: FLINK-19006 URL: https://issues.apache.org/jira/browse/FLINK-19006 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #13207: [FLINK-18952][python][docs] Add 10 minutes to DataStream API documentation

2020-08-20 Thread GitBox
flinkbot commented on pull request #13207: URL: https://github.com/apache/flink/pull/13207#issuecomment-677643498 ## CI report: * 371eaa2083054d66ef256a9a0ef7a90e116fee0d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13205: [FLINK-17330[runtime] Merge cyclic dependent pipelined regions into one region

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13205: URL: https://github.com/apache/flink/pull/13205#issuecomment-677463515 ## CI report: * e11ffec55b9151857069d64c806b47cc98d9679d Azure:

[GitHub] [flink] flinkbot commented on pull request #13208: [FLINK-18676] [FileSystem] Bump s3 aws version

2020-08-20 Thread GitBox
flinkbot commented on pull request #13208: URL: https://github.com/apache/flink/pull/13208#issuecomment-677643552 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-18676) Update version of aws to support use of default constructor of "WebIdentityTokenCredentialsProvider"

2020-08-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18676: --- Labels: pull-request-available (was: ) > Update version of aws to support use of default

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

2020-08-20 Thread liufangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181156#comment-17181156 ] liufangliang commented on FLINK-18938: -- [~jark] I understand what you mean. when we are quering a

[GitHub] [flink] batas opened a new pull request #13208: [FLINK-18676] [FileSystem] Bump s3 aws version

2020-08-20 Thread GitBox
batas opened a new pull request #13208: URL: https://github.com/apache/flink/pull/13208 ## What is the purpose of the change This pull request bumps AWS SDK version to minimal version supported WebIdentityTokenCredentialsProvider in s3-fs-package, which is described in an issue.

[GitHub] [flink-web] Myasuka commented on a change in pull request #366: Add Apache Flink release 1.10.2

2020-08-20 Thread GitBox
Myasuka commented on a change in pull request #366: URL: https://github.com/apache/flink-web/pull/366#discussion_r473940917 ## File path: _posts/2020-08-11-release-1.10.2.md ## @@ -0,0 +1,199 @@ +--- +layout: post +title: "Apache Flink 1.10.2 Released" +date: 2020-08-11

[jira] [Updated] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization

2020-08-20 Thread Mohammad Hossein Gerami (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohammad Hossein Gerami updated FLINK-18800: Priority: Critical (was: Major) > Avro serialization schema doesn't

[jira] [Commented] (FLINK-18850) Add late records dropped metric for row time over windows

2020-08-20 Thread ZhuShang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181153#comment-17181153 ] ZhuShang commented on FLINK-18850: -- hi [~libenchao], can i take this,if no one else working on this

[jira] [Updated] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization

2020-08-20 Thread Mohammad Hossein Gerami (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohammad Hossein Gerami updated FLINK-18800: Issue Type: Task (was: Improvement) > Avro serialization schema doesn't

[jira] [Updated] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization

2020-08-20 Thread Mohammad Hossein Gerami (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohammad Hossein Gerami updated FLINK-18800: Description: {color:#ff8b00}AvroSerializationSchema{color} and 

[jira] [Updated] (FLINK-18960) flink sideoutput union

2020-08-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18960: Fix Version/s: (was: 1.10.2) > flink sideoutput union > -- > >

[GitHub] [flink] curcur commented on a change in pull request #13175: [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

2020-08-20 Thread GitBox
curcur commented on a change in pull request #13175: URL: https://github.com/apache/flink/pull/13175#discussion_r473935762 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java ## @@ -320,6 +320,12 @@ void

[GitHub] [flink] curcur commented on a change in pull request #13175: [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

2020-08-20 Thread GitBox
curcur commented on a change in pull request #13175: URL: https://github.com/apache/flink/pull/13175#discussion_r473929844 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java ## @@ -320,6 +320,12 @@ void

[jira] [Updated] (FLINK-18850) Add late records dropped metric for row time over windows

2020-08-20 Thread ZhuShang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuShang updated FLINK-18850: - Attachment: (was: image-2020-08-20-20-25-03-981.png) > Add late records dropped metric for row time

[GitHub] [flink] curcur commented on a change in pull request #13175: [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

2020-08-20 Thread GitBox
curcur commented on a change in pull request #13175: URL: https://github.com/apache/flink/pull/13175#discussion_r473929844 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java ## @@ -320,6 +320,12 @@ void

[GitHub] [flink] flinkbot commented on pull request #13207: [FLINK-18952][python][docs] Add 10 minutes to DataStream API documentation

2020-08-20 Thread GitBox
flinkbot commented on pull request #13207: URL: https://github.com/apache/flink/pull/13207#issuecomment-677633881 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] [Issue Comment Deleted] (FLINK-18850) Add late records dropped metric for row time over windows

2020-08-20 Thread ZhuShang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuShang updated FLINK-18850: - Comment: was deleted (was: hi,[~libenchao]  i found the accumulator in WindowOperator {code:java}

[jira] [Commented] (FLINK-18850) Add late records dropped metric for row time over windows

2020-08-20 Thread ZhuShang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181149#comment-17181149 ] ZhuShang commented on FLINK-18850: -- hi,[~libenchao]  i found the accumulator in WindowOperator

[jira] [Updated] (FLINK-18850) Add late records dropped metric for row time over windows

2020-08-20 Thread ZhuShang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuShang updated FLINK-18850: - Attachment: image-2020-08-20-20-25-03-981.png > Add late records dropped metric for row time over

[jira] [Created] (FLINK-19005) used metaspace grow on every execution

2020-08-20 Thread Jira
Guillermo Sánchez created FLINK-19005: - Summary: used metaspace grow on every execution Key: FLINK-19005 URL: https://issues.apache.org/jira/browse/FLINK-19005 Project: Flink Issue Type:

[GitHub] [flink] curcur commented on a change in pull request #13175: [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

2020-08-20 Thread GitBox
curcur commented on a change in pull request #13175: URL: https://github.com/apache/flink/pull/13175#discussion_r473929844 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java ## @@ -320,6 +320,12 @@ void

[jira] [Updated] (FLINK-18952) Add 10 minutes to DataStream API documentation

2020-08-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18952: --- Labels: pull-request-available (was: ) > Add 10 minutes to DataStream API documentation >

[GitHub] [flink] hequn8128 opened a new pull request #13207: [FLINK-18952][python][docs] Add 10 minutes to DataStream API documentation

2020-08-20 Thread GitBox
hequn8128 opened a new pull request #13207: URL: https://github.com/apache/flink/pull/13207 ## What is the purpose of the change This pull request adds "10 minutes to DataStream API" documentation. This page a short introduction to Python DataStream, geared mainly for new users.

[jira] [Comment Edited] (FLINK-18938) Throw better exception message for quering sink-only connector

2020-08-20 Thread liufangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181135#comment-17181135 ] liufangliang edited comment on FLINK-18938 at 8/20/20, 12:22 PM: - Hi

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

2020-08-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181145#comment-17181145 ] Jark Wu commented on FLINK-18938: - The exception is exactly the same if we don't have a dependency jar

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 94e8eb39032665f77e897cb572cd4320b66635f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 94e8eb39032665f77e897cb572cd4320b66635f9 Azure:

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

2020-08-20 Thread liufangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181135#comment-17181135 ] liufangliang commented on FLINK-18938: -- Hi [~jark], Can you assign it to me ?  The following tips

[jira] [Comment Edited] (FLINK-18938) Throw better exception message for quering sink-only connector

2020-08-20 Thread liufangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181135#comment-17181135 ] liufangliang edited comment on FLINK-18938 at 8/20/20, 11:49 AM: - Hi

[jira] [Comment Edited] (FLINK-18938) Throw better exception message for quering sink-only connector

2020-08-20 Thread liufangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181135#comment-17181135 ] liufangliang edited comment on FLINK-18938 at 8/20/20, 11:49 AM: - Hi

[GitHub] [flink] wangzzu removed a comment on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

2020-08-20 Thread GitBox
wangzzu removed a comment on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-677524943 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink-web] zhuzhurk commented on a change in pull request #366: Add Apache Flink release 1.10.2

2020-08-20 Thread GitBox
zhuzhurk commented on a change in pull request #366: URL: https://github.com/apache/flink-web/pull/366#discussion_r473908601 ## File path: _posts/2020-08-11-release-1.10.2.md ## @@ -0,0 +1,199 @@ +--- +layout: post +title: "Apache Flink 1.10.2 Released" +date: 2020-08-11

[GitHub] [flink-web] asfgit closed pull request #370: Add a blog post about the current state of Flink on Docker

2020-08-20 Thread GitBox
asfgit closed pull request #370: URL: https://github.com/apache/flink-web/pull/370 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] lirui-apache commented on a change in pull request #13157: [FLINK-18900][hive] HiveCatalog should error out when listing partitions with an invalid spec

2020-08-20 Thread GitBox
lirui-apache commented on a change in pull request #13157: URL: https://github.com/apache/flink/pull/13157#discussion_r473905054 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java ## @@ -777,8 +777,11 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-666148245 ## CI report: * eb611d5b39f997fa3e986b5d163cb65a44b4b0ba UNKNOWN * a5db01bd0f63289039dfcdae41eaf099ed28a812 Azure:

[jira] [Updated] (FLINK-19004) Fail to call Hive percentile function together with distinct aggregate call

2020-08-20 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-19004: --- Description: The following test case would fail: {code} @Test public void test() throws

[jira] [Created] (FLINK-19004) Fail to call Hive percentile function together with distinct aggregate call

2020-08-20 Thread Rui Li (Jira)
Rui Li created FLINK-19004: -- Summary: Fail to call Hive percentile function together with distinct aggregate call Key: FLINK-19004 URL: https://issues.apache.org/jira/browse/FLINK-19004 Project: Flink

[GitHub] [flink-web] Myasuka commented on a change in pull request #366: Add Apache Flink release 1.10.2

2020-08-20 Thread GitBox
Myasuka commented on a change in pull request #366: URL: https://github.com/apache/flink-web/pull/366#discussion_r473897004 ## File path: _posts/2020-08-11-release-1.10.2.md ## @@ -0,0 +1,199 @@ +--- +layout: post +title: "Apache Flink 1.10.2 Released" +date: 2020-08-11

[GitHub] [flink] flinkbot edited a comment on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-666148245 ## CI report: * eb611d5b39f997fa3e986b5d163cb65a44b4b0ba UNKNOWN * a5db01bd0f63289039dfcdae41eaf099ed28a812 Azure:

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-08-20 Thread ZhuShang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181104#comment-17181104 ] ZhuShang commented on FLINK-18959: -- i also found that archiveExecutionGraph can not be reached when the

[GitHub] [flink] RocMarshal commented on pull request #13172: [FLINK-18854][docs-zh] Translate the 'API Migration Guides' page of 'Application Development' into Chinese

2020-08-20 Thread GitBox
RocMarshal commented on pull request #13172: URL: https://github.com/apache/flink/pull/13172#issuecomment-677536186 Hi, @XBaith @klion26 . Could you help me to review this PR if you have free time? Thank you. This is

[GitHub] [flink] RocMarshal removed a comment on pull request #13172: [FLINK-18854][docs-zh] Translate the 'API Migration Guides' page of 'Application Development' into Chinese

2020-08-20 Thread GitBox
RocMarshal removed a comment on pull request #13172: URL: https://github.com/apache/flink/pull/13172#issuecomment-675233767 Hi, @XBaith @klion26 . Could you help me to review this PR if you have free time? Thank you.

[GitHub] [flink] flinkbot edited a comment on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-666148245 ## CI report: * eb611d5b39f997fa3e986b5d163cb65a44b4b0ba UNKNOWN * a5db01bd0f63289039dfcdae41eaf099ed28a812 Azure:

[GitHub] [flink] wangzzu commented on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

2020-08-20 Thread GitBox
wangzzu commented on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-677524943 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-web] rmetzger commented on a change in pull request #370: Add a blog post about the current state of Flink on Docker

2020-08-20 Thread GitBox
rmetzger commented on a change in pull request #370: URL: https://github.com/apache/flink-web/pull/370#discussion_r473867137 ## File path: _posts/2020-08-20-flink-docker.md ## @@ -0,0 +1,90 @@ +--- +layout: post +title: "The State of Flink on Docker" +date:

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

2020-08-20 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181094#comment-17181094 ] Piotr Nowojski commented on FLINK-12351: Yes that's true. I was more worried about relaying on

[GitHub] [flink-web] rmetzger commented on pull request #370: Add a blog post about the current state of Flink on Docker

2020-08-20 Thread GitBox
rmetzger commented on pull request #370: URL: https://github.com/apache/flink-web/pull/370#issuecomment-677515170 Thanks a lot for your reviews! I pushed a new version. Unless there's any more feedback, I'll merge it later today.

[GitHub] [flink-benchmarks] pnowojski commented on a change in pull request #2: [FLINK-19003][checkpointing] Add micro-benchmark for unaligned checkpoints

2020-08-20 Thread GitBox
pnowojski commented on a change in pull request #2: URL: https://github.com/apache/flink-benchmarks/pull/2#discussion_r473849350 ## File path: src/main/java/org/apache/flink/benchmark/UnalignedCheckpointBenchmark.java ## @@ -0,0 +1,164 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-666148245 ## CI report: * eb611d5b39f997fa3e986b5d163cb65a44b4b0ba UNKNOWN * a5db01bd0f63289039dfcdae41eaf099ed28a812 Azure:

[GitHub] [flink-web] rmetzger commented on a change in pull request #370: Add a blog post about the current state of Flink on Docker

2020-08-20 Thread GitBox
rmetzger commented on a change in pull request #370: URL: https://github.com/apache/flink-web/pull/370#discussion_r473850331 ## File path: _posts/2020-08-20-flink-docker.md ## @@ -0,0 +1,90 @@ +--- +layout: post +title: "The State of Flink on Docker" +date:

[GitHub] [flink-web] rmetzger commented on a change in pull request #370: Add a blog post about the current state of Flink on Docker

2020-08-20 Thread GitBox
rmetzger commented on a change in pull request #370: URL: https://github.com/apache/flink-web/pull/370#discussion_r473849162 ## File path: _posts/2020-08-20-flink-docker.md ## @@ -0,0 +1,90 @@ +--- +layout: post +title: "The State of Flink on Docker" +date:

[GitHub] [flink] flinkbot edited a comment on pull request #13206: [FLINK-18948][python] Add end to end test for Python DataStream API.

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13206: URL: https://github.com/apache/flink/pull/13206#issuecomment-677500353 ## CI report: * bea57ee386d4ffdd264e3cc0116a653454103c42 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13204: [FLINK-16080][docs-zh]Translate \docs\dev\table\hive\hive_streaming.zh.md into Chinese

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13204: URL: https://github.com/apache/flink/pull/13204#issuecomment-677254693 ## CI report: * f3ff67413489210527790afa12a9f50b63ced883 Azure:

[GitHub] [flink-web] rmetzger commented on a change in pull request #370: Add a blog post about the current state of Flink on Docker

2020-08-20 Thread GitBox
rmetzger commented on a change in pull request #370: URL: https://github.com/apache/flink-web/pull/370#discussion_r473846656 ## File path: _posts/2020-08-20-flink-docker.md ## @@ -0,0 +1,90 @@ +--- +layout: post +title: "The State of Flink on Docker" +date:

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

2020-08-20 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181081#comment-17181081 ] Wenlong Lyu commented on FLINK-12351: - [~pnowojski] As I known, it is easy to get whether the op is

[GitHub] [flink] flinkbot commented on pull request #13206: [FLINK-18948][python] Add end to end test for Python DataStream API.

2020-08-20 Thread GitBox
flinkbot commented on pull request #13206: URL: https://github.com/apache/flink/pull/13206#issuecomment-677500353 ## CI report: * bea57ee386d4ffdd264e3cc0116a653454103c42 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] RocMarshal commented on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

2020-08-20 Thread GitBox
RocMarshal commented on pull request #13089: URL: https://github.com/apache/flink/pull/13089#issuecomment-677495556 ping @xccui This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] kl0u commented on pull request #6613: [FLINK-9940] [API/DataStream][File source] out-of-order files were missed in continuous monitoring

2020-08-20 Thread GitBox
kl0u commented on pull request #6613: URL: https://github.com/apache/flink/pull/6613#issuecomment-677494490 Sorry @lvhuyen for closing this, I am reopening it because I just noticed there is discussion on the related JIRA.

[GitHub] [flink] lvhuyen opened a new pull request #6613: [FLINK-9940] [API/DataStream][File source] out-of-order files were missed in continuous monitoring

2020-08-20 Thread GitBox
lvhuyen opened a new pull request #6613: URL: https://github.com/apache/flink/pull/6613 [FLINK-9940] Fix - File-source continuous monitoring mode - out-of-order files were missed ## Fix the issue with ContinuousFileMonitoringFunction - out-of-order files were missed in continuous

[GitHub] [flink] zhuxiaoshang commented on pull request #13162: [FLINK-18685][API / DataStream]JobClient.getAccumulators() blocks until streaming job has finished in local environment

2020-08-20 Thread GitBox
zhuxiaoshang commented on pull request #13162: URL: https://github.com/apache/flink/pull/13162#issuecomment-677492835 @rmetzger Sorry for the failing,what i think is make the getAccumulators() can be async invoked.But the actual behavior is not my expect. When i debug the code,the

[GitHub] [flink] flinkbot commented on pull request #13206: [FLINK-18948][python] Add end to end test for Python DataStream API.

2020-08-20 Thread GitBox
flinkbot commented on pull request #13206: URL: https://github.com/apache/flink/pull/13206#issuecomment-677491849 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] kl0u closed pull request #6613: [FLINK-9940] [API/DataStream][File source] out-of-order files were missed in continuous monitoring

2020-08-20 Thread GitBox
kl0u closed pull request #6613: URL: https://github.com/apache/flink/pull/6613 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

[GitHub] [flink] kl0u commented on pull request #6613: [FLINK-9940] [API/DataStream][File source] out-of-order files were missed in continuous monitoring

2020-08-20 Thread GitBox
kl0u commented on pull request #6613: URL: https://github.com/apache/flink/pull/6613#issuecomment-677491493 I'm closing this as "Abandoned", since there is no more activity. This is an automated message from the Apache

[jira] [Updated] (FLINK-18948) Add end to end test for Python DataStream API

2020-08-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18948: --- Labels: pull-request-available (was: ) > Add end to end test for Python DataStream API >

[GitHub] [flink] shuiqiangchen opened a new pull request #13206: [FLINK-18948][python] Add end to end test for Python DataStream API.

2020-08-20 Thread GitBox
shuiqiangchen opened a new pull request #13206: URL: https://github.com/apache/flink/pull/13206 ## What is the purpose of the change Add end to end test for Python DataStream API. ## Brief change log Added a simple Python DataStream Job, which will consume

[jira] [Closed] (FLINK-18962) Improve error message if checkpoint directory is not writable

2020-08-20 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-18962. -- Fix Version/s: 1.12.0 Resolution: Fixed Merged to master as f8ce30a50b^^..f8ce30a50b.

[GitHub] [flink] pnowojski merged pull request #13180: [FLINK-18962][checkpointing] Improve logging when checkpoint declined

2020-08-20 Thread GitBox
pnowojski merged pull request #13180: URL: https://github.com/apache/flink/pull/13180 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

[GitHub] [flink] pnowojski commented on a change in pull request #13180: [FLINK-18962][checkpointing] Improve logging when checkpoint declined

2020-08-20 Thread GitBox
pnowojski commented on a change in pull request #13180: URL: https://github.com/apache/flink/pull/13180#discussion_r473803693 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java ## @@ -129,12 +129,10 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #13175: [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13175: URL: https://github.com/apache/flink/pull/13175#issuecomment-674839926 ## CI report: * 635f839466122e36674a38a9845c2d6b5eb5c244 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13188: URL: https://github.com/apache/flink/pull/13188#issuecomment-675323573 ## CI report: * 8bbc06f7a8931c9e02130f668805a82ccc00a9e8 Azure:

[GitHub] [flink-web] azagrebin commented on a change in pull request #370: Add a blog post about the current state of Flink on Docker

2020-08-20 Thread GitBox
azagrebin commented on a change in pull request #370: URL: https://github.com/apache/flink-web/pull/370#discussion_r473789842 ## File path: _posts/2020-08-20-flink-docker.md ## @@ -0,0 +1,90 @@ +--- +layout: post +title: "The State of Flink on Docker" +date:

[jira] [Commented] (FLINK-18643) Migrate Jenkins jobs to ci-builds.apache.org

2020-08-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181055#comment-17181055 ] Robert Metzger commented on FLINK-18643: I've disabled the Jenkins profiles for Flink (except

[GitHub] [flink] flinkbot edited a comment on pull request #13205: [FLINK-17330[runtime] Merge cyclic dependent pipelined regions into one region

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13205: URL: https://github.com/apache/flink/pull/13205#issuecomment-677463515 ## CI report: * e11ffec55b9151857069d64c806b47cc98d9679d Azure:

[GitHub] [flink] flinkbot commented on pull request #13205: [FLINK-17330[runtime] Merge cyclic dependent pipelined regions into one region

2020-08-20 Thread GitBox
flinkbot commented on pull request #13205: URL: https://github.com/apache/flink/pull/13205#issuecomment-677463515 ## CI report: * e11ffec55b9151857069d64c806b47cc98d9679d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] AHeise commented on a change in pull request #13175: [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

2020-08-20 Thread GitBox
AHeise commented on a change in pull request #13175: URL: https://github.com/apache/flink/pull/13175#discussion_r473766209 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java ## @@ -320,6 +320,12 @@ void

[GitHub] [flink] flinkbot commented on pull request #13205: [FLINK-17330[runtime] Merge cyclic dependent pipelined regions into one region

2020-08-20 Thread GitBox
flinkbot commented on pull request #13205: URL: https://github.com/apache/flink/pull/13205#issuecomment-677459348 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] zhuzhurk opened a new pull request #13205: [FLINK-17330[runtime] Merge cyclic dependent pipelined regions into one region

2020-08-20 Thread GitBox
zhuzhurk opened a new pull request #13205: URL: https://github.com/apache/flink/pull/13205 ## What is the purpose of the change This PR changes regions building to merge cyclic dependent pipelined regions into one region. This is to avoid scheduling deadlocks due to cyclic

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by cyclic input dependencies between regions

2020-08-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17330: --- Labels: pull-request-available (was: ) > Avoid scheduling deadlocks caused by cyclic input

[jira] [Closed] (FLINK-18960) flink sideoutput union

2020-08-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-18960. Fix Version/s: 1.10.2 Resolution: Duplicate > flink sideoutput union >

[GitHub] [flink] kl0u commented on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

2020-08-20 Thread GitBox
kl0u commented on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-677440255 @wangzzu There is a test failure related to your changes. Please fix it and then I think I can merge :) This is

[GitHub] [flink] flinkbot edited a comment on pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13188: URL: https://github.com/apache/flink/pull/13188#issuecomment-675323573 ## CI report: * 8301e1e53770c95e2f903526ac93e80e039cf4f2 Azure:

[jira] [Commented] (FLINK-18960) flink sideoutput union

2020-08-20 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181004#comment-17181004 ] Yun Gao commented on FLINK-18960: - hi [~xiaohang.li], I checked the issue, it does existed in old

[jira] [Commented] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization

2020-08-20 Thread Mohammad Hossein Gerami (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181003#comment-17181003 ] Mohammad Hossein Gerami commented on FLINK-18800: - anybody doesn't have any idea? >

[jira] [Updated] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization

2020-08-20 Thread Mohammad Hossein Gerami (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohammad Hossein Gerami updated FLINK-18800: Description: {color:#ff8b00}AvroSerializationSchema{color} and 

[GitHub] [flink] tillrohrmann commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

2020-08-20 Thread GitBox
tillrohrmann commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r473711834 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -88,6 +88,7 @@ public Configuration

[GitHub] [flink] tillrohrmann commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

2020-08-20 Thread GitBox
tillrohrmann commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r473709875 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterClientFactory.java ## @@ -51,10 +51,7 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

2020-08-20 Thread GitBox
flinkbot edited a comment on pull request #13188: URL: https://github.com/apache/flink/pull/13188#issuecomment-675323573 ## CI report: * 8301e1e53770c95e2f903526ac93e80e039cf4f2 Azure:

[jira] [Commented] (FLINK-18643) Migrate Jenkins jobs to ci-builds.apache.org

2020-08-20 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180998#comment-17180998 ] Chesnay Schepler commented on FLINK-18643: -- hmm...I guess it's okay to only cover 1.11+ with

[GitHub] [flink] rkhachatryan commented on a change in pull request #13180: [FLINK-18962][checkpointing] Improve logging when checkpoint declined

2020-08-20 Thread GitBox
rkhachatryan commented on a change in pull request #13180: URL: https://github.com/apache/flink/pull/13180#discussion_r473689643 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java ## @@ -129,12 +129,10 @@

<    1   2   3   >