[GitHub] [flink-kubernetes-operator] spoon-lz commented on a diff in pull request #171: [FLINK-27289]Do some optimizations for "FlinkService#stopSessionCluster"

2022-04-18 Thread GitBox
spoon-lz commented on code in PR #171: URL: https://github.com/apache/flink-kubernetes-operator/pull/171#discussion_r852615405 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java: ## @@ -225,7 +225,9 @@ public Optional

[GitHub] [flink] twalthr commented on a diff in pull request #19490: [FLINK-27263][table] Rename the metadata column to the user specified…

2022-04-18 Thread GitBox
twalthr commented on code in PR #19490: URL: https://github.com/apache/flink/pull/19490#discussion_r852601520 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/MergeTableLikeUtilTest.java: ## @@ -431,6 +433,100 @@ public void

[GitHub] [flink] flinkbot commented on pull request #19512: [FLINK-23902][connectors/hive] Make flink support Hive 3.1.3 version .

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

[jira] [Commented] (FLINK-23902) Support Hive version 3.1.3

2022-04-18 Thread Jeff Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524049#comment-17524049 ] Jeff Yang commented on FLINK-23902: --- [~gaoyunhaii] Hi,Please take a look in your free time ,thank you.

[GitHub] [flink] yangjf2019 opened a new pull request, #19512: [FLINK-23902][connectors/hive] Make flink support Hive 3.1.3 version .

2022-04-18 Thread GitBox
yangjf2019 opened a new pull request, #19512: URL: https://github.com/apache/flink/pull/19512 ## What is the purpose of the change *I modified the flink-connectors module to support hive 3.1.3 version.* ## Brief change log *I added a new class and modified

[GitHub] [flink] wolfboys commented on pull request #19511: [FLINK-27299][Runtime/Configuration] flink parsing parameter bug fixed.

2022-04-18 Thread GitBox
wolfboys commented on PR #19511: URL: https://github.com/apache/flink/pull/19511#issuecomment-1102020291 > OK, I'll add testCases.  thank you 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

[GitHub] [flink] wuchong commented on pull request #19511: [FLINK-27299][Runtime/Configuration] flink parsing parameter bug fixed.

2022-04-18 Thread GitBox
wuchong commented on PR #19511: URL: https://github.com/apache/flink/pull/19511#issuecomment-1102010941 @wolfboys , the change looks good to me. However, it would be better to add a test for it, e.g. in the `GlobalConfigurationTest`. -- This is an automated message from the Apache Git

[jira] [Assigned] (FLINK-27299) flink parsing parameter bug

2022-04-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27299: --- Assignee: Huajie Wang > flink parsing parameter bug > --- > >

[GitHub] [flink] flinkbot commented on pull request #19511: [FLINK-27299][Runtime/Configuration] flink parsing parameter bug fixed.

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

[jira] [Updated] (FLINK-27299) flink parsing parameter bug

2022-04-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27299: --- Labels: easyfix pull-request-available (was: easyfix) > flink parsing parameter bug >

[GitHub] [flink] wolfboys opened a new pull request, #19511: [FLINK-27299][Runtime/Configuration] flink parsing parameter bug fixed.

2022-04-18 Thread GitBox
wolfboys opened a new pull request, #19511: URL: https://github.com/apache/flink/pull/19511 ## What is the purpose of the change When I am running a flink job, I specify a running parameter with a "#" sign in it. The parsing fails. e.g: flink run com.myJob

[jira] [Created] (FLINK-27300) Support scala case class for PulsarSchema

2022-04-18 Thread Ben Longo (Jira)
Ben Longo created FLINK-27300: - Summary: Support scala case class for PulsarSchema Key: FLINK-27300 URL: https://issues.apache.org/jira/browse/FLINK-27300 Project: Flink Issue Type: Improvement

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

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

[GitHub] [flink-kubernetes-operator] bgeng777 commented on a diff in pull request #162: [FLINK-27029] DeploymentValidator should take default flink config into account during validation

2022-04-18 Thread GitBox
bgeng777 commented on code in PR #162: URL: https://github.com/apache/flink-kubernetes-operator/pull/162#discussion_r852583825 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/validation/DefaultValidator.java: ## @@ -56,12 +57,17 @@ public class

[jira] [Commented] (FLINK-25470) Add/Expose/Differentiate metrics of checkpoint size between changelog size vs materialization size

