[jira] [Updated] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks

2022-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5718: -- Labels: pull-request-available (was: ) > Handle JVM Fatal Exceptions in Tasks >

[GitHub] [flink] hackeryard commented on pull request #3276: [FLINK-5718] [core] TaskManagers exit the JVM on fatal exceptions.

2022-04-12 Thread GitBox
hackeryard commented on PR #3276: URL: https://github.com/apache/flink/pull/3276#issuecomment-1097579093 Why taskmanager.jvm-exit-on-oom's default value is false, not true? This means that in default config, we catch OOM exception, but the jvm has already been corrupted. -- This is an

[GitHub] [flink] luoyuxia commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
luoyuxia commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r849088431 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -105,6 +108,8 @@ private void init() throws

[GitHub] [flink] luoyuxia commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
luoyuxia commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r849088431 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -105,6 +108,8 @@ private void init() throws

[jira] [Comment Edited] (FLINK-26811) Document CRD upgrade process

2022-04-12 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521457#comment-17521457 ] Gyula Fora edited comment on FLINK-26811 at 4/13/22 5:26 AM: - I think 3

[jira] [Commented] (FLINK-26811) Document CRD upgrade process

2022-04-12 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521457#comment-17521457 ] Gyula Fora commented on FLINK-26811: I think 3 needs to be changed to  1. Uninstall operator helm

[GitHub] [flink] liuzhuang2017 commented on pull request #19437: [hotfix][streaming-java][runtime] Fix code comments.

2022-04-12 Thread GitBox
liuzhuang2017 commented on PR #19437: URL: https://github.com/apache/flink/pull/19437#issuecomment-1097566595 @Myasuka ,Can you help me review this pr, thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Assigned] (FLINK-27213) Add PurgingTrigger

2022-04-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-27213: --- Assignee: zhangjingcun > Add PurgingTrigger > --- > > Key:

[GitHub] [flink] liuzhuang2017 commented on pull request #19446: [hotfix][docs-zh] Fix Chinese page for "Building Flink from Source"

2022-04-12 Thread GitBox
liuzhuang2017 commented on PR #19446: URL: https://github.com/apache/flink/pull/19446#issuecomment-1097563221 @Myasuka ,Ok,I have updated this pr as you suggested, thanks for your review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-27214) Build Failed on state backend benchmark

2022-04-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521444#comment-17521444 ] Yuan Mei commented on FLINK-27214: -- After a quick glance, it may relate to the commit

[jira] [Updated] (FLINK-27214) Build Failed on state backend benchmark

2022-04-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-27214: - Affects Version/s: 1.16.0 > Build Failed on state backend benchmark >

[jira] [Updated] (FLINK-27214) Build Failed on state backend benchmark

2022-04-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-27214: - Component/s: Benchmarks > Build Failed on state backend benchmark >

[jira] [Updated] (FLINK-27214) Build Failed on state backend benchmark

