jeyhunkarimov commented on code in PR #23612:
URL: https://github.com/apache/flink/pull/23612#discussion_r1449994298
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlShowDatabasesConverter.java:
##
@@ -0,0 +1,51 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-34047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-34047.
---
Fix Version/s: 1.19.0
1.18.1
Resolution: Fixed
master:
[f29ee07f5
XComp merged PR #24063:
URL: https://github.com/apache/flink/pull/24063
--
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.
XComp merged PR #24061:
URL: https://github.com/apache/flink/pull/24061
--
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.
flinkbot commented on PR #24078:
URL: https://github.com/apache/flink/pull/24078#issuecomment-1888578089
## CI report:
* 547c3c10e8bb800244d18ce1c4cc23642bc460bf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaborgsomogyi commented on PR #23930:
URL: https://github.com/apache/flink/pull/23930#issuecomment-1888577653
The change looks good, but timeout happened.
--
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
gaborgsomogyi commented on PR #23930:
URL: https://github.com/apache/flink/pull/23930#issuecomment-1888576964
@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 comm
XComp commented on code in PR #23971:
URL: https://github.com/apache/flink/pull/23971#discussion_r1449977361
##
.github/actions/select_workflow_configs/action.yml:
##
@@ -0,0 +1,59 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license ag
XComp commented on code in PR #23971:
URL: https://github.com/apache/flink/pull/23971#discussion_r1449977361
##
.github/actions/select_workflow_configs/action.yml:
##
@@ -0,0 +1,59 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license ag
flinkbot commented on PR #24077:
URL: https://github.com/apache/flink/pull/24077#issuecomment-1888570663
## CI report:
* d78dc4459252f1f105d0bc4337fa64726b834665 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp commented on code in PR #23971:
URL: https://github.com/apache/flink/pull/23971#discussion_r1449977361
##
.github/actions/select_workflow_configs/action.yml:
##
@@ -0,0 +1,59 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license ag
[
https://issues.apache.org/jira/browse/FLINK-34040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-34040.
---
Resolution: Fixed
The error was, indeed caused by a wrong setup of the {{github-actions}} pr
SinBex opened a new pull request, #24078:
URL: https://github.com/apache/flink/pull/24078
## What is the purpose of the change
Currently, for JobVertices without parallelism configured, the
AdaptiveBatchScheduler dynamically infers the vertex parallelism based on the
volume of input
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805915#comment-17805915
]
Hangxiang Yu commented on FLINK-34050:
--
Thanks [~lijinzhong] and [~mayuehappy] prov
[
https://issues.apache.org/jira/browse/FLINK-33768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33768:
---
Labels: pull-request-available (was: )
> Support dynamic source parallelism inference for b
[
https://issues.apache.org/jira/browse/FLINK-34036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-34036.
---
Resolution: Fixed
Yup, it was caused by what I described in my comment above. Thanks for the
swuferhong opened a new pull request, #24077:
URL: https://github.com/apache/flink/pull/24077
## What is the purpose of the change
This pr is aims to update the query hint docs to clarify the resolution of
conflicts in kv hint and list hint.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-34034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34034:
---
Labels: pull-request-available (was: )
> When kv hint and list hint handle duplicate query
snuyanzin commented on PR #23838:
URL: https://github.com/apache/flink/pull/23838#issuecomment-1888545344
Thanks for having a look I will rebase to the latest branch and split it in
2 commits: one for adopting jackson breaking change mentioned in description
and another for the actual updat
[
https://issues.apache.org/jira/browse/FLINK-33946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-33946.
--
Resolution: Fixed
merged aa0c1b5e into master
> RocksDb sets setAvoidFlushDuringShutdown to t
masteryhx closed pull request #24069: [FLINK-33946] [rocksdb] set
AvoidFlushDuringShutdown to true for avoiding Flush when Cancel Task
URL: https://github.com/apache/flink/pull/24069
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
[
https://issues.apache.org/jira/browse/FLINK-34051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-34051.
--
Fix Version/s: 1.19.0
Resolution: Fixed
merged 7745ef83 and ecb68704 into master
> Fix
masteryhx closed pull request #24066: [FLINK-34051][checkpoint] Fix
equals/hashCode/toString for SavepointRestoreSettings
URL: https://github.com/apache/flink/pull/24066
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
flinkbot commented on PR #24076:
URL: https://github.com/apache/flink/pull/24076#issuecomment-1888409523
## CI report:
* 319b84aca99ca02d59dbfb7139a92472d0b19fd3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24075:
URL: https://github.com/apache/flink/pull/24075#issuecomment-1888405606
## CI report:
* a1aa7a2284cee539e17b951a585962a416360104 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34067:
---
Labels: pull-request-available (was: )
> Fix javacc warnings in flink-sql-parser
>
jnh5y opened a new pull request, #24076:
URL: https://github.com/apache/flink/pull/24076
## What is the purpose of the change
Address the two warnings in the build for the Flink SQL Parser:
```
[INFO] — javacc:2.4:javacc (javacc) @ flink-sql-parser ---
[
https://issues.apache.org/jira/browse/FLINK-34067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jim Hughes updated FLINK-34067:
---
Description:
While extending the Flink SQL parser, I noticed these two warnings:
```
[INFO] — javacc
Jim Hughes created FLINK-34067:
--
Summary: Fix javacc warnings in flink-sql-parser
Key: FLINK-34067
URL: https://issues.apache.org/jira/browse/FLINK-34067
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-34066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34066:
---
Labels: pull-request-available (was: )
> LagFunction throw NPE when input argument are not
[
https://issues.apache.org/jira/browse/FLINK-34067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jim Hughes updated FLINK-34067:
---
Affects Version/s: 1.19.0
> Fix javacc warnings in flink-sql-parser
> --
swuferhong opened a new pull request, #24075:
URL: https://github.com/apache/flink/pull/24075
## What is the purpose of the change
Fix LagFunction throw NPE when input argument are not null.
## Brief change log
- Fix LagFunction throw NPE when input argument are n
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805871#comment-17805871
]
Yang Wang commented on FLINK-34007:
---
[~mapohl] Could you please confirm that whether "
Yunhong Zheng created FLINK-34066:
-
Summary: LagFunction throw NPE when input argument are not null
Key: FLINK-34066
URL: https://issues.apache.org/jira/browse/FLINK-34066
Project: Flink
Issu
JunRuiLee commented on PR #23852:
URL: https://github.com/apache/flink/pull/23852#issuecomment-1888377286
@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.
zhilinli123 commented on PR #87:
URL:
https://github.com/apache/flink-connector-jdbc/pull/87#issuecomment-1888373294
> @zhilinli123 I still don't understand the Jira ticket, so I can't really
review it. Perhaps @snuyanzin or @eskabetxe understand the goal of this PR.
hi~ @MartijnViss
bvarghese1 commented on PR #24009:
URL: https://github.com/apache/flink/pull/24009#issuecomment-1888372875
> From reading the code for `StreamExecIntervalJoin`, I noticed
pad/filter-left/right transformations. Seems like those can be produced when
the `TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS`
ljz2051 commented on PR #24066:
URL: https://github.com/apache/flink/pull/24066#issuecomment-1888366794
Thanks for the update, LGTM
--
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
zoudan commented on PR #23984:
URL: https://github.com/apache/flink/pull/23984#issuecomment-1888360571
@lsyldliu I have updated my code, please have a took when you have time.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
flinkbot commented on PR #24074:
URL: https://github.com/apache/flink/pull/24074#issuecomment-1888345731
## CI report:
* 970e31067f5a893ea90b3f8a33064051e597bfe3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1996fanrui commented on code in PR #741:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/741#discussion_r1449726286
##
flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/state/JobStateView.java:
##
@@ -0,0 +1,262 @@
+/*
+ * Licensed to the
Rui Fan created FLINK-34065:
---
Summary: Design AbstractAutoscalerStateStore to support serialize
State to String
Key: FLINK-34065
URL: https://issues.apache.org/jira/browse/FLINK-34065
Project: Flink
hunter-cloud09 commented on code in PR #740:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/740#discussion_r1449726381
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -369,16 +370,17 @@ prot
LadyForest opened a new pull request, #24074:
URL: https://github.com/apache/flink/pull/24074
## What is the purpose of the change
This PR is cherry-picked from https://github.com/apache/flink/pull/24051
## Brief change log
- Planning phase: Check whether the `emitUpdateW
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-31788:
--
Affects Version/s: 1.18.1
> Add back Support emitValueWithRetract for TableAggregateFunction
> ---
zoudan commented on PR #23984:
URL: https://github.com/apache/flink/pull/23984#issuecomment-1888301428
@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
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-31788:
--
Affects Version/s: 1.17.2
1.16.3
1.17.1
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805853#comment-17805853
]
Jane Chan commented on FLINK-31788:
---
Fixed in master 01569644aedb56f792c7f7e04f84612d4
LadyForest merged PR #24051:
URL: https://github.com/apache/flink/pull/24051
--
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-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan resolved FLINK-20281.
---
Fix Version/s: 1.19.0
Resolution: Fixed
> Window aggregation supports changelog stream input
[
https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan closed FLINK-20281.
-
> Window aggregation supports changelog stream input
> --
>
[
https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805852#comment-17805852
]
Jane Chan commented on FLINK-20281:
---
Fixed in master df2ecdc77b23e0e40fe151ed8a7350a6d
jiangxin369 commented on PR #23957:
URL: https://github.com/apache/flink/pull/23957#issuecomment-1888280011
@reswqa Seems that the CI failed but the cause is related to python rather
than this PR. Could you help merge it?
--
This is an automated message from the Apache Git Service.
To res
LadyForest merged PR #24030:
URL: https://github.com/apache/flink/pull/24030
--
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
snuyanzin opened a new pull request, #710:
URL: https://github.com/apache/flink-web/pull/710
(no comment)
--
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-
snuyanzin merged PR #701:
URL: https://github.com/apache/flink-web/pull/701
--
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.apa
flinkbot commented on PR #24073:
URL: https://github.com/apache/flink/pull/24073#issuecomment-1888126956
## CI report:
* 03494cb182c4f0e3fa4e407dc1f3b06dc9db40b9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
jnh5y opened a new pull request, #24073:
URL: https://github.com/apache/flink/pull/24073
## 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 on e
[
https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Burmistrov updated FLINK-34063:
Priority: Critical (was: Major)
> When snapshot compression is enabled, rescaling of a so
[
https://issues.apache.org/jira/browse/FLINK-34064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen updated FLINK-34064:
---
Affects Version/s: 1.18.0
> Expose JobManagerOperatorMetrics via REST API
>
[
https://issues.apache.org/jira/browse/FLINK-34064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen updated FLINK-34064:
---
Component/s: Runtime / REST
> Expose JobManagerOperatorMetrics via REST API
> --
Mason Chen created FLINK-34064:
--
Summary: Expose JobManagerOperatorMetrics via REST API
Key: FLINK-34064
URL: https://issues.apache.org/jira/browse/FLINK-34064
Project: Flink
Issue Type: Improve
mas-chen commented on PR #44:
URL:
https://github.com/apache/flink-connector-kafka/pull/44#issuecomment-1887855854
one-pager docs are here:
docs/content/docs/connectors/datastream/dynamic-kafka.md. Marked with
experimental status.
Also copied this into the chinese doc directory.
-
[
https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805739#comment-17805739
]
Piotr Nowojski commented on FLINK-33856:
In that case [~hejufang001] it would be
mxm commented on PR #44:
URL:
https://github.com/apache/flink-connector-kafka/pull/44#issuecomment-1887622480
A brief one-pager of the feature would be good. We can expand on it later.
Just to have something in the web docs.
--
This is an automated message from the Apache Git Service.
To
Ivan Burmistrov created FLINK-34063:
---
Summary: When snapshot compression is enabled, rescaling of a
source operator leads to some splits getting lost
Key: FLINK-34063
URL: https://issues.apache.org/jira/browse/F
mas-chen commented on PR #44:
URL:
https://github.com/apache/flink-connector-kafka/pull/44#issuecomment-1887602638
Are the Javadocs sufficient in the bare minimum case? Otherwise, I'll just
write the documentation into this PR
--
This is an automated message from the Apache Git Service.
mxm commented on PR #44:
URL:
https://github.com/apache/flink-connector-kafka/pull/44#issuecomment-1887599176
Sounds good. Can we get a bare-minimum version of the documentation into
this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
davidradl commented on PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#issuecomment-1887600132
@snuyanzin I have left this with multiple commits for now . Should we
squash to one commit and put you as a co author in the commit message? If so
how would you like me to id
davidradl commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1449155934
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/ParameterizedPredicatePlanTest.java:
##
@@ -0,0 +1,169 @@
+/*
+ * Licensed to th
mas-chen commented on PR #44:
URL:
https://github.com/apache/flink-connector-kafka/pull/44#issuecomment-1887586297
Thanks @tzulitai @mxm for your review! I've addressed all the comments and
squashed the commits. Can you please merge it at your convenience?
I'll start on the docs imme
twalthr commented on code in PR #23975:
URL: https://github.com/apache/flink/pull/23975#discussion_r1449149984
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/AsyncUtil.java:
##
@@ -0,0 +1,216 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-34036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805708#comment-17805708
]
Matthias Pohl edited comment on FLINK-34036 at 1/11/24 4:55 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-34036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805708#comment-17805708
]
Matthias Pohl commented on FLINK-34036:
---
The problem seems to be that we're not bu
twalthr commented on code in PR #23975:
URL: https://github.com/apache/flink/pull/23975#discussion_r1449138779
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecAsyncCalc.java:
##
@@ -0,0 +1,175 @@
+/*
+ * Licensed t
twalthr commented on code in PR #23975:
URL: https://github.com/apache/flink/pull/23975#discussion_r1449134322
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionMappingExtractor.java:
##
@@ -208,6 +249,32 @@ static MethodVerification
[
https://issues.apache.org/jira/browse/FLINK-32006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805698#comment-17805698
]
Junrui Li commented on FLINK-32006:
---
https://dev.azure.com/apache-flink/apache-flink/_
twalthr commented on code in PR #23975:
URL: https://github.com/apache/flink/pull/23975#discussion_r1449130065
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/UserDefinedFunctionHelper.java:
##
@@ -67,6 +67,8 @@ public final class UserDefinedFunc
snuyanzin commented on code in PR #22:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/22#discussion_r1449084708
##
flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java:
##
@@ -22,6 +22,7 @@
import org.apache.flink.a
XComp commented on code in PR #23971:
URL: https://github.com/apache/flink/pull/23971#discussion_r1449060542
##
.github/actions/select_workflow_configs/action.yml:
##
@@ -0,0 +1,59 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license ag
[
https://issues.apache.org/jira/browse/FLINK-30252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-30252:
---
Fix Version/s: shaded-19.0
(was: shaded-18.0)
> Publish flink-shaded
XComp commented on code in PR #23971:
URL: https://github.com/apache/flink/pull/23971#discussion_r1449024195
##
.github/actions/select_workflow_configs/action.yml:
##
@@ -0,0 +1,59 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license ag
zentol commented on code in PR #23971:
URL: https://github.com/apache/flink/pull/23971#discussion_r1449020160
##
.github/actions/select_workflow_configs/action.yml:
##
@@ -0,0 +1,59 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license a
zentol commented on code in PR #23971:
URL: https://github.com/apache/flink/pull/23971#discussion_r1449015851
##
.github/actions/select_workflow_configs/action.yml:
##
@@ -0,0 +1,59 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license a
zentol commented on code in PR #23971:
URL: https://github.com/apache/flink/pull/23971#discussion_r1449014250
##
.github/actions/select_workflow_configs/action.yml:
##
@@ -0,0 +1,59 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license a
zentol commented on code in PR #23971:
URL: https://github.com/apache/flink/pull/23971#discussion_r1449015851
##
.github/actions/select_workflow_configs/action.yml:
##
@@ -0,0 +1,59 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license a
zentol commented on code in PR #23971:
URL: https://github.com/apache/flink/pull/23971#discussion_r1449014250
##
.github/actions/select_workflow_configs/action.yml:
##
@@ -0,0 +1,59 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license a
[
https://issues.apache.org/jira/browse/FLINK-31977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805650#comment-17805650
]
Maximilian Michels commented on FLINK-31977:
I think this is related to FLIN
patricklucas commented on PR #23836:
URL: https://github.com/apache/flink/pull/23836#issuecomment-1887371839
My suspicion is that there's an extremely small chance of that but I have no
way to quantify it.
In our case it was actually the other way around: we set this option and
were
mxm commented on code in PR #44:
URL:
https://github.com/apache/flink-connector-kafka/pull/44#discussion_r1448982380
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/DynamicKafkaSource.java:
##
@@ -0,0 +1,199 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/FLINK-34036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805636#comment-17805636
]
Matthias Pohl commented on FLINK-34036:
---
The test failures can be reproduced local
mxm commented on code in PR #741:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/741#discussion_r1448978956
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/config/AutoscalerStandaloneOptions.java:
##
@@ -59,4 +64,47 @@ private
mxm commented on code in PR #741:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/741#discussion_r1448978630
##
flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/state/JobStateView.java:
##
@@ -0,0 +1,262 @@
+/*
+ * Licensed to the Apache
1996fanrui commented on code in PR #751:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/751#discussion_r1448948315
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -247,6 +254,69 @@ private boolean isJobUnderMemoryPressure
1996fanrui commented on code in PR #741:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/741#discussion_r1448941925
##
flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/state/JobStateView.java:
##
@@ -0,0 +1,262 @@
+/*
+ * Licensed to the
1996fanrui commented on code in PR #741:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/741#discussion_r1448928730
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/config/AutoscalerStandaloneOptions.java:
##
@@ -59,4 +64,47 @@ p
1996fanrui commented on code in PR #751:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/751#discussion_r1448858318
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/resources/ResourceCheck.java:
##
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the Apache Softw
mxm commented on code in PR #741:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/741#discussion_r1448905911
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/config/AutoscalerStandaloneOptions.java:
##
@@ -59,4 +64,47 @@ private
gaborgsomogyi commented on PR #23930:
URL: https://github.com/apache/flink/pull/23930#issuecomment-1887214969
The approach looks fine though not fully executed the full pipeline so added
an automated test to enforce `ErrorResponseBody` structure.
--
This is an automated message from the A
gyfora commented on code in PR #740:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/740#discussion_r1448906275
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -369,16 +370,17 @@ protected vo
1 - 100 of 185 matches
Mail list logo
