[GitHub] [flink] lometheus commented on pull request #14673: [FLINK-20963][python] Update example with the latest recommended API

2021-01-17 Thread GitBox
lometheus commented on pull request #14673: URL: https://github.com/apache/flink/pull/14673#issuecomment-762058823 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[jira] [Assigned] (FLINK-21006) HBaseTablePlanTest tests failed in haoop 3.1.3 with "java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Objec

2021-01-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21006: --- Assignee: WeiNan Zhao > HBaseTablePlanTest tests failed in haoop 3.1.3 with > "java.lang.NoSuchMet

[jira] [Closed] (FLINK-21007) flink sql sink 支持更新目标表的部分字段以及提供null值处理选项

2021-01-17 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-21007. Resolution: Invalid Please use English in JIRA. If you intend to ask a question in Chinese

[jira] [Comment Edited] (FLINK-21007) flink sql sink 支持更新目标表的部分字段以及提供null值处理选项

2021-01-17 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267056#comment-17267056 ] Dawid Wysakowicz edited comment on FLINK-21007 at 1/18/21, 7:53 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #14644: [FLINK-20840][table-planner] Properly transpose projection to join

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14644: URL: https://github.com/apache/flink/pull/14644#issuecomment-760117761 ## CI report: * 4e70987ec082764822d1eefa8356454ea6a274b9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rmetzger commented on a change in pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

2021-01-17 Thread GitBox
rmetzger commented on a change in pull request #14678: URL: https://github.com/apache/flink/pull/14678#discussion_r559354094 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/ExecutionFailureHandler.java ## @@ -98,11 +103,22 @@ pu

[jira] [Commented] (FLINK-20812) Support 'properties.*' option to pass through all the HBase properties

2021-01-17 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267054#comment-17267054 ] Huang Xingbo commented on FLINK-20812: -- It seems that this PR caused the tests fail

[jira] [Created] (FLINK-21006) HBaseTablePlanTest tests failed in haoop 3.1.3 with "java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object

2021-01-17 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-21006: Summary: HBaseTablePlanTest tests failed in haoop 3.1.3 with "java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V" Key: FLINK-2

[jira] [Created] (FLINK-21007) flink sql sink 支持更新目标表的部分字段以及提供null值处理选项

2021-01-17 Thread sky (Jira)
sky created FLINK-21007: --- Summary: flink sql sink 支持更新目标表的部分字段以及提供null值处理选项 Key: FLINK-21007 URL: https://issues.apache.org/jira/browse/FLINK-21007 Project: Flink Issue Type: Improvement Comp

[GitHub] [flink] leonardBang commented on a change in pull request #14644: [FLINK-20840][table-planner] Properly transpose projection to join

2021-01-17 Thread GitBox
leonardBang commented on a change in pull request #14644: URL: https://github.com/apache/flink/pull/14644#discussion_r559362690 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/delegation/PlannerContext.java ## @@ -83,8 +83,8 @@

[GitHub] [flink] flinkbot edited a comment on pull request #14663: [FLINK-20925][table-planner-blink] Separate implemention of StreamExecLookupJoin and BatchExecLookupJoin

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14663: URL: https://github.com/apache/flink/pull/14663#issuecomment-760769392 ## CI report: * 852af6f79074f5d25ef8194963c464feb0038787 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] leonardBang commented on pull request #14675: [FLINK-18383][docs]translate "JDBC SQL Connector" documentation into …

2021-01-17 Thread GitBox
leonardBang commented on pull request #14675: URL: https://github.com/apache/flink/pull/14675#issuecomment-762042289 I'd like to take a look this. This is an automated message from the Apache Git Service. To respond to the me

[GitHub] [flink] flinkbot edited a comment on pull request #14663: [FLINK-20925][table-planner-blink] Separate implemention of StreamExecLookupJoin and BatchExecLookupJoin

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14663: URL: https://github.com/apache/flink/pull/14663#issuecomment-760769392 ## CI report: * 852af6f79074f5d25ef8194963c464feb0038787 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] godfreyhe commented on a change in pull request #14663: [FLINK-20925][table-planner-blink] Separate implemention of StreamExecLookupJoin and BatchExecLookupJoin

