zoltar9264 commented on code in PR #22669:
URL: https://github.com/apache/flink/pull/22669#discussion_r1243246177
##
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java:
##
@@ -728,6 +731,7 @@ private C
twalthr commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1243252360
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/MapUnionFunction.java:
##
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/FLINK-23620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737499#comment-17737499
]
Junrui Li commented on FLINK-23620:
---
Hi [~autophagy], are you still working on this is
lindong28 commented on code in PR #22670:
URL: https://github.com/apache/flink/pull/22670#discussion_r1243174207
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ImmediateCheckpointingAfterAllTasksFinishedITCase.java:
##
@@ -0,0 +1,147 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-32228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-32228.
--
Resolution: Fixed
> Bump testcontainers to 1.18.2
> -
>
>
MartijnVisser merged PR #654:
URL: https://github.com/apache/flink-web/pull/654
--
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
MartijnVisser merged PR #658:
URL: https://github.com/apache/flink-web/pull/658
--
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
MartijnVisser merged PR #648:
URL: https://github.com/apache/flink-web/pull/648
--
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
MartijnVisser merged PR #629:
URL: https://github.com/apache/flink-web/pull/629
--
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
MartijnVisser commented on PR #604:
URL: https://github.com/apache/flink-web/pull/604#issuecomment-1608966649
Superseded by 3.0.1
--
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 comm
MartijnVisser merged PR #621:
URL: https://github.com/apache/flink-web/pull/621
--
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
MartijnVisser closed pull request #604: Apache Flink Google Cloud PubSub
Connector 3.0.0
URL: https://github.com/apache/flink-web/pull/604
--
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 specifi
MartijnVisser merged PR #615:
URL: https://github.com/apache/flink-web/pull/615
--
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
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737459#comment-17737459
]
Sergey Nuyanzin edited comment on FLINK-30629 at 6/27/23 7:43 AM:
[
https://issues.apache.org/jira/browse/FLINK-32441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737504#comment-17737504
]
Sergey Nuyanzin commented on FLINK-32441:
-
[~srichter] it looks it starts appear
twalthr commented on code in PR #22558:
URL: https://github.com/apache/flink/pull/22558#discussion_r1243287053
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CastFunctionITCase.java:
##
@@ -526,7 +526,7 @@ private static List allTypesBa
[
https://issues.apache.org/jira/browse/FLINK-32268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737510#comment-17737510
]
Sergey Nuyanzin commented on FLINK-32268:
-
probably another variation of https:/
[
https://issues.apache.org/jira/browse/FLINK-32268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737510#comment-17737510
]
Sergey Nuyanzin edited comment on FLINK-32268 at 6/27/23 7:56 AM:
[
https://issues.apache.org/jira/browse/FLINK-31724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-31724:
--
Priority: Major (was: Critical)
> SqlClientITCase.testMatchRecognize fails with "bash -c rm -
[
https://issues.apache.org/jira/browse/FLINK-31724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737511#comment-17737511
]
Qingsheng Ren commented on FLINK-31724:
---
I checked the log but didn't find anythin
Matthias Pohl created FLINK-32445:
-
Summary: BlobStore.closeAndCleanupAllData doesn't do any close
action
Key: FLINK-32445
URL: https://issues.apache.org/jira/browse/FLINK-32445
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-32268:
-
Assignee: Qingsheng Ren
> KafkaTableITCase.testKafkaSourceSinkWithBoundedTimestamp fail
[
https://issues.apache.org/jira/browse/FLINK-32379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737524#comment-17737524
]
Chesnay Schepler commented on FLINK-32379:
--
If it works, go ahead.
> Skip arch
[
https://issues.apache.org/jira/browse/FLINK-32379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-32379:
Assignee: Sergey Nuyanzin (was: Sergey Nuyanzin)
> Skip archunit tests in java1X
[
https://issues.apache.org/jira/browse/FLINK-32379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-32379:
Assignee: Sergey Nuyanzin (was: Chesnay Schepler)
> Skip archunit tests in java1
wanglijie95 commented on code in PR #22878:
URL: https://github.com/apache/flink/pull/22878#discussion_r1243336650
##
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetFormatStatisticsReportUtil.java:
##
@@ -81,7 +81,7 @@ public static Table
zentol commented on code in PR #22850:
URL: https://github.com/apache/flink/pull/22850#discussion_r1243343382
##
flink-connectors/flink-connector-datagen-test/pom.xml:
##
@@ -0,0 +1,89 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001
[
https://issues.apache.org/jira/browse/FLINK-32391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-32391:
-
Assignee: Konstantin Knauf
> YARNSessionFIFOITCase.checkForProhibitedLogContents fails
[
https://issues.apache.org/jira/browse/FLINK-32270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-32270:
-
Assignee: Konstantin Knauf
> Heartbeat timeout in AggregateReduceGroupingITCase.testAgg
[ https://issues.apache.org/jira/browse/FLINK-31664 ]
jackylau deleted comment on FLINK-31664:
--
was (Author: jackylau):
[~Sergey Nuyanzin] ok, thanks for your explain. i will contact the author first
> Add ARRAY_INTERSECT supported in SQL & Table
afedulov commented on PR #21774:
URL: https://github.com/apache/flink/pull/21774#issuecomment-1609058160
Arghhh, this example is broken 🙄
@reswqa The issue is that the original function miscalculates the distance
by making it 10 times larger than it is supposed to be based on the time
e
dawidwys commented on code in PR #22730:
URL: https://github.com/apache/flink/pull/22730#discussion_r1243361973
##
flink-python/pyflink/table/expression.py:
##
@@ -1519,6 +1519,13 @@ def array_union(self, array) -> 'Expression':
"""
return _binary_op("arrayUnio
StefanRRichter opened a new pull request, #22879:
URL: https://github.com/apache/flink/pull/22879
## What is the purpose of the change
Fixes test
`DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfterStore` that was
using the wrong executor to acknowlege a checkpoint. T
[
https://issues.apache.org/jira/browse/FLINK-32441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32441:
---
Labels: pull-request-available test-stability (was: test-stability)
> DefaultSchedulerTest#
[
https://issues.apache.org/jira/browse/FLINK-32441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-32441:
--
Assignee: Stefan Richter
> DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfte
dawidwys commented on code in PR #22730:
URL: https://github.com/apache/flink/pull/22730#discussion_r1243398481
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementTypeStrategy.java:
##
@@ -0,0 +1,147 @@
+/*
+ *
dawidwys commented on code in PR #22730:
URL: https://github.com/apache/flink/pull/22730#discussion_r1243399978
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ComparabilityUtils.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the
flinkbot commented on PR #22879:
URL: https://github.com/apache/flink/pull/22879#issuecomment-1609100787
## CI report:
* 35812bfe4491ba11b979d534147484fb9a9b7869 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dawidwys commented on code in PR #22730:
URL: https://github.com/apache/flink/pull/22730#discussion_r1243400750
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ComparabilityUtils.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-32392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737541#comment-17737541
]
Qingsheng Ren commented on FLINK-32392:
---
Backport to 1.17: 0740649c714b50b83572f14
[
https://issues.apache.org/jira/browse/FLINK-32392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-32392:
--
Fix Version/s: 1.18.0
1.16.3
1.17.2
> Several jobs faile
klion26 commented on PR #658:
URL: https://github.com/apache/flink-web/pull/658#issuecomment-1609126954
@MartijnVisser thanks for the review and merging!
--
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
jiangxin369 commented on code in PR #22670:
URL: https://github.com/apache/flink/pull/22670#discussion_r1243423393
##
docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md:
##
@@ -277,11 +277,10 @@ task with the number of new subtasks equal to the number
of running
swuferhong opened a new pull request, #22880:
URL: https://github.com/apache/flink/pull/22880
## What is the purpose of the change
CI test for https://issues.apache.org/jira/browse/FLINK-18356
## Brief change log
## Verifying this change
## Does this pull r
flinkbot commented on PR #22880:
URL: https://github.com/apache/flink/pull/22880#issuecomment-1609163175
## CI report:
* 73154a85dd96453d338cb1e09e51d37b22fd1f75 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737558#comment-17737558
]
Junhan Yang commented on FLINK-30719:
-
Looks like there is still no any proposed fix
[
https://issues.apache.org/jira/browse/FLINK-31673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737560#comment-17737560
]
Yang Wang commented on FLINK-31673:
---
The new introduced e2e test is failing. Could you
reswqa commented on PR #21774:
URL: https://github.com/apache/flink/pull/21774#issuecomment-1609191262
Well, from my point of view, how to generate data here is not what users
really want to care about. We just need to maintain a self consistent logic. So
It is ok for me to choose both opti
[
https://issues.apache.org/jira/browse/FLINK-30859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737569#comment-17737569
]
Stefan Richter commented on FLINK-30859:
[~tzulitai] I think you forgot to remov
[ https://issues.apache.org/jira/browse/FLINK-30859 ]
Stefan Richter deleted comment on FLINK-30859:
was (Author: srichter):
[~tzulitai] I think you forgot to remove some code here:
https://github.com/apache/flink/blob/149a5e34c1ed8d8943c90
pnowojski commented on code in PR #22879:
URL: https://github.com/apache/flink/pull/22879#discussion_r1243517624
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java:
##
@@ -891,7 +891,7 @@ store, new StandaloneCheckpointIDCounter()))
[ https://issues.apache.org/jira/browse/FLINK-31673 ]
Yang Wang deleted comment on FLINK-31673:
---
was (Author: fly_in_gis):
The new introduced e2e test is failing. Could you please have a look?
https://dev.azure.com/apache-flink/98463496-1af2-4
dawidwys commented on code in PR #22730:
URL: https://github.com/apache/flink/pull/22730#discussion_r1243561691
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -479,4 +480,165 @@ private Stream array
echauchot commented on PR #19:
URL:
https://github.com/apache/flink-connector-cassandra/pull/19#issuecomment-1609303291
> > Maybe we should add tests against flink master snapshot ? Right now
there is only 1.16.x 1.17.x in PRs
>
> added 1.18-SNAPSHOT tests
Got it, the failure
ashangit commented on PR #622:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/622#issuecomment-1609313144
There was an issue with new set of commits due to `deployConfig` being
created too early and missing the potential reset of spec in case of
`rolling_back`
Unittest up
[
https://issues.apache.org/jira/browse/FLINK-32389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-32389.
--
Fix Version/s: 1.18.0
Resolution: Fixed
Fixed in apache/flink:master - 6ebd9f3a5c9b387a
dependabot[bot] closed pull request #22784: Bump guava from 27.0.1-jre to
32.0.0-jre in /flink-formats/flink-orc
URL: https://github.com/apache/flink/pull/22784
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
dependabot[bot] commented on PR #22784:
URL: https://github.com/apache/flink/pull/22784#issuecomment-1609323113
Looks like com.google.guava:guava is up-to-date now, so this is no longer
needed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-32441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737605#comment-17737605
]
Martijn Visser commented on FLINK-32441:
Other occurrences:
https://dev.azure.c
MartijnVisser closed pull request #21402: Name defination suggestion for this
doc
URL: https://github.com/apache/flink/pull/21402
--
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
MartijnVisser closed pull request #21246: Update json.md
URL: https://github.com/apache/flink/pull/21246
--
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:
dawidwys commented on code in PR #22730:
URL: https://github.com/apache/flink/pull/22730#discussion_r1243602098
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementOutputTypeStrategy.java:
##
@@ -0,0 +1,43 @@
+/*
+ * Lice
MartijnVisser commented on PR #21630:
URL: https://github.com/apache/flink/pull/21630#issuecomment-1609337377
> Very sorry for missing the message, I’ll have a look soon.
Thank you!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
dawidwys commented on code in PR #22730:
URL: https://github.com/apache/flink/pull/22730#discussion_r1243602598
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementOutputTypeStrategy.java:
##
@@ -0,0 +1,43 @@
+/*
+ * Lice
dawidwys commented on code in PR #22730:
URL: https://github.com/apache/flink/pull/22730#discussion_r1243604546
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementOutputTypeStrategy.java:
##
@@ -0,0 +1,43 @@
+/*
+ * Lice
dawidwys commented on code in PR #22785:
URL: https://github.com/apache/flink/pull/22785#discussion_r1243613710
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayOfStringArgumentTypeStrategy.java:
##
@@ -0,0 +1,94 @@
+/*
+ * L
RocMarshal commented on PR #20990:
URL: https://github.com/apache/flink/pull/20990#issuecomment-1609371415
Hi, @snuyanzin @MartijnVisser Could you help to review it in your free time?
Thank you~
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
Jiabao Sun created FLINK-32446:
--
Summary: MongoWriter should regularly check whether the last write
time is greater than the specified time.
Key: FLINK-32446
URL: https://issues.apache.org/jira/browse/FLINK-32446
[
https://issues.apache.org/jira/browse/FLINK-32446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737621#comment-17737621
]
Jiabao Sun commented on FLINK-32446:
[~Leonard] Can you help assign this ticket to m
MartijnVisser commented on PR #13:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/13#issuecomment-1609378121
@jayadeep-jayaraman Thanks for the PR! Just for my understanding, is
Conscrypt a requirement when using newer Dataproc clusters?
--
This is an automated message f
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737623#comment-17737623
]
yuanfenghu commented on FLINK-23190:
[~loyi] 我认为有些缺陷，我之前也做过类似的工作，比如
> Make task-slo
[ https://issues.apache.org/jira/browse/FLINK-23190 ]
yuanfenghu deleted comment on FLINK-23190:
was (Author: JIRAUSER296932):
[~loyi] 我认为有些缺陷，我之前也做过类似的工作，比如
> Make task-slot allocation much more evenly
> ---
[
https://issues.apache.org/jira/browse/FLINK-32270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-32270:
-
Assignee: Roman Khachatryan (was: Konstantin Knauf)
> Heartbeat timeout in Agg
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737625#comment-17737625
]
yuanfenghu commented on FLINK-23190:
loyi
I think there are still some problems, m
[
https://issues.apache.org/jira/browse/FLINK-32391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737624#comment-17737624
]
Ferenc Csaky commented on FLINK-32391:
--
Hey! I can take a look at this, feel free t
[
https://issues.apache.org/jira/browse/FLINK-32031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32031:
---
Fix Version/s: gcp-pubsub-3.0.2
> Flink GCP Connector having issues with Conscrypt library
>
[
https://issues.apache.org/jira/browse/FLINK-32391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-32391:
---
Assignee: Ferenc Csaky (was: Konstantin Knauf)
> YARNSessionFIFOITCase.checkForPro
dawidwys commented on code in PR #22785:
URL: https://github.com/apache/flink/pull/22785#discussion_r1243647774
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayJoinFunction.java:
##
@@ -0,0 +1,78 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-32391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737629#comment-17737629
]
Sergey Nuyanzin commented on FLINK-32391:
-
thanks [~ferenc-csaky]
assigned to y
lindong28 commented on code in PR #22670:
URL: https://github.com/apache/flink/pull/22670#discussion_r1243651135
##
docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md:
##
@@ -277,11 +277,10 @@ task with the number of new subtasks equal to the number
of running ta
zoltar9264 commented on code in PR #22669:
URL: https://github.com/apache/flink/pull/22669#discussion_r1243650264
##
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java:
##
@@ -758,6 +762,15 @@ private
lindong28 commented on code in PR #22670:
URL: https://github.com/apache/flink/pull/22670#discussion_r1243653679
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java:
##
@@ -502,6 +503,20 @@ public CompletableFuture
updateTaskExecutionState(
lindong28 commented on code in PR #22670:
URL: https://github.com/apache/flink/pull/22670#discussion_r1243250725
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java:
##
@@ -236,6 +239,16 @@ public SchedulerBase(
this.exceptionHistory =
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737632#comment-17737632
]
yuanfenghu commented on FLINK-23190:
[~loyi] I think there are other issues to cons
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737625#comment-17737625
]
yuanfenghu edited comment on FLINK-23190 at 6/27/23 12:32 PM:
StefanRRichter merged PR #22879:
URL: https://github.com/apache/flink/pull/22879
--
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...@flin
[
https://issues.apache.org/jira/browse/FLINK-32441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737642#comment-17737642
]
Stefan Richter commented on FLINK-32441:
Fixed in master 0c787f5.
> DefaultSche
[
https://issues.apache.org/jira/browse/FLINK-32441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-32441.
--
Resolution: Fixed
> DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfterStore fails wit
dawidwys commented on code in PR #22785:
URL: https://github.com/apache/flink/pull/22785#discussion_r1243696355
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayJoinFunction.java:
##
@@ -0,0 +1,78 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-32441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-32441:
-
Fix Version/s: 1.18.0
> DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfterStore
[
https://issues.apache.org/jira/browse/FLINK-32347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-32347.
--
Resolution: Fixed
> Exceptions from the CompletedCheckpointStore are not registered by the
>
[
https://issues.apache.org/jira/browse/FLINK-32347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-32347:
---
Fix Version/s: 1.18.0
> Exceptions from the CompletedCheckpointStore are not registered by t
XComp commented on PR #22865:
URL: https://github.com/apache/flink/pull/22865#issuecomment-1609483525
@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.
To
XComp commented on PR #22873:
URL: https://github.com/apache/flink/pull/22873#issuecomment-1609491086
force-push after I rebased to the most-recent version of FLINK-32409 that
fixed CI
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-32326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-32326:
---
Fix Version/s: 1.18.0
(was: 1.19.0)
> Disable WAL in RocksDBWriteBatc
[
https://issues.apache.org/jira/browse/FLINK-32345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-32345.
--
Resolution: Fixed
> Improve parallel download of RocksDB incremental state
> -
[
https://issues.apache.org/jira/browse/FLINK-32326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-32326.
--
Resolution: Fixed
> Disable WAL in RocksDBWriteBatchWrapper by default
> -
[
https://issues.apache.org/jira/browse/FLINK-32345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-32345:
---
Fix Version/s: 1.18.0
(was: 1.19.0)
> Improve parallel download of Ro
[
https://issues.apache.org/jira/browse/FLINK-32410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-32410:
---
Fix Version/s: 1.18.0
(was: 1.19.0)
> Allocate hash-based collections
[
https://issues.apache.org/jira/browse/FLINK-32446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-32446:
--
Assignee: Jiabao Sun
> MongoWriter should regularly check whether the last write time is grea
1 - 100 of 276 matches
Mail list logo
