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
[
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
[
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
>
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
[
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
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:
[ 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:
[
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
>
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" . |
[
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
[
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
>
[
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
[
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}
[
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
[
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
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:
[
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
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`
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
[
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
[
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
[
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 (
[
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
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
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
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
[
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
[
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
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
[
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,
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
Hector Miuler Malpica Gallegos created FLINK-27821:
--
Summary: Cannot delete flinkdeployment when the pod and deployment
deleted manually
Key: FLINK-27821
URL:
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`
[
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
>
[
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
>
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
[
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
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:
[
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
>
[
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
>
[
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:
[
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
[
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
[
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
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:
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
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`
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
[
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
>
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
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
[
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 -
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
[
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
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`
[
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
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
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
[
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?
>
[
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
[
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
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
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
[
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
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
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
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:
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'>
+
+##
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`
[
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
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
[
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
[
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
[
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
[
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
[
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
>
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:
[
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
>
[
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
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
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`.
[
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
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
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
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
[
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
[
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:
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`
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:
[
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
>
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 - 100 of 129 matches
Mail list logo