[GitHub] [flink] flinkbot edited a comment on pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * e81abd70d44d6ce7221d4cd2f44d31deab78ea9a UNKNOWN * 6956309e3928df5f4e7717a978bd91eee472f6ed Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-20789) Add a metric named `deserializeFailedCount` for formats which has option `ignore-parse-errors`

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20789: --- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Add a metric named `deserializeFaile

[jira] [Updated] (FLINK-20789) Add a metric named `deserializeFailedCount` for formats which has option `ignore-parse-errors`

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20789: --- Summary: Add a metric named `deserializeFailedCount` for formats which has option `ignore-parse-erro

[jira] [Comment Edited] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

2020-12-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255853#comment-17255853 ] Qingsheng Ren edited comment on FLINK-20777 at 12/29/20, 7:41 AM:

[jira] [Commented] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

2020-12-28 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255853#comment-17255853 ] Qingsheng Ren commented on FLINK-20777: --- Hi [~873925...@qq.com], Thanks for your r

[GitHub] [flink] flinkbot edited a comment on pull request #14514: [FLINK-20793][core][tests] Fix the NamesTest due to code style refactor

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14514: URL: https://github.com/apache/flink/pull/14514#issuecomment-751931069 ## CI report: * 0a7cf741cfb092143e2dafcb8587b2294efc5dda UNKNOWN * a4538c71a6fdd097ad68b374b781b67daad49f83 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * 9a3e9ba496cc4dade2d716a4821be4df40444863 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * 9a3e9ba496cc4dade2d716a4821be4df40444863 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Comment Edited] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

2020-12-28 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255847#comment-17255847 ] jiawen xiao edited comment on FLINK-20777 at 12/29/20, 7:12 AM: --

[jira] [Commented] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

2020-12-28 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255847#comment-17255847 ] jiawen xiao commented on FLINK-20777: - sorry [~renqs],i think this is not a problem.

[GitHub] [flink] wuchong commented on a change in pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

2020-12-28 Thread GitBox
wuchong commented on a change in pull request #14464: URL: https://github.com/apache/flink/pull/14464#discussion_r549592196 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaChangelogTableITCase.java ## @@

[jira] [Created] (FLINK-20798) Service temporarily unavailable due to an ongoing leader election. Please refresh.

2020-12-28 Thread hayden zhou (Jira)
hayden zhou created FLINK-20798: --- Summary: Service temporarily unavailable due to an ongoing leader election. Please refresh. Key: FLINK-20798 URL: https://issues.apache.org/jira/browse/FLINK-20798 Proj

[GitHub] [flink] V1ncentzzZ edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-28 Thread GitBox
V1ncentzzZ edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751745476 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] flinkbot edited a comment on pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397 ## CI report: * cd05d23ea1ac2a9283e03039a3791b1cc2df1a95 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * e81abd70d44d6ce7221d4cd2f44d31deab78ea9a UNKNOWN * 6956309e3928df5f4e7717a978bd91eee472f6ed Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397 ## CI report: * cd05d23ea1ac2a9283e03039a3791b1cc2df1a95 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] SteNicholas commented on pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

2020-12-28 Thread GitBox
SteNicholas commented on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-751963694 @wuchong I have kept code spotless with Maven for conflicts resolution and modified the document. Please help to review again. -

[jira] [Updated] (FLINK-20789) Add a metric named `deserializeFaildCount` for formats which has option `ignore-parse-errors`

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20789: --- Summary: Add a metric named `deserializeFaildCount` for formats which has option `ignore-parse-error

[jira] [Commented] (FLINK-20789) Add a metric named `deserializeFaildCount` for kafka connectors

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255827#comment-17255827 ] xiaozilong commented on FLINK-20789: [~jark] Sorry, I updated the title. > Add a me

[GitHub] [flink] flinkbot edited a comment on pull request #14451: [FLINK-20704][table-planner] Some rel data type does not implement th…

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14451: URL: https://github.com/apache/flink/pull/14451#issuecomment-749321360 ## CI report: * d9c3ee87fa55ee7a1f7d4848c8a7dc542f2011a6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20789) Add a metric named `deserializeFaildCount` for formats

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20789: --- Summary: Add a metric named `deserializeFaildCount` for formats (was: Add a metric named `deseriali

