[
https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-34369.
-
Fix Version/s: elasticsearch-3.2.0
Resolution: Fixed
> Elasticsearch connector su
[
https://issues.apache.org/jira/browse/FLINK-36889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905051#comment-17905051
]
Robert Metzger commented on FLINK-36889:
Thanks, assigned.
> Mention locking do
dawidwys merged PR #25787:
URL: https://github.com/apache/flink/pull/25787
--
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.apac
[
https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-34273:
---
Summary: git fetch fails on CI (was: git fetch fails)
> git fetch fails on CI
> ---
[
https://issues.apache.org/jira/browse/FLINK-22258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905062#comment-17905062
]
Rui Fan commented on FLINK-22258:
-
Hi [~rmetzger] , thanks for asking here.
Currently,
[
https://issues.apache.org/jira/browse/FLINK-22258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905054#comment-17905054
]
Robert Metzger commented on FLINK-22258:
What's the status of this ticket?
> Ad
[
https://issues.apache.org/jira/browse/FLINK-36883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-36883.
Resolution: Fixed
Fixed in:
* master
** 529f64078a34d9840a26906bcf967a2147d305f9
* 1.20.1
[
https://issues.apache.org/jira/browse/FLINK-36753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-36753:
---
Assignee: Samrat Deb
> Adaptive Scheduler actively triggers a Checkpoint
>
[
https://issues.apache.org/jira/browse/FLINK-36753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905072#comment-17905072
]
Samrat Deb commented on FLINK-36753:
Thank you, Rui, for assigning the Jira! :)
>
JunRuiLee opened a new pull request, #25790:
URL: https://github.com/apache/flink/pull/25790
## What is the purpose of the change
[FLINK-36067][runtime] Support optimize stream graph based on input info.
## Brief change log
- Introduce StreamGraphOptimizer
Sergey Nuyanzin created FLINK-36896:
---
Summary: Table API trim expression incorrectly translated to SQL
Key: FLINK-36896
URL: https://issues.apache.org/jira/browse/FLINK-36896
Project: Flink
snuyanzin opened a new pull request, #25791:
URL: https://github.com/apache/flink/pull/25791
## What is the purpose of the change
While translation of `trim()` to SQL parenthesis are missed
## Brief change log
`SqlCallSyntax`
## Verifying this change
`Expres
[
https://issues.apache.org/jira/browse/FLINK-36067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36067:
---
Labels: pull-request-available (was: )
> Introducing the StreamGraphOptimizer component
> -
[
https://issues.apache.org/jira/browse/FLINK-36896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36896:
---
Labels: pull-request-available (was: )
> Table API trim expression incorrectly translated t
Zakelly opened a new pull request, #25792:
URL: https://github.com/apache/flink/pull/25792
## What is the purpose of the change
The watermark status is not properly handle in async state processing. It is
emitted to downstream synchronously, while the watermarks will respect the
[
https://issues.apache.org/jira/browse/FLINK-36892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36892:
---
Labels: pull-request-available (was: )
> Properly handle the watermark status
> ---
flinkbot commented on PR #25791:
URL: https://github.com/apache/flink/pull/25791#issuecomment-2538287677
## CI report:
* fe52760343c6d429d8a586dda10a37030a3dbf98 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25792:
URL: https://github.com/apache/flink/pull/25792#issuecomment-2538287976
## CI report:
* 2c6e7e5107048c628a13f4520034f940a23f2fab UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25790:
URL: https://github.com/apache/flink/pull/25790#issuecomment-2538287409
## CI report:
* 28a209691af93e57a7efe44c6d5b754b89ac7a5f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-36889:
--
Assignee: Samrat Deb
> Mention locking down a Flink cluster in the 'Production Readin
davidradl commented on code in PR #25792:
URL: https://github.com/apache/flink/pull/25792#discussion_r1881730342
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/operators/AbstractAsyncStateStreamOperatorV2.java:
##
@@ -259,17 +265,35 @@ public void proces
Au-Miner commented on code in PR #25777:
URL: https://github.com/apache/flink/pull/25777#discussion_r1881691868
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecTemporalJoin.java:
##
@@ -276,12 +278,21 @@ private Tw
Au-Miner commented on code in PR #25777:
URL: https://github.com/apache/flink/pull/25777#discussion_r1881691868
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecTemporalJoin.java:
##
@@ -276,12 +278,21 @@ private Tw
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1881754173
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,111 @@
+/*
+ * Licensed to
Zakelly commented on code in PR #25792:
URL: https://github.com/apache/flink/pull/25792#discussion_r1881755602
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/operators/AbstractAsyncStateStreamOperatorV2.java:
##
@@ -259,17 +265,35 @@ public void processW
MOBIN-F commented on code in PR #3784:
URL: https://github.com/apache/flink-cdc/pull/3784#discussion_r1881800085
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/utils/JsonRowDataSerializationSchema
[
https://issues.apache.org/jira/browse/FLINK-35887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905096#comment-17905096
]
lincoln lee commented on FLINK-35887:
-
Because the need to port to lower versions is
JunRuiLee merged PR #25658:
URL: https://github.com/apache/flink/pull/25658
--
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
[
https://issues.apache.org/jira/browse/FLINK-36068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee closed FLINK-36068.
--
> Support for adaptive job scheduling based on StreamGraph
> -
[
https://issues.apache.org/jira/browse/FLINK-36067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee updated FLINK-36067:
---
Summary: Support optimize stream graph based on input info. (was:
Introducing the StreamGraphOptimi
[
https://issues.apache.org/jira/browse/FLINK-36068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee resolved FLINK-36068.
Resolution: Fixed
master:
1580b4dd53cf023a201f12d822df0f9c1fbe241d
2e7dfae5c3b58967d160aed99d0873b
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1881856608
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,165 @@
+/*
+ * Licensed to
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1881860996
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,165 @@
+/*
+ * Licensed to
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1881862749
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,165 @@
+/*
+ * Licensed to
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1881862749
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,165 @@
+/*
+ * Licensed to
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1881852846
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,165 @@
+/*
+ * Licensed to
davidradl commented on code in PR #25784:
URL: https://github.com/apache/flink/pull/25784#discussion_r1882174945
##
docs/content.zh/docs/dev/table/sqlClient.md:
##
@@ -663,6 +663,24 @@ This configuration:
Attention Compared to the interactive
mode, SQL Client will stop execu
davidradl commented on code in PR #25784:
URL: https://github.com/apache/flink/pull/25784#discussion_r1882176878
##
docs/content.zh/docs/dev/table/sqlClient.md:
##
@@ -610,7 +610,7 @@ SQL Client will print success message if the statement is
executed successfully.
By default,
davidradl commented on code in PR #25784:
URL: https://github.com/apache/flink/pull/25784#discussion_r1882178794
##
docs/content/docs/dev/table/sqlClient.md:
##
@@ -601,6 +601,24 @@ This configuration:
Attention Compared to the interactive
mode, SQL Client will stop executio
davidradl commented on code in PR #25789:
URL: https://github.com/apache/flink/pull/25789#discussion_r1882324012
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/utils/GroupTableAggHelper.java:
##
@@ -0,0 +1,79 @@
+/*
+ * Licens
davidradl commented on code in PR #25789:
URL: https://github.com/apache/flink/pull/25789#discussion_r1882325785
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/utils/GroupTableAggHelper.java:
##
@@ -0,0 +1,79 @@
+/*
+ * Licens
davidradl commented on code in PR #25789:
URL: https://github.com/apache/flink/pull/25789#discussion_r1882325785
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/utils/GroupTableAggHelper.java:
##
@@ -0,0 +1,79 @@
+/*
+ * Licens
davidradl commented on code in PR #25789:
URL: https://github.com/apache/flink/pull/25789#discussion_r1882323328
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/asyncprocessing/AsyncStateGroupTableAggFunction.java:
##
@@ -0,0 +
davidradl commented on code in PR #25790:
URL: https://github.com/apache/flink/pull/25790#discussion_r1882334476
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IntermediateResult.java:
##
@@ -207,6 +210,10 @@ public boolean isForward() {
return i
[
https://issues.apache.org/jira/browse/FLINK-36893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905252#comment-17905252
]
Ryan van Huuksloot commented on FLINK-36893:
We use both savepoint and check
donPain commented on code in PR #25769:
URL: https://github.com/apache/flink/pull/25769#discussion_r1882539224
##
docs/content/docs/connectors/table/formats/avro.md:
##
@@ -218,4 +218,4 @@ So the following table lists the type mapping from Flink
type to Avro type.
In additio
[
https://issues.apache.org/jira/browse/FLINK-36893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui closed FLINK-36893.
---
Resolution: Won't Fix
> Support periodic full checkpoint
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-36893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905253#comment-17905253
]
Xingcan Cui commented on FLINK-36893:
-
Ah, gotcha. I just noticed https://issues.apa
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1881765938
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala:
##
@@ -1140,41 +1140,41 @@ class TemporalTypesTe
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1881732526
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,111 @@
+/*
+ * Licensed to
SML0127 commented on PR #3658:
URL: https://github.com/apache/flink-cdc/pull/3658#issuecomment-2538529346
@ruanhang1993 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.
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1881831845
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala:
##
@@ -1140,41 +1140,41 @@ class TemporalTypesTe
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1881834036
##
docs/data/sql_functions.yml:
##
@@ -679,9 +679,15 @@ temporal:
- sql: TO_DATE(string1[, string2])
table: toDate(STRING1[, STRING2])
description: Conve
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1881832830
##
docs/data/sql_functions.yml:
##
@@ -679,9 +679,15 @@ temporal:
- sql: TO_DATE(string1[, string2])
table: toDate(STRING1[, STRING2])
description: Conve
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1881841286
##
docs/data/sql_functions.yml:
##
@@ -679,9 +679,15 @@ temporal:
- sql: TO_DATE(string1[, string2])
table: toDate(STRING1[, STRING2])
description: Conve
davidradl commented on code in PR #25750:
URL: https://github.com/apache/flink/pull/25750#discussion_r1881901413
##
flink-end-to-end-tests/flink-end-to-end-tests-hive/pom.xml:
##
@@ -198,7 +198,7 @@ under the License.
snuyanzin commented on code in PR #25752:
URL: https://github.com/apache/flink/pull/25752#discussion_r1881954651
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/RankTest.scala:
##
@@ -1011,5 +1011,16 @@ class RankTest extends Tabl
[
https://issues.apache.org/jira/browse/FLINK-36896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905140#comment-17905140
]
Sergey Nuyanzin commented on FLINK-36896:
-
Merged as
[72b32fcd53f2d0d81329298a6
davidradl commented on code in PR #25784:
URL: https://github.com/apache/flink/pull/25784#discussion_r1882178794
##
docs/content/docs/dev/table/sqlClient.md:
##
@@ -601,6 +601,24 @@ This configuration:
Attention Compared to the interactive
mode, SQL Client will stop executio
davidradl commented on code in PR #25784:
URL: https://github.com/apache/flink/pull/25784#discussion_r1882182035
##
docs/content/docs/dev/table/sqlClient.md:
##
@@ -601,6 +601,24 @@ This configuration:
Attention Compared to the interactive
mode, SQL Client will stop executio
hanyuzheng7 commented on PR #25759:
URL: https://github.com/apache/flink/pull/25759#issuecomment-2539042873
@snuyanzin Yes, because this ticket just handle the SECOND and MINUTE case.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
hanyuzheng7 commented on PR #25759:
URL: https://github.com/apache/flink/pull/25759#issuecomment-2539408787
Support `MILLISECOND` now @snuyanzin
--
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
davidradl commented on code in PR #25792:
URL: https://github.com/apache/flink/pull/25792#discussion_r1882410030
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/operators/AbstractAsyncStateStreamOperator.java:
##
@@ -368,10 +385,12 @@ protected void proce
tomncooper commented on PR #25594:
URL: https://github.com/apache/flink/pull/25594#issuecomment-2539395427
The CI failure looks unrelated, a rebase and re-run might fix it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
snuyanzin commented on code in PR #25752:
URL: https://github.com/apache/flink/pull/25752#discussion_r1881952675
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/StreamLogicalOptimizeSelectDistinctRule.scala:
##
@@ -0,0
snuyanzin commented on PR #25759:
URL: https://github.com/apache/flink/pull/25759#issuecomment-2539063947
the root cause is same, if you compare output for different inputs, it will
be same.
The jira issue was raised for the case the reporter faced however it does
not mean it is limited
tomncooper commented on PR #25585:
URL: https://github.com/apache/flink/pull/25585#issuecomment-2539423237
Looks like you have failed the spotless check. You need to run `mvn
spotless:apply` and commit the changes first and then you can actually test
your code changes.
--
This is an auto
tomncooper commented on PR #25584:
URL: https://github.com/apache/flink/pull/25584#issuecomment-2539429673
Looks like you have actual [test
failures](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=63833&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a&t=075c2716-8010-
tomncooper commented on PR #25583:
URL: https://github.com/apache/flink/pull/25583#issuecomment-2539442790
Looks like you have conflicting versions of `org.ow2.asm:asm`. You may need
to override the transitive versions of kryo from other packages (in this case
the one coming from `com.twit
davidradl commented on code in PR #25770:
URL: https://github.com/apache/flink/pull/25770#discussion_r1882108757
##
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricNames.java:
##
@@ -52,6 +52,7 @@ private MetricNames() {}
public static final String NUM_PE
Wang Qilong created FLINK-36897:
---
Summary: Error in calling processElement for AbstractAsynchronous
StateStreamOperator
Key: FLINK-36897
URL: https://issues.apache.org/jira/browse/FLINK-36897
Project: F
davidradl commented on code in PR #25770:
URL: https://github.com/apache/flink/pull/25770#discussion_r1882114599
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java:
##
@@ -664,7 +740,7 @@ void testNumRestartsMetric() throws Exce
[
https://issues.apache.org/jira/browse/FLINK-36897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Qilong updated FLINK-36897:
Description:
When I created the AbstractAsynchronous StateMapBundleOperator and inherited it
from
davidradl commented on code in PR #25770:
URL: https://github.com/apache/flink/pull/25770#discussion_r1882124577
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java:
##
@@ -641,6 +643,7 @@ public final void startScheduling() {
jo
davidradl commented on code in PR #25770:
URL: https://github.com/apache/flink/pull/25770#discussion_r1882119229
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateTransitions.java:
##
@@ -139,7 +139,8 @@ void goToRestarting(
Operato
[
https://issues.apache.org/jira/browse/FLINK-36897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Qilong updated FLINK-36897:
Summary: Error executing processElement when inheriting from
AbstractAsyncStateStreamOperator (wa
davidradl commented on code in PR #25770:
URL: https://github.com/apache/flink/pull/25770#discussion_r1882114599
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java:
##
@@ -664,7 +740,7 @@ void testNumRestartsMetric() throws Exce
[
https://issues.apache.org/jira/browse/FLINK-36897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Qilong updated FLINK-36897:
Description:
When I created the AbstractAsynchronous StateMapBundleOperator and inherited it
from
davidradl commented on code in PR #25770:
URL: https://github.com/apache/flink/pull/25770#discussion_r1882125855
##
pom.xml:
##
@@ -1819,7 +1819,7 @@ under the License.
snuyanzin merged PR #25791:
URL: https://github.com/apache/flink/pull/25791
--
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 #25769:
URL: https://github.com/apache/flink/pull/25769#issuecomment-2539537588
can you also change it at
https://github.com/apache/flink/blob/72b32fcd53f2d0d81329298a6c0a7d08e084f769/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/Avr
rmetzger merged PR #25774:
URL: https://github.com/apache/flink/pull/25774
--
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.apac
[
https://issues.apache.org/jira/browse/FLINK-36725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jim Hughes reassigned FLINK-36725:
--
Assignee: (was: Jim Hughes)
> Add CompiledPlan annotations to BatchExecRuntimeFilter exec
davidradl commented on code in PR #25790:
URL: https://github.com/apache/flink/pull/25790#discussion_r1882345432
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IntermediateResultInfo.java:
##
@@ -35,6 +35,14 @@ public interface IntermediateResultInfo {
davidradl commented on code in PR #25790:
URL: https://github.com/apache/flink/pull/25790#discussion_r1882334476
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IntermediateResult.java:
##
@@ -207,6 +210,10 @@ public boolean isForward() {
return i
davidradl commented on code in PR #25790:
URL: https://github.com/apache/flink/pull/25790#discussion_r1882345432
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IntermediateResultInfo.java:
##
@@ -35,6 +35,14 @@ public interface IntermediateResultInfo {
twalthr commented on PR #15797:
URL: https://github.com/apache/flink/pull/15797#issuecomment-2539112337
@chenshaojin please open a new issue in this case.
--
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 t
davidradl commented on code in PR #25788:
URL: https://github.com/apache/flink/pull/25788#discussion_r1882245040
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java:
##
@@ -317,7 +337,7 @@ private CompletableFuture shutdownInternally(Duration
timeout) {
davidradl commented on code in PR #25788:
URL: https://github.com/apache/flink/pull/25788#discussion_r1882256774
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java:
##
@@ -264,15 +278,21 @@ protected void initChannel(SocketChannel socketChannel) {
davidradl commented on code in PR #25788:
URL: https://github.com/apache/flink/pull/25788#discussion_r1882238434
##
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java:
##
@@ -230,15 +240,17 @@ public RestClusterClient(
restCl
hanyuzheng7 commented on PR #25759:
URL: https://github.com/apache/flink/pull/25759#issuecomment-2539107679
@snuyanzin
The reason we not support `millisecond`/`nanosecond` is that floor and ceil
not support these two perfectly. You can see here
``` /**
* Keep the algorithm c
davidradl commented on code in PR #25788:
URL: https://github.com/apache/flink/pull/25788#discussion_r1882245040
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java:
##
@@ -317,7 +337,7 @@ private CompletableFuture shutdownInternally(Duration
timeout) {
[
https://issues.apache.org/jira/browse/FLINK-36893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905214#comment-17905214
]
Ryan van Huuksloot commented on FLINK-36893:
We use the Kubernetes Operator
[
https://issues.apache.org/jira/browse/FLINK-36893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905219#comment-17905219
]
Xingcan Cui commented on FLINK-36893:
-
[~ryanvanhuuksloot] I guess you meant savepoi
snuyanzin commented on code in PR #25791:
URL: https://github.com/apache/flink/pull/25791#discussion_r1881898765
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/expressions/ExpressionSerializationTest.java:
##
@@ -172,13 +172,13 @@ public static Stream t
davidradl commented on code in PR #25790:
URL: https://github.com/apache/flink/pull/25790#discussion_r1881899030
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchScheduler.java:
##
@@ -937,6 +965,26 @@ SpeculativeExecutionHandler
getS
davidradl commented on code in PR #25784:
URL: https://github.com/apache/flink/pull/25784#discussion_r1882165452
##
docs/content.zh/docs/dev/table/sql-gateway/overview.md:
##
@@ -116,6 +116,34 @@ $ curl --request GET
http://localhost:8083/v1/sessions/${sessionHandle}/operatio
davidradl commented on code in PR #25784:
URL: https://github.com/apache/flink/pull/25784#discussion_r1882166683
##
docs/content.zh/docs/dev/table/sql-gateway/overview.md:
##
@@ -116,6 +116,34 @@ $ curl --request GET
http://localhost:8083/v1/sessions/${sessionHandle}/operatio
davidradl commented on code in PR #25784:
URL: https://github.com/apache/flink/pull/25784#discussion_r1882169373
##
docs/content.zh/docs/dev/table/sql-gateway/overview.md:
##
@@ -116,6 +116,34 @@ $ curl --request GET
http://localhost:8083/v1/sessions/${sessionHandle}/operatio
davidradl commented on code in PR #25784:
URL: https://github.com/apache/flink/pull/25784#discussion_r1882167903
##
docs/content.zh/docs/dev/table/sql-gateway/overview.md:
##
@@ -116,6 +116,34 @@ $ curl --request GET
http://localhost:8083/v1/sessions/${sessionHandle}/operatio
1 - 100 of 189 matches
Mail list logo
