[
https://issues.apache.org/jira/browse/FLINK-34250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-34250:
--
Assignee: Zhenqiu Huang
> Add formats options to docs
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-34259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-34259:
--
Assignee: Jiabao Sun
> flink-connector-jdbc fails to compile with NPE on hasGenericTypesDisab
[
https://issues.apache.org/jira/browse/FLINK-34259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-34259.
--
Resolution: Fixed
main: 611b45cfa6e30c6ee1f7f752971a19bff69e23c1
> flink-connector-jdbc fails to comp
[
https://issues.apache.org/jira/browse/FLINK-34259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812571#comment-17812571
]
Weijie Guo edited comment on FLINK-34259 at 1/31/24 8:29 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-34259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34259:
---
Fix Version/s: jdbc-3.1.2
(was: 1.19.0)
> flink-connector-jdbc fails
[
https://issues.apache.org/jira/browse/FLINK-34259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812584#comment-17812584
]
Martijn Visser commented on FLINK-34259:
[~Weijie Guo] I've fixed it for you
>
TanYuxin-tyx commented on code in PR #23851:
URL: https://github.com/apache/flink/pull/23851#discussion_r1472451043
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/common/TieredStorageConfiguration.java:
##
@@ -37,8 +37,16 @@ public cla
xuyangzhong commented on PR #24226:
URL: https://github.com/apache/flink/pull/24226#issuecomment-1918697856
@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 commen
[
https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812592#comment-17812592
]
xuyang commented on FLINK-34272:
https://dev.azure.com/apache-flink/apache-flink/_build/
xuyangzhong commented on PR #24226:
URL: https://github.com/apache/flink/pull/24226#issuecomment-1918700224
The failure is caused by https://issues.apache.org/jira/browse/FLINK-34272
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
TanYuxin-tyx commented on code in PR #23851:
URL: https://github.com/apache/flink/pull/23851#discussion_r1472434029
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortBuffer.java:
##
@@ -184,6 +184,27 @@ public boolean append(ByteBuffer source, int
[
https://issues.apache.org/jira/browse/FLINK-33636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33636:
---
Labels: pull-request-available (was: )
> Implement JdbcAutoScalerEventHandler
> ---
1996fanrui opened a new pull request, #765:
URL: https://github.com/apache/flink-kubernetes-operator/pull/765
Still under development.
--
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-34317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-34317:
-
Assignee: Qingsheng Ren
> Cleanup pending Flink CDC issues on GitHub
>
[
https://issues.apache.org/jira/browse/FLINK-34317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-34317:
--
Description:
Until 01/30/2024, there are 744 open and 865 closed issues on GitHub. Outdated
a
Qingsheng Ren created FLINK-34317:
-
Summary: Cleanup pending Flink CDC issues on GitHub
Key: FLINK-34317
URL: https://issues.apache.org/jira/browse/FLINK-34317
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-34317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-34317:
--
Description:
Until 01/30/2024, there are 744 open and 865 closed issues on GitHub. Outdated
a
Gyula Fora created FLINK-34318:
--
Summary: AdaptiveScheduler resource stabilisation should happen
before the job is cancelled
Key: FLINK-34318
URL: https://issues.apache.org/jira/browse/FLINK-34318
Projec
[
https://issues.apache.org/jira/browse/FLINK-34318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812600#comment-17812600
]
Gyula Fora commented on FLINK-34318:
cc [~dmvk] [~chesnay] [~mxm]
what do you guys
XComp commented on code in PR #24237:
URL: https://github.com/apache/flink/pull/24237#discussion_r1472551337
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/ExecutingTest.java:
##
@@ -634,17 +628,23 @@ public ExecutingStateBuilder setLastRescale(Instan
ConradJam created FLINK-34319:
-
Summary: Bump okhttp version to 4.12.0
Key: FLINK-34319
URL: https://issues.apache.org/jira/browse/FLINK-34319
Project: Flink
Issue Type: Improvement
Com
TanYuxin-tyx commented on code in PR #23851:
URL: https://github.com/apache/flink/pull/23851#discussion_r1472562350
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateFactory.java:
##
@@ -160,16 +159,14 @@ public SingleInputGate
snuyanzin commented on code in PR #707:
URL: https://github.com/apache/flink-web/pull/707#discussion_r1472571063
##
docs/data/flink_connectors.yml:
##
@@ -44,11 +44,11 @@ gcp-pubsub:
compatibility: ["1.16.x", "1.17.x"]
jdbc:
- name: "Apache Flink JDBC Connector 3.1.1"
-
[
https://issues.apache.org/jira/browse/FLINK-34187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-34187:
--
Assignee: Zhongqiang Gong
> Setup CI for Flink CDC project
> --
>
[
https://issues.apache.org/jira/browse/FLINK-34182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-34182:
--
Assignee: Zhongqiang Gong
> Migrate doc website from ververica to flink
>
[
https://issues.apache.org/jira/browse/FLINK-34182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812601#comment-17812601
]
Leonard Xu commented on FLINK-34182:
Thanks [~gongzhongqiang]for taking this ticket,
[
https://issues.apache.org/jira/browse/FLINK-34187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812602#comment-17812602
]
Leonard Xu commented on FLINK-34187:
Thanks [~gongzhongqiang]for taking this ticket,
czy006 opened a new pull request, #766:
URL: https://github.com/apache/flink-kubernetes-operator/pull/766
## What is the purpose of the change
Bump okhttp version to 4.12.0
## Brief change log
- *Upgrade Pom okhttp version to 4.12.0*
## Verifying this
[
https://issues.apache.org/jira/browse/FLINK-34319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34319:
---
Labels: pull-request-available (was: )
> Bump okhttp version to 4.12.0
> --
[
https://issues.apache.org/jira/browse/FLINK-34271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812608#comment-17812608
]
Dawid Wysakowicz commented on FLINK-34271:
--
> But we don’t have tests to cover
[
https://issues.apache.org/jira/browse/FLINK-34318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812630#comment-17812630
]
Rui Fan commented on FLINK-34318:
-
Hi [~gyfora] , this proposal makes sense to me. I pro
[
https://issues.apache.org/jira/browse/FLINK-34318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-34318.
--
Resolution: Fixed
Closing this as duplicate thanks [~fanrui]
> AdaptiveScheduler resource stabilisat
[
https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812633#comment-17812633
]
Gyula Fora commented on FLINK-33092:
Sounds like a great idea [~fanrui]
> Improve
Myasuka commented on code in PR #24231:
URL: https://github.com/apache/flink/pull/24231#discussion_r1472595012
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectionDriver.java:
##
@@ -89,11 +85,6 @@ public KubernetesLeaderElectio
1996fanrui commented on PR #24012:
URL: https://github.com/apache/flink/pull/24012#issuecomment-1918804500
Hi @gyfora @mxm , this PR is related to Adaptive Scheduler. Would you mind
helping take a look? Big thanks~
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-31220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-31220:
--
Assignee: (was: Rodrigo Meneses)
> Replace Pod with PodTemplateSpec for the pod template
[
https://issues.apache.org/jira/browse/FLINK-31220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812641#comment-17812641
]
Gyula Fora commented on FLINK-31220:
Seems like this is indeed a backward incompatib
zentol merged PR #24231:
URL: https://github.com/apache/flink/pull/24231
--
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-34286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-34286.
Resolution: Fixed
master: b5a2ee4e9889f248840681544fe55e22ea097305
> Attach cluster confi
gyfora commented on PR #24012:
URL: https://github.com/apache/flink/pull/24012#issuecomment-1918817163
Thanks @1996fanrui for the PR , I will try to allocate some time to review
this in the next few days. I need some extra time to familiarise myself with
all the bits :)
--
This is an au
[
https://issues.apache.org/jira/browse/FLINK-34297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812649#comment-17812649
]
Xuannan Su commented on FLINK-34297:
[~lincoln.86xy] This change doesn't need crosst
[
https://issues.apache.org/jira/browse/FLINK-34297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-34297.
---
Resolution: Fixed
[~xuannan] Thanks for your reply!
> Release Testing Instructions: Verify FLINK-34
mxm commented on PR #24012:
URL: https://github.com/apache/flink/pull/24012#issuecomment-1918863338
Thanks for looking into this @1996fanrui! I'll 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 ab
[
https://issues.apache.org/jira/browse/FLINK-34271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812664#comment-17812664
]
xuyang commented on FLINK-34271:
[~dwysakowicz] I understand and agree with you. That's
nicusX commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1472662095
##
msf-amp-example/README.md:
##
@@ -0,0 +1,68 @@
+## Sample application: Amazon Managed Service for Apache Flink and Amazon
Managed Prometheus
Review Co
nicusX commented on PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#issuecomment-1918882599
@hlteoh37 please check out the changes. I should have addressed all the
points
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
gyfora opened a new pull request, #767:
URL: https://github.com/apache/flink-kubernetes-operator/pull/767
## What is the purpose of the change
While the proper solution should be implemented in the next (breaking) CR
version, we should remove all the unnecessary properties that would
XComp commented on code in PR #24238:
URL: https://github.com/apache/flink/pull/24238#discussion_r1472679937
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerBuilder.java:
##
Review Comment:
The comment in
`#testRequirementLowerBo
[
https://issues.apache.org/jira/browse/FLINK-34274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34274:
---
Labels: pull-request-available test-stability (was: test-stability)
> AdaptiveSchedulerTest
libenchao commented on code in PR #24234:
URL: https://github.com/apache/flink/pull/24234#discussion_r1472697963
##
docs/content/docs/dev/table/sourcesSinks.md:
##
@@ -197,10 +197,16 @@ A table source can implement further ability interfaces
such as `SupportsProject
mutate an
XComp merged PR #23970:
URL: https://github.com/apache/flink/pull/23970
--
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.
XComp merged PR #24233:
URL: https://github.com/apache/flink/pull/24233
--
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-27082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799730#comment-17799730
]
Matthias Pohl edited comment on FLINK-27082 at 1/31/24 11:44 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-27082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799730#comment-17799730
]
Matthias Pohl edited comment on FLINK-27082 at 1/31/24 11:44 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-34062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-34062.
---
Fix Version/s: 1.19.0
Resolution: Fixed
master:
[f4c0b716b01200d5e02bb49d9d859934867
[
https://issues.apache.org/jira/browse/FLINK-33914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-33914.
---
Fix Version/s: 1.19.0
1.18.2
Resolution: Fixed
master:
[85edd784f
Martijn Visser created FLINK-34320:
--
Summary: Flink Kafka connector tests time out
Key: FLINK-34320
URL: https://issues.apache.org/jira/browse/FLINK-34320
Project: Flink
Issue Type: Bug
XComp merged PR #23971:
URL: https://github.com/apache/flink/pull/23971
--
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.
XComp merged PR #24232:
URL: https://github.com/apache/flink/pull/24232
--
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-33915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-33915.
---
Fix Version/s: 1.19.0
1.18.2
Resolution: Fixed
master:
[3cd3f12db
XComp merged PR #23972:
URL: https://github.com/apache/flink/pull/23972
--
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-33915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812678#comment-17812678
]
Matthias Pohl edited comment on FLINK-33915 at 1/31/24 11:56 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-33916.
---
Fix Version/s: 1.19.0
Resolution: Fixed
master:
[ff9a3c85f69d9e01c2d5d8648c9da404a41
whhe commented on PR #72:
URL:
https://github.com/apache/flink-connector-jdbc/pull/72#issuecomment-1918992897
@eskabetxe 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
mxm commented on code in PR #768:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/768#discussion_r1472756187
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/FlinkVersion.java:
##
@@ -23,16 +23,14 @@
/** Enumeration for
[
https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34282:
--
Description:
If you are doing a new minor release, you need to update Flink version in the
fo
Matthias Pohl created FLINK-34321:
-
Summary: Make nightly trigger select the release branch
automatically
Key: FLINK-34321
URL: https://issues.apache.org/jira/browse/FLINK-34321
Project: Flink
jeyhunkarimov commented on code in PR #24239:
URL: https://github.com/apache/flink/pull/24239#discussion_r1472756844
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/ClearQueryBlockAliasResolver.java:
##
@@ -31,22 +31,19 @@
import ja
[
https://issues.apache.org/jira/browse/FLINK-33396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33396:
---
Labels: pull-request-available (was: )
> The table alias should be removed in the final pla
JingGe commented on code in PR #24156:
URL: https://github.com/apache/flink/pull/24156#discussion_r1472765262
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/ScalarFunctionsTest.scala:
##
@@ -604,6 +604,20 @@ class ScalarFunctionsTest
MartijnVisser commented on code in PR #707:
URL: https://github.com/apache/flink-web/pull/707#discussion_r1472769071
##
docs/data/flink_connectors.yml:
##
@@ -44,11 +44,11 @@ gcp-pubsub:
compatibility: ["1.16.x", "1.17.x"]
jdbc:
- name: "Apache Flink JDBC Connector 3.1.1"
[
https://issues.apache.org/jira/browse/FLINK-33973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-33973:
---
Release Note:
According to FILP-372
(https://cwiki.apache.org/confluence/display/FLINK/FLIP-372%3A+
[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-25857:
---
Release Note:
The TwoPhaseCommittingSink.createCommitter method parametrization has been
changed, a
JingGe commented on code in PR #24156:
URL: https://github.com/apache/flink/pull/24156#discussion_r1472779610
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/FlinkSqlOperatorTable.java:
##
@@ -716,6 +716,28 @@ public SqlSyntax getSyn
Matthias Pohl created FLINK-34322:
-
Summary: Make secrets work in GitHub Action workflows
Key: FLINK-34322
URL: https://issues.apache.org/jira/browse/FLINK-34322
Project: Flink
Issue Type: Su
dmvk commented on code in PR #24237:
URL: https://github.com/apache/flink/pull/24237#discussion_r1472789105
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/ExecutingTest.java:
##
@@ -634,17 +628,23 @@ public ExecutingStateBuilder setLastRescale(Instant
dmvk commented on code in PR #24237:
URL: https://github.com/apache/flink/pull/24237#discussion_r1472792536
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/ExecutingTest.java:
##
@@ -634,17 +628,23 @@ public ExecutingStateBuilder setLastRescale(Instant
pvary commented on code in PR #26:
URL:
https://github.com/apache/flink-connector-cassandra/pull/26#discussion_r1472793569
##
flink-python/setup.py:
##
@@ -0,0 +1,154 @@
+
+# Licensed to the Apache
twalthr merged PR #24242:
URL: https://github.com/apache/flink/pull/24242
--
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
[
https://issues.apache.org/jira/browse/FLINK-34316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34316:
---
Labels: pull-request-available (was: )
> Reduce instantiation of ScanRuntimeProvider in str
[
https://issues.apache.org/jira/browse/FLINK-34316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-34316.
Fix Version/s: 1.19.0
Resolution: Fixed
Fixed in master: 503580834e06455bbcaf619a51f8d18812
xuyang created FLINK-34323:
--
Summary: Session window tvf failed when using named params
Key: FLINK-34323
URL: https://issues.apache.org/jira/browse/FLINK-34323
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-34323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812698#comment-17812698
]
xuyang commented on FLINK-34323:
I'll try to fix it.
> Session window tvf failed when u
xuyangzhong opened a new pull request, #24243:
URL: https://github.com/apache/flink/pull/24243
## What is the purpose of the change
Currently, when user uses session window tvf by named params, an exception
will be thrown.
This pr is try to align the param name in Flip-145 about se
[
https://issues.apache.org/jira/browse/FLINK-34323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34323:
---
Labels: pull-request-available (was: )
> Session window tvf failed when using named params
xuyangzhong commented on code in PR #24239:
URL: https://github.com/apache/flink/pull/24239#discussion_r1472812651
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/hints/batch/NestLoopJoinHintTest.xml:
##
@@ -679,8 +680,8 @@ HashJoin(join
xuyangzhong commented on code in PR #24239:
URL: https://github.com/apache/flink/pull/24239#discussion_r1472815464
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/ClearQueryBlockAliasResolver.java:
##
@@ -31,22 +31,19 @@
import java
flinkbot commented on PR #24243:
URL: https://github.com/apache/flink/pull/24243#issuecomment-1919094882
## CI report:
* 0b9b4552565e51f68a514d24c2b244f79ea09d75 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaborgsomogyi commented on code in PR #26:
URL:
https://github.com/apache/flink-connector-cassandra/pull/26#discussion_r1472819591
##
flink-python/setup.py:
##
@@ -0,0 +1,154 @@
+
+# Licensed to th
ferenc-csaky commented on code in PR #26:
URL:
https://github.com/apache/flink-connector-cassandra/pull/26#discussion_r1472822143
##
flink-python/setup.py:
##
@@ -0,0 +1,154 @@
+
+# Licensed to the
zhuzhurk commented on code in PR #24223:
URL: https://github.com/apache/flink/pull/24223#discussion_r1472738431
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchScheduler.java:
##
@@ -187,17 +189,28 @@ public AdaptiveBatchScheduler(
LadyForest merged PR #24226:
URL: https://github.com/apache/flink/pull/24226
--
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
[
https://issues.apache.org/jira/browse/FLINK-34271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812703#comment-17812703
]
Jane Chan commented on FLINK-34271:
---
Fixed in master cb9e220c2291088459f0281aa8e8e8584
[
https://issues.apache.org/jira/browse/FLINK-34271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan resolved FLINK-34271.
---
Fix Version/s: 1.19.0
Resolution: Fixed
> Fix the potential failure test about
> GroupAggreg
Matthias Pohl created FLINK-34324:
-
Summary: s3_setup is called in test_file_sink.sh even if the
common_s3.sh is not sourced
Key: FLINK-34324
URL: https://issues.apache.org/jira/browse/FLINK-34324
Pro
[
https://issues.apache.org/jira/browse/FLINK-34324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34324:
--
Description:
See example CI run from the FLINK-34150 PR:
https://dev.azure.com/apache-flink/ap
zhuzhurk commented on code in PR #24118:
URL: https://github.com/apache/flink/pull/24118#discussion_r1472843285
##
docs/content/docs/deployment/elastic_scaling.md:
##
@@ -238,7 +238,7 @@ In addition, there are several related configuration
options that may need adjus
### Limit
zhuzhurk commented on code in PR #24118:
URL: https://github.com/apache/flink/pull/24118#discussion_r1472843285
##
docs/content/docs/deployment/elastic_scaling.md:
##
@@ -238,7 +238,7 @@ In addition, there are several related configuration
options that may need adjus
### Limit
snuyanzin opened a new pull request, #99:
URL: https://github.com/apache/flink-connector-jdbc/pull/99
As it was identified at
https://github.com/apache/flink-web/pull/707#discussion_r1472769071
there should be minimum Flink version in pom and in push pr as well
--
This is an automated
JingGe commented on code in PR #24156:
URL: https://github.com/apache/flink/pull/24156#discussion_r1472765262
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/ScalarFunctionsTest.scala:
##
@@ -604,6 +604,20 @@ class ScalarFunctionsTest
1 - 100 of 197 matches
Mail list logo