[jira] [Updated] (FLINK-20789) Add a metric named `deserializeFaildCount` for formats which has option ``

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20789: --- Summary: Add a metric named `deserializeFaildCount` for formats which has option `` (was: Add a met

[GitHub] [flink] flinkbot edited a comment on pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324 ## CI report: * d083b630115604e34b0a74498890aedbff61b2a7 UNKNOWN * d58927642909f50571ed6242605aac564e074f89 Azure: [SUCCESS](https://dev.azure.com/apache-flin

[jira] [Commented] (FLINK-20789) Add a metric named `deserializeFaildCount` for kafka connectors

2020-12-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255820#comment-17255820 ] Jark Wu commented on FLINK-20789: - IIUC, this should belong to specific format module an

[GitHub] [flink] wuchong commented on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-28 Thread GitBox
wuchong commented on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751954940 cc @fsk119 This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [flink] flinkbot edited a comment on pull request #14514: [FLINK-20793][core][tests] Fix the NamesTest due to code style refactor

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14514: URL: https://github.com/apache/flink/pull/14514#issuecomment-751931069 ## CI report: * 0a7cf741cfb092143e2dafcb8587b2294efc5dda UNKNOWN * a4538c71a6fdd097ad68b374b781b67daad49f83 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * 9a3e9ba496cc4dade2d716a4821be4df40444863 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14514: [FLINK-20793][core][tests] Fix the NamesTest due to code style refactor

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14514: URL: https://github.com/apache/flink/pull/14514#issuecomment-751931069 ## CI report: * 0a7cf741cfb092143e2dafcb8587b2294efc5dda UNKNOWN * a4538c71a6fdd097ad68b374b781b67daad49f83 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-751906693 ## CI report: * 86f6502cf9980ff8d7fd15fe058588eb9f5004cf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14503: [FLINK-20693][table-planner-blink][python] Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14503: URL: https://github.com/apache/flink/pull/14503#issuecomment-751622207 ## CI report: * 92d6c706863d0deb3dcfd5c8687f2670a72b7f0e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14483: [FLINK-18998][Runtime / Web Frontend]No watermark is shown on Flink UI when ProcessingTime is used

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14483: URL: https://github.com/apache/flink/pull/14483#issuecomment-750722975 ## CI report: * 3785cb9929bdb3bf7c6dead17b6db7910cf3b5e3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255804#comment-17255804 ] xiaozilong edited comment on FLINK-20795 at 12/29/20, 5:09 AM: ---

[jira] [Created] (FLINK-20797) can flink on k8s use pv using NFS and pvc as the hight avalibility storagedir

2020-12-28 Thread hayden zhou (Jira)
hayden zhou created FLINK-20797: --- Summary: can flink on k8s use pv using NFS and pvc as the hight avalibility storagedir Key: FLINK-20797 URL: https://issues.apache.org/jira/browse/FLINK-20797 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324 ## CI report: * d083b630115604e34b0a74498890aedbff61b2a7 UNKNOWN * d58927642909f50571ed6242605aac564e074f89 Azure: [SUCCESS](https://dev.azure.com/apache-flin

[jira] [Created] (FLINK-20796) Support unnest in the Table API

2020-12-28 Thread Dian Fu (Jira)
Dian Fu created FLINK-20796: --- Summary: Support unnest in the Table API Key: FLINK-20796 URL: https://issues.apache.org/jira/browse/FLINK-20796 Project: Flink Issue Type: Sub-task Componen

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255804#comment-17255804 ] xiaozilong edited comment on FLINK-20795 at 12/29/20, 5:01 AM: ---

[jira] [Commented] (FLINK-20791) Support local aggregate push down for Blink batch planner

2020-12-28 Thread Sebastian Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255811#comment-17255811 ] Sebastian Liu commented on FLINK-20791: --- Hi [~lirui], [~godfreyhe], [~jark], Appre

[GitHub] [flink] flinkbot edited a comment on pull request #14503: [FLINK-20693][table-planner-blink][python] Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14503: URL: https://github.com/apache/flink/pull/14503#issuecomment-751622207 ## CI report: * 92d6c706863d0deb3dcfd5c8687f2670a72b7f0e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18019) The configuration specified in TableConfig may not take effect in certain cases

2020-12-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255808#comment-17255808 ] Dian Fu commented on FLINK-18019: - This problem should still exist and you can verify it

[GitHub] [flink] fsk119 commented on a change in pull request #14437: [FLINK-20458][docs] translate gettingStarted.zh.md and correct spelling errors in gettingStarted.md

2020-12-28 Thread GitBox
fsk119 commented on a change in pull request #14437: URL: https://github.com/apache/flink/pull/14437#discussion_r549564559 ## File path: docs/dev/table/sql/gettingStarted.zh.md ## @@ -129,11 +128,11 @@ FROM employee_information GROUP BY dep_id; {% endhighlight %} -Such qu

[GitHub] [flink] flinkbot edited a comment on pull request #14493: [FLINK-20768][Connectors/ElasticSearch] Support routing field for Elasticsearch connector

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14493: URL: https://github.com/apache/flink/pull/14493#issuecomment-751222472 ## CI report: * 877575f48fc2b602a34213c3b9d31e850fe5b130 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * 8fe82a5ff01ab13c7ba704e3ced181c3a6e4fc15 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255804#comment-17255804 ] xiaozilong edited comment on FLINK-20795 at 12/29/20, 4:35 AM: ---

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255804#comment-17255804 ] xiaozilong edited comment on FLINK-20795 at 12/29/20, 4:33 AM: ---

[jira] [Commented] (FLINK-20795) add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255804#comment-17255804 ] xiaozilong commented on FLINK-20795: Hi [~zoucao], I think is useful. Mayby we shoul

[GitHub] [flink] V1ncentzzZ edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-28 Thread GitBox
V1ncentzzZ edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751745476 @flinkbot run azure. This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink] flinkbot edited a comment on pull request #14493: [FLINK-20768][Connectors/ElasticSearch] Support routing field for Elasticsearch connector

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14493: URL: https://github.com/apache/flink/pull/14493#issuecomment-751222472 ## CI report: * 179ea826af4470c6c1d9a94da5f4270f16e81f40 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] curcur commented on a change in pull request #14460: [docs/javadoc][hotfix] Explicitly Document task cancellation timeout …