2021-01-17 Thread GitBox
godfreyhe commented on a change in pull request #14663: URL: https://github.com/apache/flink/pull/14663#discussion_r559352791 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/utils/LookupJoinUtil.java ## @@ -58,4 +71,50 @@ p

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

2021-01-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-21005: --- Summary: Introduce new provider for unified Sink API and implement in planner Key: FLINK-21005 URL: https://issues.apache.org/jira/browse/FLINK-21005 Project: Flink I

[GitHub] [flink] flinkbot edited a comment on pull request #14665: [FLINK-20858][python][table-planner-blink] Port StreamExecPythonGroupWindowAggregate and BatchExecPythonGroupWindowAggregate to Java

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14665: URL: https://github.com/apache/flink/pull/14665#issuecomment-760792355 ## CI report: * b1df7f6879a63390c8f252db85f8f338a4f29427 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14665: [FLINK-20858][python][table-planner-blink] Port StreamExecPythonGroupWindowAggregate and BatchExecPythonGroupWindowAggregate to Java

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14665: URL: https://github.com/apache/flink/pull/14665#issuecomment-760792355 ## CI report: * b1df7f6879a63390c8f252db85f8f338a4f29427 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21004) test_process_mode_boot.py test hangs

2021-01-17 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-21004: - Summary: test_process_mode_boot.py test hangs (was: test_process_mode_boot.py tes hangs) > tes

[jira] [Created] (FLINK-21004) test_process_mode_boot.py tes hangs

2021-01-17 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-21004: Summary: test_process_mode_boot.py tes hangs Key: FLINK-21004 URL: https://issues.apache.org/jira/browse/FLINK-21004 Project: Flink Issue Type: Bug

[GitHub] [flink] HuangXingBo commented on pull request #14665: [FLINK-20858][python][table-planner-blink] Port StreamExecPythonGroupWindowAggregate and BatchExecPythonGroupWindowAggregate to Java

2021-01-17 Thread GitBox
HuangXingBo commented on pull request #14665: URL: https://github.com/apache/flink/pull/14665#issuecomment-762005664 @dianfu Thanks a lot for the review. I have addressed the comments at the latest commit. This is an automat

[GitHub] [flink] HuangXingBo commented on a change in pull request #14665: [FLINK-20858][python][table-planner-blink] Port StreamExecPythonGroupWindowAggregate and BatchExecPythonGroupWindowAggregate

2021-01-17 Thread GitBox
HuangXingBo commented on a change in pull request #14665: URL: https://github.com/apache/flink/pull/14665#discussion_r559334274 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecPythonGroupWindowAggregate.ja

[jira] [Assigned] (FLINK-20997) YarnTestBaseTest fails due to NPE

2021-01-17 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-20997: Assignee: Paul Lin > YarnTestBaseTest fails due to NPE > - > >

[jira] [Updated] (FLINK-20994) Add public method to create TableEnvironment in PyFlink

2021-01-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20994: Fix Version/s: 1.13.0 > Add public method to create TableEnvironment in PyFlink >

[jira] [Commented] (FLINK-13247) Implement external shuffle service for YARN

2021-01-17 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267020#comment-17267020 ] Zhijiang commented on FLINK-13247: -- AFAIK, the current assignee [~ssy] will not work on

[jira] [Commented] (FLINK-20933) Config Python Operator Use Managed Memory In Python DataStream

2021-01-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267018#comment-17267018 ] Dian Fu commented on FLINK-20933: - Fixed in release-1.12 via 78799ac2f4b12b4ce789be6ad39

[jira] [Updated] (FLINK-20933) Config Python Operator Use Managed Memory In Python DataStream

2021-01-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20933: Fix Version/s: 1.12.2 > Config Python Operator Use Managed Memory In Python DataStream > -

[GitHub] [flink] dianfu edited a comment on pull request #14676: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

2021-01-17 Thread GitBox
dianfu edited a comment on pull request #14676: URL: https://github.com/apache/flink/pull/14676#issuecomment-761985379 Closed via 78799ac2f4b12b4ce789be6ad39ef829e361e61f This is an automated message from the Apache Git Servi