2022-04-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-27214: - Summary: Build Failed on state backend benchmark (was: [Benchmark] Build Failed on state backend

[jira] [Updated] (FLINK-27214) [Benchmark] Build Failed on state backend benchmark

2022-04-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-27214: - Summary: [Benchmark] Build Failed on state backend benchmark (was: Build Failed on state backend

[jira] [Created] (FLINK-27214) Build Failed on state backend benchmark

2022-04-12 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-27214: Summary: Build Failed on state backend benchmark Key: FLINK-27214 URL: https://issues.apache.org/jira/browse/FLINK-27214 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27213) Add PurgingTrigger

2022-04-12 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-27213: Summary: Add PurgingTrigger Key: FLINK-27213 URL: https://issues.apache.org/jira/browse/FLINK-27213 Project: Flink Issue Type: New Feature

[GitHub] [flink] hehuiyuan commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
hehuiyuan commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r849021129 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -105,6 +108,8 @@ private void init() throws

[GitHub] [flink] hehuiyuan commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
hehuiyuan commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r849021129 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -105,6 +108,8 @@ private void init() throws

[GitHub] [flink] hehuiyuan commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
hehuiyuan commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r849055879 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -105,6 +108,8 @@ private void init() throws

[jira] [Commented] (FLINK-18397) Translate "Table & SQL Connectors Overview" page into Chinese

2022-04-12 Thread Jrebel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521439#comment-17521439 ] Jrebel commented on FLINK-18397: Hello, Jark Wu. I would like to transfer it to Chinese.  Can you assign

[jira] [Commented] (FLINK-26397) Chinese Translation - Add documentation for Kinesis firehose Table Api

2022-04-12 Thread Jrebel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521436#comment-17521436 ] Jrebel commented on FLINK-26397: Hello, Ahmed Hamdy. I would like to transfer it to Chinese.  Can you

[GitHub] [flink] liuzhuang2017 commented on pull request #19446: [hotfix][docs-zh] Fix Chinese page for "Building Flink from Source"

2022-04-12 Thread GitBox
liuzhuang2017 commented on PR #19446: URL: https://github.com/apache/flink/pull/19446#issuecomment-1097517407 @Myasuka ,Can you help me review this pr, thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-16095) Translate "Modules" page of "Table API & SQL" into Chinese

2022-04-12 Thread Jrebel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521431#comment-17521431 ] Jrebel commented on FLINK-16095: Hello, Jark Wu. I would like to transfer it to Chinese.  Can you assign

[jira] [Commented] (FLINK-27212) Failed to CAST('abcde', VARBINARY)

2022-04-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521428#comment-17521428 ] Shengkai Fang commented on FLINK-27212: --- cc [~matriv] [~slinkydeveloper]  > Failed to

[jira] [Updated] (FLINK-27212) Failed to CAST('abcde', VARBINARY)

2022-04-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-27212: -- Description: Please add test in the CalcITCase {code:scala} @Test def testCalc(): Unit =

[jira] [Updated] (FLINK-27212) Failed to CAST('abcde', VARBINARY)

2022-04-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-27212: -- Priority: Blocker (was: Major) > Failed to CAST('abcde', VARBINARY) >

[jira] [Commented] (FLINK-27101) Periodically break the chain of incremental checkpoint

2022-04-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521426#comment-17521426 ] Yun Tang commented on FLINK-27101: -- Just like the factory of checkpoint store, from my mind, we can

[jira] [Commented] (FLINK-27205) Translate "Concepts -> Glossary" page into Chinese

2022-04-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521424#comment-17521424 ] Yun Tang commented on FLINK-27205: -- [~liu zhuang] Already assigned to you, please go ahead. >

[jira] [Created] (FLINK-27212) Failed to CAST('abcde', VARBINARY)

2022-04-12 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-27212: - Summary: Failed to CAST('abcde', VARBINARY) Key: FLINK-27212 URL: https://issues.apache.org/jira/browse/FLINK-27212 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-27205) Translate "Concepts -> Glossary" page into Chinese

2022-04-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-27205: Assignee: Zhuang Liu > Translate "Concepts -> Glossary" page into Chinese >

[jira] [Updated] (FLINK-27205) Translate "Concepts -> Glossary" page into Chinese

2022-04-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-27205: - Fix Version/s: (was: 1.15.0) > Translate "Concepts -> Glossary" page into Chinese >

[jira] [Assigned] (FLINK-25872) Restoring from non-changelog checkpoint with changelog state-backend enabled in CLAIM mode discards state in use

2022-04-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-25872: Assignee: Yanfei Lei > Restoring from non-changelog checkpoint with changelog state-backend

[GitHub] [flink] hehuiyuan commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
hehuiyuan commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r849022769 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -173,6 +178,14 @@ public

[GitHub] [flink] flinkbot commented on pull request #19448: [FLINK-25872][state] Support restore from non-changelog checkpoint with changelog enabled in CLAIM mode

2022-04-12 Thread GitBox
flinkbot commented on PR #19448: URL: https://github.com/apache/flink/pull/19448#issuecomment-1097494365 ## CI report: * d968b906c4e1f70f36b8d62fe53a4e041a3afd4f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] hehuiyuan commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
hehuiyuan commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r849021129 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -105,6 +108,8 @@ private void init() throws

[jira] [Updated] (FLINK-25872) Restoring from non-changelog checkpoint with changelog state-backend enabled in CLAIM mode discards state in use

2022-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25872: --- Labels: pull-request-available (was: ) > Restoring from non-changelog checkpoint with

[GitHub] [flink] hehuiyuan commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
hehuiyuan commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r849021129 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -105,6 +108,8 @@ private void init() throws

[GitHub] [flink] fredia opened a new pull request, #19448: [FLINK-25872][state] Support restore from non-changelog checkpoint with changelog enabled in CLAIM mode

2022-04-12 Thread GitBox
fredia opened a new pull request, #19448: URL: https://github.com/apache/flink/pull/19448 ## What is the purpose of the change *Nowadays, recovering from non-changelog checkpoints is disallowed. Because when restoring from a non-changelog checkpoint with changelog

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #87: [FLINK-27123] Introduce filter predicate for 'LIKE'

2022-04-12 Thread GitBox
JingsongLi commented on code in PR #87: URL: https://github.com/apache/flink-table-store/pull/87#discussion_r849016332 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java: ## @@ -95,9 +109,49 @@ public Predicate

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #87: [FLINK-27123] Introduce filter predicate for 'LIKE'

2022-04-12 Thread GitBox
JingsongLi commented on code in PR #87: URL: https://github.com/apache/flink-table-store/pull/87#discussion_r849016332 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java: ## @@ -95,9 +109,49 @@ public Predicate

[GitHub] [flink] dianfu commented on a diff in pull request #19421: [FLINK-27168][API/Python]Add continuousprocessingtimetrigger and continuouseventtimetrigger triggers

2022-04-12 Thread GitBox
dianfu commented on code in PR #19421: URL: https://github.com/apache/flink/pull/19421#discussion_r848998698 ## flink-python/pyflink/datastream/window.py: ## @@ -48,6 +48,8 @@ 'Trigger', 'EventTimeTrigger', 'ProcessingTimeTrigger', +

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-12 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521415#comment-17521415 ] luoyuxia commented on FLINK-27191: -- What do you mean about the concurrency? IIUC, when access hive, the

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-12 Thread Yuan Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521408#comment-17521408 ] Yuan Zhu commented on FLINK-27191: -- Then how do we deal with the concurrency of UGI's invoking in TM

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-12 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521407#comment-17521407 ] luoyuxia commented on FLINK-27191: -- About the confict with TM's, the idea is when every call involving

[GitHub] [flink-kubernetes-operator] jbusche opened a new pull request, #166: Flink 27211 deployments/finalizers missing for OpenShift Deployment

2022-04-12 Thread GitBox
jbusche opened a new pull request, #166: URL: https://github.com/apache/flink-kubernetes-operator/pull/166 In issue [27211](https://issues.apache.org/jira/browse/FLINK-27211) found a problem where the Flink operator wouldn't deploy on an OpenShift cluster due to missing finalizers in the

[GitHub] [flink] luoyuxia commented on pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
luoyuxia commented on PR #19423: URL: https://github.com/apache/flink/pull/19423#issuecomment-1097455737 @hehuiyuan Thanks very much for your review. -- 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] luoyuxia commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
luoyuxia commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r848991099 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -105,6 +108,8 @@ private void init() throws

[GitHub] [flink] luoyuxia commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
luoyuxia commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r848990971 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -173,6 +178,14 @@ public

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator of Ftrl

2022-04-12 Thread GitBox
weibozhao commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r848984962 ## flink-ml-lib/src/main/java/org/apache/flink/ml/classification/ftrl/FtrlModelParams.java: ## @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[jira] [Comment Edited] (FLINK-26811) Document CRD upgrade process

2022-04-12 Thread Ted Chang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521050#comment-17521050 ] Ted Chang edited comment on FLINK-26811 at 4/13/22 12:26 AM: - [~gyfora]  I

[jira] [Comment Edited] (FLINK-26811) Document CRD upgrade process

2022-04-12 Thread Ted Chang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521385#comment-17521385 ] Ted Chang edited comment on FLINK-26811 at 4/13/22 12:25 AM: - [~gyfora]

[jira] [Comment Edited] (FLINK-26811) Document CRD upgrade process

2022-04-12 Thread Ted Chang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521385#comment-17521385 ] Ted Chang edited comment on FLINK-26811 at 4/13/22 12:24 AM: - [~gyfora]

[jira] [Commented] (FLINK-26811) Document CRD upgrade process

2022-04-12 Thread Ted Chang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521385#comment-17521385 ] Ted Chang commented on FLINK-26811: --- [~gyfora] Thanks savepoint restore works. [~wangyang0918] How

[GitHub] [flink] afedulov commented on pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-12 Thread GitBox
afedulov commented on PR #19405: URL: https://github.com/apache/flink/pull/19405#issuecomment-1097368326 @flinkbot run azure -- 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 the specific comment.

[GitHub] [flink] afedulov commented on pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-12 Thread GitBox
afedulov commented on PR #19405: URL: https://github.com/apache/flink/pull/19405#issuecomment-1097361070 Thanks a lot for your review @fapaul. I originally did not want to invest much time into addressing code duplication because I was under the impression that the ES6-related tests are

[GitHub] [flink] afedulov commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-12 Thread GitBox
afedulov commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r848946159 ## flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/pom.xml: ## @@ -0,0 +1,158 @@ + + +http://maven.apache.org/POM/4.0.0; +

[jira] [Created] (FLINK-27211) RBAC deployments/finalizers missing for OpenShift Deployment

2022-04-12 Thread James Busche (Jira)
James Busche created FLINK-27211: Summary: RBAC deployments/finalizers missing for OpenShift Deployment Key: FLINK-27211 URL: https://issues.apache.org/jira/browse/FLINK-27211 Project: Flink

[GitHub] [flink] afedulov commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-12 Thread GitBox
afedulov commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r848945151 ## flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/test/java/com/apache/flink/streaming/tests/Elasticsearch6SinkExternalContext.java: ## @@ -0,0

[GitHub] [flink] afedulov commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-12 Thread GitBox
afedulov commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r848940015 ## flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/test/java/com/apache/flink/streaming/tests/Elasticsearch6SinkExternalContext.java: ## @@ -0,0

[GitHub] [flink] afedulov commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-12 Thread GitBox
afedulov commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r848932798 ## flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/test/java/com/apache/flink/streaming/tests/Elasticsearch6SinkE2ECase.java: ## @@ -0,0 +1,78 @@ +/*

[jira] [Updated] (FLINK-26083) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink failed on azure due to table exists

2022-04-12 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26083: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-25875) "StatsDReporter. FilterCharacters" for special processing of the characters are comprehensive enough

2022-04-12 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25875: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-26082) CancelPartitionRequestTest.testDuplicateCancel failed on azure due to bind failed

