cris niu created FLINK-35588:
Summary: flink sql redis connector
Key: FLINK-35588
URL: https://issues.apache.org/jira/browse/FLINK-35588
Project: Flink
Issue Type: New Feature
Reporte
liyubin117 commented on code in PR #24763:
URL: https://github.com/apache/flink/pull/24763#discussion_r1637666706
##
flink-table/flink-sql-client/src/test/resources/sql/catalog_database.q:
##
@@ -769,3 +769,28 @@ desc catalog extended cat2;
+-+--
liyubin117 commented on code in PR #24763:
URL: https://github.com/apache/flink/pull/24763#discussion_r1637667029
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlDdlToOperationConverterTest.java:
##
@@ -124,6 +127,26 @@ public void t
thinker0 opened a new pull request, #94:
URL: https://github.com/apache/flink-connector-pulsar/pull/94
## Purpose of the change
*For example: Add dynamic sink topic support for Pulsar connector.*
## Brief change log
- *Change the internal design of `ProducerRegist
boring-cyborg[bot] commented on PR #94:
URL:
https://github.com/apache/flink-connector-pulsar/pull/94#issuecomment-2164765271
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-35569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-35569:
--
Fix Version/s: 1.20.0
> SnapshotFileMergingCompatibilityITCase#testSwitchFromEnablingToDisablingFileMe
[
https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854655#comment-17854655
]
LvYanquan commented on FLINK-35237:
---
I've met the same demand in Paimon Sink, and I ag
gaborgsomogyi commented on PR #24919:
URL: https://github.com/apache/flink/pull/24919#issuecomment-2164843469
I'm fine with merging it on 14th of June EOB. Let's wait on other voices.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
JingGe commented on code in PR #24471:
URL: https://github.com/apache/flink/pull/24471#discussion_r1637750136
##
flink-end-to-end-tests/flink-batch-sql-test/src/test/java/org/apache/flink/sql/tests/Generator.java:
##
@@ -0,0 +1,82 @@
+/*
+ * Licensed to the Apache Software Found
yuxiqian commented on PR #3083:
URL: https://github.com/apache/flink-cdc/pull/3083#issuecomment-2164936973
Seems there's some conflicts between `master` branch, could @loserwang1024
please rebase it when you're available?
--
This is an automated message from the Apache Git Service.
To res
[
https://issues.apache.org/jira/browse/FLINK-35570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-35570:
Fix Version/s: 1.20.0
> Consider PlaceholderStreamStateHandle in checkpoint file merging
> ---
[
https://issues.apache.org/jira/browse/FLINK-34918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34918:
-
Summary: Introduce comment for CatalogStore (was: Introduce comment for
Catalog)
> Introduce comment f
liyubin117 opened a new pull request, #24932:
URL: https://github.com/apache/flink/pull/24932
## What is the purpose of the change
Provide the ability to set comment for the catalog.
## Brief change log
* add comment instance in `CatalogDescriptor` and expose setter/gette
[
https://issues.apache.org/jira/browse/FLINK-35378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-35378.
--
Fix Version/s: 1.20.0
Resolution: Fixed
Fixed in apache/flink:master f0b01277dd23dd0edc
[
https://issues.apache.org/jira/browse/FLINK-34918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34918:
---
Labels: pull-request-available (was: )
> Introduce comment for CatalogStore
> -
Zakelly Lan created FLINK-35590:
---
Summary: Cleanup deprecated options usage in docs about state and
checkpoint
Key: FLINK-35590
URL: https://issues.apache.org/jira/browse/FLINK-35590
Project: Flink
MartijnVisser merged PR #24805:
URL: https://github.com/apache/flink/pull/24805
--
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: issues-unsubscr...@flink
flinkbot commented on PR #24932:
URL: https://github.com/apache/flink/pull/24932#issuecomment-2165051805
## CI report:
* 9e10cf9d38d624b4982a20ab863098df408358cf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
LvYanquan created FLINK-35589:
-
Summary: Support MemorySize type in FlinkCDC ConfigOptions
Key: FLINK-35589
URL: https://issues.apache.org/jira/browse/FLINK-35589
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-34914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854686#comment-17854686
]
Weijie Guo commented on FLINK-34914:
I will mark this to `won't make it` in 1.20 rel
[
https://issues.apache.org/jira/browse/FLINK-35164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan reassigned FLINK-35164:
-
Assignee: Yubin Li
> Support `ALTER CATALOG RESET` syntax
> ---
[
https://issues.apache.org/jira/browse/FLINK-35591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35591:
---
Description:
No Azure CI builds are triggered for master since
4a852fee28f2d87529dc05f5ba2e79202a0e
[
https://issues.apache.org/jira/browse/FLINK-35591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35591:
---
Priority: Blocker (was: Major)
> Azure Pipelines not running for master since c9def981
> --
[
https://issues.apache.org/jira/browse/FLINK-34918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34918:
-
Summary: Support `ALTER CATALOG COMMENT` syntax (was: Introduce comment
for CatalogStore)
> Support `A
[
https://issues.apache.org/jira/browse/FLINK-35592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35592:
-
Assignee: ZhengYu Chen
> MysqlDebeziumTimeConverter miss timezone convert to timestamp
Weijie Guo created FLINK-35591:
--
Summary: Azure Pipelines not running for master since c9def981
Key: FLINK-35591
URL: https://issues.apache.org/jira/browse/FLINK-35591
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-34918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34918:
-
Summary: Introduce comment for CatalogStore & Support `ALTER CATALOG
COMMENT` syntax (was: Support `ALT
ZhengYu Chen created FLINK-35592:
Summary: MysqlDebeziumTimeConverter miss timezone convert to
timestamp
Key: FLINK-35592
URL: https://issues.apache.org/jira/browse/FLINK-35592
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35591:
---
Description:
No Azure CI builds are triggered for master since
[c9def981|https://dev.azure.com/apac
loserwang1024 commented on PR #3412:
URL: https://github.com/apache/flink-cdc/pull/3412#issuecomment-2165162601
> @loserwang1024 mind if I cherry pick your commit?
Just do it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-35591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854705#comment-17854705
]
Lorenzo Affetti commented on FLINK-35591:
-
Back to normality
!image-2024-06-13-
[
https://issues.apache.org/jira/browse/FLINK-35591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lorenzo Affetti updated FLINK-35591:
Attachment: image-2024-06-13-12-31-18-076.png
> Azure Pipelines not running for master sin
[
https://issues.apache.org/jira/browse/FLINK-35574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yue Ma updated FLINK-35574:
---
Description:
As the first part of FLINK-35573, we need to prepare a base branch for
FRocksDB-8.10.0 first.
zoltar9264 opened a new pull request, #24933:
URL: https://github.com/apache/flink/pull/24933
## What is the purpose of the change
Clean up useless file-merging managed directory (which never be include in
any checkpoint) on exit of TM.
## Brief change log
1. Normalize f
[
https://issues.apache.org/jira/browse/FLINK-32086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32086:
---
Labels: pull-request-available (was: )
> Cleanup non-reported managed directory on exit of
flinkbot commented on PR #24933:
URL: https://github.com/apache/flink/pull/24933#issuecomment-2165343946
## CI report:
* 4e54756da848b4b6febc23f70175a563c8a95795 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
LadyForest merged PR #24763:
URL: https://github.com/apache/flink/pull/24763
--
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: issues-unsubscr...@flink.ap
[
https://issues.apache.org/jira/browse/FLINK-35164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan closed FLINK-35164.
-
> Support `ALTER CATALOG RESET` syntax
>
>
> Key: FLINK
[
https://issues.apache.org/jira/browse/FLINK-35164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan resolved FLINK-35164.
---
Fix Version/s: 1.20.0
Resolution: Fixed
Fixed in master 9d1690387849303b27050bb0cefaa1bad6e3f
[
https://issues.apache.org/jira/browse/FLINK-34914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854723#comment-17854723
]
Yubin Li commented on FLINK-34914:
--
[~Weijie Guo] Hi, sorry for the late reply. we are
[
https://issues.apache.org/jira/browse/FLINK-34914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854723#comment-17854723
]
Yubin Li edited comment on FLINK-34914 at 6/13/24 11:43 AM:
[
https://issues.apache.org/jira/browse/FLINK-34914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854723#comment-17854723
]
Yubin Li edited comment on FLINK-34914 at 6/13/24 11:49 AM:
pan3793 commented on PR #24905:
URL: https://github.com/apache/flink/pull/24905#issuecomment-2165447683
ping @1996fanrui can we include this in 1.20?
--
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
[
https://issues.apache.org/jira/browse/FLINK-35591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35591:
---
Description:
No Azure CI builds are triggered for master since c9def981. The PR CI workflows
appear
[
https://issues.apache.org/jira/browse/FLINK-34918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34918:
-
Description:
We propose to introduce `getComment()` method in `CatalogDescriptor`, and the
reasons are
[
https://issues.apache.org/jira/browse/FLINK-34918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34918:
-
Attachment: image-2024-06-13-18-01-34-910.png
Description:
We propose to introduce `getComment()` m
anupamaggarwal commented on PR #24482:
URL: https://github.com/apache/flink/pull/24482#issuecomment-2165510538
Hi @klam-shop, apologies, I missed your comment earlier. I am sorry for
leaving this PR hanging in the middle, I had to context switch to focus on some
other priorities. I might be
affo commented on PR #24471:
URL: https://github.com/apache/flink/pull/24471#issuecomment-2165511898
@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.
To
[
https://issues.apache.org/jira/browse/FLINK-35451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-35451:
-
Parent: (was: FLINK-34914)
Issue Type: New Feature (was: Sub-task)
> Support `ALTER CATALOG
[
https://issues.apache.org/jira/browse/FLINK-35451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li closed FLINK-35451.
Resolution: Duplicate
> Support `ALTER CATALOG COMMENT` syntax
> --
>
Anupam Aggarwal created FLINK-35593:
---
Summary: Apache Kubernetes Operator Docker image does not contain
Apache LICENSE
Key: FLINK-35593
URL: https://issues.apache.org/jira/browse/FLINK-35593
Project
[
https://issues.apache.org/jira/browse/FLINK-34918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34918:
-
Summary: Support `ALTER CATALOG COMMENT` syntax (was: Introduce comment
for CatalogStore & Support `ALT
[
https://issues.apache.org/jira/browse/FLINK-34917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34917:
-
Summary: Introduce comment for CatalogStore & Support enhanced `CREATE
CATALOG` syntax (was: Support en
[
https://issues.apache.org/jira/browse/FLINK-34917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34917:
-
Description:
We propose to introduce `getComment()` method in `CatalogDescriptor`, and the
reasons are
[
https://issues.apache.org/jira/browse/FLINK-34918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34918:
-
Description:
Set comment in the specified catalog. If the comment is already set in the
catalog, overri
Aviv Dozorets created FLINK-35594:
-
Summary: Downscaling doesn't release TaskManagers.
Key: FLINK-35594
URL: https://issues.apache.org/jira/browse/FLINK-35594
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-35593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-35593:
--
Assignee: Anupam Aggarwal
> Apache Kubernetes Operator Docker image does not contain
[
https://issues.apache.org/jira/browse/FLINK-35593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854751#comment-17854751
]
Robert Metzger commented on FLINK-35593:
+1 to fix this. I'll assign you to the
LadyForest commented on code in PR #24932:
URL: https://github.com/apache/flink/pull/24932#discussion_r1638176317
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterCatalogComment.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/FLINK-35594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-35594:
Component/s: Runtime / Coordination
(was: Kubernetes Operator)
> Downscaling doesn't
[
https://issues.apache.org/jira/browse/FLINK-35594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854757#comment-17854757
]
Rui Fan commented on FLINK-35594:
-
This Jira may be duplicated with
https://issues.apac
xbthink commented on PR #23454:
URL: https://github.com/apache/flink/pull/23454#issuecomment-2165733120
@littleeleventhwolf Can you post your code? I'll use your code to check it
again
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
PatrickRen merged PR #3380:
URL: https://github.com/apache/flink-cdc/pull/3380
--
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: issues-unsubscr...@flink.
twalthr merged PR #24886:
URL: https://github.com/apache/flink/pull/24886
--
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: issues-unsubscr...@flink.apach
twalthr commented on code in PR #24929:
URL: https://github.com/apache/flink/pull/24929#discussion_r1638286027
##
docs/content/docs/dev/table/sql/create.md:
##
@@ -181,10 +182,16 @@ CREATE TABLE [IF NOT EXISTS]
[catalog_name.][db_name.]table_name
:
{
- { INCLUDING | EXCLU
[
https://issues.apache.org/jira/browse/FLINK-34172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-34172.
Resolution: Fixed
Fixed in master: d0f9bb40a614c3c52c7abc9e608391e4bca9a3ca
> Add support for alt
[
https://issues.apache.org/jira/browse/FLINK-35318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854773#comment-17854773
]
linshangquan edited comment on FLINK-35318 at 6/13/24 2:55 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-26951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-26951.
---
Resolution: Won't Do
> Add HASH supported in SQL & Table API
> -
caicancai commented on code in PR #830:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/830#discussion_r1638395305
##
docs/content/docs/custom-resource/pod-template.md:
##
@@ -93,16 +90,18 @@ spec:
```
{{< hint info >}}
-When using the operator with Flink nati
vahmed-hamdy commented on code in PR #136:
URL:
https://github.com/apache/flink-connector-aws/pull/136#discussion_r1638374818
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbTypeInformedElementConverter.java:
##
@@
[
https://issues.apache.org/jira/browse/FLINK-26951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854769#comment-17854769
]
lincoln lee commented on FLINK-26951:
-
[~kartikeypant] Thank you again for your will
vahmed-hamdy commented on PR #136:
URL:
https://github.com/apache/flink-connector-aws/pull/136#issuecomment-2165938144
@hlteoh37 Thanks, for the feedback, the reason we took this approach is that
We are trying to couple it as much as possible with Flink's TypeInfo Class,
Using `AttributeCo
[
https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854789#comment-17854789
]
Matthias Pohl commented on FLINK-35042:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-26951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-26951:
Fix Version/s: (was: 1.20.0)
> Add HASH supported in SQL & Table API
> ---
lvyanquan commented on code in PR #3254:
URL: https://github.com/apache/flink-cdc/pull/3254#discussion_r1635846252
##
docs/content.zh/docs/connectors/maxcompute.md:
##
@@ -0,0 +1,342 @@
+---
+title: "MaxCompute"
+weight: 7
+type: docs
+aliases:
+ - /connectors/maxcompute
+---
+
[
https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854789#comment-17854789
]
Matthias Pohl edited comment on FLINK-35042 at 6/13/24 4:16 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854801#comment-17854801
]
Matthias Pohl commented on FLINK-35042:
---
I'm linking FLINK-34150 because we refact
[
https://issues.apache.org/jira/browse/FLINK-35318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854773#comment-17854773
]
linshangquan commented on FLINK-35318:
--
Thanks, [~qingyue] ， Do you have time to h
[
https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854800#comment-17854800
]
Matthias Pohl commented on FLINK-35042:
---
This is different to what [~Weijie Guo] o
flinkbot commented on PR #24934:
URL: https://github.com/apache/flink/pull/24934#issuecomment-2166393201
## CI report:
* d31c5b45069430fcdd04727df1aebde7dd111d97 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
LadyForest commented on code in PR #24932:
URL: https://github.com/apache/flink/pull/24932#discussion_r1638477886
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -327,11 +328,15 @@ public void createCatalog(String catal
jnh5y commented on code in PR #24929:
URL: https://github.com/apache/flink/pull/24929#discussion_r1638444015
##
docs/content/docs/dev/table/sql/create.md:
##
@@ -465,6 +480,7 @@ You can control the merging behavior of:
* GENERATED - computed columns
* METADATA - metadata colum
jnh5y commented on code in PR #24929:
URL: https://github.com/apache/flink/pull/24929#discussion_r1638447342
##
docs/content/docs/dev/table/sql/create.md:
##
@@ -406,6 +413,14 @@ Flink will assume correctness of the primary key by
assuming that the columns nu
Partition the c
liyubin117 opened a new pull request, #24934:
URL: https://github.com/apache/flink/pull/24934
## What is the purpose of the change
Introduce comment for CatalogStore and Support enhanced `CREATE CATALOG`
syntax
## Brief change log
* add comment instance in `CatalogDescri
venkata91 commented on PR #24736:
URL: https://github.com/apache/flink/pull/24736#issuecomment-2166456519
> > > Thanks, @venkata91, for your contribution! After reviewing this PR,
I'm concerned that it entirely removes limit that source parallelism should
lower than source jobVertex's max p
[
https://issues.apache.org/jira/browse/FLINK-33977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-33977:
---
Affects Version/s: 1.19.0
1.20.0
> Adaptive scheduler may not minimize the nu
[
https://issues.apache.org/jira/browse/FLINK-35594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-35594.
--
Resolution: Duplicate
> Downscaling doesn't release TaskManagers.
> --
venkata91 commented on code in PR #24736:
URL: https://github.com/apache/flink/pull/24736#discussion_r1638672737
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchSchedulerTest.java:
##
Review Comment:
Addressed it.
--
This is
David Schlosnagle created FLINK-35595:
-
Summary: MailboxProcessor#processMailsWhenDefaultActionUnavailable
is allocation intensive
Key: FLINK-35595
URL: https://issues.apache.org/jira/browse/FLINK-35595
[
https://issues.apache.org/jira/browse/FLINK-35485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854891#comment-17854891
]
Xingcan Cui commented on FLINK-35485:
-
Hi [~mapohl], I hit the exception again today
mattayes opened a new pull request, #838:
URL: https://github.com/apache/flink-kubernetes-operator/pull/838
## What is the purpose of the change
Add missing documentation for `FlinkSessionJob` CRD.
## Brief change log
Add docs for `FlinkSessionJob` CRD.
mattayes commented on PR #838:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/838#issuecomment-2166971750
@gyfora Here's a rework of #837.
--
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 t
Venkata krishnan Sowrirajan created FLINK-35596:
---
Summary: Flink application fails with The implementation of the
BlockElement is not serializable
Key: FLINK-35596
URL: https://issues.apache.org/jira
[
https://issues.apache.org/jira/browse/FLINK-35596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Venkata krishnan Sowrirajan updated FLINK-35596:
Affects Version/s: 1.19.0
> Flink application fails with The imple
[
https://issues.apache.org/jira/browse/FLINK-35596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854896#comment-17854896
]
Venkata krishnan Sowrirajan commented on FLINK-35596:
-
Most likely t
venkata91 opened a new pull request, #24935:
URL: https://github.com/apache/flink/pull/24935
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
[
https://issues.apache.org/jira/browse/FLINK-35596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35596:
---
Labels: pull-request-available (was: )
> Flink application fails with The implementation of
venkata91 commented on PR #24935:
URL: https://github.com/apache/flink/pull/24935#issuecomment-2167003430
cc @becketqin
--
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
flinkbot commented on PR #24935:
URL: https://github.com/apache/flink/pull/24935#issuecomment-2167007574
## CI report:
* 8c396c54eeda5bc8f8f656847a372b3421c25a7f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1996fanrui merged PR #24757:
URL: https://github.com/apache/flink/pull/24757
--
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: issues-unsubscr...@flink.ap
1 - 100 of 201 matches
Mail list logo