[GitHub] [flink] dianfu commented on pull request #14676: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

2021-01-17 Thread GitBox
dianfu commented on pull request #14676: URL: https://github.com/apache/flink/pull/14676#issuecomment-761985379 closed via 78799ac2f4b12b4ce789be6ad39ef829e361e61f This is an automated message from the Apache Git Service. To

[GitHub] [flink] dianfu closed pull request #14676: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

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

[jira] [Closed] (FLINK-20933) Config Python Operator Use Managed Memory In Python DataStream

2021-01-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20933. --- Fix Version/s: 1.13.0 Assignee: Huang Xingbo Resolution: Fixed Fixed in master via e1d98e2d8

[GitHub] [flink] dianfu closed pull request #14621: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

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

[jira] [Commented] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request

2021-01-17 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267014#comment-17267014 ] Yun Tang commented on FLINK-12358: -- [~trohrmann] I had a draft two years ago. However,

[GitHub] [flink] dianfu commented on a change in pull request #14665: [FLINK-20858][python][table-planner-blink] Port StreamExecPythonGroupWindowAggregate and BatchExecPythonGroupWindowAggregate to Ja

2021-01-17 Thread GitBox
dianfu commented on a change in pull request #14665: URL: https://github.com/apache/flink/pull/14665#discussion_r559287136 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecPythonGroupWindowAggregate.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #14663: [FLINK-20925][table-planner-blink] Separate implemention of StreamExecLookupJoin and BatchExecLookupJoin

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14663: URL: https://github.com/apache/flink/pull/14663#issuecomment-760769392 ## CI report: * 852af6f79074f5d25ef8194963c464feb0038787 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] godfreyhe commented on a change in pull request #14663: [FLINK-20925][table-planner-blink] Separate implemention of StreamExecLookupJoin and BatchExecLookupJoin

2021-01-17 Thread GitBox
godfreyhe commented on a change in pull request #14663: URL: https://github.com/apache/flink/pull/14663#discussion_r558185519 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLookupJoin.java ## @@

[GitHub] [flink] godfreyhe commented on a change in pull request #14663: [FLINK-20925][table-planner-blink] Separate implemention of StreamExecLookupJoin and BatchExecLookupJoin

2021-01-17 Thread GitBox
godfreyhe commented on a change in pull request #14663: URL: https://github.com/apache/flink/pull/14663#discussion_r558122588 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLookupJoin.java ## @@

[jira] [Closed] (FLINK-20966) Rename Stream(/Batch)ExecIntermediateTableScan to Stream(/Batch)PhysicalIntermediateTableScan

2021-01-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-20966. -- Resolution: Fixed Fixed in 1.13.0: 2417d2e4..b0f889a9 > Rename Stream(/Batch)ExecIntermediateTableSca

[GitHub] [flink] godfreyhe closed pull request #14638: [FLINK-20966][table-planner-blink] Rename Stream(/Batch)ExecIntermediateTableScan to Stream(/Batch)PhysicalIntermediateTableScan

2021-01-17 Thread GitBox
godfreyhe closed pull request #14638: URL: https://github.com/apache/flink/pull/14638 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 t

[GitHub] [flink] godfreyhe commented on pull request #14638: [FLINK-20966][table-planner-blink] Rename Stream(/Batch)ExecIntermediateTableScan to Stream(/Batch)PhysicalIntermediateTableScan

2021-01-17 Thread GitBox
godfreyhe commented on pull request #14638: URL: https://github.com/apache/flink/pull/14638#issuecomment-761957050 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] flinkbot edited a comment on pull request #14663: [FLINK-20925][table-planner-blink] Separate implemention of StreamExecLookupJoin and BatchExecLookupJoin

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14663: URL: https://github.com/apache/flink/pull/14663#issuecomment-760769392 ## CI report: * 4224ed129067a1550f812e8803c3298d523c2495 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-20935) can't write flink configuration to tmp file and add it to local resource in yarn session mode

2021-01-17 Thread yuemeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264565#comment-17264565 ] yuemeng edited comment on FLINK-20935 at 1/18/21, 2:44 AM: --- [~

