[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * 57ed58c709400cabc75c5a6a4fe8587bca16dbb8 Azure:

[jira] [Commented] (FLINK-19943) Support sink parallelism configuration to ElasticSearch connector

2020-12-01 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242126#comment-17242126 ] zhisheng commented on FLINK-19943: -- [~lzljs3620320] hi, this subtask will merge to 1.12? > Support

[jira] [Commented] (FLINK-12884) FLIP-144: Native Kubernetes HA Service

2020-12-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242124#comment-17242124 ] Xintong Song commented on FLINK-12884: -- [~shravan.adharapurapu], K8s HA service will be released

[jira] [Assigned] (FLINK-20425) Change exit code in FatalExitExceptionHandler to be different from JvmShutdownSafeguard

2020-12-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20425: -- Assignee: Nicholas Jiang > Change exit code in FatalExitExceptionHandler to be

[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * 6a0849e61034e34186780ce45dcf9157f65c0dfd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14177: [FLINK-16443][checkpointing] Make sure that CheckpointException are also serialized in DeclineCheckpoint.

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14177: URL: https://github.com/apache/flink/pull/14177#issuecomment-732207895 ## CI report: * ce283f64f17cadd3f4ab80534343dbfe917867fa Azure:

[jira] [Commented] (FLINK-20442) Fix license documentation mistakes in flink-python.jar

2020-12-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242112#comment-17242112 ] Dian Fu commented on FLINK-20442: - I found that part of the problems described in this JIRA also exists

[jira] [Commented] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

2020-12-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242108#comment-17242108 ] Robert Metzger commented on FLINK-18685: Thanks a lot! I assigned you. >

[jira] [Assigned] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

2020-12-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-18685: -- Assignee: Etienne Chauchot > JobClient.getAccumulators() blocks until streaming job

[jira] [Commented] (FLINK-20442) Fix license documentation mistakes in flink-python.jar

2020-12-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242107#comment-17242107 ] Dian Fu commented on FLINK-20442: - Merged to - master via 7818b7a8290c84b99e809773b8c91fb028670865 -

[jira] [Updated] (FLINK-20442) Fix license documentation mistakes in flink-python.jar

2020-12-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20442: Fix Version/s: 1.11.3 > Fix license documentation mistakes in flink-python.jar >

[GitHub] [flink] dianfu commented on pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

2020-12-01 Thread GitBox
dianfu commented on pull request #14282: URL: https://github.com/apache/flink/pull/14282#issuecomment-737047682 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] dianfu closed pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

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

[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * 6a0849e61034e34186780ce45dcf9157f65c0dfd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14177: [FLINK-16443][checkpointing] Make sure that CheckpointException are also serialized in DeclineCheckpoint.

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14177: URL: https://github.com/apache/flink/pull/14177#issuecomment-732207895 ## CI report: * ce283f64f17cadd3f4ab80534343dbfe917867fa Azure:

[jira] [Closed] (FLINK-20441) Deprecate CheckpointConfig.setPreferCheckpointForRecovery

2020-12-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-20441. -- Fix Version/s: (was: 1.13.0) 1.12.0 Resolution: Fixed >

[jira] [Commented] (FLINK-20441) Deprecate CheckpointConfig.setPreferCheckpointForRecovery

2020-12-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242102#comment-17242102 ] Robert Metzger commented on FLINK-20441: Merged to master (1.13)

[GitHub] [flink] rmetzger merged pull request #14273: [FLINK-20441] Deprecate CheckpointConfig.setPreferCheckpointForRecovery and .isPreferCheckpointForRecovery

2020-12-01 Thread GitBox
rmetzger merged pull request #14273: URL: https://github.com/apache/flink/pull/14273 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] rmetzger commented on pull request #14273: [FLINK-20441] Deprecate CheckpointConfig.setPreferCheckpointForRecovery and .isPreferCheckpointForRecovery

2020-12-01 Thread GitBox
rmetzger commented on pull request #14273: URL: https://github.com/apache/flink/pull/14273#issuecomment-737038230 I'm merging this now to proceed with the next RC This is an automated message from the Apache Git Service. To

[jira] [Issue Comment Deleted] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

2020-12-01 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-19863: - Comment: was deleted (was: another instance 

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

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

[jira] [Commented] (FLINK-12884) FLIP-144: Native Kubernetes HA Service

2020-12-01 Thread shravan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242086#comment-17242086 ] shravan commented on FLINK-12884: - [~trohrmann] [~fly_in_gis] Is the  K8s HA service with 1.12 released?

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

2020-12-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242085#comment-17242085 ] Dian Fu commented on FLINK-19863: -

[jira] [Updated] (FLINK-20433) UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test timed out after 300 seconds"

2020-12-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20433: Fix Version/s: 1.13.0 > UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test >

[jira] [Updated] (FLINK-20433) UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test timed out after 300 seconds"

2020-12-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20433: Affects Version/s: 1.13.0 > UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test

[jira] [Commented] (FLINK-20433) UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test timed out after 300 seconds"

2020-12-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242083#comment-17242083 ] Dian Fu commented on FLINK-20433: - Instance on master(1.13.0):

[jira] [Closed] (FLINK-20449) UnalignedCheckpointITCase times out

2020-12-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20449. --- Fix Version/s: (was: 1.13.0) Resolution: Duplicate This issue should be duplicate with

[jira] [Created] (FLINK-20449) UnalignedCheckpointITCase times out

2020-12-01 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20449: -- Summary: UnalignedCheckpointITCase times out Key: FLINK-20449 URL: https://issues.apache.org/jira/browse/FLINK-20449 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

2020-12-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242079#comment-17242079 ] Robert Metzger commented on FLINK-19863:

[GitHub] [flink] flinkbot edited a comment on pull request #14270: [FLINK-20436][table-planner-blink] Simplify type parameter of ExecNode

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14270: URL: https://github.com/apache/flink/pull/14270#issuecomment-736353538 ## CI report: * 88d6d6aecb9a67c4bd7065f2d58cf9793d71cf95 Azure:

[GitHub] [flink] rmetzger commented on a change in pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

2020-12-01 Thread GitBox
rmetzger commented on a change in pull request #14282: URL: https://github.com/apache/flink/pull/14282#discussion_r533926297 ## File path: flink-python/lib/LICENSE.py4j ## @@ -1,26 +0,0 @@ -Copyright (c) 2009-2018, Barthelemy Dagenais and individual contributors. All Review

[jira] [Commented] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

2020-12-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242077#comment-17242077 ] Robert Metzger commented on FLINK-20420:

[GitHub] [flink] rmetzger commented on pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

2020-12-01 Thread GitBox
rmetzger commented on pull request #14282: URL: https://github.com/apache/flink/pull/14282#issuecomment-737020504 I reported the CI failure here: https://issues.apache.org/jira/browse/FLINK-20420 This is an automated

[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * 6a0849e61034e34186780ce45dcf9157f65c0dfd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * b2173ba7a73dc7d79ba4f0679b7076400815d116 Azure:

[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

2020-12-01 Thread Partha Pradeep Mishra (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242055#comment-17242055 ] Partha Pradeep Mishra commented on FLINK-20376: --- [~klion26] Trying savepoint triggered on

[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

2020-12-01 Thread Partha Pradeep Mishra (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242053#comment-17242053 ] Partha Pradeep Mishra commented on FLINK-20376: --- [~yunta] Thanks for the response. I don't

[jira] [Commented] (FLINK-20414) 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist

2020-12-01 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242045#comment-17242045 ] zhisheng commented on FLINK-20414: -- [~jark] yes, i solved it, but the exception is not friendly, if the

[GitHub] [flink] caozhen1937 commented on a change in pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-01 Thread GitBox
caozhen1937 commented on a change in pull request #14088: URL: https://github.com/apache/flink/pull/14088#discussion_r533884649 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -24,229 +24,109 @@ specific language governing permissions and limitations under the

[GitHub] [flink] HuangXingBo commented on a change in pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-01 Thread GitBox
HuangXingBo commented on a change in pull request #14088: URL: https://github.com/apache/flink/pull/14088#discussion_r533881048 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -24,229 +24,109 @@ specific language governing permissions and limitations under the

[GitHub] [flink] flinkbot edited a comment on pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14088: URL: https://github.com/apache/flink/pull/14088#issuecomment-728662796 ## CI report: * f14b52c30b09d46b9fa03f840d0642f764122e8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14003: [FLINK-19527][Doc]Flink SQL Getting Started

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14003: URL: https://github.com/apache/flink/pull/14003#issuecomment-724292850 ## CI report: * 34877c626eb981f4dca0873d7ba2d5547b16ff2b Azure:

[GitHub] [flink] HuangXingBo commented on a change in pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-01 Thread GitBox
HuangXingBo commented on a change in pull request #14088: URL: https://github.com/apache/flink/pull/14088#discussion_r533879310 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -24,229 +24,109 @@ specific language governing permissions and limitations under the

[jira] [Updated] (FLINK-20448) Obsolete generated avro classes

2020-12-01 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-20448: --- Description: We generate avro classes for testing in some modules like {{flink-avro}} and

[GitHub] [flink] caozhen1937 commented on a change in pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-01 Thread GitBox
caozhen1937 commented on a change in pull request #14088: URL: https://github.com/apache/flink/pull/14088#discussion_r533877640 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -24,229 +24,109 @@ specific language governing permissions and limitations under the

[GitHub] [flink] caozhen1937 commented on a change in pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-01 Thread GitBox
caozhen1937 commented on a change in pull request #14088: URL: https://github.com/apache/flink/pull/14088#discussion_r533877242 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -24,229 +24,109 @@ specific language governing permissions and limitations under the

[GitHub] [flink] caozhen1937 commented on a change in pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-01 Thread GitBox
caozhen1937 commented on a change in pull request #14088: URL: https://github.com/apache/flink/pull/14088#discussion_r533877242 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -24,229 +24,109 @@ specific language governing permissions and limitations under the

[jira] [Created] (FLINK-20448) Obsolete generated avro classes

2020-12-01 Thread Rui Li (Jira)
Rui Li created FLINK-20448: -- Summary: Obsolete generated avro classes Key: FLINK-20448 URL: https://issues.apache.org/jira/browse/FLINK-20448 Project: Flink Issue Type: Test Components:

[GitHub] [flink] caozhen1937 commented on a change in pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-01 Thread GitBox
caozhen1937 commented on a change in pull request #14088: URL: https://github.com/apache/flink/pull/14088#discussion_r533875476 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -24,229 +24,109 @@ specific language governing permissions and limitations under the

[GitHub] [flink] V1ncentzzZ commented on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-01 Thread GitBox
V1ncentzzZ commented on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-736961835 cc @wuchong This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Commented] (FLINK-19398) Hive connector fails with IllegalAccessError if submitted as usercode

2020-12-01 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242014#comment-17242014 ] Yun Gao commented on FLINK-19398: - OK, I'll open the PR, very sorry for not noticed the message. > Hive

[GitHub] [flink] HuangXingBo commented on a change in pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-01 Thread GitBox
HuangXingBo commented on a change in pull request #14088: URL: https://github.com/apache/flink/pull/14088#discussion_r533856595 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -24,229 +24,109 @@ specific language governing permissions and limitations under the

[jira] [Updated] (FLINK-20447) Querying grouy by PK does not work

2020-12-01 Thread Zhenwei Feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenwei Feng updated FLINK-20447: - Priority: Major (was: Minor) > Querying grouy by PK does not work >

[GitHub] [flink] flinkbot edited a comment on pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14088: URL: https://github.com/apache/flink/pull/14088#issuecomment-728662796 ## CI report: * 0b671a6faa179d8465c67150b8459779b8674978 Azure:

[GitHub] [flink-statefun] RocMarshal closed pull request #183: [hotfix][sdk] Change variable names to comply with camel case naming rules and correct spelling of wrong words.

2020-12-01 Thread GitBox
RocMarshal closed pull request #183: URL: https://github.com/apache/flink-statefun/pull/183 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

[jira] [Created] (FLINK-20447) Querying grouy by PK does not work

2020-12-01 Thread Zhenwei Feng (Jira)
Zhenwei Feng created FLINK-20447: Summary: Querying grouy by PK does not work Key: FLINK-20447 URL: https://issues.apache.org/jira/browse/FLINK-20447 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #14270: [FLINK-20436][table-planner-blink] Simplify type parameter of ExecNode

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14270: URL: https://github.com/apache/flink/pull/14270#issuecomment-736353538 ## CI report: * 40d11837b72f31a3c99a6eb8db755acb5309f86e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14088: URL: https://github.com/apache/flink/pull/14088#issuecomment-728662796 ## CI report: * 0b671a6faa179d8465c67150b8459779b8674978 Azure:

[GitHub] [flink-statefun] RocMarshal opened a new pull request #183: [hotfix][sdk] Change variable names to comply with camel case naming rules and correct spelling of wrong words.

2020-12-01 Thread GitBox
RocMarshal opened a new pull request #183: URL: https://github.com/apache/flink-statefun/pull/183 Change variable names to comply with camel case naming rules in `org.apache.flink.statefun.sdk.match.MatchBinder` and correct spelling of wrong words in

[GitHub] [flink] SteNicholas commented on a change in pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-12-01 Thread GitBox
SteNicholas commented on a change in pull request #14028: URL: https://github.com/apache/flink/pull/14028#discussion_r533853218 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientJobClientAdapter.java ## @@ -116,8 +115,7 @@ public JobID

[GitHub] [flink] SteNicholas commented on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-12-01 Thread GitBox
SteNicholas commented on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-736948175 Thanks for @tillrohrmann detailed review reply. I agree with the point that `JobExecutionException` transporting the final `ApplicationStatus` shouldn't be used within the

[GitHub] [flink] SteNicholas commented on a change in pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-12-01 Thread GitBox
SteNicholas commented on a change in pull request #14028: URL: https://github.com/apache/flink/pull/14028#discussion_r533853218 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientJobClientAdapter.java ## @@ -116,8 +115,7 @@ public JobID

[GitHub] [flink] SteNicholas commented on a change in pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-12-01 Thread GitBox
SteNicholas commented on a change in pull request #14028: URL: https://github.com/apache/flink/pull/14028#discussion_r533851974 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/client/JobExecutionException.java ## @@ -19,41 +19,67 @@ package

[GitHub] [flink] SteNicholas commented on a change in pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-12-01 Thread GitBox
SteNicholas commented on a change in pull request #14028: URL: https://github.com/apache/flink/pull/14028#discussion_r533851974 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/client/JobExecutionException.java ## @@ -19,41 +19,67 @@ package

[GitHub] [flink] flinkbot edited a comment on pull request #14270: [FLINK-20436][table-planner-blink] Simplify type parameter of ExecNode

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14270: URL: https://github.com/apache/flink/pull/14270#issuecomment-736353538 ## CI report: * 40d11837b72f31a3c99a6eb8db755acb5309f86e Azure:

[GitHub] [flink] SteNicholas commented on a change in pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-12-01 Thread GitBox
SteNicholas commented on a change in pull request #14028: URL: https://github.com/apache/flink/pull/14028#discussion_r533850366 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java ## @@

[GitHub] [flink] caozhen1937 commented on pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-01 Thread GitBox
caozhen1937 commented on pull request #14088: URL: https://github.com/apache/flink/pull/14088#issuecomment-736942413 @HuangXingBo thank you, I have rebase `master`. This is an automated message from the Apache Git Service.

[jira] [Closed] (FLINK-20073) Add kerberos setup documentation for native k8s integration

2020-12-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20073. Resolution: Done Merged via * master: 7a7c87096ab76f416cd7c393240faa8454db36f0 * 1.12: 

[GitHub] [flink] xintongsong closed pull request #14241: [FLINK-20073][doc] Add native k8s integration to kerberos setup documentation

2020-12-01 Thread GitBox
xintongsong closed pull request #14241: URL: https://github.com/apache/flink/pull/14241 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] sjwiesman commented on a change in pull request #14257: [FLINK-19530] Reorganise contents of Table API concepts

2020-12-01 Thread GitBox
sjwiesman commented on a change in pull request #14257: URL: https://github.com/apache/flink/pull/14257#discussion_r533833261 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -36,6 +36,14 @@ For the changing dimension table, Flink allows for accessing the

[GitHub] [flink] dianfu commented on a change in pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

2020-12-01 Thread GitBox
dianfu commented on a change in pull request #14282: URL: https://github.com/apache/flink/pull/14282#discussion_r533801315 ## File path: flink-python/src/main/resources/META-INF/NOTICE ## @@ -67,11 +68,20 @@ The bundled Apache Beam dependencies bundle the following

[GitHub] [flink] dianfu commented on a change in pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

2020-12-01 Thread GitBox
dianfu commented on a change in pull request #14282: URL: https://github.com/apache/flink/pull/14282#discussion_r533801315 ## File path: flink-python/src/main/resources/META-INF/NOTICE ## @@ -67,11 +68,20 @@ The bundled Apache Beam dependencies bundle the following

[GitHub] [flink] blublinsky closed pull request #14005: Support mounting custom PVCs, secrets and config maps to job/Task manager pods

2020-12-01 Thread GitBox
blublinsky closed pull request #14005: URL: https://github.com/apache/flink/pull/14005 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 #14003: [FLINK-19527][Doc]Flink SQL Getting Started

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14003: URL: https://github.com/apache/flink/pull/14003#issuecomment-724292850 ## CI report: * cd96cfd7f843b802919f0a57a4383fc0bfcb090a Azure:

[GitHub] [flink] zentol commented on a change in pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

2020-12-01 Thread GitBox
zentol commented on a change in pull request #14282: URL: https://github.com/apache/flink/pull/14282#discussion_r533764956 ## File path: flink-python/src/main/resources/META-INF/NOTICE ## @@ -67,11 +68,20 @@ The bundled Apache Beam dependencies bundle the following

[GitHub] [flink] flinkbot edited a comment on pull request #14003: [FLINK-19527][Doc]Flink SQL Getting Started

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14003: URL: https://github.com/apache/flink/pull/14003#issuecomment-724292850 ## CI report: * cd96cfd7f843b802919f0a57a4383fc0bfcb090a Azure:

[GitHub] [flink] zentol commented on a change in pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

2020-12-01 Thread GitBox
zentol commented on a change in pull request #14282: URL: https://github.com/apache/flink/pull/14282#discussion_r533758138 ## File path: flink-python/lib/LICENSE.py4j ## @@ -1,26 +0,0 @@ -Copyright (c) 2009-2018, Barthelemy Dagenais and individual contributors. All Review

[GitHub] [flink] haseeb1431 commented on pull request #14003: [FLINK-19527][Doc]Flink SQL Getting Started

2020-12-01 Thread GitBox
haseeb1431 commented on pull request #14003: URL: https://github.com/apache/flink/pull/14003#issuecomment-736854962 Thanks for all the suggestions and inputs. I have incorporated the changes. Please have a review and let me know if we need any final touches. Thanks

[GitHub] [flink] flinkbot edited a comment on pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14282: URL: https://github.com/apache/flink/pull/14282#issuecomment-736657230 ## CI report: * b264a5b5ccd7365df1c01fbf404d728ef00bf58f Azure:

[GitHub] [flink] haseeb1431 commented on a change in pull request #14003: [FLINK-19527][Doc]Flink SQL Getting Started

2020-12-01 Thread GitBox
haseeb1431 commented on a change in pull request #14003: URL: https://github.com/apache/flink/pull/14003#discussion_r533735947 ## File path: docs/dev/table/sql/gettingStarted.md ## @@ -0,0 +1,226 @@ +--- +title: "Getting Started - Flink SQL" +nav-parent_id: sql +nav-pos: 0

[GitHub] [flink] haseeb1431 commented on a change in pull request #14003: [FLINK-19527][Doc]Flink SQL Getting Started

2020-12-01 Thread GitBox
haseeb1431 commented on a change in pull request #14003: URL: https://github.com/apache/flink/pull/14003#discussion_r533729375 ## File path: docs/dev/table/sql/gettingStarted.md ## @@ -0,0 +1,226 @@ +--- +title: "Getting Started - Flink SQL" +nav-parent_id: sql +nav-pos: 0

[GitHub] [flink] haseeb1431 commented on a change in pull request #14003: [FLINK-19527][Doc]Flink SQL Getting Started

2020-12-01 Thread GitBox
haseeb1431 commented on a change in pull request #14003: URL: https://github.com/apache/flink/pull/14003#discussion_r533726745 ## File path: docs/dev/table/sql/gettingStarted.md ## @@ -0,0 +1,226 @@ +--- +title: "Getting Started - Flink SQL" +nav-parent_id: sql +nav-pos: 0

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

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14281: URL: https://github.com/apache/flink/pull/14281#issuecomment-736654087 ## CI report: * 6a43ad75129ec9332f82134fe4c98329bd6db7b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14282: URL: https://github.com/apache/flink/pull/14282#issuecomment-736657230 ## CI report: * 63f04e148ad295e4a4c03df7e7b56825f2333655 Azure:

[GitHub] [flink] paulangton commented on pull request #11338: [FLINK-10052][ha] Tolerate temporarily suspended ZooKeeper connections

2020-12-01 Thread GitBox
paulangton commented on pull request #11338: URL: https://github.com/apache/flink/pull/11338#issuecomment-736791918 @zentol @tillrohrmann I've been running into this issue and have a lot of interest in getting it fixed, anything we can do to get this moving forward?

[jira] [Commented] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss

2020-12-01 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241831#comment-17241831 ] Nico Kruber commented on FLINK-20427: - If Flink 1.12 adds additional risks here due to the new

[GitHub] [flink] flinkbot edited a comment on pull request #13722: [FLINK-19636][coordination] Add DeclarativeSlotPool

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #13722: URL: https://github.com/apache/flink/pull/13722#issuecomment-713509789 ## CI report: * 7cdd555313da89f3b6be3da396e6782460a482d8 UNKNOWN * 2f59bf5d7da389a1f208497fec6d4453bee129de Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14283: FLINK-15649 Support mounting volumes

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14283: URL: https://github.com/apache/flink/pull/14283#issuecomment-736675395 ## CI report: * bf7d5e41e38d9dbeef734ccb80f97fe948974837 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * b2173ba7a73dc7d79ba4f0679b7076400815d116 Azure:

[jira] [Resolved] (FLINK-20418) NPE in IteratorSourceReader

2020-12-01 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20418. - Resolution: Fixed > NPE in IteratorSourceReader > --- > >

[jira] [Commented] (FLINK-20418) NPE in IteratorSourceReader

2020-12-01 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241820#comment-17241820 ] Arvid Heise commented on FLINK-20418: - Merged into master as

[GitHub] [flink] AHeise merged pull request #14279: [FLINK-20418][core] Fixing checkpointing of IteratorSourceReader.

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

[GitHub] [flink] flinkbot edited a comment on pull request #14283: FLINK-15649 Support mounting volumes

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14283: URL: https://github.com/apache/flink/pull/14283#issuecomment-736675395 ## CI report: * ca7d9b637e2ac020049e3a54b80ba6a14b9f7865 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14284: FLINK-20324 Added Configuration mount support

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14284: URL: https://github.com/apache/flink/pull/14284#issuecomment-736676337 ## CI report: * 79e46eb71823e08b4462a22c024fad6a71f4e3dd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14279: [FLINK-20418][core] Fixing checkpointing of IteratorSourceReader.

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14279: URL: https://github.com/apache/flink/pull/14279#issuecomment-736588058 ## CI report: * 05490783d40bea9c1a38f1af4c731f23bb5160c1 Azure:

[jira] [Commented] (FLINK-20444) Chain AsyncWaitOperator to new sources

2020-12-01 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241772#comment-17241772 ] Arvid Heise commented on FLINK-20444: - Merged into master as

[jira] [Resolved] (FLINK-20444) Chain AsyncWaitOperator to new sources

2020-12-01 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20444. - Fix Version/s: 1.13.0 1.12.0 Resolution: Fixed > Chain

[jira] [Assigned] (FLINK-20444) Chain AsyncWaitOperator to new sources

2020-12-01 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20444: --- Assignee: Arvid Heise > Chain AsyncWaitOperator to new sources >

[GitHub] [flink] AHeise merged pull request #14278: [FLINK-20444][runtime] Chain YieldingOperatorFactory to new sources.

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

[GitHub] [flink] flinkbot edited a comment on pull request #14284: FLINK-20324 Added Configuration mount support

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14284: URL: https://github.com/apache/flink/pull/14284#issuecomment-736676337 ## CI report: * d58f9ba006f80ae16074f0b1cf2e0025a7f5da43 Azure:

  1   2   3   4   >