2020-12-28 Thread GitBox
curcur commented on a change in pull request #14460: URL: https://github.com/apache/flink/pull/14460#discussion_r549560968 ## File path: docs/_includes/generated/all_taskmanager_section.html ## @@ -18,7 +18,7 @@ task.cancellation.timeout 18

[GitHub] [flink] curcur commented on a change in pull request #14460: [docs/javadoc][hotfix] Explicitly Document task cancellation timeout …

2020-12-28 Thread GitBox
curcur commented on a change in pull request #14460: URL: https://github.com/apache/flink/pull/14460#discussion_r549560968 ## File path: docs/_includes/generated/all_taskmanager_section.html ## @@ -18,7 +18,7 @@ task.cancellation.timeout 18

[GitHub] [flink] curcur commented on a change in pull request #14460: [docs/javadoc][hotfix] Explicitly Document task cancellation timeout …

2020-12-28 Thread GitBox
curcur commented on a change in pull request #14460: URL: https://github.com/apache/flink/pull/14460#discussion_r549560968 ## File path: docs/_includes/generated/all_taskmanager_section.html ## @@ -18,7 +18,7 @@ task.cancellation.timeout 18

[GitHub] [flink] curcur commented on a change in pull request #14460: [docs/javadoc][hotfix] Explicitly Document task cancellation timeout …

2020-12-28 Thread GitBox
curcur commented on a change in pull request #14460: URL: https://github.com/apache/flink/pull/14460#discussion_r549560968 ## File path: docs/_includes/generated/all_taskmanager_section.html ## @@ -18,7 +18,7 @@ task.cancellation.timeout 18

