[
https://issues.apache.org/jira/browse/FLINK-29409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiang Xin closed FLINK-29409.
-
> Add Transformer and Estimator for VarianceThresholdSelector
>
[
https://issues.apache.org/jira/browse/FLINK-29409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiang Xin resolved FLINK-29409.
---
Resolution: Fixed
Merged to master via ebc80ceab35ebee33e33f85704e3f4d6a85a9fd4
> Add Transformer
Yunfeng Zhou created FLINK-29595:
Summary: Add Estimator and Transformer for ChiSqSelector
Key: FLINK-29595
URL: https://issues.apache.org/jira/browse/FLINK-29595
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiang Xin updated FLINK-29592:
--
Fix Version/s: ml-2.2.0
> Add Transformer and Estimator for RobustScaler
>
[
https://issues.apache.org/jira/browse/FLINK-29593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiang Xin updated FLINK-29593:
--
Fix Version/s: ml-2.2.0
> Add Approximate Quantile Util
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-29409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiang Xin updated FLINK-29409:
--
Fix Version/s: ml-2.2.0
> Add Transformer and Estimator for VarianceThresholdSelector
>
[
https://issues.apache.org/jira/browse/FLINK-29424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiang Xin updated FLINK-29424:
--
Fix Version/s: ml-2.2.0
> Add Pull Request Template for flink-ml Project
>
[
https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616302#comment-17616302
]
Ran Tao commented on FLINK-27529:
-
[~thw]hi, Thomas, can u take a look. I have post some JetBrains IDEA
luoyuxia commented on code in PR #21026:
URL: https://github.com/apache/flink/pull/21026#discussion_r993223867
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserTypeCheckProcFactory.java:
##
@@ -1355,6 +1403,46 @@
[
https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-27529:
Labels: pull-request-available (was: pull-request-available stale-assigned)
>
kristoffSC opened a new pull request, #21029:
URL: https://github.com/apache/flink/pull/21029
## What is the purpose of the change
Unchanged backport of #<20979>
Fixing FLINK-29509 by setting the correct `subtaskId` and `numberOfSubtasks`
for
chucheng92 commented on PR #19654:
URL: https://github.com/apache/flink/pull/19654#issuecomment-1275852912
> @chucheng92 can you add a unit test? maybe that would clarify what the
underlying problem is.
pls see the IDEA screenshot. i think we need to change to equals method
instead of
[
https://issues.apache.org/jira/browse/FLINK-29586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29586:
---
Labels: pull-request-available (was: )
> Let write buffer spillable
>
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616298#comment-17616298
]
Chesnay Schepler commented on FLINK-29589:
--
Does this also happen in 1.15 / 1.16-SNAPSHOT
JingsongLi commented on PR #315:
URL:
https://github.com/apache/flink-table-store/pull/315#issuecomment-1275851335
Performance improvement:
Before:
https://user-images.githubusercontent.com/9601882/195302829-2aab66b9-88de-4ed1-93b8-457fce4b1254.png;>
Checkpoint End to End
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29589:
-
Affects Version/s: (was: 1.14.2)
(was: 1.14.3)
[
https://issues.apache.org/jira/browse/FLINK-29576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29576:
-
Fix Version/s: 1.16.0
> Serialized OperatorCoordinators are collected in a not
zentol commented on code in PR #21019:
URL: https://github.com/apache/flink/pull/21019#discussion_r993203411
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -298,6 +303,27 @@ private JobGraph createJobGraph() {
[
https://issues.apache.org/jira/browse/FLINK-28906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang resolved FLINK-28906.
---
Resolution: Fixed
> Add AlgoOperator for AgglomerativeClustering
>
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r993204783
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkAggregateExpandDistinctAggregatesRule.java:
##
@@ -484,6
chucheng92 commented on code in PR #19654:
URL: https://github.com/apache/flink/pull/19654#discussion_r993203156
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java:
##
@@ -355,7 +355,8 @@ public
[
https://issues.apache.org/jira/browse/FLINK-29176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616290#comment-17616290
]
Zhipeng Zhang edited comment on FLINK-29176 at 10/12/22 9:07 AM:
-
Hi
[ https://issues.apache.org/jira/browse/FLINK-29176 ]
Zhipeng Zhang deleted comment on FLINK-29176:
---
was (Author: JIRAUSER284184):
Duplicate with https://issues.apache.org/jira/browse/FLINK-28571
> Add python support for ChiSqTest
>
[
https://issues.apache.org/jira/browse/FLINK-29176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616290#comment-17616290
]
Zhipeng Zhang edited comment on FLINK-29176 at 10/12/22 9:06 AM:
-
Hi
flinkbot commented on PR #21028:
URL: https://github.com/apache/flink/pull/21028#issuecomment-1275836856
## CI report:
* c06b60a09b3897d82408a02daa2250c138f2565f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang closed FLINK-29176.
-
Resolution: Duplicate
Duplicate with https://issues.apache.org/jira/browse/FLINK-28571
> Add
[
https://issues.apache.org/jira/browse/FLINK-29176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang reopened FLINK-29176:
---
> Add python support for ChiSqTest
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-29176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang resolved FLINK-29176.
---
Resolution: Fixed
> Add python support for ChiSqTest
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-28229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616291#comment-17616291
]
Tigran Manasyan commented on FLINK-28229:
-
[~martijnvisser] thanks! Opened PR -
[
https://issues.apache.org/jira/browse/FLINK-29176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616290#comment-17616290
]
Zhipeng Zhang commented on FLINK-29176:
---
Hi [~zxcoccer] , sorry for the late reply.
This Jira is
Matthias Pohl created FLINK-29594:
-
Summary: RMQSourceITCase.testMessageDelivery timed out
Key: FLINK-29594
URL: https://issues.apache.org/jira/browse/FLINK-29594
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-28229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28229:
---
Labels: pull-request-available (was: )
> Introduce Source API alternatives for
>
tigrulya-exe opened a new pull request, #21028:
URL: https://github.com/apache/flink/pull/21028
## What is the purpose of the change
This pull request adds FLIP-27 Source API alternatives for
`FromElementsFunction` and `FromIteratorFunction`.
## Brief change log
kristoffSC commented on code in PR #20979:
URL: https://github.com/apache/flink/pull/20979#discussion_r993192612
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/committables/CheckpointCommittableManagerImplTest.java:
##
@@ -93,6 +95,32 @@
lsyldliu commented on code in PR #21026:
URL: https://github.com/apache/flink/pull/21026#discussion_r993131703
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITCase.java:
##
@@ -39,6 +39,8 @@
import
[
https://issues.apache.org/jira/browse/FLINK-29593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29593:
---
Labels: pull-request-available (was: )
> Add Approximate Quantile Util
>
jiangxin369 opened a new pull request, #162:
URL: https://github.com/apache/flink-ml/pull/162
…iles
## What is the purpose of the change
Add QuantileSummary to help calculate approximate quantiles
## Brief change log
*(for example:)*
- Add
[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616283#comment-17616283
]
Piotr Nowojski commented on FLINK-18647:
+1 for moving the discussion to the dev mailing list.
[
https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-29486.
-
Resolution: Implemented
> Introduce Client Parser to get statement type
>
[
https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616281#comment-17616281
]
Shengkai Fang commented on FLINK-29486:
---
The Client parser relies on the TokenManager that used by
[
https://issues.apache.org/jira/browse/FLINK-27384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-27384.
Resolution: Fixed
> In the Hive dimension table, when the data is changed on the original
>
[
https://issues.apache.org/jira/browse/FLINK-27384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-27384:
---
Fix Version/s: 1.16.0
1.15.3
1.14.7
> In the Hive dimension
[
https://issues.apache.org/jira/browse/FLINK-27384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17572727#comment-17572727
]
Leonard Xu edited comment on FLINK-27384 at 10/12/22 8:40 AM:
--
Fixed in
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616277#comment-17616277
]
Matthias Pohl commented on FLINK-29387:
---
Jiang Xin created FLINK-29593:
-
Summary: Add Approximate Quantile Util
Key: FLINK-29593
URL: https://issues.apache.org/jira/browse/FLINK-29593
Project: Flink
Issue Type: Sub-task
leonardBang merged PR #20434:
URL: https://github.com/apache/flink/pull/20434
--
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:
leonardBang merged PR #20437:
URL: https://github.com/apache/flink/pull/20437
--
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-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-29486:
-
Assignee: yuzelin
> Introduce Client Parser to get statement type
>
[
https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-29486:
--
Summary: Introduce Client Parser to get statement type (was: Enable SQL
Client to Connect
Jiang Xin created FLINK-29592:
-
Summary: Add Transformer and Estimator for RobustScaler
Key: FLINK-29592
URL: https://issues.apache.org/jira/browse/FLINK-29592
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-29486:
--
Parent: FLINK-29073
Issue Type: Sub-task (was: New Feature)
> Enable SQL Client to
[
https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616273#comment-17616273
]
Shengkai Fang commented on FLINK-29486:
---
Merged into master:
fsk119 merged PR #20931:
URL: https://github.com/apache/flink/pull/20931
--
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:
fapaul commented on code in PR #20979:
URL: https://github.com/apache/flink/pull/20979#discussion_r993147592
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/committables/CheckpointCommittableManagerImplTest.java:
##
@@ -93,6 +95,32 @@
dannycranmer commented on PR #20937:
URL: https://github.com/apache/flink/pull/20937#issuecomment-1275785276
I rebuilt `hive-exec` from source to get the shade output, I see some
additional issues with the sql NOTICE file:
These are included in `hive-exec` 3.1.3
```
[INFO]
snuyanzin commented on PR #20991:
URL: https://github.com/apache/flink/pull/20991#issuecomment-1275766548
Thanks for your contribution @ashmeet-kandhari
As I mentioned in jira issue we could continue code related discussions here
Could you please share more detail/link to ci with
[
https://issues.apache.org/jira/browse/FLINK-25538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616259#comment-17616259
]
Sergey Nuyanzin edited comment on FLINK-25538 at 10/12/22 8:08 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-29574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer closed FLINK-29574.
-
Resolution: Fixed
> Upgrade software.amazon.glue:schema-registry-common and
>
godfreyhe commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r993109931
##
_posts/2022-10-10-1.16-announcement.md:
##
@@ -0,0 +1,401 @@
+---
+layout: post
+title: "Announcing the Release of Apache Flink 1.16"
+subtitle: ""
+date:
[
https://issues.apache.org/jira/browse/FLINK-29482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616263#comment-17616263
]
Gyula Fora commented on FLINK-29482:
I think based on the slack discussions this is not an issue
[
https://issues.apache.org/jira/browse/FLINK-29233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29233.
--
Resolution: Cannot Reproduce
> Flink Kubernetes Operator example/kustomize not running
>
flinkbot commented on PR #21027:
URL: https://github.com/apache/flink/pull/21027#issuecomment-1275751017
## CI report:
* ee4c9f8099ca932751d81a29bdd7c5d95f440fd1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616262#comment-17616262
]
Yun Gao commented on FLINK-18647:
-
Hi [~pnowojski] sorry for the long delay due to just back from the
[
https://issues.apache.org/jira/browse/FLINK-25538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616259#comment-17616259
]
Sergey Nuyanzin edited comment on FLINK-25538 at 10/12/22 7:50 AM:
---
Hi
godfreyhe commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r993109931
##
_posts/2022-10-10-1.16-announcement.md:
##
@@ -0,0 +1,401 @@
+---
+layout: post
+title: "Announcing the Release of Apache Flink 1.16"
+subtitle: ""
+date:
godfreyhe commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r993109091
##
_config.yml:
##
@@ -73,6 +73,22 @@ FLINK_TABLE_STORE_GITHUB_REPO_NAME: flink-table-store
# md1_url:
[
https://issues.apache.org/jira/browse/FLINK-25538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616259#comment-17616259
]
Sergey Nuyanzin commented on FLINK-25538:
-
Hi [~ashmeet] thanks for taking it.
Is there any way
dannycranmer commented on PR #20937:
URL: https://github.com/apache/flink/pull/20937#issuecomment-1275731021
I am just verifying the NOTCE file and found a couple of issues. We are
bundling the following in our jar, however they are not explicitly called out:
> [INFO] Including
[
https://issues.apache.org/jira/browse/FLINK-29574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616245#comment-17616245
]
Danny Cranmer commented on FLINK-29574:
---
Merged commit
[
https://issues.apache.org/jira/browse/FLINK-29577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616246#comment-17616246
]
Yun Tang commented on FLINK-29577:
--
[~cailiuyang] If the disk usage could be reduced indeed, I think
[
https://issues.apache.org/jira/browse/FLINK-29574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616247#comment-17616247
]
Danny Cranmer commented on FLINK-29574:
---
Thanks for the contribution [~liangtl] !
> Upgrade
dannycranmer merged PR #21009:
URL: https://github.com/apache/flink/pull/21009
--
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-28229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-28229:
--
Assignee: Tigran Manasyan
> Introduce Source API alternatives for
>
[
https://issues.apache.org/jira/browse/FLINK-28229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616236#comment-17616236
]
Martijn Visser commented on FLINK-28229:
[~vivacell] You can open a PR without being assigned,
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r993071814
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/catalog/JavaCatalogTableTest.xml:
##
@@ -76,12 +75,11 @@
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992790858
##
flink-table/flink-sql-parser-hive/pom.xml:
##
@@ -56,6 +56,12 @@ under the License.
guava
${guava.version}
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992790858
##
flink-table/flink-sql-parser-hive/pom.xml:
##
@@ -56,6 +56,12 @@ under the License.
guava
${guava.version}
luoyuxia commented on PR #20907:
URL: https://github.com/apache/flink/pull/20907#issuecomment-1275678633
@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.
yunfengzhou-hub commented on code in PR #160:
URL: https://github.com/apache/flink-ml/pull/160#discussion_r993058402
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/splitter/Splitter.java:
##
@@ -0,0 +1,111 @@
+/*
Review Comment:
In order to align the
twalthr commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992266138
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/join/NestedLoopSemiAntiJoinTest.xml:
##
@@ -673,8 +673,8 @@
twalthr commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r993052648
##
flink-table/flink-table-planner/pom.xml:
##
@@ -127,22 +127,22 @@ under the License.
${calcite.version}
twalthr commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r993051603
##
flink-table/flink-sql-parser/pom.xml:
##
@@ -193,6 +204,10 @@ under the License.
org.apiguardian
Review Comment:
It would
haoxins commented on PR #399:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/399#issuecomment-1275662962
> Can you please add a test case for this?
will do
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
luoyuxia commented on PR #20907:
URL: https://github.com/apache/flink/pull/20907#issuecomment-1275653694
@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.
Yunfeng Zhou created FLINK-29591:
Summary: Add built-in UDFs to convert between arrays and vectors
Key: FLINK-29591
URL: https://issues.apache.org/jira/browse/FLINK-29591
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616207#comment-17616207
]
Qingsheng Ren commented on FLINK-29492:
---
Thanks [~ruanhang1993] . I've assign the ticket to you. I
[
https://issues.apache.org/jira/browse/FLINK-29006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616205#comment-17616205
]
Yufan Sheng commented on FLINK-29006:
-
[~hxb] I think we can close this issue if no new failed
201 - 287 of 287 matches
Mail list logo
