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

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

[GitHub] [flink] HuangXingBo commented on a change in pull request #14492: [FLINK-20756][python] Add PythonCalcSplitConditionRexFieldRule

2020-12-27 Thread GitBox
HuangXingBo commented on a change in pull request #14492: URL: https://github.com/apache/flink/pull/14492#discussion_r549088373 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/PythonCalcSplitRule.scala ## @@

[GitHub] [flink] HuangXingBo commented on pull request #14492: [FLINK-20756][python] Add PythonCalcSplitConditionRexFieldRule

2020-12-27 Thread GitBox
HuangXingBo commented on pull request #14492: URL: https://github.com/apache/flink/pull/14492#issuecomment-751444822 @WeiZhong94 Thanks a lot for the review. I have addressed the comments at the latest commit. This is an aut

[GitHub] [flink] flinkbot edited a comment on pull request #14492: [FLINK-20756][python] Add PythonCalcSplitConditionRexFieldRule

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

[GitHub] [flink] flinkbot edited a comment on pull request #14492: [FLINK-20756][python] Add PythonCalcSplitConditionRexFieldRule

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

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

2020-12-27 Thread GitBox
SteNicholas removed a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-751155184 > The change looks good in general. Could you add a IT case in `KafkaChangelogTableITCase` to test kafka+canal-json with metadata accessing? OK. I would like t

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

