[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789356#comment-17789356
]
Weijie Guo edited comment on FLINK-25857 at 11/24/23 7:53 AM:
[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789356#comment-17789356
]
Weijie Guo commented on FLINK-25857:
Thanks [~pvary] for the quick reply!
Yes, In
[
https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789355#comment-17789355
]
Rui Fan commented on FLINK-27681:
-
{quote}In our production, the underlying environment
1996fanrui commented on code in PR #23765:
URL: https://github.com/apache/flink/pull/23765#discussion_r1404014532
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java:
##
@@ -86,6 +86,18 @@ public class Roc
flinkbot commented on PR #23789:
URL: https://github.com/apache/flink/pull/23789#issuecomment-1825239372
## CI report:
* 30acb658f852496d73028b93467c024f3f4d43a0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-33613:
---
Assignee: Dian Fu
> Python UDF Runner process leak in Process Mode
> --
[
https://issues.apache.org/jira/browse/FLINK-33613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33613:
---
Labels: pull-request-available (was: )
> Python UDF Runner process leak in Process Mode
> -
dianfu opened a new pull request, #23789:
URL: https://github.com/apache/flink/pull/23789
## What is the purpose of the change
*This pull request fix the issue that the Java gRPC server was not shutdown
properly during job cancelling which may cause the Python process not shutdown
flinkbot commented on PR #23788:
URL: https://github.com/apache/flink/pull/23788#issuecomment-1825226910
## CI report:
* cfb92fb619cfdbaa4b610d4c95dae57922afec18 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789347#comment-17789347
]
Yun Tang commented on FLINK-31385:
--
Also picked in release-1.17 2a83c910eee711f8b5f9dd4
hehuiyuan opened a new pull request, #23788:
URL: https://github.com/apache/flink/pull/23788
## What is the purpose of the change
![image](https://github.com/apache/flink/assets/18002496/9e1e478b-84ac-4930-9a42-6bb91616a3f2)
https://nightlies.apache.org/flink/flink-docs-re
[
https://issues.apache.org/jira/browse/FLINK-31385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-31385:
-
Fix Version/s: 1.17.3
> Introduce extended Assertj Matchers for completable futures
> --
[
https://issues.apache.org/jira/browse/FLINK-33598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-33598.
--
Resolution: Fixed
Merged
master: 608546e090f5d41c6a8b9af2c264467279181027 ...
b7e8b792c086c3c445ee842
[
https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789345#comment-17789345
]
Yue Ma commented on FLINK-8:
[~pnowojski] Update: Now All the changes we need are r
[
https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789345#comment-17789345
]
Yue Ma edited comment on FLINK-8 at 11/24/23 6:49 AM:
--
[~pn
[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789335#comment-17789335
]
Peter Vary commented on FLINK-25857:
For the Iceberg connector we release separate v
[
https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789334#comment-17789334
]
Benchao Li commented on FLINK-33541:
There is no such usage: "RAND(a, 10) and RAND(b
[
https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789330#comment-17789330
]
xuyang commented on FLINK-33541:
Hi, [~libenchao] , I checked the code again and sorry f
[
https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuyang updated FLINK-33541:
---
Attachment: image-2023-11-24-13-31-21-209.png
> RAND_INTEGER can't be existed in a IF statement
> -
[
https://issues.apache.org/jira/browse/FLINK-33565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789329#comment-17789329
]
Rui Fan commented on FLINK-33565:
-
Give some background here:
[FLIP-364|https://cwiki.a
[
https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789326#comment-17789326
]
Benchao Li commented on FLINK-33490:
I agree mostly, I don't have a strong opinion w
[
https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789325#comment-17789325
]
Benchao Li commented on FLINK-33541:
{quote}I notice currently the CAST rule is corr
[
https://issues.apache.org/jira/browse/FLINK-33624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge resolved FLINK-33624.
-
Resolution: Fixed
> Bump Guava to 32.1.3-jre in flink-table
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-33624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789324#comment-17789324
]
Jing Ge commented on FLINK-33624:
-
master: 34620fc5c5698d00e64c6b15f8ce84f807a2e0d7
> B
[
https://issues.apache.org/jira/browse/FLINK-33547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui closed FLINK-33547.
---
Resolution: Duplicate
Duplicated with https://issues.apache.org/jira/browse/FLINK-33523
> SQL primi
[
https://issues.apache.org/jira/browse/FLINK-33547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789319#comment-17789319
]
Xingcan Cui commented on FLINK-33547:
-
Sure. I'll close this.
> SQL primitive array
[
https://issues.apache.org/jira/browse/FLINK-33547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789317#comment-17789317
]
Prabhu Joseph commented on FLINK-33547:
---
[~xccui] Thanks for the details. This is
[
https://issues.apache.org/jira/browse/FLINK-33523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789316#comment-17789316
]
Prabhu Joseph commented on FLINK-33523:
---
Thanks [~jeyhun]. Flink 1.17 does not hav
PrabhuJoseph commented on PR #23629:
URL: https://github.com/apache/flink/pull/23629#issuecomment-1825118817
@1996fanrui Could you help in committing this change. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789000#comment-17789000
]
zhengzhili edited comment on FLINK-33472 at 11/24/23 3:40 AM:
[
https://issues.apache.org/jira/browse/FLINK-33547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789311#comment-17789311
]
Xingcan Cui commented on FLINK-33547:
-
Hi [~jeyhun] , thanks for your attention!
Wh
mayuehappy commented on PR #23765:
URL: https://github.com/apache/flink/pull/23765#issuecomment-1825104163
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment
mayuehappy commented on PR #23765:
URL: https://github.com/apache/flink/pull/23765#issuecomment-1825103757
@masteryhx Thanks for the code review , I have updated the MR , PTAL
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789304#comment-17789304
]
Weijie Guo commented on FLINK-25857:
IIUC, this will cause our external connector si
[
https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-33635:
---
Priority: Blocker (was: Major)
> Some connectors can not compile in 1.19-SNAPSHOT
> ---
Rui Fan created FLINK-33636:
---
Summary: Implement JdbcAutoScalerEventHandler
Key: FLINK-33636
URL: https://issues.apache.org/jira/browse/FLINK-33636
Project: Flink
Issue Type: Sub-task
Com
[
https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789301#comment-17789301
]
Jiabao Sun commented on FLINK-33635:
mongodb:
https://github.com/apache/flink-conne
flinkbot commented on PR #23787:
URL: https://github.com/apache/flink/pull/23787#issuecomment-1825089599
## CI report:
* ebda3f5e2e64929e223823778ca6626435eed26b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789300#comment-17789300
]
Yuxin Tan commented on FLINK-33635:
---
The failed reason is that the APIs are changed by
[
https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-33635:
---
Description:
The sink API compatibility was broken in FLINK-25857.
org.apache.flink.api.connector.
[
https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-33635:
---
Summary: Some connectors can not compile in 1.19-SNAPSHOT (was: Some
connector can not compile in 1
JunRuiLee commented on code in PR #23758:
URL: https://github.com/apache/flink/pull/23758#discussion_r1403852951
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java:
##
@@ -676,8 +690,16 @@ public StreamExecutionEnviro
JunRuiLee commented on PR #23758:
URL: https://github.com/apache/flink/pull/23758#issuecomment-1825087740
Hi @zhuzhurk, Thanks for your review. I've updated this PR, PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
JingGe opened a new pull request, #23787:
URL: https://github.com/apache/flink/pull/23787
## What is the purpose of the change
Add the externalized connector repos into the doc to ease developer find the
related connectors.
## Verifying this change
This change is a trivi
[
https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-33635:
---
Component/s: Connectors / Common
(was: Connectors / ElasticSearch)
> Some conne
[
https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-33635:
---
Summary: Some connector can not compile in 1.19-SNAPSHOT (was: Connector
sink can not compile)
> S
[
https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789299#comment-17789299
]
Jiabao Sun commented on FLINK-33635:
It seems caused by the refactor of Sink.InitCon
[
https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-33635:
---
Summary: Connector sink can not compile (was: ElasticSearch connector main
branch can not compile)
Weijie Guo created FLINK-33635:
--
Summary: ElasticSearch connector main branch can not compile
Key: FLINK-33635
URL: https://issues.apache.org/jira/browse/FLINK-33635
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-33184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-33184.
--
Resolution: Fixed
> HybridShuffleITCase fails with exception in resource cleanup of task Map on
> AZP
[
https://issues.apache.org/jira/browse/FLINK-33184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789293#comment-17789293
]
Weijie Guo commented on FLINK-33184:
It sees that this code path(i.e. IllegalStateEx
[
https://issues.apache.org/jira/browse/FLINK-33370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-33370.
--
Fix Version/s: elasticsearch-3.1.0
Resolution: Fixed
main via b15b6f01d0eb46527cbdf2e41a16db381
reswqa merged PR #77:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/77
--
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-unsubs
[
https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-33502.
--
Assignee: Wencong Liu
Resolution: Fixed
master(1.19) via 07cc8c5c7f276261b5d7c22e0b6617b6ba9666b
[
https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-33502:
---
Fix Version/s: 1.19.0
> HybridShuffleITCase caused a fatal error
> -
reswqa merged PR #23781:
URL: https://github.com/apache/flink/pull/23781
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache
Myasuka merged PR #23764:
URL: https://github.com/apache/flink/pull/23764
--
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.apach
hackergin commented on code in PR #23752:
URL: https://github.com/apache/flink/pull/23752#discussion_r1403827616
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/hints/stream/StateTtlHintTest.java:
##
@@ -0,0 +1,195 @@
+/*
+ * Licensed to the
flinkbot commented on PR #23786:
URL: https://github.com/apache/flink/pull/23786#issuecomment-1825056837
## CI report:
* 0c724f5597a1654d83682d5c39c7ee0ef2959cca UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JingGe opened a new pull request, #23786:
URL: https://github.com/apache/flink/pull/23786
## What is the purpose of the change
remove duplicated code according the clean code concept.
## Verifying this change
This change is a trivial rework / code cleanup without any
[
https://issues.apache.org/jira/browse/FLINK-33616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yong yang closed FLINK-33616.
-
Resolution: Done
> multi lookup join error
> ---
>
> Key: FLINK-3361
snuyanzin commented on PR #23757:
URL: https://github.com/apache/flink/pull/23757#issuecomment-1825039210
Thanks for driving this :+1:
After looking at FLINK-28203 i noticed that there are also files
tools/ci/compile.sh
tools/ci/maven-utils.sh
tools/ci/verify_bundled_optional
snuyanzin commented on code in PR #23757:
URL: https://github.com/apache/flink/pull/23757#discussion_r1403810179
##
flink-table/flink-sql-gateway/pom.xml:
##
@@ -47,6 +47,7 @@
org.apache.flink
flink-sql-gateway-api
${project.version}
+
snuyanzin commented on code in PR #23757:
URL: https://github.com/apache/flink/pull/23757#discussion_r1403809755
##
flink-dist/pom.xml:
##
@@ -480,6 +508,12 @@ under the License.
${project.version}
provided
snuyanzin commented on code in PR #23757:
URL: https://github.com/apache/flink/pull/23757#discussion_r1403809450
##
flink-dist/pom.xml:
##
@@ -454,6 +470,18 @@ under the License.
provided
+
+
[
https://issues.apache.org/jira/browse/FLINK-33485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-33485.
-
Fix Version/s: 1.19.0
Resolution: Fixed
> Optimize the EXISTS sub-query by Metada
[
https://issues.apache.org/jira/browse/FLINK-33485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-33485.
---
> Optimize the EXISTS sub-query by Metadata RowCount
> -
[
https://issues.apache.org/jira/browse/FLINK-33485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789280#comment-17789280
]
Sergey Nuyanzin commented on FLINK-33485:
-
Merged to master as
[a1d4dc0a4b05164
snuyanzin merged PR #23685:
URL: https://github.com/apache/flink/pull/23685
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apa
snuyanzin commented on PR #23685:
URL: https://github.com/apache/flink/pull/23685#issuecomment-1825029898
Thanks for taking a look
--
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 com
[ https://issues.apache.org/jira/browse/FLINK-31958 ]
padavan deleted comment on FLINK-31958:
-
was (Author: JIRAUSER287909):
up
> Table to DataStream allow partial fields
>
>
> Key: FLINK-319
[
https://issues.apache.org/jira/browse/FLINK-31958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789239#comment-17789239
]
padavan commented on FLINK-31958:
-
up
> Table to DataStream allow partial fields
>
afedulov commented on code in PR #711:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1403659023
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Software Found
afedulov commented on code in PR #711:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1403659023
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Software Found
afedulov commented on code in PR #711:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1403656624
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Software Found
eskabetxe commented on PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#issuecomment-1824762588
@wanglijie95 , @snuyanzin could you check please..
The sink in this moment allows non-xa (at least once) and xa (exactly once)
connections
I need to add documentati
gyfora commented on code in PR #711:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1403619658
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Software Foundat
afedulov commented on code in PR #711:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1403615188
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Software Found
afedulov commented on code in PR #711:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1403615188
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Software Found
gyfora commented on code in PR #711:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1403612096
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Software Foundat
afedulov commented on code in PR #711:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1403603955
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Software Found
afedulov commented on PR #23777:
URL: https://github.com/apache/flink/pull/23777#issuecomment-1824713681
> We could then keep all the existing code and just wrap it.
The execution model is fundamentally different - a while loop that runs
directly in the function vs an async loop that
afedulov commented on code in PR #23777:
URL: https://github.com/apache/flink/pull/23777#discussion_r1403579962
##
flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/source/SourceReaderWithCheckpointsLatch.java:
##
@@ -0,0 +1,158 @@
+/*
+ *
afedulov commented on PR #23777:
URL: https://github.com/apache/flink/pull/23777#issuecomment-1824683968
There are some things that can probably be done, but not in the scope of
this PR. You can see how much complexity of the new Source API is already
hidden behind the `IteratorSourceReader
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789203#comment-17789203
]
Vladislav Keda commented on FLINK-32513:
Hi [~huwh]! I would like to ask if ther
mxm commented on code in PR #23777:
URL: https://github.com/apache/flink/pull/23777#discussion_r1403558590
##
flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/source/SourceReaderWithCheckpointsLatch.java:
##
@@ -0,0 +1,158 @@
+/*
+ * Lice
gyfora commented on code in PR #711:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1403543895
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Software Foundat
gyfora commented on code in PR #711:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1403540366
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Software Foundat
[
https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789178#comment-17789178
]
Gyula Fora commented on FLINK-33634:
Could you please elaborate a bit on what exactl
[
https://issues.apache.org/jira/browse/FLINK-33633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789176#comment-17789176
]
Gyula Fora commented on FLINK-33633:
I am not completely sure about this feature. It
gyfora commented on code in PR #711:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1403521447
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Software Foundat
masteryhx commented on code in PR #23765:
URL: https://github.com/apache/flink/pull/23765#discussion_r1403408187
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksNativeFullSnapshotStrategy.java:
##
@@ -80,7 +
Tony Garrard created FLINK-33634:
Summary: Add Conditions to Flink CRD's Status field
Key: FLINK-33634
URL: https://issues.apache.org/jira/browse/FLINK-33634
Project: Flink
Issue Type: Improv
afedulov commented on PR #23776:
URL: https://github.com/apache/flink/pull/23776#issuecomment-1824550622
cc @alpinegizmo
--
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-33633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tony Garrard updated FLINK-33633:
-
Priority: Not a Priority (was: Major)
> Automatic creation of RBAC for instances of Flink Deplo
Tony Garrard created FLINK-33633:
Summary: Automatic creation of RBAC for instances of Flink
Deployments
Key: FLINK-33633
URL: https://issues.apache.org/jira/browse/FLINK-33633
Project: Flink
Tony Garrard created FLINK-33632:
Summary: Add custom mutator plugin
Key: FLINK-33632
URL: https://issues.apache.org/jira/browse/FLINK-33632
Project: Flink
Issue Type: Improvement
C
[
https://issues.apache.org/jira/browse/FLINK-33630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789146#comment-17789146
]
Hang Ruan commented on FLINK-33630:
---
Hi, all.
I would like to help to resolve this p
1996fanrui commented on code in PR #21635:
URL: https://github.com/apache/flink/pull/21635#discussion_r1402925601
##
docs/content.zh/docs/dev/datastream/fault-tolerance/serialization/custom_serialization.md:
##
@@ -442,4 +445,23 @@ migrate from the old abstractions. The steps to
[
https://issues.apache.org/jira/browse/FLINK-33565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789137#comment-17789137
]
Rui Fan commented on FLINK-33565:
-
Before creating this JIRA, I found that the concurren
1 - 100 of 197 matches
Mail list logo