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

2020-12-27 Thread GitBox
flinkbot edited a comment on pull request #14437: URL: https://github.com/apache/flink/pull/14437#issuecomment-748619719 ## CI report: * 8192b4f076bc5e5c62d283ef5ff67d2182a128ea Azure:

[jira] [Commented] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255458#comment-17255458 ] Xintong Song commented on FLINK-20781: -- Looks like a real and severe bug to me. Tagging it as

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

2020-12-27 Thread GitBox
flinkbot commented on pull request #14503: URL: https://github.com/apache/flink/pull/14503#issuecomment-751619779 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-20781) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20781: - Priority: Blocker (was: Major) > UnalignedCheckpointITCase failure caused by

[jira] [Updated] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20781: - Fix Version/s: 1.12.1 > UnalignedCheckpointITCase failure caused by NullPointerException >

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

2020-12-27 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255455#comment-17255455 ] hailong wang commented on FLINK-17767: -- Great!It good to be included in TVF. I can give a hand if

[jira] [Updated] (FLINK-20693) Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java

2020-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20693: --- Labels: pull-request-available (was: ) > Port BatchExecPythonCorrelate and

[GitHub] [flink] HuangXingBo opened a new pull request #14503: [FLINK-20693][table-planner-blink][python] Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java

2020-12-27 Thread GitBox
HuangXingBo opened a new pull request #14503: URL: https://github.com/apache/flink/pull/14503 ## What is the purpose of the change *This pull request Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java* ## Brief change log - *Port

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

2020-12-27 Thread GitBox
jjiey commented on pull request #14437: URL: https://github.com/apache/flink/pull/14437#issuecomment-751618750 > Thanks for your contribution. Sorry for the late response and I left some comments. Thanks @fsk119 for your review comments. I've updated and commited the modifications.

