leozhangsr commented on code in PR #20234:
URL: https://github.com/apache/flink/pull/20234#discussion_r922636336
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitSerializerTest.java:
##
@@ -0,0 +1,54 @@
+/*
godfreyhe commented on code in PR #20243:
URL: https://github.com/apache/flink/pull/20243#discussion_r922623564
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/BatchApproxCountDistinctAggFunctions.java:
##
@@ -0,0 +1,334 @@
godfreyhe commented on code in PR #20243:
URL: https://github.com/apache/flink/pull/20243#discussion_r922623503
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/BatchApproxCountDistinctAggFunctions.java:
##
@@ -0,0 +1,334 @@
godfreyhe commented on code in PR #20243:
URL: https://github.com/apache/flink/pull/20243#discussion_r922623326
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/functions/aggregate/hyperloglog/HyperLogLogPlusPlusTest.java:
##
@@ -0,0 +1,171 @@
+/*
godfreyhe commented on code in PR #20243:
URL: https://github.com/apache/flink/pull/20243#discussion_r922623138
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/BatchApproxCountDistinctAggFunctions.java:
##
@@ -0,0 +1,334 @@
maosuhan commented on code in PR #14376:
URL: https://github.com/apache/flink/pull/14376#discussion_r922617929
##
flink-formats/flink-sql-protobuf/pom.xml:
##
@@ -0,0 +1,86 @@
+
+
+http://maven.apache.org/POM/4.0.0;
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
+
[
https://issues.apache.org/jira/browse/FLINK-27878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-27878.
---
Resolution: Fixed
> [FLIP-232] Add Retry Support For Async I/O In DataStream API
>
[
https://issues.apache.org/jira/browse/FLINK-27878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17567427#comment-17567427
]
Yun Gao commented on FLINK-27878:
-
Merged on master via e85cf8c4cdf417b47f8d53bf3bb202f79e92b205.
>
gaoyunhaii closed pull request #19983: [FLINK-27878][datastream] Add Retry
Support For Async I/O In DataStream API
URL: https://github.com/apache/flink/pull/19983
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
sunshineJK commented on PR #20127:
URL: https://github.com/apache/flink/pull/20127#issuecomment-1186037818
>
Thank you , I'm going to modify it a little bit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-27285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27285:
---
Labels: stale-major test-stability (was: test-stability)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-14527:
---
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-27814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27814:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-13503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-13503:
---
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
[
https://issues.apache.org/jira/browse/FLINK-13218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-13218:
---
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
(was:
[
https://issues.apache.org/jira/browse/FLINK-22411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-22411:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-13247:
---
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-27299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27299:
---
Labels: easyfix pull-request-available stale-assigned (was: easyfix
[
https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-12130:
---
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
[
https://issues.apache.org/jira/browse/FLINK-15832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-15832:
---
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
build (was:
[
https://issues.apache.org/jira/browse/FLINK-13213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-13213:
---
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
[
https://issues.apache.org/jira/browse/FLINK-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-13301:
---
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
(was:
[
https://issues.apache.org/jira/browse/FLINK-14875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-14875:
---
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-15077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-15077:
---
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
(was:
dependabot[bot] closed pull request #31: Bump undertow-core from 1.4.18.Final
to 2.2.11.Final in /java/showcase
URL: https://github.com/apache/flink-statefun-playground/pull/31
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
dependabot[bot] commented on PR #31:
URL:
https://github.com/apache/flink-statefun-playground/pull/31#issuecomment-1185962838
Superseded by #35.
--
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
dependabot[bot] closed pull request #29: Bump undertow-core from 1.4.18.Final
to 2.2.11.Final in /java/connected-components
URL: https://github.com/apache/flink-statefun-playground/pull/29
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
dependabot[bot] commented on PR #32:
URL:
https://github.com/apache/flink-statefun-playground/pull/32#issuecomment-1185962699
Superseded by #34.
--
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
dependabot[bot] commented on PR #30:
URL:
https://github.com/apache/flink-statefun-playground/pull/30#issuecomment-1185962674
Superseded by #33.
--
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
dependabot[bot] commented on PR #29:
URL:
https://github.com/apache/flink-statefun-playground/pull/29#issuecomment-1185963023
Superseded by #36.
--
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
dependabot[bot] opened a new pull request, #36:
URL: https://github.com/apache/flink-statefun-playground/pull/36
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.15.Final.
Commits
dependabot[bot] opened a new pull request, #34:
URL: https://github.com/apache/flink-statefun-playground/pull/34
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.15.Final.
Commits
dependabot[bot] opened a new pull request, #33:
URL: https://github.com/apache/flink-statefun-playground/pull/33
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.15.Final.
Commits
dependabot[bot] opened a new pull request, #35:
URL: https://github.com/apache/flink-statefun-playground/pull/35
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.15.Final.
Commits
dependabot[bot] closed pull request #32: Bump undertow-core from 1.4.18.Final
to 2.2.11.Final in /java/greeter
URL: https://github.com/apache/flink-statefun-playground/pull/32
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
dependabot[bot] closed pull request #30: Bump undertow-core from 1.4.18.Final
to 2.2.11.Final in /java/shopping-cart
URL: https://github.com/apache/flink-statefun-playground/pull/30
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
flinkbot commented on PR #20287:
URL: https://github.com/apache/flink/pull/20287#issuecomment-1185953861
## CI report:
* eda1b8daf6f54fdca6bd276624b564116030665e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #20286:
URL: https://github.com/apache/flink/pull/20286#issuecomment-1185950414
## CI report:
* 801141d5cd7a833e1fcdc1409f41cbbc5419ab12 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #20285:
URL: https://github.com/apache/flink/pull/20285#issuecomment-1185950009
## CI report:
* 2edaa8a696933cc2a1ed21c75dd1ebf59e920e3d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dependabot[bot] opened a new pull request, #20287:
URL: https://github.com/apache/flink/pull/20287
Bumps [aws-java-sdk-s3](https://github.com/aws/aws-sdk-java) from 1.12.7 to
1.12.261.
Changelog
Sourced from
dependabot[bot] opened a new pull request, #20286:
URL: https://github.com/apache/flink/pull/20286
Bumps [aws-java-sdk-s3](https://github.com/aws/aws-sdk-java) from 1.11.951
to 1.12.261.
Changelog
Sourced from
dependabot[bot] opened a new pull request, #20285:
URL: https://github.com/apache/flink/pull/20285
Bumps [aws-java-sdk-s3](https://github.com/aws/aws-sdk-java) from 1.11.171
to 1.12.261.
Changelog
Sourced from
gyfora commented on code in PR #278:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/278#discussion_r922510295
##
flink-kubernetes-mock-shaded/pom.xml:
##
@@ -0,0 +1,154 @@
+
Review Comment:
I completely removed the whole mock shaded module
reswqa commented on code in PR #20271:
URL: https://github.com/apache/flink/pull/20271#discussion_r922441015
##
flink-tests/src/test/java/org/apache/flink/test/scheduling/SpeculativeSchedulerITCase.java:
##
@@ -0,0 +1,245 @@
+/*
+ * Licensed to the Apache Software Foundation
gyfora commented on PR #278:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/278#issuecomment-1185818168
Also I cannot seem to run some tests from IntelliJ:
`Fabric8FlinkStandaloneKubeClientTest`
```
Test ignored.
Test ignored.
gyfora commented on code in PR #278:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/278#discussion_r922428482
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java:
##
@@ -0,0 +1,168 @@
+/*
+ *
gyfora commented on PR #278:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/278#issuecomment-1185789710
I hit a few issues during my initial local testing:
1. Had a maven test failure:
`StandaloneKubernetesJobManagerFactoryTest.testFlinkConfConfigMap:269
expected:
[
https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17567340#comment-17567340
]
Danny Cranmer commented on FLINK-24229:
---
I have published the FLIP [1], I look forward to your
trushev commented on PR #20281:
URL: https://github.com/apache/flink/pull/20281#issuecomment-1185760075
@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.
qingwei91 commented on PR #20235:
URL: https://github.com/apache/flink/pull/20235#issuecomment-1185740486
@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_r922363732
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownVisitor.java:
##
@@ -53,7 +52,6 @@
* Visitor to walk
LadyForest closed pull request #219: [FLINK-28573] Nested type will lose
nullability when converting from TableSchema
URL: https://github.com/apache/flink-table-store/pull/219
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-28573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28573:
---
Labels: pull-request-available (was: )
> Nested type will lose nullability when converting
LadyForest opened a new pull request, #219:
URL: https://github.com/apache/flink-table-store/pull/219
Fix the nullability loss for `ArrayDataType`, `MultisetDataType`,
`MapDataType` and `RowDataType`
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-28571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28571:
---
Labels: pull-request-available (was: )
> Add Chi-squared test as Transformer to ml.feature
afedulov commented on PR #20127:
URL: https://github.com/apache/flink/pull/20127#issuecomment-1185660987
Hi @sunshineJK almost there. The comment on the option still needs to be
fixed. The grammar is off (**e**nable**D** -> **E**nables), "of data of type
Bigdecimal" -> "of BigDecimal data
taosiyuan163 opened a new pull request, #132:
URL: https://github.com/apache/flink-ml/pull/132
### What is the purpose of the change
Add Chi-squared test as Transformer to ml.feature.
The chi-square statistic is a useful tool for understanding the relationship
between two
Jane Chan created FLINK-28573:
-
Summary: Nested type will lose nullability when converting from
TableSchema
Key: FLINK-28573
URL: https://issues.apache.org/jira/browse/FLINK-28573
Project: Flink
maosuhan commented on code in PR #14376:
URL: https://github.com/apache/flink/pull/14376#discussion_r922247078
##
flink-formats/flink-protobuf/pom.xml:
##
@@ -0,0 +1,123 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
maosuhan commented on code in PR #14376:
URL: https://github.com/apache/flink/pull/14376#discussion_r922244413
##
flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util/PbFormatUtils.java:
##
@@ -0,0 +1,135 @@
+/*
+ * Licensed to the Apache Software
maosuhan commented on code in PR #14376:
URL: https://github.com/apache/flink/pull/14376#discussion_r922241944
##
flink-formats/flink-protobuf/pom.xml:
##
@@ -0,0 +1,123 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
maosuhan commented on code in PR #14376:
URL: https://github.com/apache/flink/pull/14376#discussion_r922239131
##
flink-formats/flink-sql-protobuf/pom.xml:
##
@@ -0,0 +1,86 @@
+
+
+http://maven.apache.org/POM/4.0.0;
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
+
maosuhan commented on code in PR #14376:
URL: https://github.com/apache/flink/pull/14376#discussion_r922238897
##
flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util/PbCodegenUtils.java:
##
@@ -0,0 +1,270 @@
+/*
+ * Licensed to the Apache Software
maosuhan commented on code in PR #14376:
URL: https://github.com/apache/flink/pull/14376#discussion_r922237664
##
flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/deserialize/ProtoToRowConverter.java:
##
@@ -0,0 +1,137 @@
+/*
+ * Licensed to the
maosuhan commented on code in PR #14376:
URL: https://github.com/apache/flink/pull/14376#discussion_r922237403
##
flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbFormatConfig.java:
##
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the Apache Software
maosuhan commented on code in PR #14376:
URL: https://github.com/apache/flink/pull/14376#discussion_r922235724
##
flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbFormatFactory.java:
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed to the Apache Software
XComp commented on code in PR #4910:
URL: https://github.com/apache/flink/pull/4910#discussion_r97177
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java:
##
@@ -312,20 +347,104 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17567247#comment-17567247
]
Danny Cranmer commented on FLINK-24229:
---
[~prasaanth07] unfortunately I cannot commit to anything
RyanSkraba commented on PR #20267:
URL: https://github.com/apache/flink/pull/20267#issuecomment-1185538176
@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
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r922154703
##
flink-core/src/main/java/org/apache/flink/util/MutableURLClassLoader.java:
##
@@ -31,10 +35,38 @@ public abstract class MutableURLClassLoader extends
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r922152023
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/resource/ResourceManagerTest.java:
##
@@ -83,9 +82,49 @@ public void testRegisterResource()
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r922151040
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/resource/ClientResourceManager.java:
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-28572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Chan updated FLINK-28572:
Description:
*The following code prints and inserts fine*
{code:java}
public static void
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r922148716
##
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/util/ClientMutableURLClassLoaderTest.java:
##
@@ -0,0 +1,145 @@
+/*
+ * Licensed to the
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r922148341
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/SessionContext.java:
##
@@ -235,69 +231,58 @@ public static SessionContext
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r922147468
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/util/ClientMutableURLClassLoader.java:
##
@@ -0,0 +1,140 @@
+/*
+ * Licensed to the Apache Software
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r922147066
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -949,4 +954,8 @@ public ResolvedCatalogView
[
https://issues.apache.org/jira/browse/FLINK-28572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Chan updated FLINK-28572:
Description:
*The following code prints and inserts fine*
public static void main(String[] args)
Andrew Chan created FLINK-28572:
---
Summary: FlinkSQL executes Table.execute multiple times on the
same Table, and changing the Table.execute code position will produce different
phenomena
Key: FLINK-28572
URL:
[
https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17567225#comment-17567225
]
liwei li commented on FLINK-25421:
--
Oh, my God. I'm so sorry for the late reply. I was on sick leave
[
https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-25256.
--
Fix Version/s: 1.15.0
(was: 1.14.6)
Resolution: Fixed
>
pnowojski closed pull request #19273: [FLINK-25256][streaming] Externally
induced sources replay barriers received over RPC instead of inventing them out
of thin air. [1.14]
URL: https://github.com/apache/flink/pull/19273
--
This is an automated message from the Apache Git Service.
To
pnowojski commented on PR #19273:
URL: https://github.com/apache/flink/pull/19273#issuecomment-1185498343
PR has been abandoned
--
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
Simon Tao created FLINK-28571:
-
Summary: Add Chi-squared test as Transformer to ml.feature
Key: FLINK-28571
URL: https://issues.apache.org/jira/browse/FLINK-28571
Project: Flink
Issue Type: New
MartijnVisser merged PR #20226:
URL: https://github.com/apache/flink/pull/20226
--
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:
sunshineJK commented on PR #20127:
URL: https://github.com/apache/flink/pull/20127#issuecomment-1185475290
hi @afedulov Please review it again
--
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
MartijnVisser merged PR #20253:
URL: https://github.com/apache/flink/pull/20253
--
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:
GJL commented on code in PR #4910:
URL: https://github.com/apache/flink/pull/4910#discussion_r922073308
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java:
##
@@ -312,20 +347,104 @@ public void
lsyldliu commented on code in PR #20242:
URL: https://github.com/apache/flink/pull/20242#discussion_r922068090
##
flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl:
##
@@ -2203,3 +2203,81 @@ SqlNode TryCastFunctionCall() :
return
[
https://issues.apache.org/jira/browse/FLINK-28567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-28567:
--
Assignee: Alexander Trushev
> Introduce predicate inference from one side of join to
[
https://issues.apache.org/jira/browse/FLINK-16165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-16165:
---
Labels: auto-deprioritized-critical auto-deprioritized-major
auto-deprioritized-minor
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-15959:
---
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
(was:
[
https://issues.apache.org/jira/browse/FLINK-20714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-20714:
---
Labels: auto-deprioritized-major auto-deprioritized-minor keberos (was:
[
https://issues.apache.org/jira/browse/FLINK-22255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-22255:
---
Labels: auto-deprioritized-major pull-request-available (was:
pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-19957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-19957:
---
Labels: auto-deprioritized-critical auto-deprioritized-major
auto-deprioritized-minor
[
https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-13856:
---
Labels: auto-deprioritized-major pull-request-available (was:
pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25217:
---
Labels: auto-deprioritized-major pull-request-available (was:
pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-19628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-19628:
---
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
[
https://issues.apache.org/jira/browse/FLINK-21608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21608:
---
Labels: auto-deprioritized-major test-stability (was: stale-major
test-stability)
[
https://issues.apache.org/jira/browse/FLINK-24345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24345:
---
Labels: auto-deprioritized-major pull-request-available (was:
pull-request-available
1 - 100 of 211 matches
Mail list logo