[GitHub] [flink] dianfu commented on a change in pull request #14665: [FLINK-20858][python][table-planner-blink] Port StreamExecPythonGroupWindowAggregate and BatchExecPythonGroupWindowAggregate to Ja

2021-01-17 Thread GitBox
dianfu commented on a change in pull request #14665: URL: https://github.com/apache/flink/pull/14665#discussion_r559287136 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecPythonGroupWindowAggregate.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #14663: [FLINK-20925][table-planner-blink] Separate implemention of StreamExecLookupJoin and BatchExecLookupJoin

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14663: URL: https://github.com/apache/flink/pull/14663#issuecomment-760769392 ## CI report: * 4224ed129067a1550f812e8803c3298d523c2495 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19067) resource_manager and dispatcher register on different nodes in HA mode will cause FileNotFoundException

2021-01-17 Thread JieFang.He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266965#comment-17266965 ] JieFang.He commented on FLINK-19067: Thank you for your answers and suggestions > r

[jira] [Updated] (FLINK-21003) Flink add Sink to AliyunOSS doesn't work

2021-01-17 Thread zhangyunyun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangyunyun updated FLINK-21003: Description: When I add a sink to OSS, use the code below: {code:java} String path = "oss:///"; St

[jira] [Updated] (FLINK-21003) Flink add Sink to AliyunOSS doesn't work

2021-01-17 Thread zhangyunyun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangyunyun updated FLINK-21003: Description: When I add a sink to OSS, use the code below:   {code:java} String path = "oss:///";

[jira] [Created] (FLINK-21003) Flink add Sink to AliyunOSS doesn't work

2021-01-17 Thread zhangyunyun (Jira)
zhangyunyun created FLINK-21003: --- Summary: Flink add Sink to AliyunOSS doesn't work Key: FLINK-21003 URL: https://issues.apache.org/jira/browse/FLINK-21003 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-21001) Flink job is blocked while using tableEnvironment with tableFunction and join

2021-01-17 Thread Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266956#comment-17266956 ] Wu commented on FLINK-21001: I start the job at 15:48. The job is blocked and do not continu

[jira] [Commented] (FLINK-21002) Support exactly once sink for JDBC in Table SQL API

2021-01-17 Thread bruce lu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266955#comment-17266955 ] bruce lu commented on FLINK-21002: -- *Super!  It's a great feature in Table/SQL*  > Sup

[jira] [Updated] (FLINK-21001) Flink job is blocked while using tableEnvironment with tableFunction and join

2021-01-17 Thread Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wu updated FLINK-21001: --- Attachment: (was: image-2021-01-18-09-49-35-431.png) > Flink job is blocked while using tableEnvironment with ta

[jira] [Updated] (FLINK-21001) Flink job is blocked while using tableEnvironment with tableFunction and join

2021-01-17 Thread Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wu updated FLINK-21001: --- Attachment: image-2021-01-18-09-49-35-431.png > Flink job is blocked while using tableEnvironment with tableFunction

[jira] [Updated] (FLINK-21001) Flink job is blocked while using tableEnvironment with tableFunction and join

2021-01-17 Thread Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wu updated FLINK-21001: --- Attachment: client_log.txt > Flink job is blocked while using tableEnvironment with tableFunction and join > ---

[jira] [Commented] (FLINK-21002) Support exactly once sink for JDBC in Table SQL API

2021-01-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266954#comment-17266954 ] Leonard Xu commented on FLINK-21002: +1 to support this feature in Table/SQL  > Sup

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

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14678: URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721 ## CI report: * 296a46dab704e3a3553bb7a43128a3f4774bfb77 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14678: URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721 ## CI report: * 296a46dab704e3a3553bb7a43128a3f4774bfb77 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-01-17 Thread GitBox
flinkbot commented on pull request #14678: URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721 ## CI report: * 296a46dab704e3a3553bb7a43128a3f4774bfb77 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph

2021-01-17 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266945#comment-17266945 ] Zhenqiu Huang commented on FLINK-20833: --- [~rmetzger] [[~trohrmann]] Thanks for the

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