[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: * b3976f5cf20bd5a78289cf388c830a1739992bd0 Azure:

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

2020-12-27 Thread GitBox
flinkbot edited a comment on pull request #14437: URL: https://github.com/apache/flink/pull/14437#issuecomment-748619719 ## CI report: * 8192b4f076bc5e5c62d283ef5ff67d2182a128ea Azure:

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

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255442#comment-17255442 ] xx chai commented on FLINK-20780: - [^ps-flink-process.txt] the flie is I execute aux | grep

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

2020-12-27 Thread GitBox
wangyang0918 commented on pull request #14281: URL: https://github.com/apache/flink/pull/14281#issuecomment-751613713 @blublinsky Thanks for your comments. First, I believe parsing the `KubernetesOwnerReference` is not the ability of `KubernetesJobManagerFactory`. Moving the parsing

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

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-20780: Attachment: ps-flink-process.txt > Flink-sql-client query hive > > >

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

2020-12-27 Thread GitBox
wangyang0918 edited a comment on pull request #14281: URL: https://github.com/apache/flink/pull/14281#issuecomment-751185846 @blublinsky Generally, this PR could work. But I think we could make the implementation more gracefully. * We could introduce a new Kubernetes resource in Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14495: [hotfix][runtime]fix typo in HistoryServerUtils class

2020-12-27 Thread GitBox
flinkbot edited a comment on pull request #14495: URL: https://github.com/apache/flink/pull/14495#issuecomment-751225470 ## CI report: * 06d95b81212492278e8bc45f78a86e720b739f0d Azure:

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

2020-12-27 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255437#comment-17255437 ] Rui Li commented on FLINK-20780: Hmm... then I think you need to check the class path of JM/TM of your

[jira] [Assigned] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-20781: Assignee: Jiangjie Qin > UnalignedCheckpointITCase failure caused by NullPointerException >

[jira] [Updated] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20781: - Affects Version/s: 1.12.0 > UnalignedCheckpointITCase failure caused by NullPointerException >

[jira] [Closed] (FLINK-20540) The baseurl for pg database is incorrect in JdbcCatalog page

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20540. --- Fix Version/s: 1.13.0 Resolution: Fixed Fixed in master: 8da64d7982de7287766de658f6d6f03037be94e6 >

[jira] [Updated] (FLINK-20540) JdbcCatalog throws connection exception when baseUrl doesn't end with slash

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20540: Summary: JdbcCatalog throws connection exception when baseUrl doesn't end with slash (was: The baseurl

[jira] [Created] (FLINK-20783) Separate the implementation of BatchExec nodes for Join

2020-12-27 Thread Wenlong Lyu (Jira)
Wenlong Lyu created FLINK-20783: --- Summary: Separate the implementation of BatchExec nodes for Join Key: FLINK-20783 URL: https://issues.apache.org/jira/browse/FLINK-20783 Project: Flink Issue

[GitHub] [flink] wuchong merged pull request #14362: [FLINK-20540][jdbc] Fix the defaultUrl for AbstractJdbcCatalog in JDBC connector

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

[jira] [Closed] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-20389. Resolution: Fixed I close this issue again after opening FLINK-20781 as it the underlying issue seems to

[jira] [Created] (FLINK-20782) Separate the implementation of BatchExecRank

2020-12-27 Thread Wenlong Lyu (Jira)
Wenlong Lyu created FLINK-20782: --- Summary: Separate the implementation of BatchExecRank Key: FLINK-20782 URL: https://issues.apache.org/jira/browse/FLINK-20782 Project: Flink Issue Type:

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

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

[jira] [Commented] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255430#comment-17255430 ] Matthias commented on FLINK-20781: -- FLINK-20389 was linked as the most recent comments in this issue

[jira] [Commented] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255428#comment-17255428 ] Matthias commented on FLINK-20781: -- FLINK-20492 was linked as it might have been caused by changes

[jira] [Updated] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20781: - Affects Version/s: 1.13.0 > UnalignedCheckpointITCase failure caused by NullPointerException >

[jira] [Updated] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20781: - Labels: test-stability (was: ) > UnalignedCheckpointITCase failure caused by NullPointerException >

[jira] [Updated] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20781: - Description: {{UnalignedCheckpointITCase}} fails due to {{NullPointerException}} (e.g. in [this

[GitHub] [flink] flinkbot edited a comment on pull request #14495: [hotfix][runtime]fix typo in HistoryServerUtils class

2020-12-27 Thread GitBox
flinkbot edited a comment on pull request #14495: URL: https://github.com/apache/flink/pull/14495#issuecomment-751225470 ## CI report: * 06d95b81212492278e8bc45f78a86e720b739f0d Azure:

[jira] [Updated] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20781: - Summary: UnalignedCheckpointITCase failure caused by NullPointerException (was: Unal) >

[jira] [Created] (FLINK-20781) Unal

2020-12-27 Thread Matthias (Jira)
Matthias created FLINK-20781: Summary: Unal Key: FLINK-20781 URL: https://issues.apache.org/jira/browse/FLINK-20781 Project: Flink Issue Type: Bug Reporter: Matthias -- This

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255421#comment-17255421 ] Matthias commented on FLINK-20654: -- [Build

[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: * 5e1ebe24b8fcdacdc2c96a205f84208c25c4f653 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14495: [hotfix][runtime]fix typo in HistoryServerUtils class

2020-12-27 Thread GitBox
flinkbot edited a comment on pull request #14495: URL: https://github.com/apache/flink/pull/14495#issuecomment-751225470 ## CI report: * 06d95b81212492278e8bc45f78a86e720b739f0d Azure:

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

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

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255416#comment-17255416 ] Matthias commented on FLINK-20654: -- [Build

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

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255407#comment-17255407 ] xx chai commented on FLINK-20780: - There is only one node in my cluster,the cluster is my test cluster

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

2020-12-27 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255406#comment-17255406 ] Rui Li commented on FLINK-20780: Hi [~chaixiaoxue] have you set the HADOOP_CLASSPATH variable on every

[jira] [Updated] (FLINK-20744) org.apache.flink.test.checkpointing.UnalignedCheckpointITCase fails due to java.lang.ArrayIndexOutOfBoundsException

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20744: - Labels: test-stability (was: testability) >

[jira] [Updated] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20654: - Labels: pull-request-available test-stability (was: pull-request-available) > Unaligned checkpoint

[jira] [Updated] (FLINK-20770) Incorrect description for config option kubernetes.rest-service.exposed.type

2020-12-27 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20770: - Labels: starter (was: ) > Incorrect description for config option kubernetes.rest-service.exposed.type

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

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255393#comment-17255393 ] xx chai commented on FLINK-20780: - export HADOOP_HOME=/opt/cloudera/parcels/CDH/lib/hadoop export

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

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255390#comment-17255390 ] Jark Wu commented on FLINK-20780: - How did you configure the hadoop classpath? > Flink-sql-client query

[GitHub] [flink] kougazhang commented on pull request #14362: [FLINK-20540][jdbc] Fix the defaultUrl for AbstractJdbcCatalog in JDBC connector

2020-12-27 Thread GitBox
kougazhang commented on pull request #14362: URL: https://github.com/apache/flink/pull/14362#issuecomment-751585903 > @kougazhang There're failed tests, the test

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

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255387#comment-17255387 ] xx chai commented on FLINK-20780: - Every time  i restart the cluster  after you change jars in the lib

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

2020-12-27 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255386#comment-17255386 ] Rui Li commented on FLINK-20780: You need to make sure the jars are available to both sql-client and

[jira] [Commented] (FLINK-20583) Support to define the data range of decimal types in datagen table source connector

2020-12-27 Thread tonychen0716 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255384#comment-17255384 ] tonychen0716 commented on FLINK-20583: -- any result? > Support to define the data range of decimal

[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: * 9abb79a2bb6e487d3f1deb0cfc4ecfff74a7d780 Azure:

[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: * acdafc09aa2916dd50f6e2139a841ed1bfd793db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14502: [Flink-20766][table-planner-blink] Separate implementations of sort ExecNode and PhysicalNode.

2020-12-27 Thread GitBox
flinkbot edited a comment on pull request #14502: URL: https://github.com/apache/flink/pull/14502#issuecomment-751570047 ## CI report: * feec24b2df7f31564e217290d7a0d1636fac27b2 Azure:

[GitHub] [flink] flinkbot commented on pull request #14502: [Flink-20766][table-planner-blink] Separate implementations of sort ExecNode and PhysicalNode.

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

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

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255375#comment-17255375 ] xx chai commented on FLINK-20780: - I have deleted  {{flink-connector-hive_2.11-1.12.0.jar}}, 

[GitHub] [flink] flinkbot commented on pull request #14502: [Flink-20766][table-planner-blink] Separate implementations of sort ExecNode and PhysicalNode.

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

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

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255371#comment-17255371 ] Jark Wu commented on FLINK-20780: - Please remove {{flink-connector-hive_2.11-1.12.0.jar}},

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

2020-12-27 Thread GitBox
flinkbot edited a comment on pull request #14501: URL: https://github.com/apache/flink/pull/14501#issuecomment-751565111 ## CI report: * b6663b070dc3a6e687d6b68d08ba12366a4ef80e Azure:

[GitHub] [flink] wenlong88 opened a new pull request #14502: [Flink-20766][table-planner-blink] Separate implementations of sort ExecNode and PhysicalNode.

2020-12-27 Thread GitBox
wenlong88 opened a new pull request #14502: URL: https://github.com/apache/flink/pull/14502 ## What is the purpose of the change Separate the implementation of sort ExeNode ## Brief change log 1. Introduce StreamPhysicalSort, and make StreamExecSort only extended from ExecNode

[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-27 Thread GitBox
wuchong commented on a change in pull request #14464: URL: https://github.com/apache/flink/pull/14464#discussion_r549207143 ## File path: docs/dev/table/connectors/formats/canal.md ## @@ -142,6 +142,79 @@ SELECT * FROM topic_products; +Available Metadata

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

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255369#comment-17255369 ] xx chai edited comment on FLINK-20780 at 12/28/20, 3:59 AM: Flink version is

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

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255369#comment-17255369 ] xx chai commented on FLINK-20780: - Flink version is 1.12 > Flink-sql-client query hive >

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

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255368#comment-17255368 ] Jark Wu commented on FLINK-20780: - Could you provide the versions you are using, including Flink, Hive,

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

2020-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20780: Component/s: Connectors / Hive > Flink-sql-client query hive > > >

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

2020-12-27 Thread GitBox
xiaoHoly commented on pull request #14501: URL: https://github.com/apache/flink/pull/14501#issuecomment-751565702 thanks for contribution,LGTM This is an automated message from the Apache Git Service. To respond to the

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

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

[jira] [Commented] (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:comment-tabpanel=17255367#comment-17255367 ] Jark Wu commented on FLINK-14055: - Yes [~hpeter], a FLIP design doc would be helpful. > Add advanced

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

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-20780: Attachment: 1609127183(1).png > Flink-sql-client query hive > > >

[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

[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=17255366#comment-17255366 ] Jark Wu commented on FLINK-18726: - Thanks [~atri], could you prepare a design doc on Google doc to

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

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

[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

[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

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

[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

[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

[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=17255360#comment-17255360 ] jiawen xiao commented on FLINK-20778: - [~meijies],please wait ,Jark can assign to you.i think you

[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=17255358#comment-17255358 ] jiawen xiao commented on FLINK-20778: - hi,[~jark],cc > the comment for kafka split offset type is

[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 Jeremy Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255355#comment-17255355 ] Jeremy Mei commented on FLINK-20778: [~873925...@qq.com] Ok, Please assign it to me. > the comment

[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=17255354#comment-17255354 ] Huang Xingbo commented on FLINK-20254: --

[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-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=17255353#comment-17255353 ] xiaozilong commented on FLINK-20776: ok > Error message is incomplete in JSON format >

[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-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=17255350#comment-17255350 ] jiawen xiao commented on FLINK-20777: - hi,[~renqs] thanks for raising this question. which version

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

[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=17255349#comment-17255349 ] jiawen xiao commented on FLINK-20778: - [~meijies],you are right. could you create a pr to fix?  >

[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

[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

[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

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

[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

[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

[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

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

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

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

  1   2   >