[GitHub] [flink] curcur commented on a change in pull request #14460: [docs/javadoc][hotfix] Explicitly Document task cancellation timeout …

2020-12-28 Thread GitBox
curcur commented on a change in pull request #14460: URL: https://github.com/apache/flink/pull/14460#discussion_r549560865 ## File path: docs/_includes/generated/all_taskmanager_section.html ## @@ -18,7 +18,7 @@ task.cancellation.timeout 18

[jira] [Commented] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

2020-12-28 Thread zhengyu.lou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255796#comment-17255796 ] zhengyu.lou commented on FLINK-20457: - For example, currently {color:#4c9aff}datetim

[GitHub] [flink] flinkbot edited a comment on pull request #14514: [FLINK-20793][core][tests] Fix the NamesTest due to code style refactor

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14514: URL: https://github.com/apache/flink/pull/14514#issuecomment-751931069 ## CI report: * 0a7cf741cfb092143e2dafcb8587b2294efc5dda UNKNOWN * a4538c71a6fdd097ad68b374b781b67daad49f83 Azure: [PENDING](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-20795) add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true

2020-12-28 Thread zoucao (Jira)
zoucao created FLINK-20795: -- Summary: add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true Key: FLINK-20795 URL: https://issues.apache.org/jira/browse/FLINK-20795 Pr

[jira] [Updated] (FLINK-20789) Add a metric named `deserializeFaildCount` for kafka connectors

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20789: --- Description: Counts the number of deserialize failed when the option `ignore-parse-errors` is enabl

[GitHub] [flink] flinkbot edited a comment on pull request #14514: [FLINK-20793][core][tests] Fix the NamesTest due to code style refactor

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14514: URL: https://github.com/apache/flink/pull/14514#issuecomment-751931069 ## CI report: * 0a7cf741cfb092143e2dafcb8587b2294efc5dda UNKNOWN * a4538c71a6fdd097ad68b374b781b67daad49f83 UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * 8fe82a5ff01ab13c7ba704e3ced181c3a6e4fc15 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14503: [FLINK-20693][table-planner-blink][python] Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14503: URL: https://github.com/apache/flink/pull/14503#issuecomment-751622207 ## CI report: * 92d6c706863d0deb3dcfd5c8687f2670a72b7f0e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18019) The configuration specified in TableConfig may not take effect in certain cases

2020-12-28 Thread Ting Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255788#comment-17255788 ] Ting Sun commented on FLINK-18019: -- [~dian.fu] Hello, I'm wondering whether the issue i

[GitHub] [flink] flinkbot commented on pull request #14514: [FLINK-20793][core][tests] Fix the NamesTest due to code style refactor

2020-12-28 Thread GitBox
flinkbot commented on pull request #14514: URL: https://github.com/apache/flink/pull/14514#issuecomment-751931069 ## CI report: * 0a7cf741cfb092143e2dafcb8587b2294efc5dda UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14503: [FLINK-20693][table-planner-blink][python] Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14503: URL: https://github.com/apache/flink/pull/14503#issuecomment-751622207 ## CI report: * 2ea58420e5d5ac6d1930f8b847c46a60a2043b38 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] V1ncentzzZ edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-28 Thread GitBox
V1ncentzzZ edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751745476 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Updated] (FLINK-20793) Fix NamesTest due to code style refactor

2020-12-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20793: Fix Version/s: 1.12.2 1.11.4 1.13.0 > Fix NamesTest due to code styl

[jira] [Assigned] (FLINK-20793) Fix NamesTest due to code style refactor

2020-12-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20793: --- Assignee: Huang Xingbo > Fix NamesTest due to code style refactor > ---

[GitHub] [flink] flinkbot commented on pull request #14514: [FLINK-20793][core] Fix the NamesTest due to code style refactor

2020-12-28 Thread GitBox
flinkbot commented on pull request #14514: URL: https://github.com/apache/flink/pull/14514#issuecomment-751929562 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-20793) Fix NamesTest due to code style refactor