2020-12-27 Thread GitBox
SteNicholas removed a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-751155066 > Hi @SteNicholas , I would like to discuss the metadata keys first. What do you think think just use the keys and types? > > * `pk_names ARRAY` > * `sql_ty

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

2020-12-27 Thread GitBox
SteNicholas commented on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-751448004 @wuchong I have added a IT case in `KafkaChangelogTableITCase` to test Kafka and Canal JSON with metadata accessing. About the Canal JSON metadata, I prefer to the follow

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

2020-12-27 Thread GitBox
SteNicholas edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-751448004 @wuchong I have added a IT case in `KafkaChangelogTableITCase` to test Kafka and Canal JSON with metadata accessing. About the Canal JSON metadata, I prefer to the

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #14492: [FLINK-20756][python] Add PythonCalcSplitConditionRexFieldRule

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

[jira] [Created] (FLINK-20775) Missed Docker Images Flink 1.12

2020-12-27 Thread Nazar Volynets (Jira)
Nazar Volynets created FLINK-20775: -- Summary: Missed Docker Images Flink 1.12 Key: FLINK-20775 URL: https://issues.apache.org/jira/browse/FLINK-20775 Project: Flink Issue Type: Bug

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

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

[jira] [Updated] (FLINK-20775) Missed Docker Images Flink 1.12

2020-12-27 Thread Nazar Volynets (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nazar Volynets updated FLINK-20775: --- Description: Apache Flink 1.12 has been release more than 2 weeks ago: [https://flink.apache

[GitHub] [flink] reswqa opened a new pull request #14498: [hotfix][typo]Fix typo in StreamingJobGraphGenerator.areOperatorsChainable

2020-12-27 Thread GitBox
reswqa opened a new pull request #14498: URL: https://github.com/apache/flink/pull/14498 What is the purpose of the change Fix typo in StreamingJobGraphGenerator.areOperatorsChainable. There are two separate switch to determine whether the ChainingStrategy isChainable for the upst

[GitHub] [flink] flinkbot commented on pull request #14498: [hotfix][typo]Fix typo in StreamingJobGraphGenerator.areOperatorsChainable

2020-12-27 Thread GitBox
flinkbot commented on pull request #14498: URL: https://github.com/apache/flink/pull/14498#issuecomment-751453417 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] flinkbot commented on pull request #14498: [hotfix][typo]Fix typo in StreamingJobGraphGenerator.areOperatorsChainable

2020-12-27 Thread GitBox
flinkbot commented on pull request #14498: URL: https://github.com/apache/flink/pull/14498#issuecomment-751455578 ## CI report: * 8f32c65db0f2494e57b795b95095ade79371ffde UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-20773) Support allow-unescaped-control-chars option for JSON format

2020-12-27 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255207#comment-17255207 ] xiaozilong commented on FLINK-20773: Thanks [~jark] , i will do it. > Support allow

[GitHub] [flink] flinkbot edited a comment on pull request #14498: [hotfix][typo]Fix typo in StreamingJobGraphGenerator.areOperatorsChainable

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

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

2020-12-27 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-20776) Error message is incomplete in JSON format

2020-12-27 Thread xiaozilong (Jira)
xiaozilong created FLINK-20776: -- Summary: Error message is incomplete in JSON format Key: FLINK-20776 URL: https://issues.apache.org/jira/browse/FLINK-20776 Project: Flink Issue Type: Bug

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

2020-12-27 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-20777: - Summary: Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source Key: FLINK-20777 URL: https://issues.apache.org/jira/browse/FLINK-2

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

2020-12-27 Thread GitBox
wuchong commented on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-751471058 I'm also fine with that. Will review it tomorrow. This is an automated message from the Apache Git Service. To

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #14495: [hotfix][runtime]fix typo in HistoryServerUtils class

2020-12-27 Thread GitBox
V1ncentzzZ commented on a change in pull request #14495: URL: https://github.com/apache/flink/pull/14495#discussion_r549117119 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerUtils.java ## @@ -35,7 +35,6 @@ * Utility class f

[jira] [Commented] (FLINK-20776) Error message is incomplete in JSON format

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255236#comment-17255236 ] Jark Wu commented on FLINK-20776: - I think the information is clear, because the excepti

[jira] [Updated] (FLINK-18726) Support INSERT INTO specific columns

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18726: Fix Version/s: 1.13.0 > Support INSERT INTO specific columns > > >

[jira] [Commented] (FLINK-18726) Support INSERT INTO specific columns

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255237#comment-17255237 ] Jark Wu commented on FLINK-18726: - Hi [~atri], are you still working on this? If not, I

[jira] [Updated] (FLINK-18726) Support INSERT INTO specific columns

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18726: Labels: sprint (was: ) > Support INSERT INTO specific columns > > >

[jira] [Updated] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14055: Labels: sprint (was: ) > Add advanced function DDL syntax "USING JAR/FILE/ACHIVE" > -

[jira] [Updated] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14055: Fix Version/s: 1.13.0 > Add advanced function DDL syntax "USING JAR/FILE/ACHIVE" > ---

[jira] [Closed] (FLINK-13661) Add a stream specific CREATE TABLE SQL DDL

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-13661. --- Resolution: Resolved This has already been supported. > Add a stream specific CREATE TABLE SQL DDL > -

[jira] [Updated] (FLINK-18027) ROW value constructor cannot deal with complex expressions

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18027: Fix Version/s: 1.13.0 > ROW value constructor cannot deal with complex expressions > -

[jira] [Updated] (FLINK-17767) Tumble and Hop window support offset

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17767: Fix Version/s: 1.13.0 > Tumble and Hop window support offset > > >

[jira] [Updated] (FLINK-16534) Support specify savepoint path when submitting sql job through sql client

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16534: Fix Version/s: 1.13.0 > Support specify savepoint path when submitting sql job through sql client > --

[GitHub] [flink] flinkbot edited a comment on pull request #14362: [FLINK-20540][jdbc] Fix the defaultUrl for AbstractJdbcCatalog in JDBC connector

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

[jira] [Updated] (FLINK-17767) Add offset support for TUMBLE, HOP, SESSION group windows

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17767: Summary: Add offset support for TUMBLE, HOP, SESSION group windows (was: Tumble and Hop window support of

[jira] [Closed] (FLINK-8168) Add offset support for group windows

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-8168. -- Resolution: Duplicate > Add offset support for group windows > > >

[jira] [Commented] (FLINK-17767) Add offset support for TUMBLE, HOP, SESSION group windows

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255242#comment-17255242 ] Jark Wu commented on FLINK-17767: - As we are going to support window TVF to replace the

[jira] [Comment Edited] (FLINK-17767) Add offset support for TUMBLE, HOP, SESSION group windows

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255242#comment-17255242 ] Jark Wu edited comment on FLINK-17767 at 12/27/20, 2:30 PM:

[jira] [Closed] (FLINK-20380) Problems with creating iceberg Catalog (Catalog -type=hive) using flink-SQL shell

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20380. --- Resolution: Not A Problem > Problems with creating iceberg Catalog (Catalog -type=hive) using flink-SQL > s

[GitHub] [flink] flinkbot edited a comment on pull request #14362: [FLINK-20540][jdbc] Fix the defaultUrl for AbstractJdbcCatalog in JDBC connector

2020-12-27 Thread GitBox
flinkbot edited a comment on pull request #14362: URL: https://github.com/apache/flink/pull/14362#issuecomment-742906429 ## CI report: * aa34f060a06041b6e84afa54c8ae5507dba0342d Azure: [FAILURE](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-27 Thread GitBox
flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * bc5759c4d2710fd618ae0ea4541152e87d0dad65 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] hwanju opened a new pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

2020-12-27 Thread GitBox
hwanju opened a new pull request #14499: URL: https://github.com/apache/flink/pull/14499 ## What is the purpose of the change Flink app or dependent libraries can terminate JVM by System.exit or halt, by which JM or TM is terminated. As this has happened typically by accident

[jira] [Updated] (FLINK-15156) Warn user if System.exit() is called in user code

2020-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15156: --- Labels: pull-request-available starter (was: starter) > Warn user if System.exit() is calle

[GitHub] [flink] flinkbot commented on pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

2020-12-27 Thread GitBox
flinkbot commented on pull request #14499: URL: https://github.com/apache/flink/pull/14499#issuecomment-751476681 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] flinkbot edited a comment on pull request #14362: [FLINK-20540][jdbc] Fix the defaultUrl for AbstractJdbcCatalog in JDBC connector

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

[GitHub] [flink] flinkbot commented on pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

2020-12-27 Thread GitBox
flinkbot commented on pull request #14499: URL: https://github.com/apache/flink/pull/14499#issuecomment-751477248 ## CI report: * 84a20ae008df61a397e91e2238bb52afcf3e5124 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

2020-12-27 Thread GitBox
wuchong commented on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-751477517 Btw, could you add documentation for this feature? This is an automated message from the Apache Git Service. To

[GitHub] [flink] hwanju commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

2020-12-27 Thread GitBox
hwanju commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r549123415 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -527,38 +528,48 @@ protected void beforeIn

[GitHub] [flink] hwanju commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

2020-12-27 Thread GitBox
hwanju commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r549124277 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -869,6 +883,8 @@ private boolean triggerCh

[GitHub] [flink] HuangXingBo opened a new pull request #14500: [FLINK-20712][python] Add row-based support of join_lateral/left_outer_join_lateral in Python Table API

2020-12-27 Thread GitBox
HuangXingBo opened a new pull request #14500: URL: https://github.com/apache/flink/pull/14500 ## What is the purpose of the change *This pull request will Add row-based support of join_lateral/left_outer_join_lateral in Python Table API* ## Brief change log - *Add

[jira] [Updated] (FLINK-20712) Add row-based support in join_lateral/left_outer_join_lateral in Python Table API

2020-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20712: --- Labels: pull-request-available (was: ) > Add row-based support in join_lateral/left_outer_j

[GitHub] [flink] flinkbot edited a comment on pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

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

[GitHub] [flink] flinkbot commented on pull request #14500: [FLINK-20712][python] Add row-based support of join_lateral/left_outer_join_lateral in Python Table API

2020-12-27 Thread GitBox
flinkbot commented on pull request #14500: URL: https://github.com/apache/flink/pull/14500#issuecomment-751480436 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] SteNicholas commented on pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

2020-12-27 Thread GitBox
SteNicholas commented on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-751480880 > Btw, could you add documentation for this feature? No problem. This is an automated message from th

[jira] [Commented] (FLINK-18726) Support INSERT INTO specific columns

2020-12-27 Thread Atri Sharma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255251#comment-17255251 ] Atri Sharma commented on FLINK-18726: - I am actively working on this with [~twalthr]

[GitHub] [flink] flinkbot edited a comment on pull request #14498: [hotfix][typo]Fix typo in StreamingJobGraphGenerator.areOperatorsChainable

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

[GitHub] [flink] flinkbot commented on pull request #14500: [FLINK-20712][python] Add row-based support of join_lateral/left_outer_join_lateral in Python Table API

2020-12-27 Thread GitBox
flinkbot commented on pull request #14500: URL: https://github.com/apache/flink/pull/14500#issuecomment-751482579 ## CI report: * 9297ecd59a0b0444fb080439c10bd6b48810adf7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

2020-12-27 Thread GitBox
SteNicholas removed a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-751480880 > Btw, could you add documentation for this feature? No problem. This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #14500: [FLINK-20712][python] Add row-based support of join_lateral/left_outer_join_lateral in Python Table API

2020-12-27 Thread GitBox
flinkbot edited a comment on pull request #14500: URL: https://github.com/apache/flink/pull/14500#issuecomment-751482579 ## CI report: * 9297ecd59a0b0444fb080439c10bd6b48810adf7 Azure: [PENDING](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-27 Thread GitBox
SteNicholas commented on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-751484779 @wuchong I have added the document about the metadata for Canal JSON format. Please help to review the document together. --

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

2020-12-27 Thread GitBox
flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * bc5759c4d2710fd618ae0ea4541152e87d0dad65 Azure: [FAILURE](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-27 Thread GitBox
flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * bc5759c4d2710fd618ae0ea4541152e87d0dad65 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-20778) the comment for kafka split offset type is wrong

2020-12-27 Thread Jeremy Mei (Jira)
Jeremy Mei created FLINK-20778: -- Summary: the comment for kafka split offset type is wrong Key: FLINK-20778 URL: https://issues.apache.org/jira/browse/FLINK-20778 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

2020-12-27 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255285#comment-17255285 ] Zhenqiu Huang commented on FLINK-14055: --- [~jark] I would like to work on this. Sha

[GitHub] [flink] flinkbot edited a comment on pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

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

[GitHub] [flink] flinkbot edited a comment on pull request #14500: [FLINK-20712][python] Add row-based support of join_lateral/left_outer_join_lateral in Python Table API

2020-12-27 Thread GitBox
flinkbot edited a comment on pull request #14500: URL: https://github.com/apache/flink/pull/14500#issuecomment-751482579 ## CI report: * 9297ecd59a0b0444fb080439c10bd6b48810adf7 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-27 Thread GitBox
flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * 4ded1f32d30bf98ad7ac4753a2831acf2e78a4f5 Azure: [FAILURE](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-27 Thread GitBox
flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * 4ded1f32d30bf98ad7ac4753a2831acf2e78a4f5 Azure: [FAILURE](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-27 Thread GitBox
flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * 4ded1f32d30bf98ad7ac4753a2831acf2e78a4f5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14362: [FLINK-20540][jdbc] Fix the defaultUrl for AbstractJdbcCatalog in JDBC connector

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

[jira] [Closed] (FLINK-20775) Missed Docker Images Flink 1.12

2020-12-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20775. --- Resolution: Duplicate > Missed Docker Images Flink 1.12 > --- > >

[GitHub] [flink] flinkbot edited a comment on pull request #14362: [FLINK-20540][jdbc] Fix the defaultUrl for AbstractJdbcCatalog in JDBC connector

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

[jira] [Updated] (FLINK-20712) Support join_lateral/left_outer_join_lateral to accept table function directly in Python Table API

2020-12-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20712: Summary: Support join_lateral/left_outer_join_lateral to accept table function directly in Python Table AP

[GitHub] [flink] dianfu closed pull request #14500: [FLINK-20712][python] Support join_lateral/left_outer_join_lateral to accept table function directly in Python Table API

2020-12-27 Thread GitBox
dianfu closed pull request #14500: URL: https://github.com/apache/flink/pull/14500 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

[jira] [Closed] (FLINK-20712) Support join_lateral/left_outer_join_lateral to accept table function directly in Python Table API

2020-12-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20712. --- Resolution: Fixed Merged to master via 7ea384b950ed53924201604074e0748a1416cdea > Support join_lateral/left

[GitHub] [flink] flinkbot edited a comment on pull request #14492: [FLINK-20756][python] Add PythonCalcSplitConditionRexFieldRule

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

[GitHub] [flink] dianfu closed pull request #14496: [FLINK-20620][python] Port BatchExecPythonCalc and StreamExecPythonCalc to Java

2020-12-27 Thread GitBox
dianfu closed pull request #14496: URL: https://github.com/apache/flink/pull/14496 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

[jira] [Closed] (FLINK-20620) Port BatchExecPythonCalc and StreamExecPythonCalc to Java

2020-12-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20620. --- Assignee: Huang Xingbo Resolution: Fixed Merged to master via 2848d4d44c0f09a9e49b70609fd5f9be30af60ea

[jira] [Created] (FLINK-20779) Add documentation for row-based operation in Python Table API

2020-12-27 Thread Dian Fu (Jira)
Dian Fu created FLINK-20779: --- Summary: Add documentation for row-based operation in Python Table API Key: FLINK-20779 URL: https://issues.apache.org/jira/browse/FLINK-20779 Project: Flink Issue Ty

[jira] [Commented] (FLINK-20778) the comment for kafka split offset type is wrong

2020-12-27 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255349#comment-17255349 ] jiawen xiao commented on FLINK-20778: - [~meijies],you are right. could you create a

[GitHub] [flink] flinkbot edited a comment on pull request #14492: [FLINK-20756][python] Add PythonCalcSplitConditionRexFieldRule

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

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

2020-12-27 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255350#comment-17255350 ] jiawen xiao commented on FLINK-20777: - hi,[~renqs] thanks for raising this question.

[jira] [Assigned] (FLINK-20756) PythonCalcSplitConditionRule is not working as expected

2020-12-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20756: --- Assignee: Huang Xingbo > PythonCalcSplitConditionRule is not working as expected >

[jira] [Commented] (FLINK-20776) Error message is incomplete in JSON format

2020-12-27 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255353#comment-17255353 ] xiaozilong commented on FLINK-20776: ok > Error message is incomplete in JSON forma

[jira] [Closed] (FLINK-20776) Error message is incomplete in JSON format

2020-12-27 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong closed FLINK-20776. -- Resolution: Not A Problem > Error message is incomplete in JSON format > -

[jira] [Commented] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

2020-12-27 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255354#comment-17255354 ] Huang Xingbo commented on FLINK-20254: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-20778) the comment for kafka split offset type is wrong

2020-12-27 Thread Jeremy Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255355#comment-17255355 ] Jeremy Mei commented on FLINK-20778: [~873925...@qq.com] Ok, Please assign it to me.

[jira] [Assigned] (FLINK-16201) Support JSON_VALUE for blink planner

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16201: --- Assignee: Forward Xu > Support JSON_VALUE for blink planner >

[jira] [Commented] (FLINK-20778) the comment for kafka split offset type is wrong

2020-12-27 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255358#comment-17255358 ] jiawen xiao commented on FLINK-20778: - hi,[~jark],cc > the comment for kafka split

[jira] [Commented] (FLINK-20778) the comment for kafka split offset type is wrong

2020-12-27 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255360#comment-17255360 ] jiawen xiao commented on FLINK-20778: - [~meijies],please wait ,Jark can assign to yo

[jira] [Updated] (FLINK-20778) [FLINK-20778] the comment for the type of kafka consumer is wrong at KafkaPartitionSplit

2020-12-27 Thread Jeremy Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeremy Mei updated FLINK-20778: --- Summary: [FLINK-20778] the comment for the type of kafka consumer is wrong at KafkaPartitionSplit

[GitHub] [flink] meijies opened a new pull request #14501: [FLINK-20778] the comment for the type of kafka consumer is wrong at KafkaPartitionSplit

2020-12-27 Thread GitBox
meijies opened a new pull request #14501: URL: https://github.com/apache/flink/pull/14501 ## What is the purpose of the change fix comment for tyhe type of kafka consumer at ```KafkaPartitionSplit```. ## Brief change log switch the comment to related type of kafka consume at

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

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

[jira] [Updated] (FLINK-20778) [FLINK-20778] the comment for the type of kafka consumer is wrong at KafkaPartitionSplit

2020-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20778: --- Labels: pull-request-available (was: ) > [FLINK-20778] the comment for the type of kafka co

[GitHub] [flink] flinkbot commented on pull request #14501: [FLINK-20778] the comment for the type of kafka consumer is wrong at KafkaPartitionSplit

2020-12-27 Thread GitBox
flinkbot commented on pull request #14501: URL: https://github.com/apache/flink/pull/14501#issuecomment-751562731 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-20778) [FLINK-20778] the comment for the type of kafka consumer is wrong at KafkaPartitionSplit

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20778: --- Assignee: Jeremy Mei > [FLINK-20778] the comment for the type of kafka consumer is wrong at > Kaf

[jira] [Created] (FLINK-20780) Flink-sql-client query hive

2020-12-27 Thread xx chai (Jira)
xx chai created FLINK-20780: --- Summary: Flink-sql-client query hive Key: FLINK-20780 URL: https://issues.apache.org/jira/browse/FLINK-20780 Project: Flink Issue Type: Bug Components: Tabl

[jira] [Commented] (FLINK-18726) Support INSERT INTO specific columns

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255366#comment-17255366 ] Jark Wu commented on FLINK-18726: - Thanks [~atri], could you prepare a design doc on Goo

[jira] [Updated] (FLINK-20766) Separate the implementation of sort nodes

2020-12-27 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-20766: Description: includes: StreamExecSort StreamExecSortLimit StreamExecTemporalSort BatchExecSort Bat

  1   2   >