2021-01-17 Thread GitBox
flinkbot commented on pull request #14678: URL: https://github.com/apache/flink/pull/14678#issuecomment-761904406 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph

2021-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20833: --- Labels: pull-request-available (was: ) > Expose pluggable interface for exception analysis

[GitHub] [flink] HuangZhenQiu opened a new pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

2021-01-17 Thread GitBox
HuangZhenQiu opened a new pull request #14678: URL: https://github.com/apache/flink/pull/14678 ## What is the purpose of the change Add pluggable failure listener spi interface so that Flink users can customize the failure handling business logic by using the plugin framework. For e

[GitHub] [flink] zentol edited a comment on pull request #14630: [FLINK-20915][docker] Move docker entrypoint to distribution

2021-01-17 Thread GitBox
zentol edited a comment on pull request #14630: URL: https://github.com/apache/flink/pull/14630#issuecomment-761888056 > if someone downloads the binary distribution of Flink and tries to run it on a VM, are they expected to set an appropriate [FLINK_]CLASSPATH variable? To answer yo

[GitHub] [flink] zentol edited a comment on pull request #14630: [FLINK-20915][docker] Move docker entrypoint to distribution

2021-01-17 Thread GitBox
zentol edited a comment on pull request #14630: URL: https://github.com/apache/flink/pull/14630#issuecomment-761888056 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] zentol edited a comment on pull request #14630: [FLINK-20915][docker] Move docker entrypoint to distribution

2021-01-17 Thread GitBox
zentol edited a comment on pull request #14630: URL: https://github.com/apache/flink/pull/14630#issuecomment-761888056 > if someone downloads the binary distribution of Flink and tries to run it on a VM, are they expected to set an appropriate [FLINK_]CLASSPATH variable? To answer yo

[GitHub] [flink] zentol commented on pull request #14630: [FLINK-20915][docker] Move docker entrypoint to distribution

2021-01-17 Thread GitBox
zentol commented on pull request #14630: URL: https://github.com/apache/flink/pull/14630#issuecomment-761888056 > if someone downloads the binary distribution of Flink and tries to run it on a VM, are they expected to set an appropriate [FLINK_]CLASSPATH variable? To answer your exam

[GitHub] [flink] zentol commented on pull request #14630: [FLINK-20915][docker] Move docker entrypoint to distribution

2021-01-17 Thread GitBox
zentol commented on pull request #14630: URL: https://github.com/apache/flink/pull/14630#issuecomment-761885131 > I'm confused Well that makes 2 of us. https://github.com/docker-library/official-images/pull/9249#issuecomment-756731803 > If I understand you correctly, then i

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #14672: [FLINK-20998][docs] - flink-raw.jar no longer mentioned + prettier maven xml dependencies

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14672: URL: https://github.com/apache/flink/pull/14672#issuecomment-761593893 ## CI report: * f1733387653ff03bd40a52b6fa8856027024fa1b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14672: [FLINK-20998][docs] - flink-raw.jar no longer mentioned + prettier maven xml dependencies

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14672: URL: https://github.com/apache/flink/pull/14672#issuecomment-761593893 ## CI report: * 50f142696f4553e0bf7742ef4b46be78f57461d6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] sv3ndk commented on a change in pull request #14672: [FLINK-20998][docs] - flink-raw.jar no longer mentioned + prettier maven xml dependencies

2021-01-17 Thread GitBox
sv3ndk commented on a change in pull request #14672: URL: https://github.com/apache/flink/pull/14672#discussion_r559220386 ## File path: docs/dev/table/connectors/formats/raw.zh.md ## @@ -33,13 +33,7 @@ Raw format 允许读写原始(基于字节)值作为单个列。 注意: 这种格式将 `null` 值编码成 `byte[]` 类型的 `null`

[GitHub] [flink] sv3ndk commented on a change in pull request #14672: [FLINK-20998][docs] - flink-raw.jar no longer mentioned + prettier maven xml dependencies

2021-01-17 Thread GitBox
sv3ndk commented on a change in pull request #14672: URL: https://github.com/apache/flink/pull/14672#discussion_r559220386 ## File path: docs/dev/table/connectors/formats/raw.zh.md ## @@ -33,13 +33,7 @@ Raw format 允许读写原始(基于字节)值作为单个列。 注意: 这种格式将 `null` 值编码成 `byte[]` 类型的 `null`

