[jira] [Commented] (FLINK-20461) YARNFileReplicationITCase.testPerJobModeWithDefaultFileReplication

2020-12-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254761#comment-17254761 ] Xintong Song commented on FLINK-20461: -- [~hpeter], Is this related to the Azure environment? If

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

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14492: URL: https://github.com/apache/flink/pull/14492#issuecomment-751194123 ## CI report: * 8d7ba4cf9f64e73076055013e3ccb18b7bd9ec3c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-749019176 ## CI report: * b1b5c5016e4e38f895f0f0585662ba7150d2de74 Azure:

[GitHub] [flink] HuangXingBo commented on a change in pull request #14473: [FLINK-20702][python] Support Map Operation Chained Together in Python Table API

2020-12-24 Thread GitBox
HuangXingBo commented on a change in pull request #14473: URL: https://github.com/apache/flink/pull/14473#discussion_r548823631 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PythonCalcMergeRule.java ## @@

[GitHub] [flink] HuangXingBo commented on a change in pull request #14473: [FLINK-20702][python] Support Map Operation Chained Together in Python Table API

2020-12-24 Thread GitBox
HuangXingBo commented on a change in pull request #14473: URL: https://github.com/apache/flink/pull/14473#discussion_r548823460 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PythonCalcMergeRule.java ## @@

[GitHub] [flink] HuangXingBo commented on a change in pull request #14473: [FLINK-20702][python] Support Map Operation Chained Together in Python Table API

2020-12-24 Thread GitBox
HuangXingBo commented on a change in pull request #14473: URL: https://github.com/apache/flink/pull/14473#discussion_r548823408 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PythonCalcMergeRule.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #13800: [FLINK-19650][connectors jdbc]Support the limit push down for the Jdb…

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #13800: URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623 ## CI report: * f5e7891cc45eba2d0d8f28dabdf596834faf0f0a Azure:

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

2020-12-24 Thread GitBox
flinkbot commented on pull request #14492: URL: https://github.com/apache/flink/pull/14492#issuecomment-751194123 ## CI report: * 8d7ba4cf9f64e73076055013e3ccb18b7bd9ec3c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-20461) YARNFileReplicationITCase.testPerJobModeWithDefaultFileReplication

2020-12-24 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254757#comment-17254757 ] Huang Xingbo commented on FLINK-20461: -- [~hpeter] The frequency of this test case is not high, you

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

2020-12-24 Thread GitBox
flinkbot commented on pull request #14492: URL: https://github.com/apache/flink/pull/14492#issuecomment-751192778 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-20756) PythonCalcSplitConditionRule is not working as expected

2020-12-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20756: --- Labels: pull-request-available (was: ) > PythonCalcSplitConditionRule is not working as

[GitHub] [flink] HuangXingBo opened a new pull request #14492: [FLINK-20756][python] Add PythonCalcSplitConditionRexFieldRule

2020-12-24 Thread GitBox
HuangXingBo opened a new pull request #14492: URL: https://github.com/apache/flink/pull/14492 ## What is the purpose of the change *This pull request will add `PythonCalcSplitConditionRexFieldRule`* ## Brief change log - *Add

[GitHub] [flink] flinkbot edited a comment on pull request #14472: [Flink-20736] Separate implementation of BatchExecLimit,StreamExecLimit,StreamExecRank

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14472: URL: https://github.com/apache/flink/pull/14472#issuecomment-750005686 ## CI report: * 9135cbb7f107ee96b15de4b0a3453d60ee5b9de6 Azure:

[jira] [Commented] (FLINK-20461) YARNFileReplicationITCase.testPerJobModeWithDefaultFileReplication

2020-12-24 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254750#comment-17254750 ] Zhenqiu Huang commented on FLINK-20461: --- [~hxbks2ks] [~xintongsong] Looks like the issue doesn't

[jira] [Commented] (FLINK-15656) Support user-specified pod templates

2020-12-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254748#comment-17254748 ] Yang Wang commented on FLINK-15656: --- This ticket has the precedence than directly introducing some 

