[GitHub] [flink] HuangXingBo commented on a change in pull request #14791: [FLINK-21168][python][table-planner-blink] Add support for general python group window aggregate function in Physical Rule an

2021-02-02 Thread GitBox
HuangXingBo commented on a change in pull request #14791: URL: https://github.com/apache/flink/pull/14791#discussion_r569200084 ## File path:

[jira] [Commented] (FLINK-21247) flink iceberg table map cannot convert to datastream

2021-02-02 Thread donglei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1728#comment-1728 ] donglei commented on FLINK-21247: -   i change code to this  and can run normally print map data can

[jira] [Updated] (FLINK-21247) flink iceberg table map cannot convert to datastream

2021-02-02 Thread donglei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] donglei updated FLINK-21247: Attachment: image-2021-02-03-15-53-18-244.png > flink iceberg table map cannot convert to datastream >

[jira] [Updated] (FLINK-21247) flink iceberg table map cannot convert to datastream

2021-02-02 Thread donglei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] donglei updated FLINK-21247: Attachment: image-2021-02-03-15-52-12-493.png > flink iceberg table map cannot convert to datastream >

[GitHub] [flink] amaliujia commented on a change in pull request #14775: [FLINK-20964][python] Introduce PythonStreamGroupWindowAggregateOperator

2021-02-02 Thread GitBox
amaliujia commented on a change in pull request #14775: URL: https://github.com/apache/flink/pull/14775#discussion_r569195501 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/aggregate/AbstractPythonStreamGroupAggregateOperator.java ##

[GitHub] [flink] HuangXingBo commented on a change in pull request #14791: [FLINK-21168][python][table-planner-blink] Add support for general python group window aggregate function in Physical Rule an

2021-02-02 Thread GitBox
HuangXingBo commented on a change in pull request #14791: URL: https://github.com/apache/flink/pull/14791#discussion_r569195396 ## File path:

[jira] [Updated] (FLINK-21060) Could not create the DispatcherResourceManagerComponent