2022-04-12 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26082: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-26084) Python tests exit with code 137

2022-04-12 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26084: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-26091) SafetyNetCloseableRegistryTest.testNonBlockingClose failed on azure

2022-04-12 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26091: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[GitHub] [flink-ml] dependabot[bot] commented on pull request #78: Bump hadoop-common from 2.4.1 to 2.10.1 in /flink-ml-iteration

2022-04-12 Thread GitBox
dependabot[bot] commented on PR #78: URL: https://github.com/apache/flink-ml/pull/78#issuecomment-1097275402 Superseded by #84. -- 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 the specific

[GitHub] [flink-ml] dependabot[bot] closed pull request #78: Bump hadoop-common from 2.4.1 to 2.10.1 in /flink-ml-iteration

2022-04-12 Thread GitBox
dependabot[bot] closed pull request #78: Bump hadoop-common from 2.4.1 to 2.10.1 in /flink-ml-iteration URL: https://github.com/apache/flink-ml/pull/78 -- 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-ml] dependabot[bot] opened a new pull request, #84: Bump hadoop-common from 2.4.1 to 3.2.3 in /flink-ml-iteration

2022-04-12 Thread GitBox
dependabot[bot] opened a new pull request, #84: URL: https://github.com/apache/flink-ml/pull/84 Bumps hadoop-common from 2.4.1 to 3.2.3. [![Dependabot compatibility

