[
https://issues.apache.org/jira/browse/FLINK-32666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747305#comment-17747305
]
lizhiqiang edited comment on FLINK-32666 at 7/26/23 6:55 AM:
-
grandfisher created FLINK-32679:
---
Summary: Filter conditions cannot be pushed to JOIN in some case
Key: FLINK-32679
URL: https://issues.apache.org/jira/browse/FLINK-32679
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-32678:
-
Assignee: Yang Wang
> Test FLIP-285 LeaderElection
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-32666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747305#comment-17747305
]
lizhiqiang commented on FLINK-32666:
I see this restriction in the maven version in
[
https://issues.apache.org/jira/browse/FLINK-27054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747304#comment-17747304
]
Martijn Visser commented on FLINK-27054:
[~legendtkl] It all depends on a contri
Matthias Pohl created FLINK-32678:
-
Summary: Test FLIP-285 LeaderElection
Key: FLINK-32678
URL: https://issues.apache.org/jira/browse/FLINK-32678
Project: Flink
Issue Type: Technical Debt
[
https://issues.apache.org/jira/browse/FLINK-32677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747303#comment-17747303
]
Martijn Visser commented on FLINK-32677:
[~Yanfei Lei] I think that was because
Tartarus0zm commented on PR #23060:
URL: https://github.com/apache/flink/pull/23060#issuecomment-1651049951
@luoyuxia thanks for your review! I have update the pr, PTAL, and I will
add the docs for atomicity CTAS/RTAS in
[FLINK-32581](https://issues.apache.org/jira/browse/FLINK-32581)
-
Myasuka commented on PR #665:
URL: https://github.com/apache/flink-web/pull/665#issuecomment-1651049361
@JingsongLi would you please take 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 t
[
https://issues.apache.org/jira/browse/FLINK-32677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747292#comment-17747292
]
Yanfei Lei commented on FLINK-32677:
[~MartijnVisser] It seems that the Jenkins plug
[
https://issues.apache.org/jira/browse/FLINK-32677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-32677:
---
Description:
{code:java}
Response Code: 404http://codespeed.dak8s.net:8080/log"/>2717802023-07-19T11
Yanfei Lei created FLINK-32677:
--
Summary: flink-benchmarks-regression-check failed to send slack
messages since 2023.07.17
Key: FLINK-32677
URL: https://issues.apache.org/jira/browse/FLINK-32677
Project:
[
https://issues.apache.org/jira/browse/FLINK-32551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-32551.
--
Fix Version/s: kubernetes-operator-1.6.0
Resolution: Fixed
merged to main 18903878cbeff57fa1ad1
gyfora merged PR #634:
URL: https://github.com/apache/flink-kubernetes-operator/pull/634
--
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
snuyanzin commented on PR #23074:
URL: https://github.com/apache/flink/pull/23074#issuecomment-1651026104
@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.
[
https://issues.apache.org/jira/browse/FLINK-32611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32611:
---
Labels: pull-request-available (was: )
> Redirect to Apache Paimon's link instead of legacy
Myasuka opened a new pull request, #665:
URL: https://github.com/apache/flink-web/pull/665
(no comment)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-ma
[
https://issues.apache.org/jira/browse/FLINK-32666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747279#comment-17747279
]
lizhiqiang commented on FLINK-32666:
thx [~martijnvisser] [~chesnay] reply.
maven
flinkbot commented on PR #23078:
URL: https://github.com/apache/flink/pull/23078#issuecomment-1650945339
## CI report:
* e7334d5e5d953f137655d50504d6c43cd68f2d05 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong reassigned FLINK-32676:
-
Assignee: Fang Yong
> Add doc for catalog modification listener
> -
Tartarus0zm commented on code in PR #23060:
URL: https://github.com/apache/flink/pull/23060#discussion_r1274348810
##
docs/content.zh/docs/dev/table/sql/create.md:
##
@@ -557,6 +558,58 @@ INSERT INTO my_ctas_table SELECT id, name, age FROM
source_table WHERE mod(id, 1
{{< to
[
https://issues.apache.org/jira/browse/FLINK-32676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32676:
---
Labels: pull-request-available (was: )
> Add doc for catalog modification listener
> --
FangYongs opened a new pull request, #23078:
URL: https://github.com/apache/flink/pull/23078
## What is the purpose of the change
Add doc for catalog modification listener
## Brief change log
- Add doc for catalog modification listener
## Verifying this change
flinkbot commented on PR #23077:
URL: https://github.com/apache/flink/pull/23077#issuecomment-1650927484
## CI report:
* 83cab86fbe6d152754f20ebc561ae3412fde69cc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32675:
---
Labels: pull-request-available (was: )
> Add doc for the tiered storage of hybrid shuffle
>
TanYuxin-tyx opened a new pull request, #23077:
URL: https://github.com/apache/flink/pull/23077
## What is the purpose of the change
*Add document for the tiered storage of hybrid shuffle*
## Brief change log
- *Add document for the tiered storage of hybrid
[
https://issues.apache.org/jira/browse/FLINK-32668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747240#comment-17747240
]
Hongshun Wang edited comment on FLINK-32668 at 7/26/23 3:17 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-32668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747240#comment-17747240
]
Hongshun Wang edited comment on FLINK-32668 at 7/26/23 3:15 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-32668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747240#comment-17747240
]
Hongshun Wang commented on FLINK-32668:
---
[~mapohl]
In fact, it's also hard for m
Tartarus0zm commented on code in PR #23060:
URL: https://github.com/apache/flink/pull/23060#discussion_r1274313857
##
docs/content.zh/docs/dev/table/sql/create.md:
##
@@ -33,6 +33,7 @@ CREATE 语句用于向当前或指定的 [Catalog]({{< ref "docs/dev/table/catal
目前 Flink SQL 支持下列 CREATE 语句：
-
[
https://issues.apache.org/jira/browse/FLINK-27054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747239#comment-17747239
]
Kelu Tao commented on FLINK-27054:
--
Hi, [~martijnvisser] and [~alexanderpreuss] , for t
[
https://issues.apache.org/jira/browse/FLINK-31634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747238#comment-17747238
]
Yuxin Tan commented on FLINK-31634:
---
[~knaufk] Thanks for helping check the doc. I hav
[
https://issues.apache.org/jira/browse/FLINK-32675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-32675:
--
Description: The new Hybrid Shuffle mode supporting remote storage
(https://issues.apache.org/jira/bro
Fang Yong created FLINK-32676:
-
Summary: Add doc for catalog modification listener
Key: FLINK-32676
URL: https://issues.apache.org/jira/browse/FLINK-32676
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-32402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747235#comment-17747235
]
Fang Yong commented on FLINK-32402:
---
Thanks [~knaufk], I'll create an issue to add doc
[
https://issues.apache.org/jira/browse/FLINK-32655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746871#comment-17746871
]
Rui Fan edited comment on FLINK-32655 at 7/26/23 2:07 AM:
--
Than
[
https://issues.apache.org/jira/browse/FLINK-32655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-32655.
-
Fix Version/s: 1.18.0
1.16.3
1.17.2
Resolution: Fixed
> Rec
[
https://issues.apache.org/jira/browse/FLINK-32655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746871#comment-17746871
]
Rui Fan edited comment on FLINK-32655 at 7/26/23 2:07 AM:
--
Merg
1996fanrui merged PR #23071:
URL: https://github.com/apache/flink/pull/23071
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.ap
1996fanrui merged PR #23070:
URL: https://github.com/apache/flink/pull/23070
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.ap
flinkbot commented on PR #23076:
URL: https://github.com/apache/flink/pull/23076#issuecomment-1650855772
## CI report:
* 7bef28d54b12f28b3cfeaeb08e2a9afd3d4d3afc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23075:
URL: https://github.com/apache/flink/pull/23075#issuecomment-1650851240
## CI report:
* 806494851d14980c87aa484d2e96fb1429584e79 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32460:
---
Labels: pull-request-available (was: )
> Add doc for list procedures
>
luoyuxia opened a new pull request, #23076:
URL: https://github.com/apache/flink/pull/23076
## What is the purpose of the change
Add doc for show procedures statement.
## Brief change log
Add doc for show procedures statement.
## Verifying this change
[
https://issues.apache.org/jira/browse/FLINK-32674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32674:
---
Labels: pull-request-available (was: )
> Add documentation for the new Context.getTargetCol
Yuxin Tan created FLINK-32675:
-
Summary: Add doc for the tiered storage of hybrid shuffle
Key: FLINK-32675
URL: https://issues.apache.org/jira/browse/FLINK-32675
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-31487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747225#comment-17747225
]
lincoln lee commented on FLINK-31487:
-
[~knaufk] Yes, only the javadoc is currently
RanJinh commented on PR #23000:
URL: https://github.com/apache/flink/pull/23000#issuecomment-1650824543
@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.
lincoln lee created FLINK-32674:
---
Summary: Add documentation for the new Context.getTargetColumns
Key: FLINK-32674
URL: https://issues.apache.org/jira/browse/FLINK-32674
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-32468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32468.
Resolution: Fixed
master: c8ae39d4ac73f81873e1d8ac37e17c29ae330b23
> Replace Akka by Pekk
dependabot[bot] closed pull request #25: Bump certifi from 2020.12.5 to
2022.12.7
URL: https://github.com/apache/flink-jira-bot/pull/25
--
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 c
dependabot[bot] opened a new pull request, #27:
URL: https://github.com/apache/flink-jira-bot/pull/27
Bumps [certifi](https://github.com/certifi/python-certifi) from 2020.12.5 to
2023.7.22.
Commits
https://github.com/certifi/python-certifi/commit/8fb96ed81f71e7097ed11bc4d9b19af
zentol commented on PR #22996:
URL: https://github.com/apache/flink/pull/22996#issuecomment-1650191304
We can still bump it in the following days if needed.
--
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
[
https://issues.apache.org/jira/browse/FLINK-32168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32168.
Resolution: Fixed
master: dc08df6132921dec0083ebf5a54a66f8447aa2c8
> Log required/availab
[
https://issues.apache.org/jira/browse/FLINK-32165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32165.
Resolution: Fixed
> Improve observability of fine-grained resource management
> --
zentol merged PR #23064:
URL: https://github.com/apache/flink/pull/23064
--
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
[
https://issues.apache.org/jira/browse/FLINK-32673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747062#comment-17747062
]
Ryan Skraba commented on FLINK-32673:
-
Hello! There's been some work on this:
http
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1273800142
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobReconcilerTest.java:
##
@@ -409,24 +41
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1273795909
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java:
##
@@ -369,6 +395,13 @@ p
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1273795126
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SnapshotObserver.java:
##
@@ -74,8 +80,32 @@ public void obse
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1273792943
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SnapshotObserver.java:
##
@@ -124,14 +159,78 @@ private void
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1273789422
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SnapshotObserver.java:
##
@@ -74,8 +80,32 @@ public void obse
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1273789422
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SnapshotObserver.java:
##
@@ -74,8 +80,32 @@ public void obse
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1273789422
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SnapshotObserver.java:
##
@@ -74,8 +80,32 @@ public void obse
XComp commented on code in PR #22996:
URL: https://github.com/apache/flink/pull/22996#discussion_r1273769632
##
flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java:
##
Review Comment:
AkkaOptions is left like that because it's labeled as `@PublicEvolvin
mdedetrich commented on code in PR #22996:
URL: https://github.com/apache/flink/pull/22996#discussion_r1273759360
##
flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java:
##
Review Comment:
This file is still called `AkkaOptions.java`, shouldn't it be re
XComp commented on PR #22996:
URL: https://github.com/apache/flink/pull/22996#issuecomment-1650088706
@mdedetrich pointed out today that there is a Pekko 1.0.1 release on the
way. It includes a fix in `pekko-remote` which we use. It's not 100% clear
whether the issue actually affects Flink
JTaky opened a new pull request, #638:
URL: https://github.com/apache/flink-kubernetes-operator/pull/638
## What is the purpose of the change
Update documentation of the rollback features.
Flink devs who is not aware about internals of the operator's CRDs is not
obviou
[
https://issues.apache.org/jira/browse/FLINK-28046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747031#comment-17747031
]
Leonard Xu commented on FLINK-28046:
[~chesnay] We've discussed with [~afedulov],
gyfora commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1273650143
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/SnapshotType.java:
##
@@ -0,0 +1,24 @@
+/*
+ * Licensed t
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1273647391
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobReconcilerTest.java:
##
@@ -409,24 +41
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1273645546
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/SnapshotType.java:
##
@@ -0,0 +1,24 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-32673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-32673:
--
Assignee: (was: Alex Chaffee)
> Migrage Google PubSub connector to V2
> -
[
https://issues.apache.org/jira/browse/FLINK-32673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-32673:
--
Assignee: Alex Chaffee
> Migrage Google PubSub connector to V2
>
RyanSkraba commented on PR #23006:
URL: https://github.com/apache/flink/pull/23006#issuecomment-1649909051
Just to summarize (the main discussion is on the JIRA):
* Rebased and squashed all commits
* Only top level classes are `@deprecated` to ensure that the dev has the
info about
Alexander Fedulov created FLINK-32673:
-
Summary: Migrage Google PubSub connector to V2
Key: FLINK-32673
URL: https://issues.apache.org/jira/browse/FLINK-32673
Project: Flink
Issue Type: S
Alexander Fedulov created FLINK-32672:
-
Summary: Migrate RabbitMQ connector to Source V2 API
Key: FLINK-32672
URL: https://issues.apache.org/jira/browse/FLINK-32672
Project: Flink
Issue T
liming30 commented on PR #23071:
URL: https://github.com/apache/flink/pull/23071#issuecomment-1649855073
@1996fanrui CI has passed, please merge it at your convenience.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
liming30 commented on PR #23070:
URL: https://github.com/apache/flink/pull/23070#issuecomment-1649854603
@1996fanrui CI has passed, please merge it at your convenience.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
[
https://issues.apache.org/jira/browse/FLINK-32548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746998#comment-17746998
]
Rui Fan edited comment on FLINK-32548 at 7/25/23 1:24 PM:
--
Hi [
[
https://issues.apache.org/jira/browse/FLINK-32548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746998#comment-17746998
]
Rui Fan commented on FLINK-32548:
-
Hi [~knaufk] , thanks for the asking.
I think the be
[
https://issues.apache.org/jira/browse/FLINK-31889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf reassigned FLINK-31889:
Assignee: Konstantin Knauf (was: Panagiotis Garefalakis)
> Add documentation for
[
https://issues.apache.org/jira/browse/FLINK-31889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf reassigned FLINK-31889:
Assignee: Panagiotis Garefalakis (was: Konstantin Knauf)
> Add documentation for
[
https://issues.apache.org/jira/browse/FLINK-31889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf reassigned FLINK-31889:
Assignee: Panagiotis Garefalakis
> Add documentation for implementing/loading enr
flinkbot commented on PR #23074:
URL: https://github.com/apache/flink/pull/23074#issuecomment-1649809503
## CI report:
* 41c9d47a036569d7e65147089ae2a72858ddfb77 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
luoyuxia commented on code in PR #23060:
URL: https://github.com/apache/flink/pull/23060#discussion_r1273468797
##
docs/content.zh/docs/dev/table/sql/create.md:
##
@@ -557,6 +558,58 @@ INSERT INTO my_ctas_table SELECT id, name, age FROM
source_table WHERE mod(id, 1
{{< top >
snuyanzin opened a new pull request, #23074:
URL: https://github.com/apache/flink/pull/23074
…to 1 second (#22742)
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way w
[
https://issues.apache.org/jira/browse/FLINK-32574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746971#comment-17746971
]
Yanfei Lei commented on FLINK-32574:
[~renqs] I can't reproduce this bug locally, bu
[
https://issues.apache.org/jira/browse/FLINK-32574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei closed FLINK-32574.
--
Resolution: Duplicate
> RescalingITCase.testSavepointRescalingInPartitionedOperatorState fails on AZP
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746972#comment-17746972
]
Yanfei Lei commented on FLINK-32663:
[~mapohl] I think they are duplicate, I'll clos
[
https://issues.apache.org/jira/browse/FLINK-32670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32670:
--
Description: ParallelSourceFunction, RichParallelSourceFunction,
ExternallyInducedSou
XComp commented on code in PR #22987:
URL: https://github.com/apache/flink/pull/22987#discussion_r1272076683
##
flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientTest.java:
##
@@ -207,6 +210,40 @@ public void testRestClientClosedHandling() throws
Exception {
[
https://issues.apache.org/jira/browse/FLINK-32472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746953#comment-17746953
]
Feng Jin commented on FLINK-32472:
--
[~knaufk] Sure, the current task only requires com
[
https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746950#comment-17746950
]
Konstantin Knauf commented on FLINK-15736:
--
[~chesnay]Do we need any user-facin
[
https://issues.apache.org/jira/browse/FLINK-29344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-29344:
-
Fix Version/s: (was: 1.18.0)
> Make Adaptive Scheduler supports Fine-Grained Resourc
[
https://issues.apache.org/jira/browse/FLINK-29344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746947#comment-17746947
]
Konstantin Knauf commented on FLINK-29344:
--
Since the feature freeze has passed
Konstantin Knauf created FLINK-32671:
Summary: Document Externalized Declarative Resource Management
Key: FLINK-32671
URL: https://issues.apache.org/jira/browse/FLINK-32671
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf reassigned FLINK-31316:
Assignee: David Morávek (was: Konstantin Knauf)
> FLIP-291: Externalized Declara
[
https://issues.apache.org/jira/browse/FLINK-31316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf reassigned FLINK-31316:
Assignee: Konstantin Knauf (was: David Morávek)
> FLIP-291: Externalized Declara
[
https://issues.apache.org/jira/browse/FLINK-32486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746942#comment-17746942
]
Konstantin Knauf commented on FLINK-32486:
--
[~wanglijie] Tan Is there user faci
1 - 100 of 174 matches
Mail list logo
