[GitHub] [flink] flinkbot commented on pull request #15001: [FLINK-20332][runtime][k8s] Add recovered workers to pending resources for native k8s deployment

2021-02-23 Thread GitBox
flinkbot commented on pull request #15001: URL: https://github.com/apache/flink/pull/15001#issuecomment-784869362 ## CI report: * b8237298acc221208fc15cfbda8ccd6416e85740 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

2021-02-23 Thread GitBox
flinkbot edited a comment on pull request #14678: URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721 ## CI report: * cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN * 9e445296314a2bfde4c85b61f1a3d9ee892c97ba UNKNOWN Bot commands The

[jira] [Commented] (FLINK-21444) Lookup joins should deal with intermediate table scans correctly

2021-02-23 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289739#comment-17289739 ] Caizhi Weng commented on FLINK-21444: - After a deeper look into this problem I discover that this

[jira] [Commented] (FLINK-21473) Migrate ParquetInputFormat to BulkFormat interface

2021-02-23 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289738#comment-17289738 ] Etienne Chauchot commented on FLINK-21473: -- cool ! voted +1 :) > Migrate ParquetInputFormat to

[jira] [Updated] (FLINK-21444) Lookup joins should deal with intermediate table scans correctly

2021-02-23 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-21444: Description: Add the following test case to

[jira] [Commented] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

2021-02-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289733#comment-17289733 ] Xintong Song commented on FLINK-21236: -- {quote}[~xintongsong], [~trohrmann], [~ykt836], to

[GitHub] [flink] leonardBang edited a comment on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-02-23 Thread GitBox
leonardBang edited a comment on pull request #14977: URL: https://github.com/apache/flink/pull/14977#issuecomment-784862283 > https://github.com/apache/flink/blob/master/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java > > ```

[GitHub] [flink] leonardBang commented on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-02-23 Thread GitBox
leonardBang commented on pull request #14977: URL: https://github.com/apache/flink/pull/14977#issuecomment-784862283 > https://github.com/apache/flink/blob/master/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java > > ``` >

[jira] [Commented] (FLINK-21476) How to appoint jobname