[GitHub] [flink] flinkbot edited a comment on pull request #14676: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14676: URL: https://github.com/apache/flink/pull/14676#issuecomment-761815610 ## CI report: * 2bdb2217ac6e1abcf45d5b329b83b72aa54be7bb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14499: URL: https://github.com/apache/flink/pull/14499#issuecomment-751477248 ## CI report: * 56c9467b56b6e6f490103a6be681921d33da Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21002) Support exactly once sink for JDBC in Table SQL API

2021-01-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266819#comment-17266819 ] Jark Wu commented on FLINK-21002: - We should first discuss what the new options we shoul

[GitHub] [flink] wuchong commented on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2021-01-17 Thread GitBox
wuchong commented on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-761838593 I also created FLINK-21002 to expose this feature in Table API/SQL. This is an automated message from the Apach

[jira] [Created] (FLINK-21002) Support exactly once sink for JDBC in Table SQL API

2021-01-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-21002: --- Summary: Support exactly once sink for JDBC in Table SQL API Key: FLINK-21002 URL: https://issues.apache.org/jira/browse/FLINK-21002 Project: Flink Issue Type: New Fea

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

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14499: URL: https://github.com/apache/flink/pull/14499#issuecomment-751477248 ## CI report: * 56c9467b56b6e6f490103a6be681921d33da Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wuchong commented on a change in pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2021-01-17 Thread GitBox
wuchong commented on a change in pull request #10847: URL: https://github.com/apache/flink/pull/10847#discussion_r559200884 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/CheckpointAndXidSerializersTest.java ## @@ -0,0 +1,5

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

2021-01-17 Thread GitBox
hwanju edited a comment on pull request #14499: URL: https://github.com/apache/flink/pull/14499#issuecomment-761572560 > I believe sources are relatively important, in particular because some users have their own implementations there. > @hwanju do you want to address this in this PR, or

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

2021-01-17 Thread GitBox
hwanju commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r559200445 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ClusterOptions.java ## @@ -115,4 +127,35 @@ public static boolean isDeclarativeReso

[GitHub] [flink] godfreyhe commented on a change in pull request #14644: [FLINK-20840][table-planner] Properly transpose projection to join

2021-01-17 Thread GitBox
godfreyhe commented on a change in pull request #14644: URL: https://github.com/apache/flink/pull/14644#discussion_r55919 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java ## @@ -308,6 +308,14 @@

[GitHub] [flink] liuyufei9527 commented on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

2021-01-17 Thread GitBox
liuyufei9527 commented on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-761829624 @Myasuka [CI](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=12150&view=results) have passed.

[jira] [Closed] (FLINK-20989) Functions in ExplodeFunctionUtil should handle null data to avoid NPE

2021-01-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-20989. -- Resolution: Fixed Fixed in 1.11.4: 0c090cdd48d2b2362b805fe40a45cdfced5f2738 > Functions in ExplodeFun

[GitHub] [flink] godfreyhe merged pull request #14664: [FLINK-20989][table-planner-blink] Functions in ExplodeFunctionUtil should handle null data to avoid NPE

2021-01-17 Thread GitBox
godfreyhe merged pull request #14664: URL: https://github.com/apache/flink/pull/14664 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 t

[GitHub] [flink] wuchong commented on pull request #14675: [FLINK-18383][docs]translate "JDBC SQL Connector" documentation into …

2021-01-17 Thread GitBox
wuchong commented on pull request #14675: URL: https://github.com/apache/flink/pull/14675#issuecomment-761827845 Hi @leonardBang , could you help to review this? This is an automated message from the Apache Git Service. To re

[GitHub] [flink] wuchong commented on a change in pull request #14672: [FLINK-20998][docs] - flink-raw.jar no longer mentioned + prettier maven xml dependencies