[jira] [Commented] (FLINK-15656) Support user-specified pod templates

2020-12-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254746#comment-17254746 ] Yang Wang commented on FLINK-15656: --- cc [~xintongsong] Since there's no response from [~felixzheng] 

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

2020-12-24 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] [Updated] (FLINK-15656) Support user-specified pod templates

2020-12-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15656: -- Fix Version/s: 1.13.0 > Support user-specified pod templates > >

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

2020-12-24 Thread GitBox
wangyang0918 commented 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

[jira] [Updated] (FLINK-20462) MailboxOperatorTest.testAvoidTaskStarvation

2020-12-24 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-20462: - Affects Version/s: 1.13.0 > MailboxOperatorTest.testAvoidTaskStarvation >

[jira] [Commented] (FLINK-20462) MailboxOperatorTest.testAvoidTaskStarvation

2020-12-24 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254744#comment-17254744 ] Huang Xingbo commented on FLINK-20462: -- instance in Master

[jira] [Commented] (FLINK-20461) YARNFileReplicationITCase.testPerJobModeWithDefaultFileReplication

2020-12-24 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254743#comment-17254743 ] Huang Xingbo commented on FLINK-20461: --

[jira] [Commented] (FLINK-20633) test_configuration.test_add_all test failed in py35

2020-12-24 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254742#comment-17254742 ] Huang Xingbo commented on FLINK-20633: --

[jira] [Commented] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

2020-12-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254741#comment-17254741 ] Yang Wang commented on FLINK-20648: --- [~dmvk] Could you help to verify that this issue is fixed in your

[jira] [Commented] (FLINK-19446) canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

2020-12-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254740#comment-17254740 ] Jark Wu commented on FLINK-19446: - This is not fixed yet. [~Balro]. > canal-json has a situation that

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

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324 ## CI report: * d083b630115604e34b0a74498890aedbff61b2a7 UNKNOWN * 67e9e1e4c013b78eaee9fc9d215ef400bba5cc59 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-749019176 ## CI report: * d07d1cc70e51f673ed01f8fde9d8102f00afe494 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-749019176 ## CI report: * 42ac67bd1936e7ee7dc7201cb4598011495d524f Azure:

[jira] [Commented] (FLINK-20760) Broken doc link in Apache Flink Code Style and Quality Guide

2020-12-24 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254733#comment-17254733 ] Shengkai Fang commented on FLINK-20760: --- [~liqi25] Sure. > Broken doc link in Apache Flink Code

[GitHub] [flink] flinkbot commented on pull request #14491: Merge pull request #1 from apache/master

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

[GitHub] [flink] littleflowerfa closed pull request #14491: Merge pull request #1 from apache/master

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

[GitHub] [flink] littleflowerfa opened a new pull request #14491: Merge pull request #1 from apache/master

2020-12-24 Thread GitBox
littleflowerfa opened a new pull request #14491: URL: https://github.com/apache/flink/pull/14491 merge ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[jira] [Assigned] (FLINK-20760) Broken doc link in Apache Flink Code Style and Quality Guide

2020-12-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20760: --- Assignee: liqi > Broken doc link in Apache Flink Code Style and Quality Guide >

[GitHub] [flink] flinkbot edited a comment on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-749019176 ## CI report: * 42ac67bd1936e7ee7dc7201cb4598011495d524f Azure:

[jira] [Updated] (FLINK-20760) Broken doc link in Apache Flink Code Style and Quality Guide

2020-12-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20760: Component/s: Project Website > Broken doc link in Apache Flink Code Style and Quality Guide >

[jira] [Commented] (FLINK-19446) canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

2020-12-24 Thread WangRuoQi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254729#comment-17254729 ] WangRuoQi commented on FLINK-19446: --- Is this issue fixed on version 1.13? > canal-json has a

[GitHub] [flink] leonardBang commented on pull request #14084: [FLINK-15867][table-planner-blink] Support time-related types for FIRST_VALUE and LAST_VALUE aggregate functions