2022-04-18 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524033#comment-17524033 ] Yun Tang commented on FLINK-25470: -- I think the incremental size of materialization part is something

[jira] [Updated] (FLINK-27299) flink parsing parameter bug

2022-04-18 Thread Huajie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huajie Wang updated FLINK-27299: Summary: flink parsing parameter bug (was: [BUG] Flink parsing parameter bug) > flink parsing

[jira] [Updated] (FLINK-27299) [BUG] Flink parsing parameter bug

2022-04-18 Thread Huajie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huajie Wang updated FLINK-27299: Affects Version/s: 1.14.3 1.13.6 1.14.2

[GitHub] [flink] mayuehappy commented on pull request #19508: [FLINK-27218] fix the problem that the internal Serializer in Operato…

2022-04-18 Thread GitBox
mayuehappy commented on PR #19508: URL: https://github.com/apache/flink/pull/19508#issuecomment-1101965378 > Thanks for creating this PR, @mayuehappy. First of all, please fill up the description of this PR. Thanks, i've updated the description -- This is an automated message from

[jira] [Created] (FLINK-27299) [BUG] Flink parsing parameter bug

2022-04-18 Thread Huajie Wang (Jira)
Huajie Wang created FLINK-27299: --- Summary: [BUG] Flink parsing parameter bug Key: FLINK-27299 URL: https://issues.apache.org/jira/browse/FLINK-27299 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #19510: [FLINK-27298] in sqlClient.md, table name inconsistency problem.

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

[GitHub] [flink] empcl closed pull request #19487: in filesystem.md, the format parameter described is incomplete.

2022-04-18 Thread GitBox
empcl closed pull request #19487: in filesystem.md, the format parameter described is incomplete. URL: https://github.com/apache/flink/pull/19487 -- 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

[GitHub] [flink] empcl commented on pull request #19487: in filesystem.md, the format parameter described is incomplete.

2022-04-18 Thread GitBox
empcl commented on PR #19487: URL: https://github.com/apache/flink/pull/19487#issuecomment-1101956819 @MartijnVisser OK, I get it. Thank you for your reply. -- 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] [Updated] (FLINK-27298) in sqlClient.md, table name inconsistency problem.

2022-04-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27298: --- Labels: pull-request-available (was: ) > in sqlClient.md, table name inconsistency

[GitHub] [flink] chenlei677 opened a new pull request, #19510: [FLINK-27298] in sqlClient.md, table name inconsistency problem.

2022-04-18 Thread GitBox
chenlei677 opened a new pull request, #19510: URL: https://github.com/apache/flink/pull/19510 ## What is the purpose of the change This pull request fix table name inconsistency problem in sqlClient.md. ## Brief change log fix table name inconsistency problem in

[jira] [Created] (FLINK-27298) in sqlClient.md, table name inconsistency problem.

2022-04-18 Thread Jira
陈磊 created FLINK-27298: -- Summary: in sqlClient.md, table name inconsistency problem. Key: FLINK-27298 URL: https://issues.apache.org/jira/browse/FLINK-27298 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-23902) Support Hive version 3.1.3

2022-04-18 Thread Jeff Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Yang updated FLINK-23902: -- Affects Version/s: 1.15.0 1.15.1 > Support Hive version 3.1.3 >

[GitHub] [flink-kubernetes-operator] Aitozi commented on pull request #168: [FLINK-27161] Support fetch user jar from different source

2022-04-18 Thread GitBox
Aitozi commented on PR #168: URL: https://github.com/apache/flink-kubernetes-operator/pull/168#issuecomment-1101953837 Thanks for your explanation , I get your meaning. We could support session job first and then use the way of injecting init container as a bridge before the flink has

[jira] [Created] (FLINK-27297) Add the StreamExecutionEnvironment#getExecutionEnvironment(Configuration) method in PyFlink

2022-04-18 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-27297: Summary: Add the StreamExecutionEnvironment#getExecutionEnvironment(Configuration) method in PyFlink Key: FLINK-27297 URL: https://issues.apache.org/jira/browse/FLINK-27297

[jira] [Created] (FLINK-27296) CalcOperator CodeGenException: Boolean expression type expected

