ramkrish86 commented on code in PR #24896:
URL: https://github.com/apache/flink/pull/24896#discussion_r1634237585
##
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/BaseHadoopFsRecoverableFsDataOutputStream.java:
##
@@ -59,7 +59,7 @@ public void
cxzl25 commented on PR #24896:
URL: https://github.com/apache/flink/pull/24896#issuecomment-2159856148
> The commit message is not yet update
Sorry, it's updated now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
superdiaodiao commented on PR #24773:
URL: https://github.com/apache/flink/pull/24773#issuecomment-2159830832
> hi @snuyanzin @superdiaodiao do we need supports encoding args ?
> db2
https://www.ibm.com/docs/en/db2-for-zos/12?topic=functions-urlencode-urldecode
> max compute
[
https://issues.apache.org/jira/browse/FLINK-26951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853901#comment-17853901
]
Kartikey Pant commented on FLINK-26951:
---
Hey [~lincoln.86xy], can you please assign this issue to
[
https://issues.apache.org/jira/browse/FLINK-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853900#comment-17853900
]
Kartikey Pant commented on FLINK-12450:
---
Hey [~taoran]/[~jark], could you please confirm if this
xintongsong commented on PR #24896:
URL: https://github.com/apache/flink/pull/24896#issuecomment-2159816793
> Thanks, I've updated.
The commit message is not yet update. Have you forgot to push the changes?
--
This is an automated message from the Apache Git Service.
To respond
liuyongvs commented on PR #24773:
URL: https://github.com/apache/flink/pull/24773#issuecomment-2159808362
hi @snuyanzin @superdiaodiao do we need supports encoding args ?
db2
https://www.ibm.com/docs/en/db2-for-zos/12?topic=functions-urlencode-urldecode
max compute
ammar-master commented on PR #24919:
URL: https://github.com/apache/flink/pull/24919#issuecomment-2159778519
@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
ammar-master commented on code in PR #24919:
URL: https://github.com/apache/flink/pull/24919#discussion_r1634155084
##
flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/pekko/CustomSSLEngineProvider.java:
##
@@ -59,13 +71,38 @@ public TrustManager[]
ammar-master commented on code in PR #24919:
URL: https://github.com/apache/flink/pull/24919#discussion_r1634154163
##
flink-runtime/src/test/java/org/apache/flink/runtime/net/SSLUtilsTest.java:
##
@@ -148,6 +148,17 @@ void testRESTClientSSLWrongPassword(String sslProvider) {
ammar-master commented on code in PR #24919:
URL: https://github.com/apache/flink/pull/24919#discussion_r1634153986
##
flink-runtime/src/test/java/org/apache/flink/runtime/net/SSLUtilsTest.java:
##
@@ -306,6 +341,19 @@ void testInternalSSLWrongKeyPassword(String sslProvider) {
[
https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853894#comment-17853894
]
Weijie Guo commented on FLINK-18476:
[
https://issues.apache.org/jira/browse/FLINK-34914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853893#comment-17853893
]
Weijie Guo commented on FLINK-34914:
Hi [~liyubin117] and [~qingyue].
FYI: We expect the feature
yuxiqian commented on code in PR #3398:
URL: https://github.com/apache/flink-cdc/pull/3398#discussion_r1634142791
##
flink-cdc-dist/src/main/flink-cdc-bin/bin/flink-cdc.sh:
##
@@ -34,11 +34,11 @@ if [[ -z $FLINK_HOME ]]; then
exit 1
fi
-# Setup Flink related
[
https://issues.apache.org/jira/browse/FLINK-35563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35563:
---
Description:
{code:java}
Jun 08 01:52:28 deployment.apps "flink-native-k8s-application-1" deleted
Weijie Guo created FLINK-35563:
--
Summary: 'Run kubernetes application test' failed on AZP
Key: FLINK-35563
URL: https://issues.apache.org/jira/browse/FLINK-35563
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853888#comment-17853888
]
Weijie Guo commented on FLINK-18476:
test_cron_jdk21 misc
Weijie Guo created FLINK-35562:
--
Summary: WindowTableFunctionProcTimeRestoreTest produced no output
for 900 seconds
Key: FLINK-35562
URL: https://issues.apache.org/jira/browse/FLINK-35562
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35562:
---
Description:
ljz2051 commented on code in PR #24873:
URL: https://github.com/apache/flink/pull/24873#discussion_r1634123958
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/SnapshotFileMergingCompatibilityITCase.java:
##
@@ -0,0 +1,126 @@
+/*
+ * Licensed to the Apache
wenbingshen commented on code in PR #827:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/827#discussion_r1634118107
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java:
##
@@ -247,17 +249,36 @@ protected JobTopology
cxzl25 commented on PR #24896:
URL: https://github.com/apache/flink/pull/24896#issuecomment-2159691770
Gentle ping @xintongsong
--
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
wenbingshen commented on code in PR #827:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/827#discussion_r1634091321
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java:
##
@@ -247,17 +249,36 @@ protected JobTopology
gong commented on PR #3407:
URL: https://github.com/apache/flink-cdc/pull/3407#issuecomment-2159661569
@leonardBang PTAL
--
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
gong commented on PR #3207:
URL: https://github.com/apache/flink-cdc/pull/3207#issuecomment-2159656572
> @gong would you like to open a PR for release-3.1 branch?
ok, I will open the PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
reswqa commented on code in PR #24845:
URL: https://github.com/apache/flink/pull/24845#discussion_r1634076649
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/SetSerializer.java:
##
@@ -0,0 +1,168 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
reswqa commented on code in PR #24845:
URL: https://github.com/apache/flink/pull/24845#discussion_r1634061063
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/SetSerializer.java:
##
@@ -0,0 +1,168 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
1996fanrui commented on code in PR #827:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/827#discussion_r1634051534
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java:
##
@@ -247,17 +249,36 @@ protected JobTopology
[
https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853858#comment-17853858
]
Rui Fan commented on FLINK-35489:
-
Merged to main(1.9.0) via: c3e94aec0c6f081a99b7467bd0bcee551b841600
[
https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-35489:
---
Assignee: Nicolas Fraison
> Metaspace size can be too little after autotuning change memory
[
https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35489.
-
Fix Version/s: kubernetes-operator-1.9.0
Resolution: Fixed
> Metaspace size can be too little
1996fanrui merged PR #833:
URL: https://github.com/apache/flink-kubernetes-operator/pull/833
--
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:
1996fanrui commented on PR #833:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/833#issuecomment-2159610745
Thanks @ashangit for the fix and everyone for the review!
Merging~
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-35557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853850#comment-17853850
]
Xintong Song edited comment on FLINK-35557 at 6/11/24 1:26 AM:
---
I think
[
https://issues.apache.org/jira/browse/FLINK-35557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853850#comment-17853850
]
Xintong Song commented on FLINK-35557:
--
I think this is by design. As suggested by the name, the
ammar-master commented on code in PR #24919:
URL: https://github.com/apache/flink/pull/24919#discussion_r1634004521
##
docs/layouts/shortcodes/generated/security_configuration.html:
##
@@ -134,6 +134,12 @@
String
The secret to decrypt the keystore file
ammar-master commented on code in PR #24919:
URL: https://github.com/apache/flink/pull/24919#discussion_r1633910473
##
docs/layouts/shortcodes/generated/security_configuration.html:
##
@@ -134,6 +134,12 @@
String
The secret to decrypt the keystore file
morazow commented on PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#issuecomment-2159296755
Thanks @dongwoo6kim ,
Tests looks good from my side
(_Recently I faced similar issue which maybe related, when running batch
mode with setting
nicusX commented on PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#issuecomment-2159216321
I moved the example application under tests and removed the separate module
completely.
I added links to the example application in the README.
--
This is an automated
nicusX commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1633781977
##
README.md:
##
@@ -8,6 +8,14 @@ Apache Flink is an open source stream processing framework
with powerful stream-
Learn more about Flink at
[
https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853754#comment-17853754
]
Robert Metzger commented on FLINK-30400:
The problem of marking flink-connector-base provided
[
https://issues.apache.org/jira/browse/FLINK-35559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksandr Pilipenko updated FLINK-35559:
Priority: Blocker (was: Major)
> Shading issue cause class conflict
>
[
https://issues.apache.org/jira/browse/FLINK-35445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853734#comment-17853734
]
Ahmed Hamdy commented on FLINK-35445:
-
As discussed offline, there is no docs for Asyncsink, hence
[
https://issues.apache.org/jira/browse/FLINK-35445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ahmed Hamdy closed FLINK-35445.
---
Resolution: Not A Problem
> Update Async Sink documentation for Timeout configuration
>
[
https://issues.apache.org/jira/browse/FLINK-35140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853733#comment-17853733
]
Sergey Nuyanzin commented on FLINK-35140:
-
Need for PMC help as mentioned at
[
https://issues.apache.org/jira/browse/FLINK-35140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853733#comment-17853733
]
Sergey Nuyanzin edited comment on FLINK-35140 at 6/10/24 4:43 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-35140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-35140:
---
Assignee: Sergey Nuyanzin (was: Sergey Nuyanzin)
> Release
z3d1k commented on PR #142:
URL:
https://github.com/apache/flink-connector-aws/pull/142#issuecomment-2158839029
> There is a risk this will break user code depending on these libs, right?
Given this is a bug, and they should not be using the shaded libs, I think this
is ok, thoughts?
Shyam created FLINK-35561:
-
Summary: Flink REST API incorrect documentation
Key: FLINK-35561
URL: https://issues.apache.org/jira/browse/FLINK-35561
Project: Flink
Issue Type: Bug
dannycranmer commented on PR #136:
URL:
https://github.com/apache/flink-connector-aws/pull/136#issuecomment-2158683163
@hlteoh37 / @z3d1k can you please take a look at this one too?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
dannycranmer commented on code in PR #136:
URL:
https://github.com/apache/flink-connector-aws/pull/136#discussion_r1633458080
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DefaultDynamoDbElementConverter.java:
##
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853713#comment-17853713
]
Danny Cranmer commented on FLINK-35435:
---
Merged commit
[
https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-35435.
---
Resolution: Done
> [FLIP-451] Introduce timeout configuration to AsyncSink
>
[
https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35435:
-
Assignee: Ahmed Hamdy
> [FLIP-451] Introduce timeout configuration to AsyncSink
>
dannycranmer merged PR #24839:
URL: https://github.com/apache/flink/pull/24839
--
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:
dannycranmer commented on PR #142:
URL:
https://github.com/apache/flink-connector-aws/pull/142#issuecomment-2158665814
There is a risk this will break user code depending on these libs, right?
Given this is a bug, and they should not be using the shaded libs, I think this
is ok, thoughts?
[
https://issues.apache.org/jira/browse/FLINK-35559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35559:
-
Assignee: Aleksandr Pilipenko
> Shading issue cause class conflict
>
lincoln-lil commented on code in PR #24889:
URL: https://github.com/apache/flink/pull/24889#discussion_r164828
##
docs/layouts/shortcodes/generated/optimizer_config_configuration.html:
##
@@ -65,6 +71,12 @@
Enum
When it is `TRY_RESOLVE`, the
ferenc-csaky commented on code in PR #24914:
URL: https://github.com/apache/flink/pull/24914#discussion_r1633282273
##
flink-connectors/flink-file-sink-common/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/OutputStreamBasedPartFileWriter.java:
##
@@
z3d1k commented on code in PR #142:
URL:
https://github.com/apache/flink-connector-aws/pull/142#discussion_r1633275869
##
flink-connector-aws/flink-connector-kinesis/pom.xml:
##
@@ -354,6 +354,12 @@ under the License.
hlteoh37 commented on code in PR #142:
URL:
https://github.com/apache/flink-connector-aws/pull/142#discussion_r1633262253
##
flink-connector-aws/flink-connector-kinesis/pom.xml:
##
@@ -354,6 +354,12 @@ under the License.
gaborgsomogyi commented on code in PR #24914:
URL: https://github.com/apache/flink/pull/24914#discussion_r1633243846
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/operator/CompactService.java:
##
@@ -154,23 +158,27 @@
pnowojski commented on code in PR #24904:
URL: https://github.com/apache/flink/pull/24904#discussion_r1633225150
##
docs/layouts/shortcodes/generated/execution_checkpointing_configuration.html:
##
Review Comment:
fixed
--
This is an automated message from the Apache
flinkbot commented on PR #24920:
URL: https://github.com/apache/flink/pull/24920#issuecomment-2158287262
## CI report:
* 97c210a011dd34e0c19deffe746cb3e88b355ce2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
WencongLiu opened a new pull request, #24920:
URL: https://github.com/apache/flink/pull/24920
## What is the purpose of the change
_Support custom shuffle for lookup join_
## Verifying this change
UT and ITs.
## Does this pull request potentially affect one of the
gaborgsomogyi commented on PR #24891:
URL: https://github.com/apache/flink/pull/24891#issuecomment-2158262913
@wForget thanks for your efforts!
--
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
[
https://issues.apache.org/jira/browse/FLINK-35525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-35525.
-
> HDFS delegation token fetched by custom DelegationTokenProvider is not
> passed to Yarn AM
>
[
https://issues.apache.org/jira/browse/FLINK-35525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-35525.
---
Fix Version/s: 1.20.0
Resolution: Fixed
74b100b on master
> HDFS delegation token
gaborgsomogyi merged PR #24891:
URL: https://github.com/apache/flink/pull/24891
--
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:
ashangit commented on PR #833:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/833#issuecomment-2158258410
Updated the PR to take in account this
[
https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853647#comment-17853647
]
Nicolas Fraison commented on FLINK-35489:
-
Thks [~mxm] for the feedback. I've updated the
rkhachatryan commented on code in PR #24904:
URL: https://github.com/apache/flink/pull/24904#discussion_r1633189008
##
docs/layouts/shortcodes/generated/execution_checkpointing_configuration.html:
##
Review Comment:
I guess a leftover and should be removed?
--
This is
rkhachatryan commented on code in PR #24904:
URL: https://github.com/apache/flink/pull/24904#discussion_r1633189008
##
docs/layouts/shortcodes/generated/execution_checkpointing_configuration.html:
##
Review Comment:
I guess this file is a leftover and should be removed?
gaborgsomogyi commented on code in PR #24919:
URL: https://github.com/apache/flink/pull/24919#discussion_r1633123484
##
flink-runtime/src/test/java/org/apache/flink/runtime/net/SSLUtilsTest.java:
##
@@ -148,6 +148,17 @@ void testRESTClientSSLWrongPassword(String sslProvider) {
rkhachatryan commented on code in PR #24904:
URL: https://github.com/apache/flink/pull/24904#discussion_r1633185416
##
flink-core/src/main/java/org/apache/flink/api/common/operators/MailOptionsImpl.java:
##
@@ -0,0 +1,38 @@
+/*
+ * Licensed to the Apache Software Foundation
pnowojski commented on code in PR #24904:
URL: https://github.com/apache/flink/pull/24904#discussion_r1633182865
##
flink-core/src/main/java/org/apache/flink/api/common/operators/MailOptionsImpl.java:
##
@@ -0,0 +1,38 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/FLINK-35542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Gurda updated FLINK-35542:
--
Affects Version/s: jdbc-3.2.0
> ClassNotFoundException when deserializing CheckpointedOffset
>
rkhachatryan commented on code in PR #24904:
URL: https://github.com/apache/flink/pull/24904#discussion_r1633159087
##
flink-core/src/main/java/org/apache/flink/api/common/operators/MailboxExecutor.java:
##
@@ -86,6 +87,25 @@ public interface MailboxExecutor {
/** A
rkhachatryan commented on code in PR #24904:
URL: https://github.com/apache/flink/pull/24904#discussion_r1633154332
##
flink-core/src/main/java/org/apache/flink/api/common/operators/MailOptionsImpl.java:
##
@@ -0,0 +1,38 @@
+/*
+ * Licensed to the Apache Software Foundation
wForget commented on PR #24891:
URL: https://github.com/apache/flink/pull/24891#issuecomment-2158200824
> Just seen the error in the pipeline, plz fix it:
Thanks @gaborgsomogyi ,I have updated document and CI passed.
--
This is an automated message from the Apache Git Service.
To
gaborgsomogyi commented on PR #24919:
URL: https://github.com/apache/flink/pull/24919#issuecomment-2158109164
Please have a look at the failing test:
```
Jun 10 07:17:02 07:17:02.965 [INFO] Running
org.apache.flink.docs.configuration.ConfigOptionsDocsCompletenessITCase
Jun 10
hlteoh37 commented on PR #745:
URL: https://github.com/apache/flink-web/pull/745#issuecomment-2158002413
Thanks @1996fanrui - great comments! I've addressed them.
I've removed the below JIRAs from the release notes as they related to build
infrastructure:
### Subtask
-
hlteoh37 commented on code in PR #745:
URL: https://github.com/apache/flink-web/pull/745#discussion_r1633036672
##
docs/content/posts/2024-06-14-release-1.19.1.md:
##
@@ -0,0 +1,171 @@
+---
+title: "Apache Flink 1.19.1 Release Announcement"
+date: "2024-06-14T00:00:00.000Z"
hlteoh37 commented on code in PR #745:
URL: https://github.com/apache/flink-web/pull/745#discussion_r1633022942
##
docs/content/posts/2024-06-14-release-1.19.1.md:
##
@@ -0,0 +1,171 @@
+---
+title: "Apache Flink 1.19.1 Release Announcement"
+date: "2024-06-14T00:00:00.000Z"
hlteoh37 commented on code in PR #745:
URL: https://github.com/apache/flink-web/pull/745#discussion_r1633022433
##
docs/content/posts/2024-06-14-release-1.19.1.md:
##
@@ -0,0 +1,171 @@
+---
+title: "Apache Flink 1.19.1 Release Announcement"
+date: "2024-06-14T00:00:00.000Z"
[
https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853606#comment-17853606
]
Maximilian Michels commented on FLINK-35489:
Hey [~ashangit]! Good idea to switch the order
gyfora commented on code in PR #827:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/827#discussion_r1632931104
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java:
##
@@ -247,17 +249,36 @@ protected JobTopology
pnowojski commented on code in PR #24904:
URL: https://github.com/apache/flink/pull/24904#discussion_r1632887041
##
flink-core/src/main/java/org/apache/flink/api/common/operators/MailboxExecutor.java:
##
@@ -86,6 +87,25 @@ public interface MailboxExecutor {
/** A constant
[
https://issues.apache.org/jira/browse/FLINK-35556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853589#comment-17853589
]
Hong Liang Teoh commented on FLINK-35556:
-
Changing fix version to 1.19.2
> Wrong constant in
[
https://issues.apache.org/jira/browse/FLINK-35557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-35557:
Fix Version/s: 1.19.2
(was: 1.19.1)
> MemoryManager only reserves
[
https://issues.apache.org/jira/browse/FLINK-35557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853588#comment-17853588
]
Hong Liang Teoh commented on FLINK-35557:
-
Changing this to 1.19.2 release as this is a
[
https://issues.apache.org/jira/browse/FLINK-35556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-35556:
Fix Version/s: 1.19.2
(was: 1.19.1)
> Wrong constant in
[
https://issues.apache.org/jira/browse/FLINK-34633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-34633:
Fix Version/s: 1.20.0
(was: 1.19.1)
> Support unnesting array
[
https://issues.apache.org/jira/browse/FLINK-34633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853587#comment-17853587
]
Hong Liang Teoh commented on FLINK-34633:
-
Thanks for checking. Will remove the PR from the
pnowojski commented on code in PR #24904:
URL: https://github.com/apache/flink/pull/24904#discussion_r1632838546
##
flink-core/src/main/java/org/apache/flink/api/common/operators/MailboxExecutor.java:
##
@@ -86,6 +87,25 @@ public interface MailboxExecutor {
/** A constant
z3d1k commented on code in PR #142:
URL:
https://github.com/apache/flink-connector-aws/pull/142#discussion_r1632814622
##
flink-connector-aws/flink-connector-kinesis/pom.xml:
##
@@ -354,6 +354,12 @@ under the License.
foxus commented on code in PR #142:
URL:
https://github.com/apache/flink-connector-aws/pull/142#discussion_r1632803808
##
flink-connector-aws/flink-connector-kinesis/pom.xml:
##
@@ -354,6 +354,12 @@ under the License.
pnowojski commented on code in PR #24895:
URL: https://github.com/apache/flink/pull/24895#discussion_r1632799682
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceImpl.java:
##
@@ -307,18 +307,36 @@ void onProcessingTime(long
gaborgsomogyi commented on PR #24919:
URL: https://github.com/apache/flink/pull/24919#issuecomment-2157658542
@ammar-master thanks for this PR, looks quality code from first glance
perspective. I'm going to shepherd it this week...
--
This is an automated message from the Apache Git
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1632777604
##
README.md:
##
@@ -8,6 +8,14 @@ Apache Flink is an open source stream processing framework
with powerful stream-
Learn more about Flink at
1 - 100 of 107 matches
Mail list logo