2020-12-24 Thread GitBox
leonardBang commented on pull request #14084: URL: https://github.com/apache/flink/pull/14084#issuecomment-751163434 Hi @shmyer Do you have time to update this PR? This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-20642) Introduce InternalRow to optimize Row used in Python UDAF

2020-12-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20642. --- Resolution: Fixed Merged to master via 3b8998d5f3919162132681fee2b4689e9ff14c5b > Introduce InternalRow to

[GitHub] [flink] dianfu closed pull request #14487: [FLINK-20642][python] Introduce InternalRow to optimize Row used in Python UDAF

2020-12-24 Thread GitBox
dianfu closed pull request #14487: URL: https://github.com/apache/flink/pull/14487 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] [Commented] (FLINK-20359) Support adding Owner Reference to Job Manager in native kubernetes setup

2020-12-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254726#comment-17254726 ] Xintong Song commented on FLINK-20359: -- [~lublinsky], I've assigned you. Will take a look at the

[jira] [Updated] (FLINK-20763) canal format parse update record with null value get wrong result

2020-12-24 Thread WangRuoQi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WangRuoQi updated FLINK-20763: -- Attachment: canal_format.patch > canal format parse update record with null value get wrong result >

[jira] [Updated] (FLINK-20359) Support adding Owner Reference to Job Manager in native kubernetes setup

2020-12-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20359: - Fix Version/s: 1.12.1 > Support adding Owner Reference to Job Manager in native kubernetes

[jira] [Assigned] (FLINK-20359) Support adding Owner Reference to Job Manager in native kubernetes setup

2020-12-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20359: Assignee: Boris Lublinsky > Support adding Owner Reference to Job Manager in native