2022-04-18 Thread tartarus (Jira)
tartarus created FLINK-27296: Summary: CalcOperator CodeGenException: Boolean expression type expected Key: FLINK-27296 URL: https://issues.apache.org/jira/browse/FLINK-27296 Project: Flink

[jira] [Updated] (FLINK-23902) Support Hive version 3.1.3

2022-04-18 Thread Jeff Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Yang updated FLINK-23902: -- Description: Make flink support Hive version 3.1.3 version. (was: Make flink support Hive version

[jira] [Updated] (FLINK-27294) Add Transformer for EvalBinaryClass

2022-04-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27294: --- Labels: pull-request-available (was: ) > Add Transformer for EvalBinaryClass >

[GitHub] [flink] Myasuka commented on pull request #19508: [FLINK-27218] fix the problem that the internal Serializer in Operato…

2022-04-18 Thread GitBox
Myasuka commented on PR #19508: URL: https://github.com/apache/flink/pull/19508#issuecomment-1101948011 Thanks for creating this PR, @mayuehappy. First of all, please fill up the description of this PR. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink-ml] weibozhao opened a new pull request, #86: [FLINK-27294] Add Transformer for EvalBinaryClass

2022-04-18 Thread GitBox
weibozhao opened a new pull request, #86: URL: https://github.com/apache/flink-ml/pull/86 Add Transformer for EvalBinaryClass -- 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

[jira] [Resolved] (FLINK-25867) [ZH] Add ChangelogBackend documentation

2022-04-18 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-25867. -- Fix Version/s: 1.15.0 Resolution: Fixed Merged in master:

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #170: [FLINK-27235] Publish Flink k8s Operator Helm Charts via Github Actions

2022-04-18 Thread GitBox
wangyang0918 commented on PR #170: URL: https://github.com/apache/flink-kubernetes-operator/pull/170#issuecomment-1101946174 @GezimSejdiu Thanks for working on this. I have two concerns about this PR. * `https://downloads.apache.org/flink/` is not a right place to host the snapshot helm

[GitHub] [flink] Myasuka merged pull request #19252: [FLINK-25867][docs] translate ChangelogBackend documentation to chinese

2022-04-18 Thread GitBox
Myasuka merged PR #19252: URL: https://github.com/apache/flink/pull/19252 -- 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:

[jira] [Commented] (FLINK-27289) Do some optimizations for "FlinkService#stopSessionCluster"

2022-04-18 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524021#comment-17524021 ] Yang Wang commented on FLINK-27289: --- Valid improvement. I have assigned this ticket to you and happy

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a diff in pull request #171: [FLINK-27289]Do some optimizations for "FlinkService#stopSessionCluster"

2022-04-18 Thread GitBox
wangyang0918 commented on code in PR #171: URL: https://github.com/apache/flink-kubernetes-operator/pull/171#discussion_r852551483 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java: ## @@ -225,7 +225,9 @@ public Optional

[jira] [Updated] (FLINK-27295) UnalignedCheckpointITCase failed due to OperatorCoordinatorHolder cannot mark checkpoint

2022-04-18 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-27295: - Description:   {code:java} 09:17:42,931 [flink-akka.actor.default-dispatcher-9] INFO

[jira] [Created] (FLINK-27295) UnalignedCheckpointITCase failed due to OperatorCoordinatorHolder cannot mark checkpoint

2022-04-18 Thread Yun Tang (Jira)
Yun Tang created FLINK-27295: Summary: UnalignedCheckpointITCase failed due to OperatorCoordinatorHolder cannot mark checkpoint Key: FLINK-27295 URL: https://issues.apache.org/jira/browse/FLINK-27295

[jira] [Assigned] (FLINK-27289) Do some optimizations for "FlinkService#stopSessionCluster"

2022-04-18 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-27289: - Assignee: liuzhuo > Do some optimizations for "FlinkService#stopSessionCluster" >

[jira] [Commented] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-18 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524019#comment-17524019 ] Feifan Wang commented on FLINK-27187: - kindly ping [~roman]  > The attemptsPerUpload metric may be

[GitHub] [flink] Myasuka commented on pull request #19500: [FLINK-27278][docs] Fix wrong indentation in windows docs

2022-04-18 Thread GitBox
Myasuka commented on PR #19500: URL: https://github.com/apache/flink/pull/19500#issuecomment-1101938647 @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.

[jira] [Commented] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-18 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524018#comment-17524018 ] Yun Gao commented on FLINK-27148: - Fix on master via 2c608b8efa18e4633ba4cee308ea71a4c54ab955 >

[jira] [Closed] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-18 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-27148. --- Resolution: Fixed > UnalignedCheckpointITCase fails on AZP > -- > >

[GitHub] [flink] gaoyunhaii closed pull request #19464: [FLINK-27148][checkpoint] Skip snapshotting the coordinators state or the master state if the pending checkpoint has been disposed.

2022-04-18 Thread GitBox
gaoyunhaii closed pull request #19464: [FLINK-27148][checkpoint] Skip snapshotting the coordinators state or the master state if the pending checkpoint has been disposed. URL: https://github.com/apache/flink/pull/19464 -- This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-27288) flink operator crd is too long

2022-04-18 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524017#comment-17524017 ] Yang Wang commented on FLINK-27288: --- [~kent.yin] Please do not create a blocker if you indeed believe

[jira] [Updated] (FLINK-27288) flink operator crd is too long

2022-04-18 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-27288: -- Component/s: Kubernetes Operator (was: flink-contrib) > flink operator crd is

[jira] [Updated] (FLINK-27288) flink operator crd is too long

2022-04-18 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-27288: -- Priority: Critical (was: Blocker) > flink operator crd is too long > --

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #168: [FLINK-27161] Support fetch user jar from different source

2022-04-18 Thread GitBox
wangyang0918 commented on PR #168: URL: https://github.com/apache/flink-kubernetes-operator/pull/168#issuecomment-1101934289 @Aitozi It will be great and makes things easier if the upstream Flink could support remote user jars directly. Benefit from YARN distributed cache, the YARN

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #93: [FLINK-27283] Add end to end tests for table store

2022-04-18 Thread GitBox
tsreaper commented on code in PR #93: URL: https://github.com/apache/flink-table-store/pull/93#discussion_r852538248 ## flink-table-store-e2e-tests/pom.xml: ## @@ -0,0 +1,113 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #93: [FLINK-27283] Add end to end tests for table store

2022-04-18 Thread GitBox
JingsongLi commented on code in PR #93: URL: https://github.com/apache/flink-table-store/pull/93#discussion_r852534507 ## flink-table-store-e2e-tests/src/test/resources/log4j2-test.properties: ## @@ -0,0 +1,28 @@

[jira] [Created] (FLINK-27294) Add Transformer for EvalBinaryClass

2022-04-18 Thread weibo zhao (Jira)
weibo zhao created FLINK-27294: -- Summary: Add Transformer for EvalBinaryClass Key: FLINK-27294 URL: https://issues.apache.org/jira/browse/FLINK-27294 Project: Flink Issue Type: New Feature

[GitHub] [flink] pltbkd commented on pull request #19464: [FLINK-27148][checkpoint] Skip snapshotting the coordinators state or the master state if the pending checkpoint has been disposed.

2022-04-18 Thread GitBox
pltbkd commented on PR #19464: URL: https://github.com/apache/flink/pull/19464#issuecomment-1101908514 @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-ml] zhipeng93 commented on pull request #83: [FLINK-27170] Add Transformer and Estimator for Ftrl

2022-04-18 Thread GitBox
zhipeng93 commented on PR #83: URL: https://github.com/apache/flink-ml/pull/83#issuecomment-1101907239 Should we make `FTRL` an optimizer or an algorithm? As I see, FTRL is an optimizer that could be used to optimize Logistic Regression, just as SGD. -- This is an automated message from

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

2022-04-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-27213. --- Fix Version/s: 1.16.0 Assignee: zhangjingcun Resolution: Fixed Merged to master via

[GitHub] [flink] dianfu closed pull request #19480: [FLINK-27213][API/Python]Add PurgingTrigger

2022-04-18 Thread GitBox
dianfu closed pull request #19480: [FLINK-27213][API/Python]Add PurgingTrigger URL: https://github.com/apache/flink/pull/19480 -- 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-shaded] RetroDreams closed pull request #109: [FLINK-27293] Update jackson-bom to address CVE-2020-36518

2022-04-18 Thread GitBox
RetroDreams closed pull request #109: [FLINK-27293] Update jackson-bom to address CVE-2020-36518 URL: https://github.com/apache/flink-shaded/pull/109 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Updated] (FLINK-26048) Yarn access should be separated by semicolon

2022-04-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26048: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-26202) Support Table API in Pulsar Source Connector

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

