[GitHub] [flink-kubernetes-operator] SteNicholas commented on pull request #247: [FLINK-27668] Document dynamic operator configuration

2022-05-27 Thread GitBox
SteNicholas commented on PR #247: URL: https://github.com/apache/flink-kubernetes-operator/pull/247#issuecomment-1140177723 @gyfora , PTAL. -- 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

[jira] [Commented] (FLINK-27668) Document dynamic operator configuration

2022-05-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543414#comment-17543414 ] Nicholas Jiang commented on FLINK-27668: [~gyfora], could you please assign this ticket to me? I

[jira] [Updated] (FLINK-27668) Document dynamic operator configuration

2022-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27668: --- Labels: pull-request-available (was: ) > Document dynamic operator configuration >

[GitHub] [flink-kubernetes-operator] SteNicholas opened a new pull request, #247: [FLINK-27668] Document dynamic operator configuration

2022-05-27 Thread GitBox
SteNicholas opened a new pull request, #247: URL: https://github.com/apache/flink-kubernetes-operator/pull/247 The Kubernetes operator now support dynamic config changes through the operator ConfigMap.This feature is not documented properly and it should be added to the

[jira] [Commented] (FLINK-27009) Support SQL job submission in flink kubernetes opeartor

2022-05-27 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543405#comment-17543405 ] Biao Geng commented on FLINK-27009: --- hi [~mbalassi] thanks for paying attention. I have already

[jira] [Created] (FLINK-27822) Translate the doc of checkpoint/savepoint guarantees

2022-05-27 Thread fanrui (Jira)
fanrui created FLINK-27822: -- Summary: Translate the doc of checkpoint/savepoint guarantees Key: FLINK-27822 URL: https://issues.apache.org/jira/browse/FLINK-27822 Project: Flink Issue Type:

[jira] (FLINK-26937) Introduce Leveled compression for LSM

2022-05-27 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26937 ] liwei li deleted comment on FLINK-26937: -- was (Author: liliwei): may i have a try? > Introduce Leveled compression for LSM > - > > Key:

[jira] [Updated] (FLINK-27788) Adding annotation to k8 operator Pod

2022-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27788: --- Labels: pull-request-available (was: ) > Adding annotation to k8 operator Pod >

[GitHub] [flink-kubernetes-operator] mbalassi commented on a diff in pull request #246: [FLINK-27788] Adding annotation to k8 operator Pod

2022-05-27 Thread GitBox
mbalassi commented on code in PR #246: URL: https://github.com/apache/flink-kubernetes-operator/pull/246#discussion_r884046691 ## helm/flink-kubernetes-operator/templates/flink-operator.yaml: ## @@ -34,6 +34,12 @@ spec: {{- include "flink-operator.selectorLabels" . |

[jira] [Commented] (FLINK-27009) Support SQL job submission in flink kubernetes opeartor

2022-05-27 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543358#comment-17543358 ] Márton Balassi commented on FLINK-27009: Hi [~bgeng777], do you mind if I take a stab at this or

[jira] [Closed] (FLINK-27506) update playgrounds for Flink 1.14

2022-05-27 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson closed FLINK-27506. -- Fix Version/s: 1.14.4 Resolution: Fixed > update playgrounds for Flink 1.14 >

