[
https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong updated FLINK-32755:
--
Parent: FLINK-32898
Issue Type: Sub-task (was: Improvement)
> Add quick start guide for
[
https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong updated FLINK-32755:
--
Parent: (was: FLINK-32898)
Issue Type: Improvement (was: Sub-task)
> Add quick start
[
https://issues.apache.org/jira/browse/FLINK-32970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob closed FLINK-32970.
-
Resolution: Won't Fix
> could not load external class using "-C" option
>
[
https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong updated FLINK-32755:
--
Parent: FLINK-32898
Issue Type: Sub-task (was: Improvement)
> Add quick start guide for
[
https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong updated FLINK-32755:
--
Parent: (was: FLINK-25318)
Issue Type: Improvement (was: Sub-task)
> Add quick start
jiangxin369 commented on code in PR #23331:
URL: https://github.com/apache/flink/pull/23331#discussion_r1312581263
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointAfterAllTasksFinishedITCase.java:
##
@@ -75,6 +76,12 @@ public void setUp() {
jiangxin369 commented on code in PR #23331:
URL: https://github.com/apache/flink/pull/23331#discussion_r1312581263
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointAfterAllTasksFinishedITCase.java:
##
@@ -75,6 +76,12 @@ public void setUp() {
[
https://issues.apache.org/jira/browse/FLINK-33013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761166#comment-17761166
]
Jiabao Sun commented on FLINK-33013:
PR is ready
[
https://issues.apache.org/jira/browse/FLINK-32423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761162#comment-17761162
]
Guozhen Yang commented on FLINK-32423:
--
[~gyfora] The flow is not introduced by the
zhu created FLINK-33014:
---
Summary: flink jobmanager raise java.io.IOException: Connection
reset by peer
Key: FLINK-33014
URL: https://issues.apache.org/jira/browse/FLINK-33014
Project: Flink
Issue
Jiabao-Sun commented on PR #15:
URL:
https://github.com/apache/flink-connector-mongodb/pull/15#issuecomment-1702109177
Hi @leonardBang, could you help review this when you have time?
--
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-32968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong closed FLINK-32968.
-
Fix Version/s: 1.18.0
1.19.0
Resolution: Fixed
Fixed by
Jiabao Sun created FLINK-33013:
--
Summary: Shade flink-connector-base info
flink-sql-connector-connector
Key: FLINK-33013
URL: https://issues.apache.org/jira/browse/FLINK-33013
Project: Flink
FangYongs merged PR #23307:
URL: https://github.com/apache/flink/pull/23307
--
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-32396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong reassigned FLINK-32396:
-
Assignee: Fang Yong
> Support timestamp for jdbc driver and gateway
>
A-Forward-Scholar commented on PR #253:
URL: https://github.com/apache/flink-ml/pull/253#issuecomment-1702040771
Hello teachers, this problem seems that the beam package in pyflink has
changed. How should I solve this problem?
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-33004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761151#comment-17761151
]
Zhanghao Chen commented on FLINK-33004:
---
[~lsy] big +1 for it. Could you collaborate a bit how you
FangYongs commented on code in PR #23307:
URL: https://github.com/apache/flink/pull/23307#discussion_r1312469628
##
docs/content/docs/dev/table/catalogs.md:
##
@@ -801,10 +806,9 @@ env.executeSql("CREATE TABLE ...").wait();
```
For sql-gateway, you can add the option
WencongLiu closed pull request #23341: 6912 test6
URL: https://github.com/apache/flink/pull/23341
--
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:
WencongLiu closed pull request #23340: 6912 test5
URL: https://github.com/apache/flink/pull/23340
--
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:
WencongLiu closed pull request #23340: 6912 test5
URL: https://github.com/apache/flink/pull/23340
--
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:
WencongLiu closed pull request #23326: 6912 Test4
URL: https://github.com/apache/flink/pull/23326
--
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:
WencongLiu closed pull request #23326: 6912 Test4
URL: https://github.com/apache/flink/pull/23326
--
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:
WencongLiu closed pull request #23325: 6912 Test 2
URL: https://github.com/apache/flink/pull/23325
--
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:
WencongLiu closed pull request #23318: 6912 Test 1
URL: https://github.com/apache/flink/pull/23318
--
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:
Zakelly commented on PR #23344:
URL: https://github.com/apache/flink/pull/23344#issuecomment-1702019270
@masteryhx Would you please take a look? Thanks a lot!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
hackergin commented on PR #23109:
URL: https://github.com/apache/flink/pull/23109#issuecomment-1702018328
@luoyuxia Thank you for the edits, it looks much better after the
modifications.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
luoyuxia commented on PR #23109:
URL: https://github.com/apache/flink/pull/23109#issuecomment-1702016186
@hackergin I append a small commit in [refine doc by
yuxia](https://github.com/apache/flink/pull/23109/commits/bb66f553c157da629433588390cfb93c47fb56ab),
please PTAL. If you don't have
jiangxin369 commented on PR #23332:
URL: https://github.com/apache/flink/pull/23332#issuecomment-1701976462
@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
[
https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-32996:
Assignee: Jiang Xin
> CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished
lindong28 commented on code in PR #23331:
URL: https://github.com/apache/flink/pull/23331#discussion_r1312412768
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointAfterAllTasksFinishedITCase.java:
##
@@ -106,7 +113,7 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761124#comment-17761124
]
Sergey Nuyanzin commented on FLINK-32996:
-
[
https://issues.apache.org/jira/browse/FLINK-30719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761123#comment-17761123
]
Sergey Nuyanzin commented on FLINK-30719:
-
snuyanzin commented on PR #23217:
URL: https://github.com/apache/flink/pull/23217#issuecomment-1701883872
That's a good question
I've never encountered an issue, however I remember @zentol always asked to
exclude junit5 extention in poms for test-jar in case there are junit4 baed
[
https://issues.apache.org/jira/browse/FLINK-32785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761112#comment-17761112
]
Sergey Nuyanzin commented on FLINK-32785:
-
Hi [~qingyue]
thanks for your response
I gave another
[
https://issues.apache.org/jira/browse/FLINK-30433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-30433:
---
Labels: auto-deprioritized-critical test-stability (was: stale-critical
test-stability)
[
https://issues.apache.org/jira/browse/FLINK-25442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25442:
---
Labels: auto-deprioritized-critical test-stability (was:
auto-deprioritized-critical
[
https://issues.apache.org/jira/browse/FLINK-31174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-31174:
---
Labels: auto-deprioritized-minor pull-request-available (was:
pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32570:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-32268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32268:
---
Labels: stale-assigned test-stability (was: test-stability)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-18896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-18896:
---
Labels: auto-deprioritized-minor pull-request-available (was:
pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-30812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-30812:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-32620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32620:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
flinkbot commented on PR #23345:
URL: https://github.com/apache/flink/pull/23345#issuecomment-1701788080
## CI report:
* c35d3715779fd64edf4c69ad2727ef6960b72a4f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761087#comment-17761087
]
Neng Lu commented on FLINK-32938:
-
I have prepared a draft PR for solve this issue:
snuyanzin opened a new pull request, #23345:
URL: https://github.com/apache/flink/pull/23345
## What is the purpose of the change
The issue is that `tmpResult` could refer to not initialised variable and
this fact leads to compiliation issues.
It could be reproduced with
boring-cyborg[bot] commented on PR #59:
URL:
https://github.com/apache/flink-connector-pulsar/pull/59#issuecomment-1701779323
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
nlu90 opened a new pull request, #59:
URL: https://github.com/apache/flink-connector-pulsar/pull/59
## Purpose of the change
Replace PulsarAdmin calls with PulsarClient or Consumer calls
## Brief change log
- *Change the internal design of `ProducerRegister`.*
[
https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-33010:
---
Assignee: Sergey Nuyanzin
> NPE when using GREATEST() in Flink SQL
>
[
https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761085#comment-17761085
]
Sergey Nuyanzin edited comment on FLINK-33010 at 8/31/23 8:55 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761085#comment-17761085
]
Sergey Nuyanzin commented on FLINK-33010:
-
Thanks for your response, yes confirm I was able to
kurnoolsaketh closed pull request #31: De 5143
URL: https://github.com/apache/flink-connector-opensearch/pull/31
--
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
kurnoolsaketh opened a new pull request, #31:
URL: https://github.com/apache/flink-connector-opensearch/pull/31
## Description
### This PR is for review purposes only – once it's approved, I will close
it and push this branch version to our codeartifact.
Currently, the
gfmio opened a new pull request, #336:
URL: https://github.com/apache/flink-statefun/pull/336
This PR adds the topic, partition and offset to the error message when Flink
encounters a null key to simplify finding the offending message.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761051#comment-17761051
]
Tzu-Li (Gordon) Tai edited comment on FLINK-30238 at 8/31/23 5:40 PM:
[
https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761051#comment-17761051
]
Tzu-Li (Gordon) Tai edited comment on FLINK-30238 at 8/31/23 5:39 PM:
[
https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761051#comment-17761051
]
Tzu-Li (Gordon) Tai commented on FLINK-30238:
-
hi all, I'd like to move this ticket forward
flinkbot commented on PR #23344:
URL: https://github.com/apache/flink/pull/23344#issuecomment-1701453546
## CI report:
* 595ab2652e82da35e48d3df5b9c31cd555cd9966 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly opened a new pull request, #23344:
URL: https://github.com/apache/flink/pull/23344
## What is the purpose of the change
This PR replace ListState#clear along with following ListState#add with a
ListState#update, which reduces the state access overhead for KeyedState and
[
https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761031#comment-17761031
]
Alexis Sarda-Espinosa commented on FLINK-16686:
---
cc [~yunta]
I wanted to check if this
[
https://issues.apache.org/jira/browse/FLINK-32874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761006#comment-17761006
]
Morey Straus commented on FLINK-32874:
--
Thank you for the triage and for the link. I didn't
[
https://issues.apache.org/jira/browse/FLINK-28594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-28594:
--
Priority: Minor (was: Major)
> Add metrics for FlinkService
>
>
[
https://issues.apache.org/jira/browse/FLINK-31611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-31611:
--
Priority: Minor (was: Major)
> Add delayed restart to failed jobs
>
[
https://issues.apache.org/jira/browse/FLINK-28261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-28261:
--
Priority: Not a Priority (was: Major)
> Consider Using Dependent Resources for Ingress
>
[
https://issues.apache.org/jira/browse/FLINK-28593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-28593:
--
Priority: Not a Priority (was: Major)
> Introduce default CR templates at operator level
>
[
https://issues.apache.org/jira/browse/FLINK-27491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi closed FLINK-27491.
-
Release Note: Closing this issue according to the comments from the
community
Resolution:
ferenc-csaky commented on PR #23293:
URL: https://github.com/apache/flink/pull/23293#issuecomment-1701244450
Thanks for the review @hackergin! @PatrickRen if you have some time can you
check on this one?
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-30119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Clara Xiong closed FLINK-30119.
---
Release Note: Given the impact vs benefit of the change, we can revisit
next time we get a change
[
https://issues.apache.org/jira/browse/FLINK-30119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760994#comment-17760994
]
Clara Xiong commented on FLINK-30119:
-
Given the impact and benefit of the change, we can revisit
[
https://issues.apache.org/jira/browse/FLINK-31509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-31509:
---
Component/s: (was: Kubernetes Operator)
> REST Service missing sessionAffinity causes job run
[
https://issues.apache.org/jira/browse/FLINK-31509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760970#comment-17760970
]
Gyula Fora commented on FLINK-31509:
I will update the component [~eleroy] . Operator issues are the
[
https://issues.apache.org/jira/browse/FLINK-31493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Emmanuel Leroy updated FLINK-31493:
---
Labels: helm (was: auto-deprioritized-major helm)
> helm upgrade does not work, because
[
https://issues.apache.org/jira/browse/FLINK-31509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760950#comment-17760950
]
Emmanuel Leroy commented on FLINK-31509:
[~gyfora] It is a k8s integration issue, but it is
[
https://issues.apache.org/jira/browse/FLINK-32991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-32991.
Resolution: Fixed
> Some metrics from autoscaler never get registered
>
[
https://issues.apache.org/jira/browse/FLINK-32992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760934#comment-17760934
]
Maximilian Michels commented on FLINK-32992:
That makes sense. Closing.
> Recommended
[
https://issues.apache.org/jira/browse/FLINK-32992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-32992.
Resolution: Not A Problem
> Recommended parallelism metric is a duplicate of
[
https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760933#comment-17760933
]
Matt Wang commented on FLINK-32804:
---
[~renqs] I just started doing this verification today. I will
zhougit86 commented on PR #23323:
URL: https://github.com/apache/flink/pull/23323#issuecomment-1700993996
> > @libenchao Hi Master, This CI seems failed with Node.js related issue.
Would you please help review the Pb projection logic first? I have made it pass
all the proto2row test. Let
reswqa closed pull request #22665: Update japicmp configuration for 1.17.1
URL: https://github.com/apache/flink/pull/22665
--
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
reswqa closed pull request #22666: Update japicmp configuration for 1.16.2
URL: https://github.com/apache/flink/pull/22666
--
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-33008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760911#comment-17760911
]
Gyula Fora commented on FLINK-33008:
done :)
> Use KubernetesClient from JOSDK context
>
[
https://issues.apache.org/jira/browse/FLINK-33008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-33008:
--
Assignee: Daren Wong
> Use KubernetesClient from JOSDK context
>
flinkbot commented on PR #23343:
URL: https://github.com/apache/flink/pull/23343#issuecomment-1700948563
## CI report:
* b0be30cb9104d8f5f0c8a39d53fcb4057b2c0d7c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ferenc-csaky opened a new pull request, #23343:
URL: https://github.com/apache/flink/pull/23343
## What is the purpose of the change
Removes HBase connector code from the main repo, as the HBase connector is
externalized to the
flinkbot commented on PR #23342:
URL: https://github.com/apache/flink/pull/23342#issuecomment-1700940821
## CI report:
* 8d9a41285d36bf7cdd1f9bbe4b4248520af4cfd6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
KarmaGYZ commented on code in PR #23201:
URL: https://github.com/apache/flink/pull/23201#discussion_r1311485147
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java:
##
@@ -359,24 +425,45 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-32999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32999:
---
Labels: pull-request-available (was: )
> Remove HBase connector from master branch
>
KarmaGYZ commented on code in PR #23201:
URL: https://github.com/apache/flink/pull/23201#discussion_r1311545630
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java:
##
@@ -347,8 +376,45 @@ &&
ferenc-csaky opened a new pull request, #23342:
URL: https://github.com/apache/flink/pull/23342
## What is the purpose of the change
Removes HBase connector code from the main repo, as the HBase connector is
externalized to the
KarmaGYZ commented on code in PR #23201:
URL: https://github.com/apache/flink/pull/23201#discussion_r1311522921
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java:
##
@@ -128,20 +152,13 @@ public
gfmio opened a new pull request, #334:
URL: https://github.com/apache/flink-statefun/pull/334
This PR fixes the unclosed response warnings that Statefun reports when an
HTTP request by Flink fails.
The PR also sets the recommended logger setting to get more details about
the issue
KarmaGYZ commented on code in PR #23201:
URL: https://github.com/apache/flink/pull/23201#discussion_r1311511758
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java:
##
@@ -359,24 +425,45 @@ private void
KarmaGYZ commented on code in PR #23201:
URL: https://github.com/apache/flink/pull/23201#discussion_r1311485147
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java:
##
@@ -359,24 +425,45 @@ private void
KarmaGYZ commented on code in PR #23201:
URL: https://github.com/apache/flink/pull/23201#discussion_r1311481212
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java:
##
@@ -83,6 +87,24 @@ public
gfmio commented on PR #333:
URL: https://github.com/apache/flink-statefun/pull/333#issuecomment-1700851010
Question for the maintainers: Do you think we should keep this a fixed list
or shall we make this configurable as a comma separated list in either the
flink config or the
[
https://issues.apache.org/jira/browse/FLINK-33012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-33012:
-
Assignee: (was: Matthias Pohl)
> LeaderElectionTest.testHasLeadership fails on AZP
[
https://issues.apache.org/jira/browse/FLINK-33012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-33012:
-
Assignee: (was: Matthias Pohl)
> LeaderElectionTest.testHasLeadership fails on AZP
[
https://issues.apache.org/jira/browse/FLINK-33012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760866#comment-17760866
]
Matthias Pohl commented on FLINK-33012:
---
I would leave this one open and see whether it pops up
[
https://issues.apache.org/jira/browse/FLINK-33012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-33012:
-
Assignee: Matthias Pohl
> LeaderElectionTest.testHasLeadership fails on AZP due to
gfmio opened a new pull request, #333:
URL: https://github.com/apache/flink-statefun/pull/333
This PR increases the list of status codes considered retryable.
* When Flink Statefun has high load, it can happen that the requests are
sent too slowly and the server read timeout cuts off
1 - 100 of 213 matches
Mail list logo
