[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789356#comment-17789356
]
Weijie Guo edited comment on FLINK-25857 at 11/24/23 7:53 AM:
--
Thanks
[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789356#comment-17789356
]
Weijie Guo commented on FLINK-25857:
Thanks [~pvary] for the quick reply!
Yes, In principle, it is
[
https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789355#comment-17789355
]
Rui Fan commented on FLINK-27681:
-
{quote}In our production, the underlying environment may produce some
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
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
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=17789347#comment-17789347
]
Yun Tang commented on FLINK-31385:
--
Also picked in release-1.17
hehuiyuan opened a new pull request, #23788:
URL: https://github.com/apache/flink/pull/23788
## What is the purpose of the change
[
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 ...
[
https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789345#comment-17789345
]
Yue Ma commented on FLINK-8:
[~pnowojski] Update: Now All the changes we need are released in
[
https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789345#comment-17789345
]
Yue Ma edited comment on FLINK-8 at 11/24/23 6:49 AM:
--
[~pnowojski] Update:
[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789335#comment-17789335
]
Peter Vary commented on FLINK-25857:
For the Iceberg connector we release separate versions for
[
https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789334#comment-17789334
]
Benchao Li commented on FLINK-33541:
There is no such usage: "RAND(a, 10) and RAND(b, 10) ".
The
[
https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789330#comment-17789330
]
xuyang commented on FLINK-33541:
Hi, [~libenchao] , I checked the code again and sorry for this mistake.
[
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=17789329#comment-17789329
]
Rui Fan commented on FLINK-33565:
-
Give some background here:
[
https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789326#comment-17789326
]
Benchao Li commented on FLINK-33490:
I agree mostly, I don't have a strong opinion whether to have a
[
https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789325#comment-17789325
]
Benchao Li commented on FLINK-33541:
{quote}I notice currently the CAST rule is correct. It forbids
[
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=17789324#comment-17789324
]
Jing Ge commented on FLINK-33624:
-
master: 34620fc5c5698d00e64c6b15f8ce84f807a2e0d7
> Bump Guava to
[
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
[
https://issues.apache.org/jira/browse/FLINK-33547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789319#comment-17789319
]
Xingcan Cui commented on FLINK-33547:
-
Sure. I'll close this.
> SQL primitive array type after
[
https://issues.apache.org/jira/browse/FLINK-33547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789317#comment-17789317
]
Prabhu Joseph commented on FLINK-33547:
---
[~xccui] Thanks for the details. This issue seems to be
[
https://issues.apache.org/jira/browse/FLINK-33523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789316#comment-17789316
]
Prabhu Joseph commented on FLINK-33523:
---
Thanks [~jeyhun]. Flink 1.17 does not have this
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
[
https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789000#comment-17789000
]
zhengzhili edited comment on FLINK-33472 at 11/24/23 3:40 AM:
--
[~mapohl]
[
https://issues.apache.org/jira/browse/FLINK-33547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789311#comment-17789311
]
Xingcan Cui commented on FLINK-33547:
-
Hi [~jeyhun] , thanks for your attention!
What you explained
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
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
[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789304#comment-17789304
]
Weijie Guo commented on FLINK-25857:
IIUC, this will cause our external connector sink to be unable
[
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
[
https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789301#comment-17789301
]
Jiabao Sun commented on FLINK-33635:
mongodb:
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=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.
[
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
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
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
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
[
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
[
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)
>
[
https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789299#comment-17789299
]
Jiabao Sun commented on FLINK-33635:
It seems caused by the refactor of Sink.InitContext.
[
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:
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-33184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789293#comment-17789293
]
Weijie Guo commented on FLINK-33184:
It sees that this code path(i.e. IllegalStateException: Leaking
[
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
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:
[
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
[
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:
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:
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:
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
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
[
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=17789280#comment-17789280
]
Sergey Nuyanzin commented on FLINK-33485:
-
Merged to master as
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:
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
[ 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:
[
https://issues.apache.org/jira/browse/FLINK-31958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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
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
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
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
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
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
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789203#comment-17789203
]
Vladislav Keda commented on FLINK-32513:
Hi [~huwh]! I would like to ask if there are any news
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 @@
+/*
+ *
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
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
[
https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789178#comment-17789178
]
Gyula Fora commented on FLINK-33634:
Could you please elaborate a bit on what exactly do you suggest
[
https://issues.apache.org/jira/browse/FLINK-33633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789176#comment-17789176
]
Gyula Fora commented on FLINK-33633:
I am not completely sure about this feature. It's generally an
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
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:
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.
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-33630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789146#comment-17789146
]
Hang Ruan commented on FLINK-33630:
---
Hi, all.
I would like to help to resolve this problem. Please
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
[
https://issues.apache.org/jira/browse/FLINK-33565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789137#comment-17789137
]
Rui Fan commented on FLINK-33565:
-
Before creating this JIRA, I found that the concurrentExceptions
1 - 100 of 197 matches
Mail list logo
