dannycranmer commented on PR #20245:
URL: https://github.com/apache/flink/pull/20245#issuecomment-1182837228
Your CI failed with compile errors, looks like `spotless` failures. You
should run a build locally to ensure all tests and quality checks pass. When
spotless fails you can run a comm
dannycranmer commented on PR #20245:
URL: https://github.com/apache/flink/pull/20245#issuecomment-1182835559
Please squash commits before the final push.
--
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
zhuzhurk commented on code in PR #20222:
URL: https://github.com/apache/flink/pull/20222#discussion_r919710604
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java:
##
@@ -220,46 +217,57 @@ protected void startSchedulingInternal() {
}
zhuzhurk commented on code in PR #20222:
URL: https://github.com/apache/flink/pull/20222#discussion_r919707593
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java:
##
@@ -324,13 +332,24 @@ private void restartTasksWithDelay(final
FailureHandl
zhuzhurk commented on code in PR #20222:
URL: https://github.com/apache/flink/pull/20222#discussion_r919706770
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java:
##
@@ -324,13 +332,24 @@ private void restartTasksWithDelay(final
FailureHandl
zhuzhurk commented on code in PR #20222:
URL: https://github.com/apache/flink/pull/20222#discussion_r919704888
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerBuilder.java:
##
@@ -0,0 +1,319 @@
+/*
+ * Licensed to the Apache Software Foundation
swuferhong commented on code in PR #20009:
URL: https://github.com/apache/flink/pull/20009#discussion_r919703569
##
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcFileFormatFactory.java:
##
@@ -167,5 +190,187 @@ public ChangelogMode getChangelogMode() {
p
godfreyhe commented on code in PR #20248:
URL: https://github.com/apache/flink/pull/20248#discussion_r919698302
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkRecomputeStatisticsProgram.java:
##
@@ -116,32 +121,42 @@ p
dinggege-1024 closed pull request #20241: [FLINK-28486] Flink FileSystem SQL
Connector Doc is not right
URL: https://github.com/apache/flink/pull/20241
--
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 t
[
https://issues.apache.org/jira/browse/FLINK-28486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566189#comment-17566189
]
DingGeGe commented on FLINK-28486:
--
[~lzljs3620320] Hi ,please review the new pr
[#20
dinggege1024 commented on PR #20255:
URL: https://github.com/apache/flink/pull/20255#issuecomment-1182819312
> ## CI report:
> *
[5ff1a54](https://github.com/apache/flink/commit/5ff1a54cfd958034bd92a01778ebea62010856c6)
Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4
dinggege1024 commented on PR #20255:
URL: https://github.com/apache/flink/pull/20255#issuecomment-1182818519
@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 comme
[
https://issues.apache.org/jira/browse/FLINK-28420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-28420:
-
Assignee: Qingsheng Ren
> Support partial lookup caching in lookup join runners
> -
[
https://issues.apache.org/jira/browse/FLINK-28532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-28532:
-
Assignee: Alexander Smirnov
> Support InputFormat as full caching provider in lookup ta
[
https://issues.apache.org/jira/browse/FLINK-28421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-28421:
-
Assignee: Alexander Smirnov
> Support SourceFunction as full caching provider in lookup
[
https://issues.apache.org/jira/browse/FLINK-28418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-28418:
-
Assignee: Qingsheng Ren
> Add runtime provider interface for partial caching lookup
> -
[
https://issues.apache.org/jira/browse/FLINK-28419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-28419:
-
Assignee: Alexander Smirnov
> Add runtime provider interface for full caching lookup
>
morhidi commented on code in PR #311:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/311#discussion_r919692265
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/lifecycle/LifecycleMetrics.java:
##
@@ -0,0 +1,217 @@
+/*
+ * Li
morhidi commented on code in PR #311:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/311#discussion_r919691516
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/lifecycle/LifecycleMetrics.java:
##
@@ -0,0 +1,217 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-28421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-28421:
--
Summary: Support SourceFunction as full caching provider in lookup table
source (was: Support
Qingsheng Ren created FLINK-28532:
-
Summary: Support InputFormat as full caching provider in lookup
table source
Key: FLINK-28532
URL: https://issues.apache.org/jira/browse/FLINK-28532
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Trushev updated FLINK-28530:
--
Description:
Conditions extraction in batch mode was introduced here FLINK-12509 and i
[
https://issues.apache.org/jira/browse/FLINK-28531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566188#comment-17566188
]
Aitozi commented on FLINK-28531:
[~xtsong] Thanks for your information. It seems a dupli
[
https://issues.apache.org/jira/browse/FLINK-28530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Trushev updated FLINK-28530:
--
Description:
Conditions extraction in batch mode was introduced here FLINK-12509 and i
gyfora commented on code in PR #311:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/311#discussion_r919678114
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/lifecycle/LifecycleMetrics.java:
##
@@ -0,0 +1,217 @@
+/*
+ * Lic
[
https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566180#comment-17566180
]
Danny Cranmer commented on FLINK-24229:
---
[~prasaanth07] Flink connectors are being
trushev commented on PR #20261:
URL: https://github.com/apache/flink/pull/20261#issuecomment-1182786958
@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.
trushev commented on PR #20261:
URL: https://github.com/apache/flink/pull/20261#issuecomment-1182786906
`CassandraConnectorITCase` failed on CI but it shouldn't have been affected
by this changes and it works fine locally. Triggering pipeline again
--
This is an automated message from the
morhidi commented on code in PR #311:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/311#discussion_r919663834
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/lifecycle/LifecycleMetrics.java:
##
@@ -0,0 +1,217 @@
+/*
+ * Li
wanglijie95 commented on code in PR #20222:
URL: https://github.com/apache/flink/pull/20222#discussion_r919661044
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java:
##
@@ -385,7 +386,8 @@ private SchedulerNG createScheduler(
dinggege1024 commented on PR #20255:
URL: https://github.com/apache/flink/pull/20255#issuecomment-1182777301
Hi @JingsongLi review this issue,plz. I have updated in this issue by your
suggestion.
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
wanglijie95 commented on code in PR #20222:
URL: https://github.com/apache/flink/pull/20222#discussion_r919645557
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java:
##
@@ -324,13 +332,24 @@ private void restartTasksWithDelay(final
FailureHa
[
https://issues.apache.org/jira/browse/FLINK-28531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566162#comment-17566162
]
Xintong Song commented on FLINK-28531:
--
[~aitozi],
Which version of Flink did you u
morhidi commented on code in PR #316:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/316#discussion_r919652468
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/service/FlinkServiceTest.java:
##
@@ -293,7 +293,7 @@ public void testCl
morhidi commented on code in PR #316:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/316#discussion_r919652210
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/service/FlinkServiceTest.java:
##
@@ -293,7 +293,7 @@ public void testCl
morhidi commented on code in PR #316:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/316#discussion_r919652210
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/service/FlinkServiceTest.java:
##
@@ -293,7 +293,7 @@ public void testCl
LadyForest commented on code in PR #210:
URL: https://github.com/apache/flink-table-store/pull/210#discussion_r919649696
##
docs/content/docs/engines/spark.md:
##
@@ -41,17 +41,33 @@ Download [flink-table-store-spark-{{< version
>}}.jar](https://repo.maven.apache
You are using
liuzhuang2017 commented on PR #20253:
URL: https://github.com/apache/flink/pull/20253#issuecomment-1182767837
@MartijnVisser , Sorry to bother you again, can you help me review this pr?
Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
[
https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566154#comment-17566154
]
Prasaanth commented on FLINK-24229:
---
Hi all, excited to see Flink supporting a DynamoD
LadyForest commented on code in PR #210:
URL: https://github.com/apache/flink-table-store/pull/210#discussion_r919642060
##
docs/content/docs/engines/spark.md:
##
@@ -41,17 +41,33 @@ Download [flink-table-store-spark-{{< version
>}}.jar](https://repo.maven.apache
You are using
swuferhong commented on code in PR #20008:
URL: https://github.com/apache/flink/pull/20008#discussion_r919636056
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/utils/StatisticsReportTestBase.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed to the Apac
gaoyunhaii commented on code in PR #20223:
URL: https://github.com/apache/flink/pull/20223#discussion_r919606689
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/JobStatusHook.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
gaoyunhaii commented on PR #20239:
URL: https://github.com/apache/flink/pull/20239#issuecomment-1182736598
@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
morhidi commented on code in PR #316:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/316#discussion_r919620212
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/service/FlinkServiceTest.java:
##
@@ -293,7 +293,7 @@ public void testCl
DavidLiu001 commented on PR #20143:
URL: https://github.com/apache/flink/pull/20143#issuecomment-1182728130
@MartijnVisser The comment issues have been resolved, if there is no
further comment, please help merge this PR.
Thanks
--
This is an automated message from the Apache Git Ser
SteNicholas commented on code in PR #211:
URL: https://github.com/apache/flink-table-store/pull/211#discussion_r919616462
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/AbstractTableStoreFactory.java:
##
@@ -132,9 +133,14 @@ private static vo
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566131#comment-17566131
]
Jinzhong Li commented on FLINK-28515:
-
[~roman] [~yunta] Could you please take a loo
SteNicholas commented on code in PR #211:
URL: https://github.com/apache/flink-table-store/pull/211#discussion_r919615647
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/AbstractTableStoreFactory.java:
##
@@ -132,9 +133,14 @@ private static vo
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566127#comment-17566127
]
Yanfei Lei edited comment on FLINK-28515 at 7/13/22 3:20 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566127#comment-17566127
]
Yanfei Lei edited comment on FLINK-28515 at 7/13/22 3:20 AM:
-
Aitozi commented on PR #20256:
URL: https://github.com/apache/flink/pull/20256#issuecomment-1182719574
@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.
T
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566127#comment-17566127
]
Yanfei Lei commented on FLINK-28515:
I think this is reasonable. Although TM will de
leozhangsr commented on PR #20234:
URL: https://github.com/apache/flink/pull/20234#issuecomment-1182716948
@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-28531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566124#comment-17566124
]
Aitozi commented on FLINK-28531:
cc [~wangyang0918] [~xtsong]
> Shutdown cluster after
[
https://issues.apache.org/jira/browse/FLINK-28122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-28122:
---
Assignee: hunter
> Translate "Overview " and "Project Configuration" in "User-defined Sources &
>
[
https://issues.apache.org/jira/browse/FLINK-28531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566123#comment-17566123
]
Aitozi commented on FLINK-28531:
I propose to fix this in two way:
First, in the Dispat
[
https://issues.apache.org/jira/browse/FLINK-28529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566122#comment-17566122
]
Yanfei Lei commented on FLINK-28529:
Sure, look like it's caused by checkpoint expir
bgeng777 commented on code in PR #316:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/316#discussion_r919604652
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/service/FlinkServiceTest.java:
##
@@ -293,7 +293,7 @@ public void testC
Aitozi created FLINK-28531:
--
Summary: Shutdown cluster after history server archive finished
Key: FLINK-28531
URL: https://issues.apache.org/jira/browse/FLINK-28531
Project: Flink
Issue Type: Bug
bgeng777 commented on code in PR #316:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/316#discussion_r919604652
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/service/FlinkServiceTest.java:
##
@@ -293,7 +293,7 @@ public void testC
wangyang0918 commented on code in PR #316:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/316#discussion_r919604132
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/service/FlinkServiceTest.java:
##
@@ -293,7 +293,7 @@ public void t
flinkbot commented on PR #20261:
URL: https://github.com/apache/flink/pull/20261#issuecomment-1182705940
## CI report:
* 221a9ecd46069d80583c766bf39f095714801f88 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Tartarus0zm commented on PR #20252:
URL: https://github.com/apache/flink/pull/20252#issuecomment-1182705141
@wuchong @godfreyhe @lsyldliu @luoyuxia @beyond1920 please take a look,
if you have time, thanks
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-28122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566118#comment-17566118
]
hunter commented on FLINK-28122:
[~jark] Hi,Jark,I am very interested to do it, I can do
godfreyhe commented on code in PR #20246:
URL: https://github.com/apache/flink/pull/20246#discussion_r919600208
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala:
##
@@ -397,7 +398,7 @@ class TableEnvironmentTest {
()
[
https://issues.apache.org/jira/browse/FLINK-28530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28530:
---
Labels: pull-request-available (was: )
> Improvement of extraction of conditions that can b
trushev opened a new pull request, #20261:
URL: https://github.com/apache/flink/pull/20261
## What is the purpose of the change
This PR is aimed at replacing current extraction algorithm with new one
which covers more complex case with deep nested predicate:
for all n > 0
((
[
https://issues.apache.org/jira/browse/FLINK-28265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566116#comment-17566116
]
Yang Wang commented on FLINK-28265:
---
Since we always add the new checkpoint first and
luoyuxia commented on PR #20247:
URL: https://github.com/apache/flink/pull/20247#issuecomment-1182702339
@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.
luoyuxia commented on PR #20251:
URL: https://github.com/apache/flink/pull/20251#issuecomment-1182701721
@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-26412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26412:
-
Summary: Hive dialect supports "CREATE FUNCTION USING xxx.jar" (was: Hive
dialect supports "CREATE TEMP
[
https://issues.apache.org/jira/browse/FLINK-26412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26412:
-
Description:
In Hive, it's supported to use such sql like
{code:java}
CREATE FUNCTION USING xxx.jar
{cod
flinkbot commented on PR #20260:
URL: https://github.com/apache/flink/pull/20260#issuecomment-1182700946
## CI report:
* 0c6876ba81e8834bf4846331783638f29b619884 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-24900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-24900:
Fix Version/s: 1.17.0
> Support to run multiple shuffle plugins in one session cluster
> -
flinkbot commented on PR #20259:
URL: https://github.com/apache/flink/pull/20259#issuecomment-1182700677
## CI report:
* af4fd0821d53c752d5fe88982e17af7cfd0cbb6b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566114#comment-17566114
]
Huang Xingbo commented on FLINK-28525:
--
Thanks for the quick fix.
> HiveDialectITC
yangjunhan commented on PR #20260:
URL: https://github.com/apache/flink/pull/20260#issuecomment-1182699144
Hi, @simplejason. Could you please help review this PR regarding the
runtime-web changes?
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
[
https://issues.apache.org/jira/browse/FLINK-28525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566112#comment-17566112
]
luoyuxia commented on FLINK-28525:
--
Thanks for reporting it. I'll fix it as soon as pos
[
https://issues.apache.org/jira/browse/FLINK-28530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Trushev updated FLINK-28530:
--
Summary: Improvement of extraction of conditions that can be pushed into
join inputs
[
https://issues.apache.org/jira/browse/FLINK-28315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28315:
---
Labels: pull-request-available (was: )
> [UI] Introduce aggregate stats in tables of the su
yangjunhan opened a new pull request, #20260:
URL: https://github.com/apache/flink/pull/20260
## What is the purpose of the change
A subtask for the
[FLIP-241](https://cwiki.apache.org/confluence/display/FLINK/FLIP-241%3A+Completed+Jobs+Information+Enhancement),
the reference
[
https://issues.apache.org/jira/browse/FLINK-28524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566111#comment-17566111
]
Jark Wu commented on FLINK-28524:
-
Sorry, there is already an issue for this. FLINK-1610
[
https://issues.apache.org/jira/browse/FLINK-28524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-28524.
---
Resolution: Duplicate
> Translate "User-defined Sources & Sinks"
>
Alexander Trushev created FLINK-28530:
-
Summary: Improvement of conditions extraction that can be pushed
into join inputs
Key: FLINK-28530
URL: https://issues.apache.org/jira/browse/FLINK-28530
Pr
[
https://issues.apache.org/jira/browse/FLINK-26993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566110#comment-17566110
]
Huang Xingbo commented on FLINK-26993:
--
instance in release-1.14:
https://dev.azur
[
https://issues.apache.org/jira/browse/FLINK-28525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28525:
---
Labels: pull-request-available test-stability (was: test-stability)
> HiveDialectITCase.tes
luoyuxia opened a new pull request, #20259:
URL: https://github.com/apache/flink/pull/20259
## What is the purpose of the change
To fix the unstable test for
`HiveDialectITCase#testTableWithSubDirsInPartitionDir`
## Brief change log
- Change `satisfies` to `satisfi
[
https://issues.apache.org/jira/browse/FLINK-28305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566109#comment-17566109
]
Huang Xingbo commented on FLINK-28305:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-28527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo closed FLINK-28527.
Resolution: Duplicate
> Fail to lateral join with UDTF from Table with timstamp column
> -
[
https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566106#comment-17566106
]
Huang Xingbo commented on FLINK-28198:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-28529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-28529:
Assignee: Yanfei Lei
> ChangelogPeriodicMaterializationSwitchStateBackendITCase.testSwitc
[
https://issues.apache.org/jira/browse/FLINK-28529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566105#comment-17566105
]
Huang Xingbo commented on FLINK-28529:
--
Hi [~Yanfei Lei], could you help take a loo
[
https://issues.apache.org/jira/browse/FLINK-28525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-28525:
Assignee: luoyuxia
> HiveDialectITCase.testTableWithSubDirsInPartitionDir failed with
>
Huang Xingbo created FLINK-28529:
Summary:
ChangelogPeriodicMaterializationSwitchStateBackendITCase.testSwitchFromDisablingToEnablingInClaimMode
failed with CheckpointException: Checkpoint expired before completing
Key: FLINK-285
[
https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-28528:
---
Description:
The bug can be reproduced with the following test. The test can pass if we use
the com
Xuannan Su created FLINK-28528:
--
Summary: Table.getSchema fails on table with watermark
Key: FLINK-28528
URL: https://issues.apache.org/jira/browse/FLINK-28528
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-28267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-28267:
-
Assignee: Qingsheng Ren
> KafkaSourceLegacyITCase.testBrokerFailure hang on azure
> ---
Xuannan Su created FLINK-28527:
--
Summary: Fail to lateral join with UDTF from Table with timstamp
column
Key: FLINK-28527
URL: https://issues.apache.org/jira/browse/FLINK-28527
Project: Flink
I
Xuannan Su created FLINK-28526:
--
Summary: Fail to lateral join with UDTF from Table with timstamp
column
Key: FLINK-28526
URL: https://issues.apache.org/jira/browse/FLINK-28526
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-28525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566100#comment-17566100
]
Huang Xingbo commented on FLINK-28525:
--
Hi [~luoyuxia] , could you help take a look
1 - 100 of 337 matches
Mail list logo
