[
https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang closed FLINK-31402.
--
Resolution: Fixed
> Remove ConverterUtils Deprecated Method
> ---
[
https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699186#comment-17699186
]
Lijie Wang commented on FLINK-31402:
Fix via
master: a7b0c2707518a8b7f589e50fa4eafa
[
https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699186#comment-17699186
]
Lijie Wang edited comment on FLINK-31402 at 3/11/23 7:57 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-31402:
--
Assignee: Shilun Fan
> Remove ConverterUtils Deprecated Method
>
[
https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-31402:
---
Fix Version/s: 1.18.0
> Remove ConverterUtils Deprecated Method
> --
wanglijie95 merged PR #22159:
URL: https://github.com/apache/flink/pull/22159
--
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.a
lindong28 commented on code in PR #218:
URL: https://github.com/apache/flink-ml/pull/218#discussion_r1133042094
##
flink-ml-core/src/test/java/org/apache/flink/ml/api/PipelineTest.java:
##
@@ -95,4 +109,59 @@ public void testPipeline() throws Exception {
// Executes the
lindong28 commented on code in PR #218:
URL: https://github.com/apache/flink-ml/pull/218#discussion_r1133042094
##
flink-ml-core/src/test/java/org/apache/flink/ml/api/PipelineTest.java:
##
@@ -95,4 +109,59 @@ public void testPipeline() throws Exception {
// Executes the
lindong28 commented on code in PR #218:
URL: https://github.com/apache/flink-ml/pull/218#discussion_r1130430131
##
flink-ml-core/src/test/java/org/apache/flink/ml/api/IntegrateWithServableTest.java:
##
@@ -0,0 +1,106 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
[
https://issues.apache.org/jira/browse/FLINK-30640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699161#comment-17699161
]
Shengkai Fang commented on FLINK-30640:
---
Because the current problem is much diffe
[
https://issues.apache.org/jira/browse/FLINK-30640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-30640.
-
Resolution: Fixed
> Unstable test in CliClientITCase
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699160#comment-17699160
]
Yun Tang commented on FLINK-31238:
--
[~mayuehappy] Thanks for the reply.
Considering th
[
https://issues.apache.org/jira/browse/FLINK-31403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-31403:
--
Description:
The CliClientITCase fails in the
https://dev.azure.com/apache-flink/apache-flink
Shengkai Fang created FLINK-31403:
-
Summary: CliClientITCase print unexpected border when printing
explain results
Key: FLINK-31403
URL: https://issues.apache.org/jira/browse/FLINK-31403
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-30640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-30640:
--
Priority: Major (was: Blocker)
> Unstable test in CliClientITCase
> -
[
https://issues.apache.org/jira/browse/FLINK-30640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699159#comment-17699159
]
Shengkai Fang commented on FLINK-30640:
---
SQL Client infers the column width from t
flinkbot commented on PR #22159:
URL: https://github.com/apache/flink/pull/22159#issuecomment-1464818200
## CI report:
* 52bf5080c464417b229a339245b8015785fae7ec UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shilun Fan updated FLINK-31402:
---
Description: Many methods in ConverterUtils have been Deprecated, we can
replace the Deprecated meth
[
https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31402:
---
Labels: pull-request-available (was: )
> Remove ConverterUtils Deprecated Method
>
slfan1989 opened a new pull request, #22159:
URL: https://github.com/apache/flink/pull/22159
## What is the purpose of the change
JIRA: FLINK-31402. Remove ConverterUtils Deprecated Method.
Many methods in ConverterUtils have been Deprecated, we can replace the
Deprecat
luoyuxia commented on PR #22106:
URL: https://github.com/apache/flink/pull/22106#issuecomment-1464817133
@Aitozi Thanks for your reviewing. I have fixed your comments. PTAL again.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
luoyuxia commented on code in PR #22106:
URL: https://github.com/apache/flink/pull/22106#discussion_r1133025171
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/validate/FlinkSqlConformance.java:
##
@@ -60,24 +54,12 @@ public boolean isHavingAlias() {
[
https://issues.apache.org/jira/browse/FLINK-31292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31292.
Resolution: Fixed
master: d2d4dd0bf8d206307eb2c93aa97e7c1cb750f187
> User HadoopUtils to get Conf
JingsongLi merged PR #592:
URL: https://github.com/apache/flink-table-store/pull/592
--
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...@
Shilun Fan created FLINK-31402:
--
Summary: Remove ConverterUtils Deprecated Method
Key: FLINK-31402
URL: https://issues.apache.org/jira/browse/FLINK-31402
Project: Flink
Issue Type: Improvement
wsry commented on PR #22155:
URL: https://github.com/apache/flink/pull/22155#issuecomment-1464796764
This patch is picked. CI [SUCCESS]. Merging.
--
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 t
wsry merged PR #22155:
URL: https://github.com/apache/flink/pull/22155
--
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.apache.o
liyubin117 commented on PR #592:
URL:
https://github.com/apache/flink-table-store/pull/592#issuecomment-1464752148
@JingsongLi I have added more tests, please take a look
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
tzulitai commented on code in PR #22126:
URL: https://github.com/apache/flink/pull/22126#discussion_r1132976860
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -302,7 +302,7 @@ public void resum
[
https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699131#comment-17699131
]
Tzu-Li (Gordon) Tai edited comment on FLINK-31363 at 3/10/23 11:57 PM:
---
tzulitai commented on code in PR #22126:
URL: https://github.com/apache/flink/pull/22126#discussion_r1132976860
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -302,7 +302,7 @@ public void resum
tzulitai commented on code in PR #22126:
URL: https://github.com/apache/flink/pull/22126#discussion_r1132976860
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -302,7 +302,7 @@ public void resum
tzulitai commented on code in PR #22126:
URL: https://github.com/apache/flink/pull/22126#discussion_r1132976860
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -302,7 +302,7 @@ public void resum
lightzhao commented on code in PR #22126:
URL: https://github.com/apache/flink/pull/22126#discussion_r1132969427
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -302,7 +302,7 @@ public void resu
[
https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-31102:
-
Description:
Remove all elements that equal to element from array.
Syntax:
array_remove(array, needle)
[
https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-31102:
-
Description:
Remove all elements that equal to element from array.
Syntax:
array_remove(array, needle)
[
https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699131#comment-17699131
]
Tzu-Li (Gordon) Tai edited comment on FLINK-31363 at 3/10/23 11:04 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699136#comment-17699136
]
jackylau commented on FLINK-31102:
--
[~Sergey Nuyanzin] ,thanks for your suggestion and
tzulitai commented on code in PR #22126:
URL: https://github.com/apache/flink/pull/22126#discussion_r1132948153
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -302,7 +302,7 @@ public void resum
[
https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699131#comment-17699131
]
Tzu-Li (Gordon) Tai edited comment on FLINK-31363 at 3/10/23 10:38 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699131#comment-17699131
]
Tzu-Li (Gordon) Tai edited comment on FLINK-31363 at 3/10/23 10:36 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699131#comment-17699131
]
Tzu-Li (Gordon) Tai commented on FLINK-31363:
-
Looking at the KafkaProducer
mohsenrezaeithe commented on PR #21849:
URL: https://github.com/apache/flink/pull/21849#issuecomment-1464450206
+ @zentol, since the latest commits seem to have removed the assignment.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
tzulitai commented on code in PR #22126:
URL: https://github.com/apache/flink/pull/22126#discussion_r1132772741
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -302,7 +302,7 @@ public void resum
[
https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699077#comment-17699077
]
Mason Chen commented on FLINK-31305:
BTW, I had a mishap with git and so this is the
[
https://issues.apache.org/jira/browse/FLINK-31401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699072#comment-17699072
]
Junrui Li commented on FLINK-31401:
---
[~mbalassi] Thanks so much for your volunteering
[
https://issues.apache.org/jira/browse/FLINK-31385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699037#comment-17699037
]
David Morávek commented on FLINK-31385:
---
master: 8424ed2c02e2cc23003919eda53c0fda9
[
https://issues.apache.org/jira/browse/FLINK-31385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek resolved FLINK-31385.
---
Fix Version/s: 1.18.0
Resolution: Fixed
> Introduce extended Assertj Matchers for com
dmvk merged PR #22140:
URL: https://github.com/apache/flink/pull/22140
--
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.apache.o
flinkbot commented on PR #22158:
URL: https://github.com/apache/flink/pull/22158#issuecomment-1464043867
## CI report:
* 5e485d67acf67ceeff4e9b49f4bd3d8e2444d816 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-25347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25347:
---
Labels: pull-request-available (was: )
> Replace deprecated TableSchema with Schema in Merg
wuchong opened a new pull request, #22158:
URL: https://github.com/apache/flink/pull/22158
## What is the purpose of the change
Replace deprecated `TableSchema` with `Schema` in `MergeTableLikeUtil`.
## Brief change log
- Replace deprecated `TableSchema` w
[
https://issues.apache.org/jira/browse/FLINK-25347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-25347:
---
Assignee: Jark Wu
> Replace deprecated TableSchema with Schema in MergeTableLikeUtil
>
[
https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699005#comment-17699005
]
Sergey Nuyanzin edited comment on FLINK-31102 at 3/10/23 4:02 PM:
[
https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699005#comment-17699005
]
Sergey Nuyanzin commented on FLINK-31102:
-
Thanks, it already looks better
howev
[
https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699003#comment-17699003
]
Tzu-Li (Gordon) Tai commented on FLINK-31363:
-
Thanks for reporting this [~l
flinkbot commented on PR #22157:
URL: https://github.com/apache/flink/pull/22157#issuecomment-1464004662
## CI report:
* 64d5f54076a4f8f8505e9b726ff6e886bf590462 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
rkhachatryan commented on code in PR #22153:
URL: https://github.com/apache/flink/pull/22153#discussion_r1132534295
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobResourceRequirements.java:
##
@@ -0,0 +1,204 @@
+/*
+ * Licensed to the Apache Software Founda
[
https://issues.apache.org/jira/browse/FLINK-31401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31401:
---
Labels: pull-request-available (was: )
> testTransformationSetParallelism fails on 10 core
mbalassi opened a new pull request, #22157:
URL: https://github.com/apache/flink/pull/22157
Minor improvement to the test, so that it does not fail on 10 core machines.
cc @JunRuiLee
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
Márton Balassi created FLINK-31401:
--
Summary: testTransformationSetParallelism fails on 10 core machines
Key: FLINK-31401
URL: https://issues.apache.org/jira/browse/FLINK-31401
Project: Flink
flinkbot commented on PR #22156:
URL: https://github.com/apache/flink/pull/22156#issuecomment-1463935653
## CI report:
* d585109ec39d802dea485dd363c3c21c553383b3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-18958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-18958.
---
Fix Version/s: (was: 1.17.0)
Assignee: (was: Feng Jin)
Resolution: Fixed
> Lose colu
wuchong closed pull request #13177: [FLINK-18958] Lose column comment when
create table
URL: https://github.com/apache/flink/pull/13177
--
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 c
leonardBang commented on code in PR #618:
URL: https://github.com/apache/flink-web/pull/618#discussion_r1132492657
##
docs/content/posts/2023-03-09-release-1.17.0.md:
##
@@ -0,0 +1,481 @@
+---
+authors:
+- LeonardXu:
+ name: "Leonard Xu"
+ twitter: Leonardxbj
+date: "2023-03-0
[
https://issues.apache.org/jira/browse/FLINK-30129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30129:
---
Labels: pull-request-available (was: )
> Push projection through ChangelogNormalize
> -
wuchong opened a new pull request, #22156:
URL: https://github.com/apache/flink/pull/22156
## What is the purpose of the change
Currently, the `ChangelogNormalize` node is generated during the physical
optimization phase. That means the projection is not pushed through
`Chang
flinkbot commented on PR #22155:
URL: https://github.com/apache/flink/pull/22155#issuecomment-1463919298
## CI report:
* 55e4310d5b00b2bc6a294db1ee3c62b28ce0ff8f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17698956#comment-17698956
]
jackylau edited comment on FLINK-31102 at 3/10/23 2:48 PM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17698956#comment-17698956
]
jackylau commented on FLINK-31102:
--
[~jackylau] yeap, it is a misspelling and i have fi
[
https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-31102:
-
Description:
Remove all elements that equal to element from array.
Syntax:
array_remove(array, needle)
wsry opened a new pull request, #22155:
URL: https://github.com/apache/flink/pull/22155
## What is the purpose of the change
Currently, the SortMergeResultPartition may allocate more network buffers
than the guaranteed size of the LocalBufferPool. As a result, some result
partitions
[
https://issues.apache.org/jira/browse/FLINK-31396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31396.
--
Fix Version/s: 1.18.0
Resolution: Fixed
master(1.18) via 49929f844975418850ec0334adf4d06c7c895d
reswqa closed pull request #22151: [FLINK-31396][network] Replace the nano time
by milliseconds as the timeout time for batch read buffer pool
URL: https://github.com/apache/flink/pull/22151
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-31386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao closed FLINK-31386.
---
Resolution: Fixed
> Fix the potential deadlock issue of blocking shuffle
> -
[
https://issues.apache.org/jira/browse/FLINK-31386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17698953#comment-17698953
]
Yingjie Cao commented on FLINK-31386:
-
Merged into 1.17 to unblock release. Will pic
flinkbot commented on PR #22154:
URL: https://github.com/apache/flink/pull/22154#issuecomment-1463895360
## CI report:
* 7bbfe65d88e8a643b0824965f0308e35ce4ccb85 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
leonardBang commented on code in PR #618:
URL: https://github.com/apache/flink-web/pull/618#discussion_r1132459372
##
docs/content/posts/2023-03-09-release-1.17.0.md:
##
@@ -0,0 +1,481 @@
+---
+authors:
+- LeonardXu:
+ name: "Leonard Xu"
+ twitter: Leonardxbj
+date: "2023-03-0
reswqa opened a new pull request, #22154:
URL: https://github.com/apache/flink/pull/22154
Backport FLINK-31393 to release-1.17.
--
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 co
wsry merged PR #22148:
URL: https://github.com/apache/flink/pull/22148
--
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.apache.o
reswqa commented on PR #22147:
URL: https://github.com/apache/flink/pull/22147#issuecomment-1463884228
@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.
T
ferenc-csaky commented on PR #5:
URL:
https://github.com/apache/flink-connector-hbase/pull/5#issuecomment-1463882888
> @ferenc-csaky With @zentol his comments, do you think you could continue
working on this?
Yep, definitely.
--
This is an automated message from the Apache Git Ser
leonardBang commented on code in PR #618:
URL: https://github.com/apache/flink-web/pull/618#discussion_r1132433420
##
docs/content/posts/2023-03-09-release-1.17.0.md:
##
@@ -0,0 +1,481 @@
+---
+authors:
+- LeonardXu:
+ name: "Leonard Xu"
+ twitter: Leonardxbj
+date: "2023-03-0
leonardBang commented on code in PR #618:
URL: https://github.com/apache/flink-web/pull/618#discussion_r1132430851
##
docs/content/posts/2023-03-09-release-1.17.0.md:
##
@@ -0,0 +1,481 @@
+---
+authors:
+- LeonardXu:
+ name: "Leonard Xu"
+ twitter: Leonardxbj
+date: "2023-03-0
Maximilian Michels created FLINK-31400:
--
Summary: Add autoscaler integration for Iceberg source
Key: FLINK-31400
URL: https://issues.apache.org/jira/browse/FLINK-31400
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-31400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-31400:
---
Description:
A very critical part in the scaling algorithm is setting the source pro
[
https://issues.apache.org/jira/browse/FLINK-31395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17698939#comment-17698939
]
Matthias Pohl commented on FLINK-31395:
---
# Is it a test-code-only issue or does it
[
https://issues.apache.org/jira/browse/FLINK-31399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-31399:
--
Description: In FLINK-31317, we've introduced data structures for setting
job resource require
flinkbot commented on PR #22153:
URL: https://github.com/apache/flink/pull/22153#issuecomment-1463787619
## CI report:
* ae1018adab6c66c589cefaa7ea47e9eaa6515ca1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
David Morávek created FLINK-31399:
-
Summary: AdaptiveScheduler is able to handle changes in job
resource requirements
Key: FLINK-31399
URL: https://issues.apache.org/jira/browse/FLINK-31399
Project: F
[
https://issues.apache.org/jira/browse/FLINK-31317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31317:
---
Labels: pull-request-available (was: )
> Introduce data structures for managing resource re
[
https://issues.apache.org/jira/browse/FLINK-31317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-31317:
--
Description: We need to introduce new data structures -
JobResourceRequirements and JobVertexR
dmvk opened a new pull request, #22153:
URL: https://github.com/apache/flink/pull/22153
https://issues.apache.org/jira/browse/FLINK-31317
We need to introduce new data structures - JobResourceRequirements and
JobVertexResource requirements and the corresponding tooling, that we'll
pr
dmvk commented on code in PR #22140:
URL: https://github.com/apache/flink/pull/22140#discussion_r1132331319
##
flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/core/testutils/FlinkAssertionsTest.java:
##
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the Apac
rkhachatryan commented on code in PR #22140:
URL: https://github.com/apache/flink/pull/22140#discussion_r1132327002
##
flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/core/testutils/FlinkAssertionsTest.java:
##
@@ -0,0 +1,121 @@
+/*
+ * Licensed to
dmvk commented on PR #22140:
URL: https://github.com/apache/flink/pull/22140#issuecomment-1463745907
Thank you, @rkhachatryan, @reswqa, and @snuyanzin, for looking into this!
I've addressed all your comments. PTAL
--
This is an automated message from the Apache Git Service.
To respond to
dmvk commented on code in PR #22140:
URL: https://github.com/apache/flink/pull/22140#discussion_r1132309980
##
flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/FlinkAssertions.java:
##
@@ -25,11 +25,11 @@
import org.assertj.core.api.L
dmvk commented on code in PR #22140:
URL: https://github.com/apache/flink/pull/22140#discussion_r1132307750
##
flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/FlinkCompletableFutureAssert.java:
##
@@ -0,0 +1,104 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17698917#comment-17698917
]
Sriram Ganesh edited comment on FLINK-31135 at 3/10/23 12:25 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17698917#comment-17698917
]
Sriram Ganesh commented on FLINK-31135:
---
[~Swathi Chandrashekar] - it is a pod tem
1 - 100 of 184 matches
Mail list logo