2021-02-23 Thread jjiey (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289730#comment-17289730 ] jjiey commented on FLINK-21476: --- It's a duplicate issues, you can specify in this way: val tabConf =

[GitHub] [flink-statefun] tzulitai commented on pull request #201: [FLINK-21459] [sdks] Implement remote Java SDK

2021-02-23 Thread GitBox
tzulitai commented on pull request #201: URL: https://github.com/apache/flink-statefun/pull/201#issuecomment-784858955 The CI was failing due to E2Es (incompatibility between the Testcontainer usage of the Docker Java API + the Docker version used by Github Actions). I've disabled the E2E

[jira] [Commented] (FLINK-21393) Implement ParquetAvroInputFormat

2021-02-23 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289729#comment-17289729 ] Timo Walther commented on FLINK-21393: -- What is the status of the new source interfaces? Is it

[GitHub] [flink] flinkbot commented on pull request #15001: [FLINK-20332][runtime][k8s] Add recovered workers to pending resources for native k8s deployment

2021-02-23 Thread GitBox
flinkbot commented on pull request #15001: URL: https://github.com/apache/flink/pull/15001#issuecomment-784858319 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] flinkbot edited a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
flinkbot edited a comment on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-759361463 ## CI report: * 4e37e897e9cce7d900d4d22a3e50e1314f5239cb Azure:

[jira] [Updated] (FLINK-20332) Add workers recovered from previous attempt to pending resources

2021-02-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20332: --- Labels: pull-request-available (was: ) > Add workers recovered from previous attempt to

[GitHub] [flink] xintongsong opened a new pull request #15001: [FLINK-20332][runtime][k8s] Add recovered workers to pending resources for native k8s deployment

2021-02-23 Thread GitBox
xintongsong opened a new pull request #15001: URL: https://github.com/apache/flink/pull/15001 ## 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 re-transferring

[jira] [Commented] (FLINK-21468) ParquetTableSource: where clause on integer does not work

2021-02-23 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289724#comment-17289724 ] Etienne Chauchot commented on FLINK-21468: -- Hi [~ZhenqiuHuang], thanks for the quick reply ! >

[jira] [Commented] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

2021-02-23 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289723#comment-17289723 ] Dawid Wysakowicz commented on FLINK-21214: --

[jira] [Commented] (FLINK-21393) Implement ParquetAvroInputFormat

2021-02-23 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289722#comment-17289722 ] Etienne Chauchot commented on FLINK-21393: -- [~Wosinsan] I'm sorry I started to implement this

[jira] [Updated] (FLINK-21468) ParquetTableSource: where clause on integer does not work

2021-02-23 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated FLINK-21468: - Description: Using _ParquetTableSource_ with a parquet field mapped (at least for

[jira] [Created] (FLINK-21476) How to appoint jobname

2021-02-23 Thread ranqiqiang (Jira)
ranqiqiang created FLINK-21476: -- Summary: How to appoint jobname Key: FLINK-21476 URL: https://issues.apache.org/jira/browse/FLINK-21476 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-02-23 Thread GitBox
flinkbot edited a comment on pull request #14977: URL: https://github.com/apache/flink/pull/14977#issuecomment-783054931 ## CI report: * 9b596a1dded4d768f64b785205d1ce01ff79671b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-02-23 Thread GitBox
flinkbot edited a comment on pull request #14868: URL: https://github.com/apache/flink/pull/14868#issuecomment-773192044 ## CI report: * 997d4dddfc4d6ae2f45d80102655d02f09168d1b Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

2021-02-23 Thread GitBox
rkhachatryan commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r581677040 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/changelog/state/ChangelogAggregatingState.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
flinkbot edited a comment on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-759361463 ## CI report: * 4e37e897e9cce7d900d4d22a3e50e1314f5239cb Azure:

[GitHub] [flink] Thesharing commented on a change in pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-02-23 Thread GitBox
Thesharing commented on a change in pull request #14868: URL: https://github.com/apache/flink/pull/14868#discussion_r581676700 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManagerBuildUtil.java ## @@ -0,0 +1,174 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-12607) Introduce a REST API that returns the maxParallelism of a job

2021-02-23 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289713#comment-17289713 ] Robert Metzger commented on FLINK-12607: Sorry for my delayed response. Yes, you can set

[GitHub] [flink] wangyang0918 commented on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
wangyang0918 commented on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-784837661 cc @tillrohrmann I have addressed the comments and force pushed. This is an automated message from the

[GitHub] [flink] Thesharing commented on a change in pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-02-23 Thread GitBox
Thesharing commented on a change in pull request #14868: URL: https://github.com/apache/flink/pull/14868#discussion_r581615458 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManagerBuildUtil.java ## @@ -0,0 +1,174 @@ +/* + * Licensed to

[GitHub] [flink] Thesharing commented on a change in pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-02-23 Thread GitBox
Thesharing commented on a change in pull request #14868: URL: https://github.com/apache/flink/pull/14868#discussion_r581615048 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManagerBuildUtil.java ## @@ -0,0 +1,174 @@ +/* + * Licensed to

[GitHub] [flink] Thesharing commented on a change in pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-02-23 Thread GitBox
Thesharing commented on a change in pull request #14868: URL: https://github.com/apache/flink/pull/14868#discussion_r581008912 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/DistributionPattern.java ## @@ -18,29 +18,15 @@ package

[GitHub] [flink] Thesharing commented on a change in pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-02-23 Thread GitBox
Thesharing commented on a change in pull request #14868: URL: https://github.com/apache/flink/pull/14868#discussion_r581003377 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartition.java ## @@ -90,21 +89,12 @@ void

[GitHub] [flink] flinkbot edited a comment on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-02-23 Thread GitBox
flinkbot edited a comment on pull request #14977: URL: https://github.com/apache/flink/pull/14977#issuecomment-783054931 ## CI report: * 9b596a1dded4d768f64b785205d1ce01ff79671b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-02-23 Thread GitBox
flinkbot edited a comment on pull request #14868: URL: https://github.com/apache/flink/pull/14868#issuecomment-773192044 ## CI report: * 997d4dddfc4d6ae2f45d80102655d02f09168d1b Azure:

[jira] [Commented] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram

2021-02-23 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289707#comment-17289707 ] Matthias commented on FLINK-21445: -- Thanks for taking over here, [~nicholasjiang]. It was on my list

[jira] [Assigned] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram

2021-02-23 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-21445: Assignee: Nicholas Jiang (was: Matthias) > Application mode does not set the configuration when

[jira] [Assigned] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram

2021-02-23 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-21445: Assignee: Matthias > Application mode does not set the configuration when building

[GitHub] [flink] Thesharing commented on a change in pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-02-23 Thread GitBox
Thesharing commented on a change in pull request #14868: URL: https://github.com/apache/flink/pull/14868#discussion_r581001291 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartition.java ## @@ -32,25 +32,24 @@

[GitHub] [flink] docete commented on a change in pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-02-23 Thread GitBox
docete commented on a change in pull request #14977: URL: https://github.com/apache/flink/pull/14977#discussion_r581667233 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/table/TableSinkITCase.scala ## @@ -838,6

[jira] [Updated] (FLINK-21411) The components on which Flink depends may contain vulnerabilities. If yes, fix them.

2021-02-23 Thread dgbro (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dgbro updated FLINK-21411: -- Description: In Flink v1.11.3 contains mesos(version: 1.0.1) okhttp(version: 3.7.0) log4j(version:2.12.1)

[jira] [Updated] (FLINK-21475) StateWithExecutionGraph.suspend fails with IllegalStateException

2021-02-23 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21475: --- Issue Type: Bug (was: New Feature) > StateWithExecutionGraph.suspend fails with

[jira] [Created] (FLINK-21475) StateWithExecutionGraph.suspend fails with IllegalStateException

2021-02-23 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-21475: -- Summary: StateWithExecutionGraph.suspend fails with IllegalStateException Key: FLINK-21475 URL: https://issues.apache.org/jira/browse/FLINK-21475 Project: Flink

[jira] [Commented] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

2021-02-23 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289675#comment-17289675 ] Nicholas Jiang commented on FLINK-21236: [~xintongsong], [~trohrmann], [~ykt836], to summarize,

[jira] [Commented] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram

2021-02-23 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289674#comment-17289674 ] Nicholas Jiang commented on FLINK-21445: [~fly_in_gis], [~mapohl], I would like to do a bit

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

2021-02-23 Thread GitBox
curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r581644315 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/changelog/state/ChangelogAggregatingState.java ## @@ -0,0

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r581639223 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesFactoryWithPodTemplateTestBase.java ## @@

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r581600918 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesFactoryWithPodTemplateTestBase.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #15000: [FLINK-21453][checkpointing] Do not ignore endOfInput when terminating a job with savepoint

2021-02-23 Thread GitBox
flinkbot edited a comment on pull request #15000: URL: https://github.com/apache/flink/pull/15000#issuecomment-784489457 ## CI report: * 4e4231296c7fa16f15e412497c9d0bef1cb79e84 UNKNOWN * c2ded9ce880794d345203018c323c9dceea4a514 Azure:

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r581608052 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesFactoryWithPodTemplateTestBase.java ## @@

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r581591845 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java ## @@ -339,6 +339,11 @@ public void

[jira] [Commented] (FLINK-21397) BufferUnderflowException when read parquet

2021-02-23 Thread lihe ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289662#comment-17289662 ] lihe ma commented on FLINK-21397: - thanks for your reply,  I set source.reader.element.queue.capacity to

[jira] [Updated] (FLINK-21472) FencingTokenException: Fencing token mismatch

2021-02-23 Thread hayden zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-21472: Description: org.apache.flink.runtime.rest.handler.job.JobsOverviewHandler [] - Unhandled

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r581608052 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesFactoryWithPodTemplateTestBase.java ## @@

[GitHub] [flink] sllence commented on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-02-23 Thread GitBox
sllence commented on pull request #14977: URL: https://github.com/apache/flink/pull/14977#issuecomment-784740389

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r581608052 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesFactoryWithPodTemplateTestBase.java ## @@

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r581605815 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/utils/KubernetesUtilsTest.java ## @@ -75,6 +81,91 @@ public void

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r581600918 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesFactoryWithPodTemplateTestBase.java ## @@

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r581595192 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -396,6 +401,42 @@ public static String

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r581594031 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -396,6 +401,42 @@ public static String

[jira] [Closed] (FLINK-21461) FileNotFoundException when sink to hive

2021-02-23 Thread zhuxiaoshang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuxiaoshang closed FLINK-21461. Resolution: Not A Problem > FileNotFoundException when sink to hive >

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r581591845 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java ## @@ -339,6 +339,11 @@ public void

[jira] [Commented] (FLINK-21461) FileNotFoundException when sink to hive

2021-02-23 Thread zhuxiaoshang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289623#comment-17289623 ] zhuxiaoshang commented on FLINK-21461: -- our legacy spark compaction program cause this. Not a

[GitHub] [flink] wuchong commented on pull request #14840: [FLINK-21231][sql-client] add "SHOW VIEWS" to SQL client

2021-02-23 Thread GitBox
wuchong commented on pull request #14840: URL: https://github.com/apache/flink/pull/14840#issuecomment-784725659 Could you rebase and resolve the conflicts first? I will review this PR after that. This is an automated

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-23 Thread GitBox
wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r581591845 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java ## @@ -339,6 +339,11 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-02-23 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN *

[GitHub] [flink] wuchong commented on a change in pull request #12803: [FLINK-18461][table-planner-blink] Fix Changelog source can't be insert into upsert sink

2021-02-23 Thread GitBox
wuchong commented on a change in pull request #12803: URL: https://github.com/apache/flink/pull/12803#discussion_r581589324 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/BufferReduceStatementExecutor.java

[GitHub] [flink] kylemeow commented on a change in pull request #12803: [FLINK-18461][table-planner-blink] Fix Changelog source can't be insert into upsert sink

2021-02-23 Thread GitBox
kylemeow commented on a change in pull request #12803: URL: https://github.com/apache/flink/pull/12803#discussion_r581588515 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/BufferReduceStatementExecutor.java

[jira] [Updated] (FLINK-21455) Deploy history server on kubernetes

2021-02-23 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-21455: Component/s: Deployment / Kubernetes > Deploy history server on kubernetes >

[jira] [Commented] (FLINK-21474) Migrate ParquetTableSource to use DynamicTableSource Interface

2021-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289596#comment-17289596 ] Jingsong Lee commented on FLINK-21474: -- I think we can just connect new ParquetInputFormat in 

[jira] [Reopened] (FLINK-20984) can not convert an array into Table

2021-02-23 Thread Spongebob (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spongebob reopened FLINK-20984: --- It is too easier to catch the network buffer memory exceed exception when using fromValues to build a

[jira] [Assigned] (FLINK-21474) Migrate ParquetTableSource to use DynamicTableSource Interface

2021-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-21474: Assignee: Zhenqiu Huang > Migrate ParquetTableSource to use DynamicTableSource Interface

[jira] [Updated] (FLINK-21474) Migrate ParquetTableSource to use DynamicTableSource Interface

2021-02-23 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-21474: -- Summary: Migrate ParquetTableSource to use DynamicTableSource Interface (was: Migrate

[jira] [Assigned] (FLINK-21473) Migrate ParquetInputFormat to BulkFormat interface

2021-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-21473: Assignee: Zhenqiu Huang > Migrate ParquetInputFormat to BulkFormat interface >

[jira] [Updated] (FLINK-21474) Migrate ParquetTableSource to DynamicTable Source Interface

2021-02-23 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-21474: -- Summary: Migrate ParquetTableSource to DynamicTable Source Interface (was: Migrate

[jira] [Updated] (FLINK-21474) Migrate ParquetTableSource to DynamicTableSource Interface

2021-02-23 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-21474: -- Summary: Migrate ParquetTableSource to DynamicTableSource Interface (was: Migrate

[jira] [Created] (FLINK-21474) Migrate FileSystemTableSource to DynamicTable Source Interface

2021-02-23 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-21474: - Summary: Migrate FileSystemTableSource to DynamicTable Source Interface Key: FLINK-21474 URL: https://issues.apache.org/jira/browse/FLINK-21474 Project: Flink

[jira] [Closed] (FLINK-21005) Introduce new provider for unified Sink API and implement in planner

2021-02-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21005. --- Resolution: Fixed Fixed in master: 3ac83641c52dfa4fa67366c62335bcb7ee8a6624 > Introduce new provider for

[GitHub] [flink] wuchong merged pull request #14822: [FLINK-21005][table-api] Introduce new provider for unified Sink API and implement in planner

2021-02-23 Thread GitBox
wuchong merged pull request #14822: URL: https://github.com/apache/flink/pull/14822 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] [Created] (FLINK-21473) Migrate ParquetInputFormat to BulkFormat interface

2021-02-23 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-21473: - Summary: Migrate ParquetInputFormat to BulkFormat interface Key: FLINK-21473 URL: https://issues.apache.org/jira/browse/FLINK-21473 Project: Flink Issue

[GitHub] [flink-statefun] sjwiesman edited a comment on pull request #201: [FLINK-21459] [sdks] Implement remote Java SDK

2021-02-23 Thread GitBox
sjwiesman edited a comment on pull request #201: URL: https://github.com/apache/flink-statefun/pull/201#issuecomment-784384927  Very excited to see this. I did not do a code review but I spent today building a demo to get my head in the right space for the new docs and there’s one things

[GitHub] [flink-statefun] sjwiesman edited a comment on pull request #201: [FLINK-21459] [sdks] Implement remote Java SDK

2021-02-23 Thread GitBox
sjwiesman edited a comment on pull request #201: URL: https://github.com/apache/flink-statefun/pull/201#issuecomment-784384927  Very excited to see this. I did not do a code review but I spent today building a demo to get my head in the right space for the new docs and there’s one things

[jira] [Created] (FLINK-21472) encingTokenException: Fencing token mismatch

2021-02-23 Thread hayden zhou (Jira)
hayden zhou created FLINK-21472: --- Summary: encingTokenException: Fencing token mismatch Key: FLINK-21472 URL: https://issues.apache.org/jira/browse/FLINK-21472 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21471) jobmanger, taskmanager, and job hang abnormally, and the blobstore directory is not deleted

2021-02-23 Thread kangTwang (Jira)
kangTwang created FLINK-21471: - Summary: jobmanger, taskmanager, and job hang abnormally, and the blobstore directory is not deleted Key: FLINK-21471 URL: https://issues.apache.org/jira/browse/FLINK-21471

[jira] [Commented] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

2021-02-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289565#comment-17289565 ] 俞剑波 commented on FLINK-20951: - Thanks to the help of Jack and Rui Li, the configuration of this parameter is

[jira] [Commented] (FLINK-21231) add "SHOW VIEWS" to SQL client

2021-02-23 Thread tim yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289579#comment-17289579 ] tim yu commented on FLINK-21231: @Jingsong Lee (Jira) Could you please check the code of issue

[jira] [Commented] (FLINK-21359) CompatibilityResult issues with Flink 1.9.0

2021-02-23 Thread Siva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289547#comment-17289547 ] Siva commented on FLINK-21359: -- We are using BytesDeserializationSchema implements

[jira] [Commented] (FLINK-10407) FLIP-159: Reactive mode

2021-02-23 Thread John Phelan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289525#comment-17289525 ] John Phelan commented on FLINK-10407: - Nice! This looks huge! On Fri, Jan 22, 2021 at 7:33 AM Till

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 release

2021-02-23 Thread Piotr Gwiazda (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289481#comment-17289481 ] Piotr Gwiazda commented on FLINK-20632: --- Hi. It might be worth hosting the image somwhere else so

[jira] [Commented] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

2021-02-23 Thread hayden zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289456#comment-17289456 ] hayden zhou commented on FLINK-21325: - JobManager log is attached above just now. >

[jira] [Updated] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

2021-02-23 Thread hayden zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-21325: Attachment: flink--standalonesession-0-mta-flink-jobmanager-56cf5bbf6-2chwc.log >

[GitHub] [flink] PChou commented on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

2021-02-23 Thread GitBox
PChou commented on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-784663867 @wangyang0918 thanks for reviewing, hope for fixing in the next release! This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-23 Thread GitBox
flinkbot edited a comment on pull request #14847: URL: https://github.com/apache/flink/pull/14847#issuecomment-772387941 ## CI report: * 9a2ea20ce0803e48edfc3ab7bcc02078b7410fbf UNKNOWN * 4aecfae5f4889de59c7f1d71d39647b6ee6f9ad8 UNKNOWN *

[jira] [Created] (FLINK-21470) testSafetyNetClose fail

2021-02-23 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21470: - Summary: testSafetyNetClose fail Key: FLINK-21470 URL: https://issues.apache.org/jira/browse/FLINK-21470 Project: Flink Issue Type: Bug Components: API

[jira] [Updated] (FLINK-21470) testSafetyNetClose fail

2021-02-23 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21470: -- Labels: test-stability (was: ) > testSafetyNetClose fail > --- > >

[jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

2021-02-23 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289444#comment-17289444 ] Guowei Ma commented on FLINK-15493: ---

[jira] [Commented] (FLINK-21450) Add local recovery support to adaptive scheduler

2021-02-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-21450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289421#comment-17289421 ] Dominik Wosiński commented on FLINK-21450: -- I can try to tackle that. > Add local recovery

[jira] [Commented] (FLINK-21393) Implement ParquetAvroInputFormat

2021-02-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-21393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289420#comment-17289420 ] Dominik Wosiński commented on FLINK-21393: -- [~rmetzger] feel free to assign the [~echauchot],

[GitHub] [flink] flinkbot edited a comment on pull request #14822: [FLINK-21005][table-api] Introduce new provider for unified Sink API and implement in planner

2021-02-23 Thread GitBox
flinkbot edited a comment on pull request #14822: URL: https://github.com/apache/flink/pull/14822#issuecomment-770394744 ## CI report: * f555e1a49a573cac5e047eb20c75b944ef84ded3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15000: [FLINK-21453][checkpointing] Do not ignore endOfInput when terminating a job with savepoint

2021-02-23 Thread GitBox
flinkbot edited a comment on pull request #15000: URL: https://github.com/apache/flink/pull/15000#issuecomment-784489457 ## CI report: * 4e4231296c7fa16f15e412497c9d0bef1cb79e84 UNKNOWN * c3d684a81e5ce56ecbea25b4f91a1e2502322172 Azure:

[GitHub] [flink] advancedwebdeveloper commented on pull request #14934: Upgrade the os-maven-plugin depency, to version 1.7.0

2021-02-23 Thread GitBox
advancedwebdeveloper commented on pull request #14934: URL: https://github.com/apache/flink/pull/14934#issuecomment-784548588 @rmetzger , what's next? This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #15000: [FLINK-21453][checkpointing] Do not ignore endOfInput when terminating a job with savepoint

2021-02-23 Thread GitBox
flinkbot edited a comment on pull request #15000: URL: https://github.com/apache/flink/pull/15000#issuecomment-784489457 ## CI report: * 4e4231296c7fa16f15e412497c9d0bef1cb79e84 UNKNOWN * c3d684a81e5ce56ecbea25b4f91a1e2502322172 Azure:

  1   2   3   4   >