2020-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20793: --- Labels: pull-request-available test-stability (was: test-stability) > Fix NamesTest due to

[GitHub] [flink] HuangXingBo opened a new pull request #14514: [FLINK-20793][core] Fix the NamesTest due to code style refactor

2020-12-28 Thread GitBox
HuangXingBo opened a new pull request #14514: URL: https://github.com/apache/flink/pull/14514 ## What is the purpose of the change *This pull request will Fix the NamesTest due to code style refactor* ## Brief change log - *Fix the NamesTest due to code style refactor*

[GitHub] [flink] HuangXingBo closed pull request #14513: [hotfix] Fix the NamesTest due to code style refactor

2020-12-28 Thread GitBox
HuangXingBo closed pull request #14513: URL: https://github.com/apache/flink/pull/14513 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] flinkbot commented on pull request #14513: [hotfix] Fix the NamesTest due to code style refactor

2020-12-28 Thread GitBox
flinkbot commented on pull request #14513: URL: https://github.com/apache/flink/pull/14513#issuecomment-751928383 ## CI report: * 9f854369bee8f8e62999d4be28cc6c027172dd26 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14503: [FLINK-20693][table-planner-blink][python] Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14503: URL: https://github.com/apache/flink/pull/14503#issuecomment-751622207 ## CI report: * 2ea58420e5d5ac6d1930f8b847c46a60a2043b38 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * 8b19d3eb2fc61752ac94cb2b6c50b3306ab68730 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-20794) Support to select distinct columns in the Table API

2020-12-28 Thread Dian Fu (Jira)
Dian Fu created FLINK-20794: --- Summary: Support to select distinct columns in the Table API Key: FLINK-20794 URL: https://issues.apache.org/jira/browse/FLINK-20794 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-20793) Fix NamesTest due to code style refactor

2020-12-28 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20793: Summary: Fix NamesTest due to code style refactor Key: FLINK-20793 URL: https://issues.apache.org/jira/browse/FLINK-20793 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #14513: [hotfix] Fix the NamesTest due to code style refactor

2020-12-28 Thread GitBox
flinkbot commented on pull request #14513: URL: https://github.com/apache/flink/pull/14513#issuecomment-751926896 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Commented] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

2020-12-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255779#comment-17255779 ] Dian Fu commented on FLINK-20457: - Per my understanding, the timezone info should only b

[GitHub] [flink] HuangXingBo opened a new pull request #14513: [hotfix] Fix the NamesTest due to code style refactor

2020-12-28 Thread GitBox
HuangXingBo opened a new pull request #14513: URL: https://github.com/apache/flink/pull/14513 ## What is the purpose of the change *This pull request will Fix the NamesTest due to code style refactor* ## Brief change log - *Fix the NamesTest due to code style refac

[GitHub] [flink] zhisheng17 closed pull request #14495: [hotfix][runtime]fix typo in HistoryServerUtils class

2020-12-28 Thread GitBox
zhisheng17 closed pull request #14495: URL: https://github.com/apache/flink/pull/14495 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] zhisheng17 commented on pull request #14495: [hotfix][runtime]fix typo in HistoryServerUtils class

2020-12-28 Thread GitBox
zhisheng17 commented on pull request #14495: URL: https://github.com/apache/flink/pull/14495#issuecomment-751926256 thanks @tillrohrmann , I get it, I will close this PR. This is an automated message from the Apache Git Servi

[jira] [Commented] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

2020-12-28 Thread zhengyu.lou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255775#comment-17255775 ] zhengyu.lou commented on FLINK-20457: - re: [~dian.fu] It seems in from_collection th

[GitHub] [flink] V1ncentzzZ edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-28 Thread GitBox
V1ncentzzZ edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751745476 @flinkbot run azure. This is an automated message from the Apache Git Service. To respond to the messa

[jira] [Updated] (FLINK-20787) Improve the Table API to make it usable

