[
https://issues.apache.org/jira/browse/FLINK-35175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839505#comment-17839505
]
Weijie Guo commented on FLINK-35175:
Not include the fix:
flinkbot commented on PR #24697:
URL: https://github.com/apache/flink/pull/24697#issuecomment-2068639529
## CI report:
* e9029b47bf3793ae8efe33e4b4ba8448a27c200f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
jectpro7 commented on code in PR #24681:
URL: https://github.com/apache/flink/pull/24681#discussion_r1574275399
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed
Zakelly commented on code in PR #24681:
URL: https://github.com/apache/flink/pull/24681#discussion_r1574275896
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ContextKey.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache
dalongliu created FLINK-35195:
-
Summary: Support the execution of materialized table in continuous
mode
Key: FLINK-35195
URL: https://issues.apache.org/jira/browse/FLINK-35195
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyuzhi updated FLINK-35192:
--
Attachment: screenshot-2.png
> operator oom
>
>
> Key: FLINK-35192
>
dalongliu created FLINK-35204:
-
Summary: Support the execution of alter materialized table set
options
Key: FLINK-35204
URL: https://issues.apache.org/jira/browse/FLINK-35204
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35202:
--
Description:
{code:SQL}
ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name
SET
[
https://issues.apache.org/jira/browse/FLINK-35203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35203:
--
Description:
{code:SQL}
ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name
SET
masteryhx commented on code in PR #24682:
URL: https://github.com/apache/flink/pull/24682#discussion_r1574455229
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStResourceContainer.java:
##
@@ -0,0 +1,544 @@
+/*
+ * Licensed to the
MartijnVisser commented on PR #23844:
URL: https://github.com/apache/flink/pull/23844#issuecomment-2068667425
Most likely we'll have to rewrite/reimplement the entire Hadoop-based
filesystem implementations, since they've moved from the V1 API to the V2 API
for the AWS SDK. So either
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyuzhi updated FLINK-35192:
--
Attachment: screenshot-1.png
> operator oom
>
>
> Key: FLINK-35192
>
Wenbing Shen created FLINK-35196:
Summary: bouncycastle class not found for flink pulsar connector
Key: FLINK-35196
URL: https://issues.apache.org/jira/browse/FLINK-35196
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35195:
--
Summary: Support the execution of create materialized table in continuous
mode (was: Support the
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyuzhi updated FLINK-35192:
--
Description:
The kubernetest operator docker process was killed by kernel cause out of
memory(the
wenbingshen closed pull request #91: [FLINK-35196] [Connector / Pulsar] Fix
bouncycastle class not found
URL: https://github.com/apache/flink-connector-pulsar/pull/91
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-35191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-35191:
-
Assignee: Feng Jin
> Support alter materialized table related syntaxes: suspend, resume,
[
https://issues.apache.org/jira/browse/FLINK-35206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35206:
--
Description:
The desc syntax supports materialized table:
{code:SQL}
DESC Orders
{code}
Return the
masteryhx commented on code in PR #24682:
URL: https://github.com/apache/flink/pull/24682#discussion_r1574482995
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStOperationUtils.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the
caicancai commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1574216679
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,65 @@ specific language governing permissions and limitations
under the License.
boring-cyborg[bot] commented on PR #99:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/99#issuecomment-2068646947
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
hlteoh37 opened a new pull request, #99:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/99
Drop 1.17 runs from CI and bump default Flink version in pom
--
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-35134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35134:
---
Labels: pull-request-available (was: )
> Release flink-connector-elasticsearch vX.X.X for
jectpro7 commented on code in PR #24681:
URL: https://github.com/apache/flink/pull/24681#discussion_r1574272182
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStWriteBatchOperation.java:
##
@@ -0,0 +1,96 @@
+/*
+ * Licensed to the
reta commented on code in PR #91:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/91#discussion_r1574279683
##
flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilderBase.java:
##
@@ -263,6
dalongliu created FLINK-35193:
-
Summary: Support drop materialized table syntax and execution
Key: FLINK-35193
URL: https://issues.apache.org/jira/browse/FLINK-35193
Project: Flink
Issue Type:
chenyuzhi created FLINK-35192:
-
Summary: operator oom
Key: FLINK-35192
URL: https://issues.apache.org/jira/browse/FLINK-35192
Project: Flink
Issue Type: Bug
Components: Kubernetes
dalongliu created FLINK-35205:
-
Summary: Support the execution of alter materialized table reset
options
Key: FLINK-35205
URL: https://issues.apache.org/jira/browse/FLINK-35205
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35194:
--
Summary: Support describe job syntax and execution (was: Support describe
job syntax)
> Support
[
https://issues.apache.org/jira/browse/FLINK-35205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35205:
--
Description:
{code:SQL}
ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name RESET ('key');
yeezychao commented on PR #24689:
URL: https://github.com/apache/flink/pull/24689#issuecomment-2068868982
@Myasuka Thx u for your reply. Maybe we can create a new Jira to discuss how
to works in standalone env. Can you review this pr first？
--
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-35183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35183:
---
Labels: pull-request-available (was: )
> Expose FlinkMinorVersion as metric for
Dian Fu created FLINK-35208:
---
Summary: Respect pipeline.cached-files during processing Python
dependencies
Key: FLINK-35208
URL: https://issues.apache.org/jira/browse/FLINK-35208
Project: Flink
dalongliu created FLINK-35190:
-
Summary: Support the syntaxes of Create, Suspend, Resume, Refresh
and Drop materialized table
Key: FLINK-35190
URL: https://issues.apache.org/jira/browse/FLINK-35190
[
https://issues.apache.org/jira/browse/FLINK-35102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35102.
Resolution: Fixed
fixed via 5e52d8620cee995b55f003956c3f7d7a3bdf4a22
> Incorret Type mapping for
fredia commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1574293924
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -50,15 +50,24 @@ public class AsyncExecutionController {
dalongliu created FLINK-35197:
-
Summary: Support the execution of suspend, resume materialized
table in continuous mode
Key: FLINK-35197
URL: https://issues.apache.org/jira/browse/FLINK-35197
Project:
dalongliu created FLINK-35201:
-
Summary: Support the execution of drop materialized table in full
refresh mode
Key: FLINK-35201
URL: https://issues.apache.org/jira/browse/FLINK-35201
Project: Flink
dalongliu created FLINK-35200:
-
Summary: Support the execution of suspend, resume materialized
table in full refresh mode
Key: FLINK-35200
URL: https://issues.apache.org/jira/browse/FLINK-35200
Project:
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839545#comment-17839545
]
chenyuzhi edited comment on FLINK-35192 at 4/22/24 8:18 AM:
the yaml spec:
boring-cyborg[bot] commented on PR #91:
URL:
https://github.com/apache/flink-connector-pulsar/pull/91#issuecomment-2068776075
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
[
https://issues.apache.org/jira/browse/FLINK-35196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35196:
---
Labels: pull-request-available (was: )
> bouncycastle class not found for flink pulsar
[
https://issues.apache.org/jira/browse/FLINK-35191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35191:
--
Description:
SQL statement as follows:
{code:SQL}
// suspend
ALTER MATERIALIZED TABLE
[
https://issues.apache.org/jira/browse/FLINK-35193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35193:
--
Description:
{code:SQL}
DROP MATERIALIZED TABLE [ IF EXISTS ] [catalog_name.][db_name.]table_name
[
https://issues.apache.org/jira/browse/FLINK-35199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35199:
--
Description:
In full refresh mode, support creates materialized table and its background
refresh
[
https://issues.apache.org/jira/browse/FLINK-35199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35199:
--
Summary: Support the execution of create materialized table in full refresh
mode (was: Support the
[
https://issues.apache.org/jira/browse/FLINK-35191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839585#comment-17839585
]
dalongliu commented on FLINK-35191:
---
Thanks for taking this ticket, assign to you.
> Support alter
[
https://issues.apache.org/jira/browse/FLINK-35186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35186:
---
Labels: pull-request-available (was: )
> Create State V2 from new StateDescriptor
>
Zakelly opened a new pull request, #24697:
URL: https://github.com/apache/flink/pull/24697
## This is only a draft for testing purpose, do not merge this
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server,
dalongliu created FLINK-35191:
-
Summary: Support alter materialized table related syntaxes:
suspend, resume, refresh, set and reset
Key: FLINK-35191
URL: https://issues.apache.org/jira/browse/FLINK-35191
[
https://issues.apache.org/jira/browse/FLINK-35193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35193:
--
Summary: Support drop materialized table syntax and execution in continuous
mode (was: Support drop
dalongliu created FLINK-35194:
-
Summary: Support describe job syntax
Key: FLINK-35194
URL: https://issues.apache.org/jira/browse/FLINK-35194
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyuzhi updated FLINK-35192:
--
Description:
The kubernetest operator docker process was killed by kernel cause out of
memory(the
[
https://issues.apache.org/jira/browse/FLINK-35195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35195:
--
Summary: Support the execution of create materialized table in continuous
refresh mode (was: Support
dalongliu created FLINK-35203:
-
Summary: Support the execution of alter materialized table set
refresh mode
Key: FLINK-35203
URL: https://issues.apache.org/jira/browse/FLINK-35203
Project: Flink
dalongliu created FLINK-35206:
-
Summary: Desc table syntax support materialized table
Key: FLINK-35206
URL: https://issues.apache.org/jira/browse/FLINK-35206
Project: Flink
Issue Type: Sub-task
wenbingshen commented on PR #91:
URL:
https://github.com/apache/flink-connector-pulsar/pull/91#issuecomment-2068796453
@syhily @snuyanzin @tsreaper PTAL. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-35190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35190:
--
Description:
Create materialized table syntax:
{code:SQL}
CREATE MATERIALIZED TABLE
[
https://issues.apache.org/jira/browse/FLINK-35190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35190:
--
Description:
{code:SQL}
CREATE MATERIALIZED TABLE [catalog_name.][db_name.]table_name
[ ([ ]) ]
[
https://issues.apache.org/jira/browse/FLINK-35195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35195:
--
Description:
{code:SQL}
CREATE MATERIALIZED TABLE [catalog_name.][db_name.]table_name
[ ([ ]) ]
[
https://issues.apache.org/jira/browse/FLINK-35195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35195:
--
Description:
In continuous refresh mode, support creates materialized table and its
background
[
https://issues.apache.org/jira/browse/FLINK-35191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839567#comment-17839567
]
Feng Jin commented on FLINK-35191:
--
[~lsy] I would like to take this issue. Please assign this task to
[
https://issues.apache.org/jira/browse/FLINK-35190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839566#comment-17839566
]
Feng Jin commented on FLINK-35190:
--
[~lsy] I would like to take this issue. Please assign this task to
[
https://issues.apache.org/jira/browse/FLINK-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35133:
--
Fix Version/s: cassandra-3.2.0
> Release flink-connector-cassandra v3.2.0 for Flink 1.19
>
[
https://issues.apache.org/jira/browse/FLINK-35190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839586#comment-17839586
]
dalongliu commented on FLINK-35190:
---
Thanks for taking this ticket, assign to you.
> Support create
Zakelly Lan created FLINK-35186:
---
Summary: Create State V2 from new StateDescriptor
Key: FLINK-35186
URL: https://issues.apache.org/jira/browse/FLINK-35186
Project: Flink
Issue Type: Sub-task
yuxiqian commented on PR #3227:
URL: https://github.com/apache/flink-cdc/pull/3227#issuecomment-2068618701
@JNSimba Thanks for pointing it out, #3215 and #3224 share changes by
extending `DorisSchemaChangeManager`. I could rebase one after merge another /
combine them into one PR. @JNSimba
[
https://issues.apache.org/jira/browse/FLINK-35178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35178:
---
Attachment: image-2024-04-22-15-16-02-381.png
> Checkpoint CLAIM mode does not fully control snapshot
reta commented on code in PR #91:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/91#discussion_r1574288489
##
flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriter.java:
##
@@ -161,17 +166,46 @@
dalongliu created FLINK-35188:
-
Summary: Introduce CatalogMaterializedTable and related interface
to support materialized table
Key: FLINK-35188
URL: https://issues.apache.org/jira/browse/FLINK-35188
dalongliu created FLINK-35199:
-
Summary: Support the execution of create materialized table in
full refreshmode
Key: FLINK-35199
URL: https://issues.apache.org/jira/browse/FLINK-35199
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35197:
--
Summary: Support the execution of suspend, resume materialized table in
continuous refresh mode
[
https://issues.apache.org/jira/browse/FLINK-35193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35193:
--
Summary: Support drop materialized table syntax and execution in continuous
refresh mode (was:
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839545#comment-17839545
]
chenyuzhi edited comment on FLINK-35192 at 4/22/24 8:21 AM:
the yaml spec:
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839546#comment-17839546
]
chenyuzhi commented on FLINK-35192:
---
Could you help to have look at this operator problem when you
[
https://issues.apache.org/jira/browse/FLINK-35197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35197:
--
Description:
In continuous refresh mode, support suspend, resume the background refresh job
of
[
https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839553#comment-17839553
]
Ryan Skraba commented on FLINK-32523:
-
1.20 Java 17 / Test (module: tests)
Zakelly commented on code in PR #24682:
URL: https://github.com/apache/flink/pull/24682#discussion_r1574434930
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStOperationUtils.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the
MartijnVisser commented on PR #23844:
URL: https://github.com/apache/flink/pull/23844#issuecomment-2068660231
> Could we resolve this by the solution
See the comment above; how would you resolve the situation?
--
This is an automated message from the Apache Git Service.
To respond
TanYuxin-tyx commented on PR #24695:
URL: https://github.com/apache/flink/pull/24695#issuecomment-2068681183
@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
twalthr merged PR #24661:
URL: https://github.com/apache/flink/pull/24661
--
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:
leonardBang merged PR #3224:
URL: https://github.com/apache/flink-cdc/pull/3224
--
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-35102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35102:
---
Fix Version/s: cdc-3.1.0
> Incorret Type mapping for Flink CDC Doris connector
>
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839545#comment-17839545
]
chenyuzhi commented on FLINK-35192:
---
the yaml spec:
{code:yaml}
apiVersion: apps/v1
kind: Deployment
[
https://issues.apache.org/jira/browse/FLINK-35202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35202:
--
Summary: Support the execution of alter materialized table set freshness
(was: Support the execution
dalongliu created FLINK-35202:
-
Summary: Support the execution of set freshness for materialized
table
Key: FLINK-35202
URL: https://issues.apache.org/jira/browse/FLINK-35202
Project: Flink
wenbingshen opened a new pull request, #91:
URL: https://github.com/apache/flink-connector-pulsar/pull/91
## Purpose of the change
1. The `bouncycastle` dependency was removed in this PR
https://github.com/apache/flink-connector-pulsar/pull/9 , which was correct at
the time, and
Zakelly commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1574334314
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java:
##
@@ -830,6 +832,8 @@ public CompletableFuture submitTask(
Ryan Skraba created FLINK-35207:
---
Summary: Kubernetes session E2E test fails to fetch packages.
Key: FLINK-35207
URL: https://issues.apache.org/jira/browse/FLINK-35207
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-35194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35194:
--
Description:
{code:java}
{ DESCRIBE | DESC } JOB 'xxx'
{code}
> Support describe job syntax and
masteryhx commented on code in PR #24681:
URL: https://github.com/apache/flink/pull/24681#discussion_r1574412285
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStValueState.java:
##
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the Apache
mbalassi opened a new pull request, #819:
URL: https://github.com/apache/flink-kubernetes-operator/pull/819
## What is the purpose of the change
* Adds new convenience metric for tracking minor version of running
applications per namespace
* Changes current Flink version metric to
[
https://issues.apache.org/jira/browse/FLINK-35208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-35208:
Description:
Currently, PyFlink will make use of distributed cache
dannycranmer merged PR #28:
URL: https://github.com/apache/flink-connector-cassandra/pull/28
--
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-35178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839522#comment-17839522
]
elon_X commented on FLINK-35178:
[~lijinzhong]
Thank you for your response.
I have been using the
dalongliu created FLINK-35189:
-
Summary: Introduce test-filesystem Catalog based on FileSystem
Connector to support materialized table
Key: FLINK-35189
URL: https://issues.apache.org/jira/browse/FLINK-35189
[
https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839540#comment-17839540
]
Roman Boyko commented on FLINK-35184:
-
Most probably the easiest way to fix it would be to replace
dalongliu created FLINK-35198:
-
Summary: Support the execution of refresh materialized table
Key: FLINK-35198
URL: https://issues.apache.org/jira/browse/FLINK-35198
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-35198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35198:
--
Description:
{code:SQL}
ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name REFRESH
[
https://issues.apache.org/jira/browse/FLINK-35204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35204:
--
Description:
{code:SQL}
ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name SET ('key' =
1 - 100 of 220 matches
Mail list logo