[jira] [Updated] (FLINK-25989) EventTimeWindowCheckpointingITCase failed with exit code 137

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

[jira] [Updated] (FLINK-11852) Improve Processing function example

2022-04-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11852: --- Labels: auto-deprioritized-minor auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-25884) PulsarSourceITCase.testTaskManagerFailure failed on azure

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

[jira] [Updated] (FLINK-26203) Support Table API in Pulsar Sink Connector

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

[jira] [Updated] (FLINK-12395) Add more detailed javadoc for getDescription() and getDetailedDescription() in catalog object interfaces

2022-04-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12395: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-12470) FLIP39: Flink ML pipeline and ML libs

2022-04-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12470: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned

[jira] [Updated] (FLINK-12499) JDBCAppendTableSink support retry

2022-04-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12499: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-19697) Make the Sink API committer retry-able

2022-04-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19697: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-12256) Implement Confluent Schema Registry Catalog

2022-04-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12256: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[jira] [Updated] (FLINK-11747) Elasticsearch 6 connector - Expose RestHighLevelClient to allow for custom sniffing

2022-04-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11747: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned

[jira] [Updated] (FLINK-12770) Make number of bulk concurrentRequests configurable

2022-04-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12770: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-13194) Add explicit clarification about thread-safety of state in document

