Sxnan commented on PR #20147:
URL: https://github.com/apache/flink/pull/20147#issuecomment-1191070807
Hi @gaoyunhaii! Thanks for your review! I made changes according to your
comments. Could you please take another look?
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-26944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26944:
---
Labels: pull-request-available (was: )
> Add ADD_MONTHS supported in SQL and Table API
>
zzzs opened a new pull request, #20323:
URL: https://github.com/apache/flink/pull/20323
## What is the purpose of the change
Add add_months(startDate, numMonths) SQL function.
Examples:
```sql
> SELECT add_months('2016-08-31', 1);
2016-09-30
> SELECT
TanYuxin-tyx commented on PR #20315:
URL: https://github.com/apache/flink/pull/20315#issuecomment-1191057362
@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
yunfengzhou-hub commented on code in PR #20275:
URL: https://github.com/apache/flink/pull/20275#discussion_r926266725
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java:
##
@@ -308,6 +335,26 @@ private void
dongjoon-hyun commented on PR #19844:
URL: https://github.com/apache/flink/pull/19844#issuecomment-1191056678
Could you review this when you have some time, @mbalassi and @gyfora ? :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
dongjoon-hyun commented on PR #19844:
URL: https://github.com/apache/flink/pull/19844#issuecomment-1191055489
For a record, to reviewers, ORC-1198 is already shipped via Apache ORC 1.7.5
and included in this PR.
--
This is an automated message from the Apache Git Service.
To respond to
Tartarus0zm commented on code in PR #20252:
URL: https://github.com/apache/flink/pull/20252#discussion_r926251262
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTableAs.java:
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software
TanYuxin-tyx commented on PR #20315:
URL: https://github.com/apache/flink/pull/20315#issuecomment-1191030734
@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
TanYuxin-tyx commented on PR #20315:
URL: https://github.com/apache/flink/pull/20315#issuecomment-1191023869
@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
fredia commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r926233838
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java:
##
@@ -0,0 +1,255 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/FLINK-28514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao resolved FLINK-28514.
-
Resolution: Fixed
Merged into master via 9a141441cb96837d92c4bd348b4c05617100e14b
> Remove
[
https://issues.apache.org/jira/browse/FLINK-28619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569257#comment-17569257
]
zhouli edited comment on FLINK-28619 at 7/21/22 3:56 AM:
-
when using
[
https://issues.apache.org/jira/browse/FLINK-28619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569257#comment-17569257
]
zhouli commented on FLINK-28619:
when using upsert-kafka as a sink, it will write DELETE data as Kafka
wsry merged PR #20294:
URL: https://github.com/apache/flink/pull/20294
--
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:
wsry commented on PR #20294:
URL: https://github.com/apache/flink/pull/20294#issuecomment-1191009568
@TanYuxin-tyx Thanks for the change. LGTM.
--
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
zhipeng93 commented on code in PR #131:
URL: https://github.com/apache/flink-ml/pull/131#discussion_r926208138
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorslicer/VectorSlicer.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/FLINK-28619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569256#comment-17569256
]
simenliuxing commented on FLINK-28619:
--
[~Zsigner] [~Leo Zhou] [~jark] can you take a look at it？
[
https://issues.apache.org/jira/browse/FLINK-28151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-28151:
--
Summary: Introduce the operation-related API for HiveServer2 Endpoint
(was: Introduce the
[
https://issues.apache.org/jira/browse/FLINK-28151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-28151:
--
Description: (was: Allow to cancel the ope)
> Allow to cancel the Operation for the
[
https://issues.apache.org/jira/browse/FLINK-28151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-28151:
--
Description: Allow to cancel the ope (was: Allow to open/close/configure
the session using
[
https://issues.apache.org/jira/browse/FLINK-28151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-28151:
--
Summary: Allow to cancel the Operation for the HiveServer2 Endpoint (was:
Introduce the
[
https://issues.apache.org/jira/browse/FLINK-28519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao reassigned FLINK-28519:
---
Assignee: Yuxin Tan
> Fix the bug that SortMergeResultPartitionReadScheduler may not read
simenliuxing created FLINK-28619:
Summary: flink sql window aggregation using early fire will
produce empty data
Key: FLINK-28619
URL: https://issues.apache.org/jira/browse/FLINK-28619
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28565.
Fix Version/s: table-store-0.3.0
Resolution: Fixed
master:
[
https://issues.apache.org/jira/browse/FLINK-28376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao reassigned FLINK-28376:
---
Assignee: Yuxin Tan
> Restrict the number of threads for sort-shuffle data read
>
[
https://issues.apache.org/jira/browse/FLINK-28376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao resolved FLINK-28376.
-
Resolution: Fixed
Merged into master via 2f76a30569332728def4df0c316ee1a4f3409aa9
> Restrict
JingsongLi merged PR #220:
URL: https://github.com/apache/flink-table-store/pull/220
--
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:
wsry merged PR #20308:
URL: https://github.com/apache/flink/pull/20308
--
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:
wsry commented on PR #20308:
URL: https://github.com/apache/flink/pull/20308#issuecomment-1190994642
@TanYuxin-tyx Thanks for the change. LGTM.
--
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
[
https://issues.apache.org/jira/browse/FLINK-28152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-28152:
-
Assignee: Shengkai Fang
> Introduce the statement-related API for HiveServer2 Endpoint
[
https://issues.apache.org/jira/browse/FLINK-28514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao reassigned FLINK-28514:
---
Assignee: Yuxin Tan
> Remove data flush in SortMergeResultPartition
>
yunfengzhou-hub commented on code in PR #20275:
URL: https://github.com/apache/flink/pull/20275#discussion_r926212897
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/CloseableSubtaskGateway.java:
##
@@ -0,0 +1,182 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-28618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liubo updated FLINK-28618:
--
Description:
I build the newest master flink and copy
yunfengzhou-hub commented on code in PR #20275:
URL: https://github.com/apache/flink/pull/20275#discussion_r926212561
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorEventDispatcherImpl.java:
##
@@ -82,6 +83,10 @@ public void
liubo created FLINK-28618:
-
Summary: Cannot use hive.dialect on master
Key: FLINK-28618
URL: https://issues.apache.org/jira/browse/FLINK-28618
Project: Flink
Issue Type: Bug
Components:
yunfengzhou-hub commented on code in PR #20275:
URL: https://github.com/apache/flink/pull/20275#discussion_r926212101
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java:
##
@@ -277,29 +300,33 @@ private void
wsry commented on PR #20294:
URL: https://github.com/apache/flink/pull/20294#issuecomment-1190986105
@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
yunfengzhou-hub commented on code in PR #20275:
URL: https://github.com/apache/flink/pull/20275#discussion_r926211762
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java:
##
@@ -277,29 +300,33 @@ private void
yunfengzhou-hub commented on code in PR #20275:
URL: https://github.com/apache/flink/pull/20275#discussion_r926211546
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/CloseableSubtaskGateway.java:
##
@@ -0,0 +1,182 @@
+/*
+ * Licensed to the Apache
yunfengzhou-hub commented on code in PR #20275:
URL: https://github.com/apache/flink/pull/20275#discussion_r926210901
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java:
##
@@ -236,7 +240,20 @@ public void
yunfengzhou-hub commented on code in PR #20275:
URL: https://github.com/apache/flink/pull/20275#discussion_r926210804
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/CloseableSubtaskGateway.java:
##
@@ -0,0 +1,182 @@
+/*
+ * Licensed to the Apache
yunfengzhou-hub commented on code in PR #20275:
URL: https://github.com/apache/flink/pull/20275#discussion_r926210207
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/CloseableSubtaskGateway.java:
##
@@ -0,0 +1,182 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-28550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao resolved FLINK-28550.
-
Resolution: Fixed
Merged into master via 5923c510f24269a83e9886f96f62571602c448e7
> Remove the
[
https://issues.apache.org/jira/browse/FLINK-28547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-28547:
Component/s: Tests
> Add IT cases for SpeculativeScheduler
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-28547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28547.
---
Resolution: Done
Done via fd763672b858e74b24760e5c98ff9af22caa8a14
> Add IT cases for SpeculativeScheduler
yunfengzhou-hub commented on code in PR #20275:
URL: https://github.com/apache/flink/pull/20275#discussion_r926209447
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/CloseableSubtaskGateway.java:
##
@@ -0,0 +1,182 @@
+/*
+ * Licensed to the Apache
zhuzhurk closed pull request #20271: [FLINK-28547][runtime] Add IT cases for
SpeculativeScheduler.
URL: https://github.com/apache/flink/pull/20271
--
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
wsry merged PR #20295:
URL: https://github.com/apache/flink/pull/20295
--
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:
[
https://issues.apache.org/jira/browse/FLINK-28446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan closed FLINK-28446.
-
> Expose more information in PartitionDescriptor to support more optimized
> Shuffle Service
>
wsry commented on PR #20295:
URL: https://github.com/apache/flink/pull/20295#issuecomment-1190979018
@TanYuxin-tyx Thanks for the change. LGTM.
--
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
[
https://issues.apache.org/jira/browse/FLINK-28446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao resolved FLINK-28446.
-
Resolution: Fixed
Merged into master via e630778eb8b500148b01583d34ec195a80c99c3f
> Expose
Myracle commented on PR #20319:
URL: https://github.com/apache/flink/pull/20319#issuecomment-1190977997
@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-24434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569247#comment-17569247
]
Huang Xingbo commented on FLINK-24434:
--
{code:java}
2022-07-20T13:36:55.8006262Z Caused by:
[
https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
KurtDing updated FLINK-28177:
-
Attachment: image-2022-07-21-10-48-33-213.png
>
[
https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569244#comment-17569244
]
KurtDing commented on FLINK-28177:
--
I think this is because of the connection loss of elasticsearch in
[
https://issues.apache.org/jira/browse/FLINK-28550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao reassigned FLINK-28550:
---
Assignee: Yuxin Tan
> Remove the unused field in SortMergeSubpartitionReader
>
[
https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569245#comment-17569245
]
KurtDing commented on FLINK-28177:
--
!image-2022-07-21-10-48-33-213.png!
>
link3280 commented on PR #20159:
URL: https://github.com/apache/flink/pull/20159#issuecomment-1190976770
New ticket https://issues.apache.org/jira/browse/FLINK-28617.
I'll open tickets/PRs for the gateway separately for the rest statements.
--
This is an automated message from the
jjiey commented on PR #20316:
URL: https://github.com/apache/flink/pull/20316#issuecomment-1190976473
> @jjiey could you a add picture of the part you translate? Just like
[#19496
(comment)](https://github.com/apache/flink/pull/19496#issuecomment-1115132533)
@ChengkaiYang2022 fine.
Paul Lin created FLINK-28617:
Summary: Support stop job statement in SqlGatewayService
Key: FLINK-28617
URL: https://issues.apache.org/jira/browse/FLINK-28617
Project: Flink
Issue Type: Sub-task
luoyuxia commented on PR #20211:
URL: https://github.com/apache/flink/pull/20211#issuecomment-1190972490
@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-28530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569238#comment-17569238
]
Alexander Trushev commented on FLINK-28530:
---
Please assign this ticket to me
> Improvement of
fredia commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r92622
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStoreImpl.java:
##
@@ -409,39 +405,31 @@ private void discardLocalStateForCheckpoint(long
fsk119 commented on PR #20159:
URL: https://github.com/apache/flink/pull/20159#issuecomment-1190968837
> > Thanks for your contribution. Currently the `SqlGatewayService` already
supported executeSql, could you also support this feature in the SQL Gateway?
>
> @fsk119
[
https://issues.apache.org/jira/browse/FLINK-24434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-24434:
-
Affects Version/s: 1.16.0
> PyFlink YARN per-job on Docker test fails on Azure
>
Sxnan commented on code in PR #20147:
URL: https://github.com/apache/flink/pull/20147#discussion_r926192780
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java:
##
@@ -2203,13 +2199,21 @@ public StreamGraph
[
https://issues.apache.org/jira/browse/FLINK-24434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-24434:
Assignee: Huang Xingbo
> PyFlink YARN per-job on Docker test fails on Azure
>
[
https://issues.apache.org/jira/browse/FLINK-24434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-24434:
-
Priority: Critical (was: Major)
> PyFlink YARN per-job on Docker test fails on Azure
>
link3280 commented on PR #20159:
URL: https://github.com/apache/flink/pull/20159#issuecomment-1190954677
> Thanks for your contribution. Currently the `SqlGatewayService` already
supported executeSql, could you also support this feature in the SQL Gateway?
@fsk119 `SqlGatewayService`
[
https://issues.apache.org/jira/browse/FLINK-24434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569232#comment-17569232
]
Huang Xingbo commented on FLINK-24434:
--
[
https://issues.apache.org/jira/browse/FLINK-24434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569231#comment-17569231
]
Huang Xingbo commented on FLINK-24434:
--
zzzs commented on PR #20310:
URL: https://github.com/apache/flink/pull/20310#issuecomment-1190951809
@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-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569228#comment-17569228
]
Yingjie Cao commented on FLINK-27691:
-
yunfengzhou-hub commented on code in PR #133:
URL: https://github.com/apache/flink-ml/pull/133#discussion_r926165477
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/featurehasher/FeatureHasherParams.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-26949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569219#comment-17569219
]
zhaoshuo commented on FLINK-26949:
--
[~lsy] I've made a pull request. Please take a review.
> Add NVL
rkhachatryan commented on code in PR #20217:
URL: https://github.com/apache/flink/pull/20217#discussion_r926152251
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendLocalHandle.java:
##
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apache
rkhachatryan commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r926149940
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java:
##
@@ -0,0 +1,255 @@
+/*
+ * Licensed to the Apache Software
rkhachatryan commented on code in PR #20217:
URL: https://github.com/apache/flink/pull/20217#discussion_r926143658
##
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java:
##
@@ -329,14 +343,28 @@ public void confirm(SequenceNumber
rkhachatryan commented on code in PR #20217:
URL: https://github.com/apache/flink/pull/20217#discussion_r926143502
##
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/DuplicatingOutputStreamWithPos.java:
##
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the Apache
wanglijie95 commented on PR #20218:
URL: https://github.com/apache/flink/pull/20218#issuecomment-1190888225
@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
rkhachatryan commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r926126113
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java:
##
@@ -0,0 +1,255 @@
+/*
+ * Licensed to the Apache Software
rkhachatryan commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r926125810
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java:
##
@@ -0,0 +1,255 @@
+/*
+ * Licensed to the Apache Software
rkhachatryan commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r926124747
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java:
##
@@ -0,0 +1,255 @@
+/*
+ * Licensed to the Apache Software
rkhachatryan commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r926124747
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java:
##
@@ -0,0 +1,255 @@
+/*
+ * Licensed to the Apache Software
rkhachatryan commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r926118182
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStoreImpl.java:
##
@@ -141,6 +158,29 @@ public void storeLocalState(
[
https://issues.apache.org/jira/browse/FLINK-22234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-22234:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-25442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25442:
---
Labels: auto-deprioritized-critical stale-critical test-stability (was:
[
https://issues.apache.org/jira/browse/FLINK-20020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-20020:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-15123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-15123:
---
Labels: auto-deprioritized-major starter (was: stale-major starter)
Priority: Minor
[
https://issues.apache.org/jira/browse/FLINK-28083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28083:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-27805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27805:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-28424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28424:
---
Labels: stale-critical test-stability (was: test-stability)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-28125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28125:
---
Labels: pull-request-available stale-assigned starter (was:
pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-25582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25582:
---
Labels: auto-deprioritized-minor pull-request-available (was:
pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-27415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27415:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
dannycranmer commented on PR #20133:
URL: https://github.com/apache/flink/pull/20133#issuecomment-1190799792
@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
rkhachatryan commented on code in PR #19679:
URL: https://github.com/apache/flink/pull/19679#discussion_r925990350
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapAggregatingState.java:
##
@@ -136,18 +144,29 @@ public ACC apply(ACC accumulator, IN value)
xinbinhuang commented on PR #20289:
URL: https://github.com/apache/flink/pull/20289#issuecomment-1190689007
@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
qingwei91 commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r925920284
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownVisitor.java:
##
@@ -53,7 +52,6 @@
* Visitor to walk
1 - 100 of 314 matches
Mail list logo