2021-02-02 Thread Spongebob (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spongebob updated FLINK-21060: -- Attachment: yarn_with_detached_mode.log > Could not create the DispatcherResourceManagerComponent >

[jira] [Updated] (FLINK-21060) Could not create the DispatcherResourceManagerComponent

2021-02-02 Thread Spongebob (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spongebob updated FLINK-21060: -- Attachment: (was: yarn_with_detached_mode.log) > Could not create the

[GitHub] [flink] amaliujia commented on a change in pull request #14775: [FLINK-20964][python] Introduce PythonStreamGroupWindowAggregateOperator

2021-02-02 Thread GitBox
amaliujia commented on a change in pull request #14775: URL: https://github.com/apache/flink/pull/14775#discussion_r569194581 ## File path: flink-python/pyflink/proto/flink-fn-execution.proto ## @@ -147,6 +147,30 @@ message UserDefinedAggregateFunction { bool

[jira] [Commented] (FLINK-21060) Could not create the DispatcherResourceManagerComponent

2021-02-02 Thread Spongebob (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1726#comment-1726 ] Spongebob commented on FLINK-21060: --- I uploaded the yarn log for the situation of with flink detached

[jira] [Updated] (FLINK-21060) Could not create the DispatcherResourceManagerComponent

2021-02-02 Thread Spongebob (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spongebob updated FLINK-21060: -- Attachment: yarn_with_detached_mode.log > Could not create the DispatcherResourceManagerComponent >

[jira] [Created] (FLINK-21247) flink iceberg table map cannot convert to datastream

2021-02-02 Thread donglei (Jira)
donglei created FLINK-21247: --- Summary: flink iceberg table map cannot convert to datastream Key: FLINK-21247 URL: https://issues.apache.org/jira/browse/FLINK-21247 Project: Flink Issue Type: New

[GitHub] [flink] amaliujia commented on a change in pull request #14791: [FLINK-21168][python][table-planner-blink] Add support for general python group window aggregate function in Physical Rule and

2021-02-02 Thread GitBox
amaliujia commented on a change in pull request #14791: URL: https://github.com/apache/flink/pull/14791#discussion_r569191629 ## File path:

[GitHub] [flink-benchmarks] Thesharing commented on a change in pull request #7: [FLINK-20612][runtime] Add benchmarks for scheduler

2021-02-02 Thread GitBox
Thesharing commented on a change in pull request #7: URL: https://github.com/apache/flink-benchmarks/pull/7#discussion_r569191404 ## File path: src/main/java/org/apache/flink/scheduler/benchmark/SchedulerBenchmarkUtils.java ## @@ -0,0 +1,245 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-772182984 ## CI report: * 20eea1289502f47226453012ae600303352f7cb9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14843: backport [FLINK-21215][task] Do not overwrite the original CheckpointFailureReason in AsyncCheckpointRunnable

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14843: URL: https://github.com/apache/flink/pull/14843#issuecomment-772295777 ## CI report: * 450cfb4ea7052e7ac66319aada922bbc465b1795 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14844: [FLINK-21208][python] Make Arrow Coder serialize schema info in every batch

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

[GitHub] [flink] flinkbot edited a comment on pull request #14799: [WIP] Wrapped StateBackend to forward state changes to StateChangleLog

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14799: URL: https://github.com/apache/flink/pull/14799#issuecomment-769554549 ## CI report: * 89066112157569ad58908e401696b45a56f48fc3 Azure:

[jira] [Commented] (FLINK-21030) Broken job restart for job with disjoint graph

2021-02-02 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277769#comment-17277769 ] Zhu Zhu commented on FLINK-21030: - I guess I had misunderstood the protocol of

[GitHub] [flink] flinkbot edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * c7e6b28b249f85cf52740d5201a769e0982a60aa UNKNOWN * f291c334a6571adc1141a6201e2e531d3b221efa Azure:

[jira] [Commented] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully

2021-02-02 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277767#comment-17277767 ] Yang Wang commented on FLINK-20417: --- Some users send me with private email to share they also come

[GitHub] [flink] xintongsong commented on a change in pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-02-02 Thread GitBox
xintongsong commented on a change in pull request #14647: URL: https://github.com/apache/flink/pull/14647#discussion_r569188934 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultSlotStatusSyncer.java ## @@ -224,11 +224,12 @@

[GitHub] [flink] rkhachatryan commented on pull request #14829: (1.12) [FLINK-21132][runtime] Don't end input on stop with savepoint

2021-02-02 Thread GitBox
rkhachatryan commented on pull request #14829: URL: https://github.com/apache/flink/pull/14829#issuecomment-772302135 ABP failure is not related (FLINK-21025). This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-21025) SQLClientHBaseITCase fails when untarring HBase

2021-02-02 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277764#comment-17277764 ] Roman Khachatryan commented on FLINK-21025: --- 1.12: 

[GitHub] [flink] amaliujia commented on a change in pull request #14791: [FLINK-21168][python][table-planner-blink] Add support for general python group window aggregate function in Physical Rule and

2021-02-02 Thread GitBox
amaliujia commented on a change in pull request #14791: URL: https://github.com/apache/flink/pull/14791#discussion_r569187223 ## File path:

[GitHub] [flink] amaliujia commented on a change in pull request #14791: [FLINK-21168][python][table-planner-blink] Add support for general python group window aggregate function in Physical Rule and

2021-02-02 Thread GitBox
amaliujia commented on a change in pull request #14791: URL: https://github.com/apache/flink/pull/14791#discussion_r569186393 ## File path:

[jira] [Updated] (FLINK-21081) Re-compute tasks to trigger when tasks get triggered before finished

2021-02-02 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21081: Description: When considering checkpoint while tasks get to finished, CheckpointCoordinator computes the

[jira] [Updated] (FLINK-21081) Re-compute tasks to trigger when tasks get triggered before finished

2021-02-02 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21081: Description: When considering checkpoint while tasks get to finished, CheckpointCoordinator computes the

[jira] [Updated] (FLINK-21246) Decline Checkpoint if some tasks finished before get triggered

2021-02-02 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21246: Description: When considering checkpoint while tasks get to finished, CheckpointCoordinator computes the

[jira] [Updated] (FLINK-21246) Decline Checkpoint if some tasks finished before get triggered

2021-02-02 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21246: Description: When considering checkpoint while tasks get to finished, CheckpointCoordinator computes the

[jira] [Created] (FLINK-21246) Decline Checkpoint if some tasks finished before get triggered

2021-02-02 Thread Yun Gao (Jira)
Yun Gao created FLINK-21246: --- Summary: Decline Checkpoint if some tasks finished before get triggered Key: FLINK-21246 URL: https://issues.apache.org/jira/browse/FLINK-21246 Project: Flink Issue

[jira] [Commented] (FLINK-21244) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel Fail

2021-02-02 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277759#comment-17277759 ] Guowei Ma commented on FLINK-21244: --- thanks! [~pnowojski] >

[jira] [Closed] (FLINK-21243) Add Java SDK maven module

2021-02-02 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21243. --- Fix Version/s: statefun-3.0.0 Assignee: Igal Shilman Resolution:

[jira] [Closed] (FLINK-21230) Add protobuf wrapper types for the StateFun SDK types.

2021-02-02 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21230. --- Fix Version/s: statefun-3.0.0 Assignee: Igal Shilman Resolution:

[GitHub] [flink-statefun] tzulitai closed pull request #197: [FLINK-21243] Add a maven module for the Java SDK

2021-02-02 Thread GitBox
tzulitai closed pull request #197: URL: https://github.com/apache/flink-statefun/pull/197 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-statefun] tzulitai commented on pull request #197: [FLINK-21243] Add a maven module for the Java SDK

2021-02-02 Thread GitBox
tzulitai commented on pull request #197: URL: https://github.com/apache/flink-statefun/pull/197#issuecomment-772296232 One thing though (which is easily resolvable): I believe we would need to amend the bundled NOTICE file for this artifact, since it is bundling and shading protobuf.

[GitHub] [flink] flinkbot commented on pull request #14844: [FLINK-21208][python] Make Arrow Coder serialize schema info in every batch

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

[GitHub] [flink] flinkbot commented on pull request #14843: backport [FLINK-21215][task] Do not overwrite the original CheckpointFailureReason in AsyncCheckpointRunnable

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

[GitHub] [flink] flinkbot edited a comment on pull request #14799: [WIP] Wrapped StateBackend to forward state changes to StateChangleLog

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14799: URL: https://github.com/apache/flink/pull/14799#issuecomment-769554549 ## CI report: * 89066112157569ad58908e401696b45a56f48fc3 Azure:

[GitHub] [flink-statefun] tzulitai commented on pull request #197: [FLINK-21243] Add a maven module for the Java SDK

2021-02-02 Thread GitBox
tzulitai commented on pull request #197: URL: https://github.com/apache/flink-statefun/pull/197#issuecomment-772292853 Thanks @igalshilman! LGTM, I'll merge this as well as #196. This is an automated message from the Apache

[GitHub] [flink] flinkbot commented on pull request #14844: [FLINK-21208][python] Make Arrow Coder serialize schema info in every batch

2021-02-02 Thread GitBox
flinkbot commented on pull request #14844: URL: https://github.com/apache/flink/pull/14844#issuecomment-772289781 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-21208) pyarrow exception when using window with pandas udaf

2021-02-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21208: --- Labels: pull-request-available (was: ) > pyarrow exception when using window with pandas

[GitHub] [flink] HuangXingBo opened a new pull request #14844: [FLINK-21208][python] Make Arrow Coder serialize schema info in every batch

2021-02-02 Thread GitBox
HuangXingBo opened a new pull request #14844: URL: https://github.com/apache/flink/pull/14844 ## What is the purpose of the change *This pull request will make Arrow Coder serialize schema info in every batch* ## Brief change log - *make Arrow Coder serialize

[GitHub] [flink] flinkbot commented on pull request #14843: backport [FLINK-21215][task] Do not overwrite the original CheckpointFailureReason in AsyncCheckpointRunnable

2021-02-02 Thread GitBox
flinkbot commented on pull request #14843: URL: https://github.com/apache/flink/pull/14843#issuecomment-772286261 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 #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14647: URL: https://github.com/apache/flink/pull/14647#issuecomment-760154591 ## CI report: * 970360401dcd333f1a3b29355392385262953246 Azure:

[GitHub] [flink] pnowojski opened a new pull request #14843: backport [FLINK-21215][task] Do not overwrite the original CheckpointFailureReason in AsyncCheckpointRunnable

2021-02-02 Thread GitBox
pnowojski opened a new pull request #14843: URL: https://github.com/apache/flink/pull/14843 backport part of FLINK-21215. Original fix had two fixes (or one fix and one optimisation, depending how you look at it). As the code has changed too much, I'm back-porting to release-1.11 just one

[jira] [Commented] (FLINK-21030) Broken job restart for job with disjoint graph

2021-02-02 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277736#comment-17277736 ] Matthias commented on FLINK-21030: -- Thanks for the analysis, that makes sense. I went ahead with this

[GitHub] [flink] flinkbot edited a comment on pull request #14842: [FLINK-21238][python] Support to close PythonFunctionFactory

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14842: URL: https://github.com/apache/flink/pull/14842#issuecomment-772256636 ## CI report: * e64470869ec5501fbb2b81bc5db796d7c8450ffb Azure:

[jira] [Closed] (FLINK-21244) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel Fail

2021-02-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-21244. -- Resolution: Duplicate >

[jira] [Commented] (FLINK-21244) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel Fail

2021-02-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277728#comment-17277728 ] Piotr Nowojski commented on FLINK-21244: [~maguowei] this is the same issue that you reported

[jira] [Commented] (FLINK-21244) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel Fail

2021-02-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277727#comment-17277727 ] Piotr Nowojski commented on FLINK-21244: Another failure caused by FLINK-20675 >

[jira] [Created] (FLINK-21245) Support StreamExecCalc json serialization/deserialization

2021-02-02 Thread godfrey he (Jira)
godfrey he created FLINK-21245: -- Summary: Support StreamExecCalc json serialization/deserialization Key: FLINK-21245 URL: https://issues.apache.org/jira/browse/FLINK-21245 Project: Flink Issue

[jira] [Updated] (FLINK-21215) Checkpoint was declined because one input stream is finished

2021-02-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21215: --- Fix Version/s: 1.12.2 1.11.4 > Checkpoint was declined because one input

[jira] [Closed] (FLINK-21096) Introduce ExecNodeGraphJsonPlanGenerator to serialize ExecNodeGraph to json plan and deserialize json plan to ExecNodeGraph

2021-02-02 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21096. -- Resolution: Fixed Fixed in 1.13.0: 0150ae471ce1c82404d51be2855f642d91088ad7 > Introduce

[jira] [Updated] (FLINK-21215) Checkpoint was declined because one input stream is finished

2021-02-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21215: --- Affects Version/s: 1.12.2 1.11.4 > Checkpoint was declined because

[jira] [Closed] (FLINK-21093) Support StreamExecTableSource json serialization/deserialization

2021-02-02 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21093. -- Resolution: Fixed Fixed in 1.13.0: c37905e8d812d243321c7a32a6f74cbde0294ce0 > Support

[jira] [Closed] (FLINK-21094) Support StreamExecSink json serialization/deserialization

2021-02-02 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21094. -- Resolution: Fixed Fixed in 1.13.0: cae238841271ae9494c0cf7887ed8e4b0f8f2c84 > Support StreamExecSink

[jira] [Closed] (FLINK-21092) Introduce getJsonPlan, explainJsonPlan and executeJsonPlan in TableEnvironmentInternal

2021-02-02 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21092. -- Resolution: Fixed Fixed in 1.13.0: e16e45f29e0c8b7dc771f4acb50e5b3910a751e2 > Introduce getJsonPlan,

[jira] [Updated] (FLINK-21244) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel Fail

2021-02-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21244: --- Affects Version/s: (was: 1.11.0) 1.11.4 >

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

2021-02-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277719#comment-17277719 ] Piotr Nowojski commented on FLINK-21132: {quote} I think data flow and gateway event are go

[GitHub] [flink] godfreyhe closed pull request #14729: [FLINK-21092][FLINK-21093][FLINK-21094][FLINK-21096][table-planner-blink] Support ExecNode plan serialization/deserialization for `INSERT INTO My

2021-02-02 Thread GitBox
godfreyhe closed pull request #14729: URL: https://github.com/apache/flink/pull/14729 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] flinkbot edited a comment on pull request #14842: [FLINK-21238][python] Support to close PythonFunctionFactory

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14842: URL: https://github.com/apache/flink/pull/14842#issuecomment-772256636 ## CI report: * e64470869ec5501fbb2b81bc5db796d7c8450ffb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14835: [FLINK-21213][task] Degrade log level to INFO when ignore to decline checkpoint as task not running

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14835: URL: https://github.com/apache/flink/pull/14835#issuecomment-771620432 ## CI report: * 6ecaa1370de5c2681bef2aa1f84ebaba2623f217 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14829: (1.12) [FLINK-21132][runtime] Don't end input on stop with savepoint

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14829: URL: https://github.com/apache/flink/pull/14829#issuecomment-770746355 ## CI report: * 573520d871f6fcbd2e0cb3468eed08c90bfba1e6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14815: [FLINK-21132][runtime] Don't end input on stop with savepoint

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14815: URL: https://github.com/apache/flink/pull/14815#issuecomment-769949393 ## CI report: * e3139520c1b415600222869adaf5be2f6b818429 UNKNOWN * b53567a0fdb4a291e4452c1bf00070fa65cb4856 Azure:

[GitHub] [flink] flinkbot commented on pull request #14842: [FLINK-21238][python] Support to close PythonFunctionFactory

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

[GitHub] [flink] flinkbot edited a comment on pull request #14839: [WIP][state] Add DFS-based StateChangelog (PoC)

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14839: URL: https://github.com/apache/flink/pull/14839#issuecomment-772060196 ## CI report: * a0d75a1671f3537cf3cf8ef72d08cbffc3d71295 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14835: [FLINK-21213][task] Degrade log level to INFO when ignore to decline checkpoint as task not running

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14835: URL: https://github.com/apache/flink/pull/14835#issuecomment-771620432 ## CI report: * 6ecaa1370de5c2681bef2aa1f84ebaba2623f217 Azure:

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

2021-02-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-12607: -- Assignee: John Phelan > Introduce a REST API that returns the maxParallelism of a

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

2021-02-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277709#comment-17277709 ] Robert Metzger commented on FLINK-12607: Great! Thanks a lot. I assigned you! > Introduce a

[jira] [Commented] (FLINK-19951) PyFlink end-to-end test stuck in "Reading kafka messages"

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

[jira] [Updated] (FLINK-21244) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel Fail

2021-02-02 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21244: -- Summary: UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel Fail

[jira] [Created] (FLINK-21244) shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel Fail

2021-02-02 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21244: - Summary: shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel Fail Key: FLINK-21244 URL: https://issues.apache.org/jira/browse/FLINK-21244 Project: Flink

[GitHub] [flink] Myasuka commented on pull request #14835: [FLINK-21213][task] Degrade log level to INFO when ignore to decline checkpoint as task not running

2021-02-02 Thread GitBox
Myasuka commented on pull request #14835: URL: https://github.com/apache/flink/pull/14835#issuecomment-772245037 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot commented on pull request #14842: [FLINK-21238][python] Support to close PythonFunctionFactory

2021-02-02 Thread GitBox
flinkbot commented on pull request #14842: URL: https://github.com/apache/flink/pull/14842#issuecomment-772240337 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-21238) Support to close PythonFunctionFactory

2021-02-02 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-21238: Summary: Support to close PythonFunctionFactory (was: Support to close PythonFunctionFactory manually)

[jira] [Updated] (FLINK-21238) Support to close PythonFunctionFactory

2021-02-02 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-21238: Description: PythonFunctionFactory is used to convert a Python class to a Java PythonFunction

[jira] [Updated] (FLINK-21238) Support to close PythonFunctionFactory manually

2021-02-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21238: --- Labels: pull-request-available (was: ) > Support to close PythonFunctionFactory manually >

[GitHub] [flink] dianfu opened a new pull request #14842: [FLINK-21238][python] Support to close PythonFunctionFactory manually

2021-02-02 Thread GitBox
dianfu opened a new pull request #14842: URL: https://github.com/apache/flink/pull/14842 ## What is the purpose of the change *This pull request support to close PythonFunctionFactory manually.* ## Brief change log - *Introduce PythonFunctionFactoryImpl which allows

[jira] [Updated] (FLINK-21238) Support to close PythonFunctionFactory manually

2021-02-02 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-21238: Description: PythonFunctionFactory is used to convert a Python class to a Java PythonFunction

[GitHub] [flink] flinkbot edited a comment on pull request #14837: [FLINK-20417][k8s] Create a new watcher when the old one is closed with HTTP_GONE

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14837: URL: https://github.com/apache/flink/pull/14837#issuecomment-771773023 ## CI report: * 8e26c4c6349e0d0bd2f078ffcfda63c5b6293bd2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14837: [FLINK-20417][k8s] Create a new watcher when the old one is closed with HTTP_GONE

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14837: URL: https://github.com/apache/flink/pull/14837#issuecomment-771773023 ## CI report: * 8e26c4c6349e0d0bd2f078ffcfda63c5b6293bd2 Azure:

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

2021-02-02 Thread GitBox
MiLk commented on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-772208383 No, I'm doing the following: ``` apiVersion: v1 kind: Pod metadata: name: pod-template spec: containers: - name:

[GitHub] [flink] flinkbot edited a comment on pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14834: URL: https://github.com/apache/flink/pull/14834#issuecomment-771607546 ## CI report: * bc778f3e205ebde76a63b6163a7fc66699fb1659 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14788: [FLINK-21180][python] Move the state module from 'pyflink.common' to 'pyflink.datastream'.

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14788: URL: https://github.com/apache/flink/pull/14788#issuecomment-768901227 ## CI report: * fd3c22ae3c320b98c2ed42c4c143cb2d57cad66a Azure:

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

2021-02-02 Thread GitBox
wangyang0918 commented on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-772197835 @MiLk Thanks for your testing. Could you please share how do you set the request and limit for ephemeral storage, like the following? ``` volumes: - name:

[GitHub] [flink] flinkbot edited a comment on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-772182984 ## CI report: * 20eea1289502f47226453012ae600303352f7cb9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14729: [FLINK-21092][FLINK-21093][FLINK-21094][FLINK-21096][table-planner-blink] Support ExecNode plan serialization/deserialization for `IN

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14729: URL: https://github.com/apache/flink/pull/14729#issuecomment-765399004 ## CI report: * 8e7fedb102a0d654ecd59f862e9b912471c2386f Azure:

[GitHub] [flink] flinkbot commented on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

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

[GitHub] [flink] flinkbot edited a comment on pull request #14788: [FLINK-21180][python] Move the state module from 'pyflink.common' to 'pyflink.datastream'.

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14788: URL: https://github.com/apache/flink/pull/14788#issuecomment-768901227 ## CI report: * Unknown: [CANCELED](TBD) * fd3c22ae3c320b98c2ed42c4c143cb2d57cad66a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14729: [FLINK-21092][FLINK-21093][FLINK-21094][FLINK-21096][table-planner-blink] Support ExecNode plan serialization/deserialization for `IN

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14729: URL: https://github.com/apache/flink/pull/14729#issuecomment-765399004 ## CI report: * 8e7fedb102a0d654ecd59f862e9b912471c2386f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14647: URL: https://github.com/apache/flink/pull/14647#issuecomment-760154591 ## CI report: * 0b72f53fbfe19ef426572f78ac716521bc63ab64 Azure:

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

2021-02-02 Thread GitBox
MiLk commented on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-772181752 Thank you for your work Following the discussion on the user ML at the beginning of the week, I tried your PR against my workload. My goal was to set the ephemeral

[jira] [Commented] (FLINK-21232) Introduce pluggable Hadoop delegation token providers

2021-02-02 Thread jackwangcs (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277649#comment-17277649 ] jackwangcs commented on FLINK-21232: Hi [~lirui], thanks. I submited a PoC PR for this. However,

[GitHub] [flink] flinkbot commented on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-02-02 Thread GitBox
flinkbot commented on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-772174441 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-21232) Introduce pluggable Hadoop delegation token providers

2021-02-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21232: --- Labels: pull-request-available (was: ) > Introduce pluggable Hadoop delegation token

[GitHub] [flink] JackWangCS commented on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-02-02 Thread GitBox
JackWangCS commented on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-772173966 The PR is just a PoC and still working in progress. This is an automated message from the Apache Git

[GitHub] [flink] JackWangCS opened a new pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-02-02 Thread GitBox
JackWangCS opened a new pull request #14841: URL: https://github.com/apache/flink/pull/14841 ## What is the purpose of the change Introduce a pluggable delegation provider via SPI. Delegation provider could be placed in connector related code and is more extendable comparing

[GitHub] [flink] flinkbot edited a comment on pull request #14788: [FLINK-21180][python] Move the state module from 'pyflink.common' to 'pyflink.datastream'.

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14788: URL: https://github.com/apache/flink/pull/14788#issuecomment-768901227 ## CI report: * Unknown: [CANCELED](TBD) * fd3c22ae3c320b98c2ed42c4c143cb2d57cad66a UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-02-02 Thread GitBox
flinkbot edited a comment on pull request #14647: URL: https://github.com/apache/flink/pull/14647#issuecomment-760154591 ## CI report: * 0b72f53fbfe19ef426572f78ac716521bc63ab64 Azure:

  1   2   3   4   5   >