[
https://issues.apache.org/jira/browse/FLINK-33827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33827:
Description: (was: There are a few pages in the documentation that need
to be reviewed and updated for
[
https://issues.apache.org/jira/browse/FLINK-33829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33829:
Description:
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12353640
[
https://issues.apache.org/jira/browse/FLINK-33830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge resolved FLINK-33830.
-
Fix Version/s: (was: 1.17.0)
Resolution: Fixed
> Select executing Release Manager
> -
[
https://issues.apache.org/jira/browse/FLINK-33830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33830:
Affects Version/s: 1.18.0
(was: 1.17.0)
> Select executing Release Manager
> --
[
https://issues.apache.org/jira/browse/FLINK-33831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge resolved FLINK-33831.
-
Resolution: Fixed
> Checkout the release branch
> ---
>
> Key: F
zhutong6688 opened a new pull request, #23931:
URL: https://github.com/apache/flink/pull/23931
## What is the purpose of the change
Fix NullArgumentException of getQuantile method in
DescriptiveStatisticsHistogramStatistics
## Brief change log
This DescriptiveSta
echauchot opened a new pull request, #31:
URL: https://github.com/apache/flink-connector-shared-utils/pull/31
@zentol next version jira label for new connector-parent already exists but
contains version 1.1.0 and not 1.0.1 (hence this change). Do you agree that the
yet-to-release changes [1
flinkbot commented on PR #23931:
URL: https://github.com/apache/flink/pull/23931#issuecomment-1856171367
## CI report:
* ee5a7de3a7921a54c8561cb20ab7c56f2e6c7de7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhutong6688 commented on PR #23931:
URL: https://github.com/apache/flink/pull/23931#issuecomment-1856196745
old PR is #23749 and #23915. This PR is new, but the content is the same
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
Zakelly commented on PR #21635:
URL: https://github.com/apache/flink/pull/21635#issuecomment-1856242365
Hi @masteryhx , sorry for the late reply!
After reading your PR, I finally figured out why the default implementation
of old method and new method should call each other. I think we
[
https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796841#comment-17796841
]
Tongtong Zhu commented on FLINK-33588:
--
[~jingge] The New PRĀ #23931 [https://github
[
https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796843#comment-17796843
]
Piotr Nowojski commented on FLINK-27681:
I could help reviewing and generally sp
[
https://issues.apache.org/jira/browse/FLINK-33666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796862#comment-17796862
]
Timo Walther commented on FLINK-33666:
--
[~jhughes] was this issue resolved? Was it
[
https://issues.apache.org/jira/browse/FLINK-33666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796882#comment-17796882
]
Jim Hughes commented on FLINK-33666:
[~twalthr] Yes, the issue has been resolved.
T
TestBoost commented on PR #23910:
URL: https://github.com/apache/flink/pull/23910#issuecomment-1856543512
Hi,
So to clarify, would the preferred change be to start a cluster
per-test-class and to share between test methods? Looking at the test class,
perhaps this could be accomplishe
[
https://issues.apache.org/jira/browse/FLINK-33835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge resolved FLINK-33835.
-
Resolution: Fixed
> Stage source and binary releases on dist.apache.org
> --
[
https://issues.apache.org/jira/browse/FLINK-33834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge resolved FLINK-33834.
-
Resolution: Fixed
> Build and stage Java and Python artifacts
>
[
https://issues.apache.org/jira/browse/FLINK-33836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33836:
Description:
The final step of building the candidate is to propose a website pull request
containing the
[
https://issues.apache.org/jira/browse/FLINK-33756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796939#comment-17796939
]
Jeyhun Karimov commented on FLINK-33756:
[~jhughes] Yes it is just printing/logg
[
https://issues.apache.org/jira/browse/FLINK-33756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796949#comment-17796949
]
Jim Hughes commented on FLINK-33756:
Hi [~jeyhunkarimov], I am not actively working
cuibo01 commented on PR #23924:
URL: https://github.com/apache/flink/pull/23924#issuecomment-1857131919
hi @luoyuxia Can you review the pr ? Thank you
--
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 g
[
https://issues.apache.org/jira/browse/FLINK-32862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hang Ruan closed FLINK-32862.
-
Resolution: Won't Fix
> Support INIT operation type to be compatible with DTS on Alibaba Cloud
> ---
1996fanrui commented on code in PR #726:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/726#discussion_r1427474826
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java:
##
@@ -219,6 +219,22 @@ private static ConfigOptions.Op
1996fanrui commented on code in PR #21635:
URL: https://github.com/apache/flink/pull/21635#discussion_r1427479694
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshot.java:
##
@@ -124,11 +124,40 @@ void readSnapshot(int readVersion, DataInputV
[
https://issues.apache.org/jira/browse/FLINK-33819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796977#comment-17796977
]
xiangyu feng commented on FLINK-33819:
--
+1 for this. This will save lots of cpu usa
xiangforever2014 commented on code in PR #23253:
URL: https://github.com/apache/flink/pull/23253#discussion_r1427483790
##
docs/content.zh/docs/deployment/cli.md:
##
@@ -125,6 +125,43 @@ Lastly, you can optionally provide what should be the
[binary format]({{< ref "d
The pat
1996fanrui commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1427486350
##
flink-autoscaler/pom.xml:
##
@@ -66,6 +66,12 @@ under the License.
jackson-databind
+
+org.quartz-sc
xiangforever2014 commented on code in PR #23253:
URL: https://github.com/apache/flink/pull/23253#discussion_r1427486664
##
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java:
##
@@ -188,6 +207,21 @@ CompletableFuture triggerSavepoint(
*/
Co
reswqa commented on code in PR #83:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/83#discussion_r1427487497
##
flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilderBaseTest.java:
##
@@ -99,7 +
reswqa commented on code in PR #83:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/83#discussion_r1427487497
##
flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilderBaseTest.java:
##
@@ -99,7 +
reswqa commented on code in PR #83:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/83#discussion_r1427487497
##
flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilderBaseTest.java:
##
@@ -99,7 +
reswqa commented on code in PR #83:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/83#discussion_r1427487497
##
flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilderBaseTest.java:
##
@@ -99,7 +
xiangforever2014 commented on code in PR #23253:
URL: https://github.com/apache/flink/pull/23253#discussion_r1427489342
##
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java:
##
@@ -164,6 +164,14 @@ public class CliFrontendParser {
[
https://issues.apache.org/jira/browse/FLINK-33449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796978#comment-17796978
]
xuyang commented on FLINK-33449:
Hi, [~leoyy] , thanks for your explanation.
After your
masteryhx commented on code in PR #21635:
URL: https://github.com/apache/flink/pull/21635#discussion_r1427497404
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshot.java:
##
@@ -124,11 +124,40 @@ void readSnapshot(int readVersion, DataInputVi
zhengzhili333 commented on PR #23880:
URL: https://github.com/apache/flink/pull/23880#issuecomment-1857188917
Thank you for your suggestion, I have modified that interface and also
corrected the point you mentioned earlier.
--
This is an automated message from the Apache Git Service.
To r
ruanhang1993 commented on PR #20:
URL:
https://github.com/apache/flink-connector-mongodb/pull/20#issuecomment-1857189111
@Jiabao-Sun Thanks for the quick reply.
I am not sure whether this PR is correct. It seems like every connector has
different settings for the CI to use the SNAPSHOT v
masteryhx commented on PR #21635:
URL: https://github.com/apache/flink/pull/21635#issuecomment-1857189693
> Hi @masteryhx , sorry for the late reply!
>
> After reading your PR, I finally figured out why the default
implementation of old method and new method should call each other. I
[
https://issues.apache.org/jira/browse/FLINK-32573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796980#comment-17796980
]
Jinsui Chen commented on FLINK-32573:
-
hi, [~Wencong Liu] . Would you please assign
tombentley opened a new pull request, #705:
URL: https://github.com/apache/flink-web/pull/705
(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
ruanhang1993 closed pull request #20: [hotfix] Test connector against Flink
1.16.2, 1.17.1, 1.18.0 instead of Flink SNAPSHOT version
URL: https://github.com/apache/flink-connector-mongodb/pull/20
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
ruanhang1993 commented on PR #20:
URL:
https://github.com/apache/flink-connector-mongodb/pull/20#issuecomment-1857208606
Hi, @Jiabao-Sun .
I think using all SNAPSHOT versions could help us to check the changes in
Flink. Let's keep the settings now. Close this PR.
--
This is an automat
KarmaGYZ commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1427513961
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolBridge.java:
##
@@ -200,10 +226,45 @@ protected void onReleaseTaskManager
ruanhang1993 opened a new pull request, #75:
URL: https://github.com/apache/flink-connector-kafka/pull/75
I find that some connectors(e.g. ES, mongodb, JDBC) are using the SNAPSHOT
flink versions for main branch in `weekly.yml`. I think this will help to check
changes in these version quick
xintongsong commented on code in PR #23870:
URL: https://github.com/apache/flink/pull/23870#discussion_r1427504078
##
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java:
##
@@ -173,6 +173,18 @@ public class TaskManagerOptions {
KarmaGYZ commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1427515551
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java:
##
@@ -127,7 +155,28 @@ public void increaseResourceRequire
KarmaGYZ commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1427515808
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java:
##
@@ -127,7 +155,28 @@ public void increaseResourceRequire
zhutong6688 commented on PR #23931:
URL: https://github.com/apache/flink/pull/23931#issuecomment-1857225538
@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 commen
boring-cyborg[bot] commented on PR #21:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/21#issuecomment-1857232953
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This
[
https://issues.apache.org/jira/browse/FLINK-33819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796992#comment-17796992
]
Hangxiang Yu commented on FLINK-33819:
--
Linked FLINK-20684 as it has been discussed
reswqa commented on PR #23910:
URL: https://github.com/apache/flink/pull/23910#issuecomment-1857249121
To be honest, I prefer to leave it as it is. Since I don't see much benefit,
this `1s` speed up doesn't necessarily show up in the CI environment, but it
does increase the instability of t
masteryhx commented on code in PR #23928:
URL: https://github.com/apache/flink/pull/23928#discussion_r1427533090
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlValueState.java:
##
@@ -48,7 +48,11 @@ public T value() throws IOException {
@Override
Zakelly commented on code in PR #23928:
URL: https://github.com/apache/flink/pull/23928#discussion_r1427540869
##
flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlValueStateTestContext.java:
##
@@ -21,14 +21,14 @@
import org.apache.flink.api.common.state.State;
1996fanrui commented on PR #23247:
URL: https://github.com/apache/flink/pull/23247#issuecomment-1857272908
Thanks everyone for the review, 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
1996fanrui merged PR #23247:
URL: https://github.com/apache/flink/pull/23247
--
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
Zakelly commented on PR #23928:
URL: https://github.com/apache/flink/pull/23928#issuecomment-1857273442
@masteryhx Thanks so much for your review! I have update my PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
[
https://issues.apache.org/jira/browse/FLINK-32895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-32895.
-
Fix Version/s: 1.19.0
Resolution: Fixed
> Introduce the max attempts for Exponential Delay Restar
[
https://issues.apache.org/jira/browse/FLINK-32895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17797017#comment-17797017
]
Rui Fan commented on FLINK-32895:
-
Merged to master(1.19) via :
1c7b10873be475b73d78a08
Yangze Guo created FLINK-33852:
--
Summary: FLIP-403 High Availability Services for OLAP Scenarios
Key: FLINK-33852
URL: https://issues.apache.org/jira/browse/FLINK-33852
Project: Flink
Issue Type
xuyangzhong commented on PR #23779:
URL: https://github.com/apache/flink/pull/23779#issuecomment-1857309968
Hi, @libenchao sorry for this noise. I have updated this pr to test
non-deterministic results about RAND and RAND_INTEGER. Could you have a look
again?
--
This is an automated mess
xuyangzhong commented on code in PR #19866:
URL: https://github.com/apache/flink/pull/19866#discussion_r1427570136
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/MultipleInputCreationTest.xml:
##
@@ -109,39 +109,6 @@ MultipleI
wanglijie95 commented on code in PR #23694:
URL: https://github.com/apache/flink/pull/23694#discussion_r1427580681
##
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/decorators/InitTaskManagerDecoratorTest.java:
##
@@ -282,12 +282,22 @@ void testNodeAffinit
flashJd commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1427581625
##
flink-autoscaler/pom.xml:
##
@@ -66,6 +66,12 @@ under the License.
jackson-databind
+
+org.quartz-sched
[
https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tongtong Zhu updated FLINK-33588:
-
Attachment: image-2023-12-15-13-59-28-201.png
> Fix Flink Checkpointing Statistics Bug
> ---
[
https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17797041#comment-17797041
]
Tongtong Zhu commented on FLINK-33588:
--
[~jingge] CI report is no problem is Succes
singhravidutt commented on PR #23489:
URL: https://github.com/apache/flink/pull/23489#issuecomment-1857360296
@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
leonardBang commented on PR #23604:
URL: https://github.com/apache/flink/pull/23604#issuecomment-1857368007
@reswqa Could you help review this PR?
--
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
leonardBang commented on PR #23590:
URL: https://github.com/apache/flink/pull/23590#issuecomment-1857368418
@dawidwys Would you like to help review this PR?
--
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
1996fanrui commented on code in PR #23922:
URL: https://github.com/apache/flink/pull/23922#discussion_r1427612626
##
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendConfigTest.java:
##
@@ -359,6 +361,50 @@
leonardBang merged PR #23607:
URL: https://github.com/apache/flink/pull/23607
--
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
[
https://issues.apache.org/jira/browse/FLINK-32850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779841#comment-17779841
]
Leonard Xu edited comment on FLINK-32850 at 12/15/23 6:58 AM:
1996fanrui commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1427526869
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java:
##
@@ -103,12 +106,35 @@ public class DefaultDeclarativeS
[
https://issues.apache.org/jira/browse/FLINK-33450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33450:
Description: Design doc:
https://docs.google.com/document/d/1lE4s3ZAyCfzYT4dNOVarz5dIctQ8UUAVqjPKlQ1XU1c/e
[
https://issues.apache.org/jira/browse/FLINK-33853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33853:
---
Summary: [JUnit5 Migration] Migrate Junit5 for DefaultDeclarativeSlotPool
test classes of runtime mo
RocMarshal created FLINK-33853:
--
Summary: Migrate Junit5 for DefaultDeclarativeSlotPool test classes
Key: FLINK-33853
URL: https://issues.apache.org/jira/browse/FLINK-33853
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-33853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33853:
---
Summary: [JUnit5 Migration] Migrate Junit5 for DeclarativeSlotPoolBridge
test classes of runtime mod
RocMarshal opened a new pull request, #23932:
URL: https://github.com/apache/flink/pull/23932
## What is the purpose of the change
[FLINK-33853][runtime][JUnit5 Migration] Migrate Junit5 for
DeclarativeSlotPoolBridge test classes of runtime module
## Brief chang
xuyangzhong commented on PR #19866:
URL: https://github.com/apache/flink/pull/19866#issuecomment-1857405822
Hi, @lsyldliu. I rebased the master. Could you have a look again?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-33853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33853:
---
Labels: pull-request-available (was: )
> [JUnit5 Migration] Migrate Junit5 for DeclarativeS
flinkbot commented on PR #23932:
URL: https://github.com/apache/flink/pull/23932#issuecomment-1857412172
## CI report:
* bd328df2d2f1dea0cbe121e16a83734451e19306 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
201 - 280 of 280 matches
Mail list logo