[GitHub] [flink] flinkbot commented on pull request #19447: Bump hadoop-common from 2.8.5 to 3.2.3

2022-04-12 Thread GitBox
flinkbot commented on PR #19447: URL: https://github.com/apache/flink/pull/19447#issuecomment-1097274807 ## CI report: * 629aafd465d47f624cbca562ee184d4be0e61725 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] dependabot[bot] closed pull request #19362: Bump hadoop-common from 2.8.5 to 2.10.1

2022-04-12 Thread GitBox
dependabot[bot] closed pull request #19362: Bump hadoop-common from 2.8.5 to 2.10.1 URL: https://github.com/apache/flink/pull/19362 -- 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 the specific

[GitHub] [flink] dependabot[bot] commented on pull request #19362: Bump hadoop-common from 2.8.5 to 2.10.1

2022-04-12 Thread GitBox
dependabot[bot] commented on PR #19362: URL: https://github.com/apache/flink/pull/19362#issuecomment-1097270559 Superseded by #19447. -- 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 the specific

[GitHub] [flink] dependabot[bot] opened a new pull request, #19447: Bump hadoop-common from 2.8.5 to 3.2.3

2022-04-12 Thread GitBox
dependabot[bot] opened a new pull request, #19447: URL: https://github.com/apache/flink/pull/19447 Bumps hadoop-common from 2.8.5 to 3.2.3. [![Dependabot compatibility

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848791202 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date:

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848789068 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date:

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848782042 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date:

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848778948 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date:

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848778948 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date:

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848775592 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date:

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848772395 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date:

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848771870 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date:

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848767877 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date:

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848764381 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date:

[jira] [Updated] (FLINK-27210) StateFun example link on datastream integration page is broken

