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?
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 a
[
https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853647#comment-17853647
]
Nicolas Fraison commented on FLINK-35489:
-
Thks [~mxm] for the feedback. I've up
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
[comment](https://issues.apache.org/jira/browse/FLINK-35489?focusedCommentId=17853606&page=com.atlassian.jira.plugin.system.issueta
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: issues-unsubscr...@flink
[
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 f
[
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
> ---
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 the
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
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`
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 Git
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 @@ priv
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.
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.
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:
##
@@ -50,7
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 optimiz
[
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
> --
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?
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: issues-unsubscr...@flink.
[
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
> -
[
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:comment-tabpanel&focusedCommentId=17853713#comment-17853713
]
Danny Cranmer commented on FLINK-35435:
---
Merged commit
[{{c9def98}}|https://githu
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
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 t
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
Components
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?
[
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 flink-connector-opensea
[
https://issues.apache.org/jira/browse/FLINK-35140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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:comment-tabpanel&focusedCommentId=17853733#comment-17853733
]
Sergey Nuyanzin commented on FLINK-35140:
-
Need for PMC help as mentioned at
ht
[
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-35445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853734#comment-17853734
]
Ahmed Hamdy commented on FLINK-35445:
-
As discussed offline, there is no docs for As
[
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-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853754#comment-17853754
]
Robert Metzger commented on FLINK-30400:
The problem of marking flink-connector-
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://
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 m
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 `startingOffset
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
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
[
https://issues.apache.org/jira/browse/FLINK-35557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853850#comment-17853850
]
Xintong Song commented on FLINK-35557:
--
I think this is by design. As suggested by
[
https://issues.apache.org/jira/browse/FLINK-35557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853850#comment-17853850
]
Xintong Song edited comment on FLINK-35557 at 6/11/24 1:26 AM:
---
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, plea
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: issues-unsu
[
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 aft
[
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 setting
[
https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853858#comment-17853858
]
Rui Fan commented on FLINK-35489:
-
Merged to main(1.9.0) via: c3e94aec0c6f081a99b7467bd0
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 getJobTopo
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)
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)
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 l
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
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 getJobTop
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 comme
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 getJobTop
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 Softwa
[
https://issues.apache.org/jira/browse/FLINK-35562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35562:
---
Description:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=60172&view=logs&
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-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853888#comment-17853888
]
Weijie Guo commented on FLINK-18476:
test_cron_jdk21 misc
https://dev.azure.com/apa
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-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
Ju
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 configurations
[
https://issues.apache.org/jira/browse/FLINK-34914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853893#comment-17853893
]
Weijie Guo commented on FLINK-34914:
Hi [~liyubin117] and [~qingyue].
FYI: We expec
[
https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853894#comment-17853894
]
Weijie Guo commented on FLINK-18476:
https://dev.azure.com/apache-flink/apache-flink
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) {
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_r1634155084
##
flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/pekko/CustomSSLEngineProvider.java:
##
@@ -59,13 +71,38 @@ public TrustManager[] trustManage
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 comme
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
https://www.alibaba
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
[
https://issues.apache.org/jira/browse/FLINK-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853900#comment-17853900
]
Kartikey Pant commented on FLINK-12450:
---
Hey [~taoran]/[~jark], could you please c
[
https://issues.apache.org/jira/browse/FLINK-26951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853901#comment-17853901
]
Kartikey Pant commented on FLINK-26951:
---
Hey [~lincoln.86xy], can you please assig
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://w
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
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
reswqa commented on code in PR #24900:
URL: https://github.com/apache/flink/pull/24900#discussion_r1634238153
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageConsumerClient.java:
##
@@ -148,12 +162,52 @@ public void
gyfora commented on code in PR #827:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/827#discussion_r1634247827
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java:
##
@@ -247,17 +249,36 @@ protected JobTopology getJobTopology
gyfora merged PR #827:
URL: https://github.com/apache/flink-kubernetes-operator/pull/827
--
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
X-czh commented on PR #24845:
URL: https://github.com/apache/flink/pull/24845#issuecomment-2159873214
rebased
--
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
[
https://issues.apache.org/jira/browse/FLINK-35328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-35328.
--
Fix Version/s: kubernetes-operator-1.9.0
Assignee: Wenbing Shen
Resolution: Fixed
merg
[
https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853908#comment-17853908
]
Hang Ruan commented on FLINK-30400:
---
[~rmetzger] ,Thanks for the suggestion.
I will w
gyfora merged PR #831:
URL: https://github.com/apache/flink-kubernetes-operator/pull/831
--
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
[
https://issues.apache.org/jira/browse/FLINK-35052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-35052.
--
Fix Version/s: kubernetes-operator-1.9.0
Resolution: Fixed
merged to main ebd720329eeea983ce4ec
gyfora closed pull request #737: Adding affinity rule.
URL: https://github.com/apache/flink-kubernetes-operator/pull/737
--
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 unsu
gyfora commented on PR #737:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/737#issuecomment-2159881613
I am closing this PR due to inactivity, please re-open if you pick it up
again
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
wenbingshen commented on code in PR #827:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/827#discussion_r1634261181
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java:
##
@@ -247,17 +249,36 @@ protected JobTopology getJobTop
xintongsong commented on PR #24896:
URL: https://github.com/apache/flink/pull/24896#issuecomment-2159897218
Thanks, @cxzl25. 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 the specific
xintongsong closed pull request #24896: [FLINK-35531] Avoid calling hsync in
flush method in BaseHadoopFsRecoverableFsDataOutputStream
URL: https://github.com/apache/flink/pull/24896
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
[
https://issues.apache.org/jira/browse/FLINK-35531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-35531.
Fix Version/s: 1.18.2
1.20.0
1.19.2
Assignee: dzcxzl
gyfora merged PR #829:
URL: https://github.com/apache/flink-kubernetes-operator/pull/829
--
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
Zakelly commented on code in PR #24895:
URL: https://github.com/apache/flink/pull/24895#discussion_r1634298332
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceImpl.java:
##
@@ -307,18 +307,37 @@ void onProcessingTime(long time)
gyfora commented on code in PR #834:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/834#discussion_r1632739981
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/reconciler/ReconciliationMetadata.java:
##
@@ -35,19 +34,15 @@ p
gaborgsomogyi commented on PR #24891:
URL: https://github.com/apache/flink/pull/24891#issuecomment-2157579431
Just seen the error in the pipeline, plz fix it:
```
Jun 06 10:28:18 10:28:18.128 [INFO] Running
org.apache.flink.docs.configuration.ConfigOptionsDocsCompletenessITCase
Jun
hlteoh37 commented on code in PR #142:
URL:
https://github.com/apache/flink-connector-aws/pull/142#discussion_r1632760932
##
flink-connector-aws/flink-connector-kinesis/pom.xml:
##
@@ -354,6 +354,12 @@ under the License.
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
[https:
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 Servi
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 time
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.
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.
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 f
[
https://issues.apache.org/jira/browse/FLINK-34633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853587#comment-17853587
]
Hong Liang Teoh commented on FLINK-34633:
-
Thanks for checking. Will remove the
[
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 const
1 - 100 of 119 matches
Mail list logo