[GitHub] [flink] xintongsong edited a comment on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
xintongsong edited a comment on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-751162371 > [FLINK-20359](https://github.com/apache/flink/pull/14281), > [FLINK-20324](https://github.com/apache/flink/pull/14284), >

[GitHub] [flink] xintongsong commented on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
xintongsong commented on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-751162371 > [FLINK-20359](https://github.com/apache/flink/pull/14281), > [FLINK-20324](https://github.com/apache/flink/pull/14284), >

[jira] [Closed] (FLINK-20759) The separator causes job submission to fail through the flink command line

2020-12-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-20759. - Fix Version/s: (was: 1.13.0) Resolution: Not A Problem Not a problem. > The separator

[GitHub] [flink] wangyang0918 commented on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
wangyang0918 commented on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-751161546 @blublinsky For FLINK-20359, I will have a look in this week. And the other two tickets, let's do the pod template first.

[jira] [Commented] (FLINK-20359) Support adding Owner Reference to Job Manager in native kubernetes setup

2020-12-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254723#comment-17254723 ] Yang Wang commented on FLINK-20359: --- cc [~xintongsong] Could you please assign this ticket to

[GitHub] [flink] flinkbot edited a comment on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-749019176 ## CI report: * 42ac67bd1936e7ee7dc7201cb4598011495d524f Azure:

[GitHub] [flink] blublinsky commented on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
blublinsky commented on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-751160248 [FLINK-20359](https://github.com/apache/flink/pull/14281), [FLINK-20324](https://github.com/apache/flink/pull/14284),

[GitHub] [flink] flinkbot edited a comment on pull request #13800: [FLINK-19650][connectors jdbc]Support the limit push down for the Jdb…

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #13800: URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623 ## CI report: * f408d4cb2758fe350988e815b93b1c48d15497aa Azure:

[GitHub] [flink] xintongsong commented on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
xintongsong commented on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-751159951 @blublinsky Which other PRs do you mean? This is an automated message from the Apache Git Service. To

[GitHub] [flink] blublinsky commented on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
blublinsky commented on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-751159447 Thanks guys, can we do the same with other PRs? This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

2020-12-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254722#comment-17254722 ] Xintong Song commented on FLINK-20505: -- I'd suggest to close the ticket as `Won't Do` and open

[jira] [Commented] (FLINK-20760) Broken doc link in Apache Flink Code Style and Quality Guide

2020-12-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254721#comment-17254721 ] 李奇 commented on FLINK-20760: Hi,can you assign this issue to me? > Broken doc link in Apache Flink Code

[jira] [Updated] (FLINK-20767) add nested field support for SupportsFilterPushDown

2020-12-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20767: Parent: FLINK-16987 Issue Type: Sub-task (was: Improvement) > add nested field support for

[GitHub] [flink] flinkbot edited a comment on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-749019176 ## CI report: * 42ac67bd1936e7ee7dc7201cb4598011495d524f Azure:

[GitHub] [flink] wangyang0918 commented on a change in pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
wangyang0918 commented on a change in pull request #14447: URL: https://github.com/apache/flink/pull/14447#discussion_r548783056 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java ## @@ -53,13 +53,27 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13800: [FLINK-19650][connectors jdbc]Support the limit push down for the Jdb…

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #13800: URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623 ## CI report: * f408d4cb2758fe350988e815b93b1c48d15497aa Azure:

[GitHub] [flink] JackWangCS commented on pull request #14452: [FLINK-20710][Hive] HiveTableInputFormat and HiveSourceFileEnumerator will throw IllegalArgumentException when creating splits for tables

2020-12-24 Thread GitBox
JackWangCS commented on pull request #14452: URL: https://github.com/apache/flink/pull/14452#issuecomment-751156950 @JingsongLi , do we have any plan to support write(INSERT INTO and INSERT OVERWRITE) hive partitions on different nameservices? It's very common that some old partitions of

[jira] [Commented] (FLINK-20692) Allow set line delimiter using CsvRowDeserializationSchema

2020-12-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254715#comment-17254715 ] Jark Wu commented on FLINK-20692: - Why do you need to split line for the csv in Kafka? IIUC, the csv

[jira] [Comment Edited] (FLINK-16108) StreamSQLExample is failed if running in blink planner

2020-12-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254713#comment-17254713 ] Jark Wu edited comment on FLINK-16108 at 12/25/20, 3:03 AM: Hi [~wtog],

[jira] [Comment Edited] (FLINK-16108) StreamSQLExample is failed if running in blink planner

2020-12-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254713#comment-17254713 ] Jark Wu edited comment on FLINK-16108 at 12/25/20, 3:02 AM: Hi [~wtog],

[jira] [Commented] (FLINK-16108) StreamSQLExample is failed if running in blink planner

2020-12-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254713#comment-17254713 ] Jark Wu commented on FLINK-16108: - Hi [~wtog], {{INSERT INTO}} mapping fields of query to fields of sink

[GitHub] [flink] JingsongLi commented on pull request #14452: [FLINK-20710][Hive] HiveTableInputFormat and HiveSourceFileEnumerator will throw IllegalArgumentException when creating splits for tables

2020-12-24 Thread GitBox
JingsongLi commented on pull request #14452: URL: https://github.com/apache/flink/pull/14452#issuecomment-751156218 +1 Merged to commit "[FLINK-20710][hive] Hive reading fail when splits on different FileSystem nameservices"

[GitHub] [flink] xintongsong commented on a change in pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-24 Thread GitBox
xintongsong commented on a change in pull request #14447: URL: https://github.com/apache/flink/pull/14447#discussion_r548777962 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java ## @@ -53,13 +53,27 @@

[GitHub] [flink] JingsongLi merged pull request #14452: [FLINK-20710][Hive] HiveTableInputFormat and HiveSourceFileEnumerator will throw IllegalArgumentException when creating splits for tables with p

2020-12-24 Thread GitBox
JingsongLi merged pull request #14452: URL: https://github.com/apache/flink/pull/14452 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

[jira] [Closed] (FLINK-20763) canal format parse update record with null value get wrong result

2020-12-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20763. --- Resolution: Duplicate > canal format parse update record with null value get wrong result >

[jira] [Created] (FLINK-20767) add nested field support for SupportsFilterPushDown

2020-12-24 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-20767: - Summary: add nested field support for SupportsFilterPushDown Key: FLINK-20767 URL: https://issues.apache.org/jira/browse/FLINK-20767 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #14472: [Flink-20736] Separate implementation of BatchExecLimit,StreamExecLimit,StreamExecRank

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14472: URL: https://github.com/apache/flink/pull/14472#issuecomment-750005686 ## CI report: * 9135cbb7f107ee96b15de4b0a3453d60ee5b9de6 Azure:

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

2020-12-24 Thread GitBox
SteNicholas commented 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 to add a

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

2020-12-24 Thread GitBox
SteNicholas edited 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` > *

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

2020-12-24 Thread GitBox
SteNicholas commented 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_types

[GitHub] [flink] lirui-apache commented on pull request #14484: [FLINK-20722][hive] HiveTableSink should copy the record when convert…

2020-12-24 Thread GitBox
lirui-apache commented on pull request #14484: URL: https://github.com/apache/flink/pull/14484#issuecomment-751154305 Hi @godfreyhe , could you help review this PR? Thanks. This is an automated message from the Apache Git

[GitHub] [flink] dianfu commented on a change in pull request #14473: [FLINK-20702][python] Support Map Operation Chained Together in Python Table API

2020-12-24 Thread GitBox
dianfu commented on a change in pull request #14473: URL: https://github.com/apache/flink/pull/14473#discussion_r548780762 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PythonCalcMergeRule.java ## @@ -0,0

[jira] [Commented] (FLINK-20762) Remove unused checkpointStorage path after job finished

2020-12-24 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254710#comment-17254710 ] Yun Tang commented on FLINK-20762: -- [~Jiangang] I think you could read some existing information and

[jira] [Comment Edited] (FLINK-20762) Remove unused checkpointStorage path after job finished

2020-12-24 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254710#comment-17254710 ] Yun Tang edited comment on FLINK-20762 at 12/25/20, 2:46 AM: - [~Jiangang] I

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

2020-12-24 Thread Wenlong Lyu (Jira)
Wenlong Lyu created FLINK-20766: --- Summary: Separate the implementation of stream sort nodes Key: FLINK-20766 URL: https://issues.apache.org/jira/browse/FLINK-20766 Project: Flink Issue Type:

[jira] [Commented] (FLINK-20765) ScalarOperatorGens doesn't set proper nullability for result type of generated expressions

2020-12-24 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254709#comment-17254709 ] Rui Li commented on FLINK-20765: It seems that {{ScalarOperatorGens}} always generates expressions will

[GitHub] [flink] flinkbot edited a comment on pull request #14489: [FLINK-20764] In BatchGroupedReduceOperator, fix timer logic

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14489: URL: https://github.com/apache/flink/pull/14489#issuecomment-751064657 ## CI report: * 9b02c1a275368284a86403f38a2eab0a65bd1299 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14472: [Flink-20736] Separate implementation of BatchExecLimit,StreamExecLimit,StreamExecRank

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14472: URL: https://github.com/apache/flink/pull/14472#issuecomment-750005686 ## CI report: * 9135cbb7f107ee96b15de4b0a3453d60ee5b9de6 Azure:

[jira] [Updated] (FLINK-20765) ScalarOperatorGens doesn't set proper nullability for result type of generated expressions

2020-12-24 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-20765: --- Description: Suppose we have a function that takes a BOOLEAN NOT NULL parameter: {code} /**

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

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14451: URL: https://github.com/apache/flink/pull/14451#issuecomment-749321360 ## CI report: * 573a9ab1bd4b6b68d428b6de6b7700debabfb162 Azure:

[jira] [Created] (FLINK-20765) ScalarOperatorGens doesn't set proper nullability for result type of generated expressions

2020-12-24 Thread Rui Li (Jira)
Rui Li created FLINK-20765: -- Summary: ScalarOperatorGens doesn't set proper nullability for result type of generated expressions Key: FLINK-20765 URL: https://issues.apache.org/jira/browse/FLINK-20765

[jira] [Updated] (FLINK-20763) canal format parse update record with null value get wrong result

2020-12-24 Thread WangRuoQi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WangRuoQi updated FLINK-20763: -- Description: When i use canal format to consume mysql binlog like this: {code:java} select

[GitHub] [flink] wenlong88 commented on pull request #14472: [Flink-20736] Separate implementation of BatchExecLimit,StreamExecLimit,StreamExecRank

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

[GitHub] [flink] wuchong commented on pull request #14466: [FLINK-20657][connectors/jdbc] Migrate jdbc InputFormat/LookupFunction to SimpleJdbcConnectionProvider for connection establishment

2020-12-24 Thread GitBox
wuchong commented on pull request #14466: URL: https://github.com/apache/flink/pull/14466#issuecomment-751150556 Btw, I just merged #14387 which added `isConnectionValid` method to `JdbcConnectionProvider`. Could you rebase the branch and adapt the code?

[jira] [Closed] (FLINK-19691) Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19691. --- Resolution: Fixed Fixed in master: f5e829c4ffed88e1a79b76e9fc8579013502ddc0 > Expose

[jira] [Updated] (FLINK-19691) Support connection.max-retry-timeout configuration for JDBC connector

2020-12-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19691: Summary: Support connection.max-retry-timeout configuration for JDBC connector (was: Expose

[jira] [Closed] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

2020-12-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20552. --- Resolution: Fixed Fixed in master: 21a08ea5696c92505f85f3cba0e47e32d7c1e21d > JdbcDynamicTableSink doesn't

[GitHub] [flink] wuchong closed pull request #14387: [FLINK-19691][jdbc] Support connection.max-retry-timeout configuration for JDBC connector

2020-12-24 Thread GitBox
wuchong closed pull request #14387: URL: https://github.com/apache/flink/pull/14387 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] wuchong merged pull request #14468: [FLINK-20552][connectors/jdbc] JdbcDynamicTableSink doesn't sink buff…

2020-12-24 Thread GitBox
wuchong merged pull request #14468: URL: https://github.com/apache/flink/pull/14468 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 #14451: [FLINK-20704][table-planner] Some rel data type does not implement th…

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14451: URL: https://github.com/apache/flink/pull/14451#issuecomment-749321360 ## CI report: * 573a9ab1bd4b6b68d428b6de6b7700debabfb162 Azure:

[GitHub] [flink] wuchong commented on a change in pull request #14466: [FLINK-20657][connectors/jdbc] Migrate jdbc InputFormat/LookupFunction to SimpleJdbcConnectionProvider for connection establishme

2020-12-24 Thread GitBox
wuchong commented on a change in pull request #14466: URL: https://github.com/apache/flink/pull/14466#discussion_r548779793 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/connection/JdbcConnectionProvider.java ## @@

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

2020-12-24 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254702#comment-17254702 ] Huang Xingbo commented on FLINK-20756: -- [~zhongwei] Thanks a lot for reporting this issue. I will

[GitHub] [flink] flinkbot edited a comment on pull request #14490: [FLINK-19667] Add AWS Glue Schema Registry integration

2020-12-24 Thread GitBox
flinkbot edited a comment on pull request #14490: URL: https://github.com/apache/flink/pull/14490#issuecomment-751138236 ## CI report: * aaab180b545b8845af8ba761102a3e2eb46b7f16 Azure:

[GitHub] [flink] xintongsong closed pull request #14485: [FLINK-20648][coordination][k8s] Start leader election service before creating JobMaster

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

[GitHub] [flink] xintongsong commented on pull request #14485: [FLINK-20648][coordination][k8s] Start leader election service before creating JobMaster

2020-12-24 Thread GitBox
xintongsong commented on pull request #14485: URL: https://github.com/apache/flink/pull/14485#issuecomment-751142558 Merged in 2c92ea9a06fc13d8adedd4cd5737ab89cd0a7334 This is an automated message from the Apache Git

[jira] [Closed] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

2020-12-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20648. Resolution: Fixed Fixed on release-1.12 via: * 368b204d82ea274be9a47d7f1b9d24c7365c3b2d Fixed

[GitHub] [flink] xintongsong closed pull request #14486: [FLINK-20648][k8s] Add itcase for recovering from savepoint with Kubernetes HA enabled

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

  1   2   3   >