2022-04-12 Thread Mans Singh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mans Singh updated FLINK-27210: --- Attachment: Screen Shot 2022-04-12 at 2.44.51 PM.png > StateFun example link on datastream

[jira] [Created] (FLINK-27210) StateFun example link on datastream integration page is broken

2022-04-12 Thread Mans Singh (Jira)
Mans Singh created FLINK-27210: -- Summary: StateFun example link on datastream integration page is broken Key: FLINK-27210 URL: https://issues.apache.org/jira/browse/FLINK-27210 Project: Flink

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848756714 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date:

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848754022 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date:

[GitHub] [flink] snuyanzin commented on a diff in pull request #18487: [FLINK-25788][Table SQL / API] Add show connectors command

2022-04-12 Thread GitBox
snuyanzin commented on code in PR #18487: URL: https://github.com/apache/flink/pull/18487#discussion_r848689122 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -1899,4 +1905,14 @@ public TableResult

[jira] [Closed] (FLINK-25806) Remove legacy high availability services

2022-04-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25806. Resolution: Fixed master: ba027b6b1a956b425ff14ed8b55c6aeef3e565c8 > Remove legacy high

[GitHub] [flink] zentol merged pull request #19438: [FLINK-25806][ha] Remove legacy HA services

2022-04-12 Thread GitBox
zentol merged PR #19438: URL: https://github.com/apache/flink/pull/19438 -- 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 the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848138561 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date:

[jira] [Commented] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked

2022-04-12 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521221#comment-17521221 ] fanrui commented on FLINK-26762: Thanks for your quick feedback.  By default, the memory-segment size

[GitHub] [flink] flinkbot commented on pull request #19446: [hotfix][docs-zh] Fix Chinese page for "Building Flink from Source"

2022-04-12 Thread GitBox
flinkbot commented on PR #19446: URL: https://github.com/apache/flink/pull/19446#issuecomment-1096902402 ## CI report: * cb457dd65723a277e0c487b63ed6a56e36669f00 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #19445: [FLINK-27209][build] Half the memory and double forkCount for running unit tests

2022-04-12 Thread GitBox
flinkbot commented on PR #19445: URL: https://github.com/apache/flink/pull/19445#issuecomment-1096894390 ## CI report: * e7b0dc90e48047af924a07d71f255ce7bfb52fc7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 opened a new pull request, #19446: [hotfix][docs-zh] Fix Chinese page for "Building Flink from Source"

2022-04-12 Thread GitBox
liuzhuang2017 opened a new pull request, #19446: URL: https://github.com/apache/flink/pull/19446 ## What is the purpose of the change Fix Chinese page for "Building Flink from Source" ## Brief change log Fix Chinese page for "Building Flink from Source"

[jira] [Updated] (FLINK-27209) Half the Xmx and double the forkCount for unit tests

2022-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27209: --- Labels: pull-request-available (was: ) > Half the Xmx and double the forkCount for unit

[GitHub] [flink] pnowojski opened a new pull request, #19445: [FLINK-27209][build] Half the memory and double forkCount for running unit tests

2022-04-12 Thread GitBox
pnowojski opened a new pull request, #19445: URL: https://github.com/apache/flink/pull/19445 Additionally mark TaskExecutorRecoveryTest as an ITCase due to memory consumption and starting up TaskManagers ## What is the purpose of the change Purpose of this change is to

[jira] [Created] (FLINK-27209) Half the Xmx and double the forkCount for unit tests

2022-04-12 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-27209: -- Summary: Half the Xmx and double the forkCount for unit tests Key: FLINK-27209 URL: https://issues.apache.org/jira/browse/FLINK-27209 Project: Flink

[GitHub] [flink-web] akalash commented on pull request #524: Add Buffer debloating blog post

2022-04-12 Thread GitBox
akalash commented on PR #524: URL: https://github.com/apache/flink-web/pull/524#issuecomment-1096864423 > "instabilities", do you mean "imbalances" or "varying conditions" (instabilities refer rather to failures than to stable conditions) Let's discuss it later but I think that

[jira] [Created] (FLINK-27208) Update the documentation to configure the IDE with scalafmt

2022-04-12 Thread Timo Walther (Jira)
Timo Walther created FLINK-27208: Summary: Update the documentation to configure the IDE with scalafmt Key: FLINK-27208 URL: https://issues.apache.org/jira/browse/FLINK-27208 Project: Flink

[jira] [Closed] (FLINK-27154) Disable web.cancel.enable for application clusters

2022-04-12 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-27154. -- Resolution: Fixed Merged to main: b87211168665a34dff15cd28e3a0c0bb34f9283e > Disable

  1   2   3   4   >