2021-01-17 Thread GitBox
wuchong commented on a change in pull request #14672: URL: https://github.com/apache/flink/pull/14672#discussion_r559191882 ## File path: docs/dev/table/connectors/formats/raw.zh.md ## @@ -33,13 +33,7 @@ Raw format 允许读写原始(基于字节)值作为单个列。 注意: 这种格式将 `null` 值编码成 `byte[]` 类型的 `null

[jira] [Commented] (FLINK-20726) Introduce Pulsar connector

2021-01-17 Thread Jianyun Zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266797#comment-17266797 ] Jianyun Zhao commented on FLINK-20726: -- Thank you very much for your help! > Intro

[GitHub] [flink] flinkbot edited a comment on pull request #14676: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14676: URL: https://github.com/apache/flink/pull/14676#issuecomment-761815610 ## CI report: * 2bdb2217ac6e1abcf45d5b329b83b72aa54be7bb Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] pipiliang removed a comment on pull request #14677: Merge pull request #1 from apache/master

2021-01-17 Thread GitBox
pipiliang removed a comment on pull request #14677: URL: https://github.com/apache/flink/pull/14677#issuecomment-761817426 merge This is an automated message from the Apache Git Service. To respond to the message, please log

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

2021-01-17 Thread GitBox
pipiliang commented on pull request #14677: URL: https://github.com/apache/flink/pull/14677#issuecomment-761817426 merge This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[GitHub] [flink] pipiliang closed pull request #14677: Merge pull request #1 from apache/master

2021-01-17 Thread GitBox
pipiliang closed pull request #14677: URL: https://github.com/apache/flink/pull/14677 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 t

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

2021-01-17 Thread GitBox
flinkbot commented on pull request #14677: URL: https://github.com/apache/flink/pull/14677#issuecomment-761817266 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

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

2021-01-17 Thread GitBox
pipiliang opened a new pull request #14677: URL: https://github.com/apache/flink/pull/14677 update fork ## 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

[GitHub] [flink] flinkbot commented on pull request #14676: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

2021-01-17 Thread GitBox
flinkbot commented on pull request #14676: URL: https://github.com/apache/flink/pull/14676#issuecomment-761815610 ## CI report: * 2bdb2217ac6e1abcf45d5b329b83b72aa54be7bb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14674: [FLINK-20831][table/sql runtime] Introduce the in-memory topN buffer

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14674: URL: https://github.com/apache/flink/pull/14674#issuecomment-761760740 ## CI report: * e30838a252ad02c36ef1a50ae161f5cc7b48cff3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14676: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

2021-01-17 Thread GitBox
flinkbot commented on pull request #14676: URL: https://github.com/apache/flink/pull/14676#issuecomment-761812777 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] HuangXingBo opened a new pull request #14676: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

2021-01-17 Thread GitBox
HuangXingBo opened a new pull request #14676: URL: https://github.com/apache/flink/pull/14676 ## What is the purpose of the change *This pull request will Config Python Operator Use Managed Memory In Python DataStream* ## Brief change log - *Add method `setManaged

[GitHub] [flink] flinkbot edited a comment on pull request #14675: [FLINK-18383][docs]translate "JDBC SQL Connector" documentation into …

2021-01-17 Thread GitBox
flinkbot edited a comment on pull request #14675: URL: https://github.com/apache/flink/pull/14675#issuecomment-761769906 ## CI report: * 519566b1079bfca772b00c6c905cbb177594b346 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14675: [FLINK-18383][docs]translate "JDBC SQL Connector" documentation into …

2021-01-17 Thread GitBox
flinkbot commented on pull request #14675: URL: https://github.com/apache/flink/pull/14675#issuecomment-761769906 ## CI report: * 519566b1079bfca772b00c6c905cbb177594b346 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-18383) Translate "JDBC SQL Connector" page into Chinese

2021-01-17 Thread bruce lu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266739#comment-17266739 ] bruce lu commented on FLINK-18383: -- The translation job is finished! Hi, [~jark], could

[GitHub] [flink] flinkbot commented on pull request #14675: [FLINK-18383][docs]translate "JDBC SQL Connector" documentation into …

2021-01-17 Thread GitBox
flinkbot commented on pull request #14675: URL: https://github.com/apache/flink/pull/14675#issuecomment-761767301 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

  1   2   >