[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-27 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543099#comment-17543099 ] Galen Warren commented on FLINK-27813: -- Are you using RequestReplyFunctionBuilder to build your

[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-27 Thread Oleksandr (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543094#comment-17543094 ] Oleksandr commented on FLINK-27813: --- [~galenwarren]  we have such specs for example: {code:java}

[jira] [Updated] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-27 Thread Oleksandr (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr updated FLINK-27813: -- Description: Issue was met after migration from  flink-statefun:3.1.1-java11 to

[jira] [Closed] (FLINK-27818) Model enums as references in OpenAPI spec

2022-05-27 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27818. Resolution: Fixed master: e7834d8b56a7b4b1c2674ab399032e21e76d9e63 > Model enums as

[GitHub] [flink] zentol merged pull request #19835: [FLINK-27818][rest][docs] Model enums as references

2022-05-27 Thread GitBox
zentol merged PR #19835: URL: https://github.com/apache/flink/pull/19835 -- 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-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

2022-05-27 Thread EMing Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543006#comment-17543006 ] EMing Zhou commented on FLINK-27734: Hi [~Feifan Wang]     I also found that it may be due to an

[GitHub] [flink] flinkbot commented on pull request #19837: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connecto…

2022-05-27 Thread GitBox
flinkbot commented on PR #19837: URL: https://github.com/apache/flink/pull/19837#issuecomment-1139747723 ## CI report: * 0444a912f1d97bc13f7ea5747aae4c52c93e7fa4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] JasonLeeCoding opened a new pull request, #19837: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connecto…

2022-05-27 Thread GitBox
JasonLeeCoding opened a new pull request, #19837: URL: https://github.com/apache/flink/pull/19837 ## What is the purpose of the change *Modify the code error in the document* ## Brief change log *Modify the code error in the document* ## Verifying this

[jira] [Commented] (FLINK-27804) Do not observe cluster/job mid upgrade

2022-05-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542984#comment-17542984 ] Gyula Fora commented on FLINK-27804: The problem is that I cannot reliably say what the root cause

[jira] [Comment Edited] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

2022-05-27 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542979#comment-17542979 ] Feifan Wang edited comment on FLINK-27734 at 5/27/22 3:34 PM: -- Thanks for

[jira] [Commented] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

2022-05-27 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542983#comment-17542983 ] Feifan Wang commented on FLINK-27734: - [~Zsigner] , I think the problem is strict equals operator (

[jira] [Commented] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

2022-05-27 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542979#comment-17542979 ] Feifan Wang commented on FLINK-27734: - Thanks for reply [~Zsigner] , I want just remove single

[GitHub] [flink-table-store] ajian2002 commented on pull request #121: [FLINK-27626] Introduce AggregatuibMergeFunction

2022-05-27 Thread GitBox
ajian2002 commented on PR #121: URL: https://github.com/apache/flink-table-store/pull/121#issuecomment-1139717042 > @tsreaper 我为每一列的功能,不同的聚合类型都扩展了列功能接口,不同的数据类型实现了不同类型的列接口功能。这种实现关系确保我们有所有的列聚合接口。 Now we can specify different aggregate functions for different columns, but I haven't

[GitHub] [flink-table-store] ajian2002 commented on pull request #121: [FLINK-27626] Introduce AggregatuibMergeFunction

2022-05-27 Thread GitBox
ajian2002 commented on PR #121: URL: https://github.com/apache/flink-table-store/pull/121#issuecomment-1139716861 > @tsreaper 我为每一列实现了列聚合函数接口,所有不同的聚合种类都扩展了列聚合函数接口,不同的数据类型实现了对应种类的列聚合函数接口。这三层关系确保我们有足够的灵活性。 Now we can specify different aggregate functions for different columns, but I

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator for OnlineLogisticRegression

2022-05-27 Thread GitBox
lindong28 commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r883628874 ## flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java: ## @@ -182,4 +193,63 @@ public void snapshotState(StateSnapshotContext

[jira] [Commented] (FLINK-25538) [JUnit5 Migration] Module: flink-connector-kafka

2022-05-27 Thread Anatoly Popov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542972#comment-17542972 ] Anatoly Popov commented on FLINK-25538: --- [~renqs] I would be interested to work on this one. Could

[jira] [Commented] (FLINK-27804) Do not observe cluster/job mid upgrade

2022-05-27 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542971#comment-17542971 ] Yang Wang commented on FLINK-27804: --- If this issue occurs every few hundred upgrades, then I am afraid

[GitHub] [flink-table-store] ajian2002 commented on pull request #121: [FLINK-27626] Introduce AggregatuibMergeFunction

2022-05-27 Thread GitBox
ajian2002 commented on PR #121: URL: https://github.com/apache/flink-table-store/pull/121#issuecomment-1139714404 @tsreaper I implement the column aggregation function interface for each column, all the different aggregation kinds extend the column aggregation function interface, and

[jira] [Commented] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

2022-05-27 Thread EMing Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542970#comment-17542970 ] EMing Zhou commented on FLINK-27734: Hi [~Feifan Wang]  So I think this value should not be changed,

[jira] [Commented] (FLINK-27805) Bump ORC version to 1.7.2

2022-05-27 Thread Dongjoon Hyun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542965#comment-17542965 ] Dongjoon Hyun commented on FLINK-27805: --- Please take over this, [~sonice_lj]. :) > Bump ORC

[jira] [Commented] (FLINK-27821) Cannot delete flinkdeployment when the pod and deployment deleted manually

2022-05-27 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542961#comment-17542961 ] Aitozi commented on FLINK-27821: [~Miuler] The deletion of the session cluster's flinkdeployment object

[jira] [Commented] (FLINK-27821) Cannot delete flinkdeployment when the pod and deployment deleted manually

2022-05-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542931#comment-17542931 ] Gyula Fora commented on FLINK-27821: cc [~aitozi] , maybe you have seen something similar > Cannot

[jira] [Commented] (FLINK-27821) Cannot delete flinkdeployment when the pod and deployment deleted manually

2022-05-27 Thread Hector Miuler Malpica Gallegos (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542930#comment-17542930 ] Hector Miuler Malpica Gallegos commented on FLINK-27821: I delete the

[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-27 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542929#comment-17542929 ] Galen Warren commented on FLINK-27813: -- Hmm, not sure. The relevant part of the error message seems

[jira] [Updated] (FLINK-27821) Cannot delete flinkdeployment when the pod and deployment deleted manually

2022-05-27 Thread Hector Miuler Malpica Gallegos (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hector Miuler Malpica Gallegos updated FLINK-27821: --- Description: My operator was installed with following

[jira] [Updated] (FLINK-27821) Cannot delete flinkdeployment when the pod and deployment deleted manually

2022-05-27 Thread Hector Miuler Malpica Gallegos (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hector Miuler Malpica Gallegos updated FLINK-27821: --- Description: My operator was installed with following

[jira] [Updated] (FLINK-27821) Cannot delete flinkdeployment when the pod and deployment deleted manually

2022-05-27 Thread Hector Miuler Malpica Gallegos (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hector Miuler Malpica Gallegos updated FLINK-27821: --- Description: My operator was installed with following

[jira] [Updated] (FLINK-27821) Cannot delete flinkdeployment when the pod and deployment deleted manually

2022-05-27 Thread Hector Miuler Malpica Gallegos (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hector Miuler Malpica Gallegos updated FLINK-27821: --- Description: My operator was installed with following

[jira] [Updated] (FLINK-27821) Cannot delete flinkdeployment when the pod and deployment deleted manually

2022-05-27 Thread Hector Miuler Malpica Gallegos (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hector Miuler Malpica Gallegos updated FLINK-27821: --- Description: My operator was installed with following

[jira] [Created] (FLINK-27821) Cannot delete flinkdeployment when the pod and deployment deleted manually

2022-05-27 Thread Hector Miuler Malpica Gallegos (Jira)
Hector Miuler Malpica Gallegos created FLINK-27821: -- Summary: Cannot delete flinkdeployment when the pod and deployment deleted manually Key: FLINK-27821 URL:

[GitHub] [flink] flinkbot commented on pull request #19836: [FLINK-27819][rest][docs] Use proper operationIds

2022-05-27 Thread GitBox
flinkbot commented on PR #19836: URL: https://github.com/apache/flink/pull/19836#issuecomment-1139623281 ## CI report: * 031ebf31dd920a905ed1e506bd8cc5112f3fb9db UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-27812) Support Dynamic Change of Watched Namespaces

2022-05-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-27812: -- Assignee: Matyas Orhidi > Support Dynamic Change of Watched Namespaces >

[jira] [Updated] (FLINK-27819) Generate better operationIds for OpenAPI spec

2022-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27819: --- Labels: pull-request-available (was: ) > Generate better operationIds for OpenAPI spec >

[GitHub] [flink] zentol opened a new pull request, #19836: [FLINK-27819][rest][docs] Use proper operationIds

2022-05-27 Thread GitBox
zentol opened a new pull request, #19836: URL: https://github.com/apache/flink/pull/19836 Adds some simple generation logic and covers a few edge-cases to have proper operationIds in the OpenAPI spec. These are used for the generated method names. The naming pattern is similar to

[jira] [Commented] (FLINK-27802) Savepoint restore errors are swallowed for Flink 1.15

2022-05-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542910#comment-17542910 ] Gyula Fora commented on FLINK-27802: that's true, but people generally look at the logs of the last

[jira] [Created] (FLINK-27820) Handle Upgrade/Deployment errors gracefully

2022-05-27 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-27820: -- Summary: Handle Upgrade/Deployment errors gracefully Key: FLINK-27820 URL: https://issues.apache.org/jira/browse/FLINK-27820 Project: Flink Issue Type:

[jira] [Updated] (FLINK-27775) FlinkKafkaProducer VS KafkaSink

2022-05-27 Thread Jiangfei Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangfei Liu updated FLINK-27775: - Issue Type: Bug (was: Improvement) > FlinkKafkaProducer VS KafkaSink >

[jira] [Updated] (FLINK-27804) Do not observe cluster/job mid upgrade

2022-05-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27804: --- Fix Version/s: kubernetes-operator-1.0.0 > Do not observe cluster/job mid upgrade >

[jira] [Closed] (FLINK-27804) Do not observe cluster/job mid upgrade

2022-05-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-27804. -- Resolution: Fixed Merged main: aa4f1d64d223d2dfa434edcd4c2ae8a9b54d0fdf release-1.0:

[jira] [Comment Edited] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

2022-05-27 Thread EMing Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542839#comment-17542839 ] EMing Zhou edited comment on FLINK-27734 at 5/27/22 12:55 PM: -- Hi [~Feifan

[jira] [Commented] (FLINK-27804) Do not observe cluster/job mid upgrade

2022-05-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542902#comment-17542902 ] Gyula Fora commented on FLINK-27804: Yes I completely agree that it should work, but we once out of

[jira] [Commented] (FLINK-20681) Support specifying the hdfs path when ship archives or files

2022-05-27 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542901#comment-17542901 ] ming li commented on FLINK-20681: - hi, [~RocMarshal], what is the current progress of this issue? We

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #245: [FLINK-27804] Do not observe cluster/job mid upgrade

2022-05-27 Thread GitBox
gyfora merged PR #245: URL: https://github.com/apache/flink-kubernetes-operator/pull/245 -- 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-kubernetes-operator] gyfora commented on pull request #245: [FLINK-27804] Do not observe cluster/job mid upgrade

2022-05-27 Thread GitBox
gyfora commented on PR #245: URL: https://github.com/apache/flink-kubernetes-operator/pull/245#issuecomment-1139590007 Merging this for now, there is definitely follow up work to be done in the future to handle cases when the actual deployment step fails during an upgrade which is

[GitHub] [flink] flinkbot commented on pull request #19835: [FLINK-27818][rest][docs] Model enums as references

2022-05-27 Thread GitBox
flinkbot commented on PR #19835: URL: https://github.com/apache/flink/pull/19835#issuecomment-1139584486 ## CI report: * 44ca2a00ec5913a38cea4c218bc0e148cf8c762a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-27819) Generate better operationIds for OpenAPI spec

2022-05-27 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27819: Summary: Generate better operationIds for OpenAPI spec Key: FLINK-27819 URL: https://issues.apache.org/jira/browse/FLINK-27819 Project: Flink Issue

[jira] [Updated] (FLINK-27818) Model enums as references in OpenAPI spec

2022-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27818: --- Labels: pull-request-available (was: ) > Model enums as references in OpenAPI spec >

[GitHub] [flink] zentol opened a new pull request, #19835: [FLINK-27818][rest][docs] Model enums as references

2022-05-27 Thread GitBox
zentol opened a new pull request, #19835: URL: https://github.com/apache/flink/pull/19835 Make sure the spec uses enum references for all endpoints, as otherwise a separate class is generated for each of them. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Created] (FLINK-27818) Model enums as references in OpenAPI spec

2022-05-27 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27818: Summary: Model enums as references in OpenAPI spec Key: FLINK-27818 URL: https://issues.apache.org/jira/browse/FLINK-27818 Project: Flink Issue

[jira] [Commented] (FLINK-25197) Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackson2

2022-05-27 Thread Oleksandr (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542896#comment-17542896 ] Oleksandr commented on FLINK-25197: --- Hi, [~galenwarren] could your fix affect this issue -

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #239: [FLINK-27714] Migrate to java-operator-sdk v3

2022-05-27 Thread GitBox
morhidi commented on PR #239: URL: https://github.com/apache/flink-kubernetes-operator/pull/239#issuecomment-1139569167 None of the aforementioned issues are blockers, and the retry mechanism in JOSDK solves them under the hood, but we can wait for another patch/minor release before

[jira] [Comment Edited] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

2022-05-27 Thread EMing Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542839#comment-17542839 ] EMing Zhou edited comment on FLINK-27734 at 5/27/22 12:12 PM: -- Hi [~Feifan

[GitHub] [flink] flinkbot commented on pull request #19834: [FLINK-27797][API/Python] PythonTableUtils.getCollectionInputFormat c…

2022-05-27 Thread GitBox
flinkbot commented on PR #19834: URL: https://github.com/apache/flink/pull/19834#issuecomment-1139545614 ## CI report: * 50e1d2ecad8b4193b5ddc70be829ad08e01132e6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27797) PythonTableUtils.getCollectionInputFormat cannot correctly handle None values

2022-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27797: --- Labels: pull-request-available (was: ) > PythonTableUtils.getCollectionInputFormat cannot

[GitHub] [flink] BiGsuw opened a new pull request, #19834: [FLINK-27797][API/Python] PythonTableUtils.getCollectionInputFormat c…

2022-05-27 Thread GitBox
BiGsuw opened a new pull request, #19834: URL: https://github.com/apache/flink/pull/19834 What is the purpose of the change fix PythonTableUtils.getCollectionInputFormat cannot correctly handle None values , which is described in FLINK-27797 Does this pull request potentially

[GitHub] [flink] xuyangzhong commented on a diff in pull request #19797: [FLINK-27741][table-planner] Fix NPE when use dense_rank() and rank()…

2022-05-27 Thread GitBox
xuyangzhong commented on code in PR #19797: URL: https://github.com/apache/flink/pull/19797#discussion_r883538277 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/OverAggregateITCase.scala: ## @@ -159,6 +159,66 @@ class

[jira] [Commented] (FLINK-27797) PythonTableUtils.getCollectionInputFormat cannot correctly handle None values

2022-05-27 Thread EMing Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542882#comment-17542882 ] EMing Zhou commented on FLINK-27797: can I get this ticket? >

[jira] [Commented] (FLINK-27722) Slack: set up auto-updated invitation link

2022-05-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542878#comment-17542878 ] Jark Wu commented on FLINK-27722: - Not sure how others doing this, like Airbyte and Materialize. It

[jira] [Updated] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-27 Thread Oleksandr (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr updated FLINK-27813: -- Description: Issue was met after migration from  flink-statefun:3.1.1-java11 to

[GitHub] [flink] gaborgsomogyi commented on pull request #19825: [FLINK-27171][runtime][security] Add periodic kerberos delegation token obtain possibility to DelegationTokenManager

2022-05-27 Thread GitBox
gaborgsomogyi commented on PR #19825: URL: https://github.com/apache/flink/pull/19825#issuecomment-1139506508 @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

[GitHub] [flink-ml] dotbg commented on pull request #95: Migrated to flink 1.15.0.

2022-05-27 Thread GitBox
dotbg commented on PR #95: URL: https://github.com/apache/flink-ml/pull/95#issuecomment-1139500172 thanks a lot @yunfengzhou-hub, @lindong28 . Sorry did not have time recently. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-27 Thread Oleksandr (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr updated FLINK-27813: -- Attachment: screenshot-1.png > java.lang.IllegalStateException: after migration from statefun-3.1.1

[jira] [Created] (FLINK-27817) TaskManager metaspace OOM for session cluster

2022-05-27 Thread godfrey he (Jira)
godfrey he created FLINK-27817: -- Summary: TaskManager metaspace OOM for session cluster Key: FLINK-27817 URL: https://issues.apache.org/jira/browse/FLINK-27817 Project: Flink Issue Type: New

[GitHub] [flink] luoyuxia commented on pull request #19713: [FLINK-27597][hive] HiveCatalog support to get statistic for partitioned table

2022-05-27 Thread GitBox
luoyuxia commented on PR #19713: URL: https://github.com/apache/flink/pull/19713#issuecomment-1139493879 > @swuferhong Thanks for you reiview. But for alter hive partitioned table‘s statistics, it's expected to use `HiveCatalog#alterPartitionColumnStatistics`. For Hive, if you want

[jira] [Created] (FLINK-27816) file source reader has Some requirements

2022-05-27 Thread jinshuangxian (Jira)
jinshuangxian created FLINK-27816: - Summary: file source reader has Some requirements Key: FLINK-27816 URL: https://issues.apache.org/jira/browse/FLINK-27816 Project: Flink Issue Type:

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #121: [FLINK-27626] Introduce AggregatuibMergeFunction

2022-05-27 Thread GitBox
tsreaper commented on code in PR #121: URL: https://github.com/apache/flink-table-store/pull/121#discussion_r883447651 ## docs/content/docs/development/create-table.md: ## @@ -268,3 +268,39 @@ For example, the inputs: Output: - <1, 25.2, 20, 'This is a book'> + +##

[GitHub] [flink] flinkbot commented on pull request #19833: [FLINK-27778][table][planner] Use correct 'newName()' method

2022-05-27 Thread GitBox
flinkbot commented on PR #19833: URL: https://github.com/apache/flink/pull/19833#issuecomment-1139460307 ## CI report: * 001e34182005a7d21edb3e3265b7298b4ed24007 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27778) table-planner should not use CodeSplitUtils#newName

2022-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27778: --- Labels: pull-request-available (was: ) > table-planner should not use

[GitHub] [flink] zentol opened a new pull request, #19833: [FLINK-27778][table][planner] Use correct 'newName()' method

2022-05-27 Thread GitBox
zentol opened a new pull request, #19833: URL: https://github.com/apache/flink/pull/19833 Fix an issue where the planner was using a method from the wrong class. -- 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-27778) table-planner should not use CodeSplitUtils#newName

2022-05-27 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542856#comment-17542856 ] Chesnay Schepler commented on FLINK-27778: -- Reached out to [~tiwalter]; the planner is using

[jira] [Assigned] (FLINK-27778) table-planner should not use CodeSplitUtils#newName

2022-05-27 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-27778: Assignee: Chesnay Schepler > table-planner should not use CodeSplitUtils#newName

[jira] [Updated] (FLINK-27815) Improve the join reorder strategy for batch sql job

2022-05-27 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-27815: --- Description: Join is heavy operation in the execution, the join order in a query can have a

[jira] [Updated] (FLINK-27778) table-planner should not use CodeSplitUtils#newName

2022-05-27 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27778: - Summary: table-planner should not use CodeSplitUtils#newName (was: table-planner

[jira] [Assigned] (FLINK-27815) Improve the join reorder strategy for batch sql job

2022-05-27 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27815: -- Assignee: godfrey he > Improve the join reorder strategy for batch sql job >

[jira] [Created] (FLINK-27815) Improve the join reorder strategy for batch sql job

2022-05-27 Thread godfrey he (Jira)
godfrey he created FLINK-27815: -- Summary: Improve the join reorder strategy for batch sql job Key: FLINK-27815 URL: https://issues.apache.org/jira/browse/FLINK-27815 Project: Flink Issue Type:

[jira] [Updated] (FLINK-27812) Support Dynamic Change of Watched Namespaces

2022-05-27 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi updated FLINK-27812: -- Issue Type: New Feature (was: Improvement) > Support Dynamic Change of Watched Namespaces >

[jira] [Updated] (FLINK-27814) Add an abstraction layer for connectors to read and write row data instead of key-values

2022-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27814: --- Labels: pull-request-available (was: ) > Add an abstraction layer for connectors to read

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #244: [FLINK-27520] Use admission-controller-framework in Webhook

2022-05-27 Thread GitBox
morhidi commented on code in PR #244: URL: https://github.com/apache/flink-kubernetes-operator/pull/244#discussion_r883354595 ## flink-kubernetes-webhook/pom.xml: ## @@ -36,6 +36,19 @@ under the License. org.apache.flink flink-kubernetes-operator

[GitHub] [flink-table-store] tsreaper opened a new pull request, #142: [FLINK-27814] Add an abstraction layer for connectors to read and write row data instead of key-values

2022-05-27 Thread GitBox
tsreaper opened a new pull request, #142: URL: https://github.com/apache/flink-table-store/pull/142 Currently `FileStore` exposes an interface for reading and writing `KeyValue`. However connectors may have different ways to change a `RowData` to `KeyValue` under different `WriteMode`.

[jira] [Commented] (FLINK-27778) table-planner should explicitly depend on table-code-splitter

2022-05-27 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542851#comment-17542851 ] Chesnay Schepler commented on FLINK-27778: -- Actually, it is not clear to me why the

[jira] [Created] (FLINK-27814) Add an abstraction layer for connectors to read and write row data instead of key-values

2022-05-27 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-27814: --- Summary: Add an abstraction layer for connectors to read and write row data instead of key-values Key: FLINK-27814 URL: https://issues.apache.org/jira/browse/FLINK-27814

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #239: [FLINK-27714] Migrate to java-operator-sdk v3

2022-05-27 Thread GitBox
morhidi commented on code in PR #239: URL: https://github.com/apache/flink-kubernetes-operator/pull/239#discussion_r883435675 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigManager.java: ## @@ -63,7 +63,7 @@ public class

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #239: [FLINK-27714] Migrate to java-operator-sdk v3

2022-05-27 Thread GitBox
morhidi commented on code in PR #239: URL: https://github.com/apache/flink-kubernetes-operator/pull/239#discussion_r883435675 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigManager.java: ## @@ -63,7 +63,7 @@ public class

[jira] [Updated] (FLINK-27812) Support Dynamic Change of Watched Namespaces

2022-05-27 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi updated FLINK-27812: -- Component/s: Kubernetes Operator Fix Version/s: kubernetes-operator-1.1.0

[jira] [Updated] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-27 Thread Oleksandr (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr updated FLINK-27813: -- Summary: java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0 (was:

[GitHub] [flink] flinkbot commented on pull request #19832: [FLINK-27811][build][netty] Remove unused netty dependency

2022-05-27 Thread GitBox
flinkbot commented on PR #19832: URL: https://github.com/apache/flink/pull/19832#issuecomment-1139437495 ## CI report: * 2e879c6480c669616a7a1f81ed17ee54dbe01391 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-27813) java.lang.IllegalStateException: afte migration from statefun 3.1.1 to 3.2.0

2022-05-27 Thread Oleksandr (Jira)
Oleksandr created FLINK-27813: - Summary: java.lang.IllegalStateException: afte migration from statefun 3.1.1 to 3.2.0 Key: FLINK-27813 URL: https://issues.apache.org/jira/browse/FLINK-27813 Project:

[jira] [Updated] (FLINK-27811) Remove netty dependency in flink-test-utils

2022-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27811: --- Labels: pull-request-available (was: ) > Remove netty dependency in flink-test-utils >

[GitHub] [flink] zentol opened a new pull request, #19832: [FLINK-27811][build][netty] Remove unused netty dependency

2022-05-27 Thread GitBox
zentol opened a new pull request, #19832: URL: https://github.com/apache/flink/pull/19832 Nothing references the relocated netty, so we can safely remove this. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

  1   2   >