2020-12-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20787: Description: Currently, there are quite a few bugs in the Table API which makes it difficult to use. Users

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * 514d2afb5520388488b7189f18ee1a97d39ea386 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14451: [FLINK-20704][table-planner] Some rel data type does not implement th…

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14451: URL: https://github.com/apache/flink/pull/14451#issuecomment-749321360 ## CI report: * d9c3ee87fa55ee7a1f7d4848c8a7dc542f2011a6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] V1ncentzzZ edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-28 Thread GitBox
V1ncentzzZ edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751745476 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Commented] (FLINK-20789) Add a metric named `deserializeFaildCount` for kafka connectors

2020-12-28 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255766#comment-17255766 ] xiaozilong commented on FLINK-20789: cc [~jark] > Add a metric named `deserializeFa

[GitHub] [flink] flinkbot edited a comment on pull request #14451: [FLINK-20704][table-planner] Some rel data type does not implement th…

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

[GitHub] [flink] godfreyhe commented on pull request #14451: [FLINK-20704][table-planner] Some rel data type does not implement th…

2020-12-28 Thread GitBox
godfreyhe commented on pull request #14451: URL: https://github.com/apache/flink/pull/14451#issuecomment-751915927 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] godfreyhe commented on a change in pull request #14451: [FLINK-20704][table-planner] Some rel data type does not implement th…

2020-12-28 Thread GitBox
godfreyhe commented on a change in pull request #14451: URL: https://github.com/apache/flink/pull/14451#discussion_r549537552 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/schema/MapRelDataType.scala ## @@ -45,5 +45,4 @@ class MapRelD

[GitHub] [flink] flinkbot edited a comment on pull request #14509: [FLINK-20654][checkpointing] Decline checkpoints until restored channel state is consumed

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

[GitHub] [flink] flinkbot edited a comment on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-751906693 ## CI report: * 86f6502cf9980ff8d7fd15fe058588eb9f5004cf Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2020-12-28 Thread GitBox
flinkbot commented on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-751906693 ## CI report: * 86f6502cf9980ff8d7fd15fe058588eb9f5004cf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14509: [FLINK-20654][checkpointing] Decline checkpoints until restored channel state is consumed

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14509: URL: https://github.com/apache/flink/pull/14509#issuecomment-751746750 ## CI report: * 89cc24da926665e094006c6a825429c1efb7697c Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2020-12-28 Thread GitBox
flinkbot commented on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-751903408 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] blublinsky commented on pull request #14281: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes setup

2020-12-28 Thread GitBox
blublinsky commented on pull request #14281: URL: https://github.com/apache/flink/pull/14281#issuecomment-751903397 @wangyang0918 Redid the implementation based on your request. Had to move it https://github.com/apache/flink/pull/14512.

[GitHub] [flink] blublinsky opened a new pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2020-12-28 Thread GitBox
blublinsky opened a new pull request #14512: URL: https://github.com/apache/flink/pull/14512 ## What is the purpose of the change Flink implementation is often a part of the larger application. As a result a synchronized management - clean up of Flink resources, when a main

[GitHub] [flink] flinkbot edited a comment on pull request #14511: [FLINK-20792][build] Allow shorthand calls to spotless

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

[GitHub] [flink] flinkbot edited a comment on pull request #14509: [FLINK-20654][checkpointing] Decline checkpoints until restored channel state is consumed

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14509: URL: https://github.com/apache/flink/pull/14509#issuecomment-751746750 ## CI report: * 692de7c951bd21f3841560cc351c3aae3f33719c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14509: [FLINK-20654][checkpointing] Decline checkpoints until restored channel state is consumed

2020-12-28 Thread GitBox
flinkbot edited a comment on pull request #14509: URL: https://github.com/apache/flink/pull/14509#issuecomment-751746750 ## CI report: * 692de7c951bd21f3841560cc351c3aae3f33719c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] sv3ndk closed pull request #14494: [hotfix][docs] uses lambda in Learn Flink example instead of FilterFunction

2020-12-28 Thread GitBox
sv3ndk closed pull request #14494: URL: https://github.com/apache/flink/pull/14494 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 t

  1   2   3   4   >