2022-04-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13194: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned

[jira] [Updated] (FLINK-13611) Introduce analyze statistic utility to generate table & column statistics

2022-04-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13611: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-14079) Full data type support in planner

2022-04-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14079: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-27293) CVE-2020-36518 in flink-shaded jackson

2022-04-18 Thread Spencer Deehring (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spencer Deehring updated FLINK-27293: - Description: jackson-databind contains a CVE and is pulled in via jackson-bom located

[jira] [Updated] (FLINK-27293) CVE-2020-36518 in flink-shaded jackson

2022-04-18 Thread Spencer Deehring (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spencer Deehring updated FLINK-27293: - Description: jackson-databind contains a CVE and is pulled in via jackson-bom located

[jira] [Updated] (FLINK-27293) CVE-2020-36518 in flink-shaded jackson

2022-04-18 Thread Spencer Deehring (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spencer Deehring updated FLINK-27293: - Description: jackson-databind contains a CVE and is pulled in via jackson-bom located

[jira] [Updated] (FLINK-27293) CVE-2020-36518 in flink-shaded jackson

2022-04-18 Thread Spencer Deehring (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spencer Deehring updated FLINK-27293: - Description: jackson-databind contains a CVE and is pulled in via jackson-bom located

[jira] [Updated] (FLINK-27293) CVE-2020-36518 in flink-shaded jackson

2022-04-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27293: --- Labels: pull-request-available (was: ) > CVE-2020-36518 in flink-shaded jackson >

[GitHub] [flink-shaded] RetroDreams opened a new pull request, #109: [FLINK-27293] Update jackson-bom to address CVE-2020-36518

2022-04-18 Thread GitBox
RetroDreams opened a new pull request, #109: URL: https://github.com/apache/flink-shaded/pull/109 Addressing CVE-2020-36518 References: https://github.com/FasterXML/jackson/wiki/Jackson-Release-2.13#micro-patches https://github.com/FasterXML/jackson-databind/issues/2816 --

[jira] [Created] (FLINK-27293) CVE-2020-36518 in flink-shaded jackson

2022-04-18 Thread Spencer Deehring (Jira)
Spencer Deehring created FLINK-27293: Summary: CVE-2020-36518 in flink-shaded jackson Key: FLINK-27293 URL: https://issues.apache.org/jira/browse/FLINK-27293 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #19509: [hotfix][docs-zh] Delete redundant lines in pulsar.md

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

[GitHub] [flink] zhuanshenbsj1 opened a new pull request, #19509: [hotfix][docs-zh] Delete redundant lines in pulsar.md

2022-04-18 Thread GitBox
zhuanshenbsj1 opened a new pull request, #19509: URL: https://github.com/apache/flink/pull/19509 ## What is the purpose of the change **A few lines(about java11) in Chinese pulsar document are redundant.** **English document:**

[GitHub] [flink] liuzhuang2017 commented on pull request #19491: [hotfix][docs-zh] Delete the "mongodb.md" file under "Formats" under "DataStream Connectors".

2022-04-18 Thread GitBox
liuzhuang2017 commented on PR #19491: URL: https://github.com/apache/flink/pull/19491#issuecomment-1101511796 @wuchong ,Thanks 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 to

[GitHub] [flink] wuchong merged pull request #19491: [hotfix][docs-zh] Delete the "mongodb.md" file under "Formats" under "DataStream Connectors".

2022-04-18 Thread GitBox
wuchong merged PR #19491: URL: https://github.com/apache/flink/pull/19491 -- 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] flinkbot commented on pull request #19508: [FLINK-27218] fix the problem that the internal Serializer in Operato…

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

[jira] [Commented] (FLINK-27218) Serializer in OperatorState has not been updated when new Serializers are NOT incompatible

2022-04-18 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523702#comment-17523702 ] Yue Ma commented on FLINK-27218: [~yunta] hi , I drafted a pr

[jira] [Updated] (FLINK-27218) Serializer in OperatorState has not been updated when new Serializers are NOT incompatible

2022-04-18 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yue Ma updated FLINK-27218: --- Attachment: image-2022-04-18-21-48-30-519.png > Serializer in OperatorState has not been updated when new

[jira] [Updated] (FLINK-27218) Serializer in OperatorState has not been updated when new Serializers are NOT incompatible

2022-04-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27218: --- Labels: pull-request-available (was: ) > Serializer in OperatorState has not been updated

[GitHub] [flink] mayuehappy opened a new pull request, #19508: [FLINK-27218] fix the problem that the internal Serializer in Operato…

2022-04-18 Thread GitBox
mayuehappy opened a new pull request, #19508: URL: https://github.com/apache/flink/pull/19508 …rState may have not been updated when sechema changes ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server,

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

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

[jira] [Assigned] (FLINK-27290) Translate the "Data Type" section of "Data Types" in to Chinese

2022-04-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27290: --- Assignee: Chengkai Yang > Translate the "Data Type" section of "Data Types" in to Chinese >

[jira] [Updated] (FLINK-27292) Translate the "Data Type Extraction" section of "Data Types" in to Chinese

2022-04-18 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27292: -- Description: This JIRA translate the "Data Type Extraction" section in Data Types. The url

[jira] [Updated] (FLINK-27291) Translate the "List of Data Types" section of "Data Types" in to Chinese

2022-04-18 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27291: -- Description: This JIRA translate the "List of Data Types" section in Data Types. The url is

[jira] [Created] (FLINK-27292) Translate the "Data Type Extraction" section of "Data Types" in to Chinese

2022-04-18 Thread Chengkai Yang (Jira)
Chengkai Yang created FLINK-27292: - Summary: Translate the "Data Type Extraction" section of "Data Types" in to Chinese Key: FLINK-27292 URL: https://issues.apache.org/jira/browse/FLINK-27292

[jira] [Updated] (FLINK-27290) Translate the "Data Type" section of "Data Types" in to Chinese

2022-04-18 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27290: -- Priority: Minor (was: Major) > Translate the "Data Type" section of "Data Types" in to

[jira] [Updated] (FLINK-27276) Translate "Data Types" page of "Table API & SQL" in to Chinese

2022-04-18 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27276: -- Priority: Minor (was: Major) > Translate "Data Types" page of "Table API & SQL" in to

[jira] [Created] (FLINK-27291) Translate the "List of Data Types" section of "Data Types" in to Chinese

2022-04-18 Thread Chengkai Yang (Jira)
Chengkai Yang created FLINK-27291: - Summary: Translate the "List of Data Types" section of "Data Types" in to Chinese Key: FLINK-27291 URL: https://issues.apache.org/jira/browse/FLINK-27291 Project:

[jira] (FLINK-27290) Translate the "Data Type" section of "Data Types" in to Chinese

2022-04-18 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27290 ] Chengkai Yang deleted comment on FLINK-27290: --- was (Author: JIRAUSER282569): This JIRA translate the first section in Data Types. The url is

[jira] [Commented] (FLINK-27290) Translate the "Data Type" section of "Data Types" in to Chinese

2022-04-18 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523666#comment-17523666 ] Chengkai Yang commented on FLINK-27290: --- This JIRA translate the first section in Data Types. The

  1   2   3   >