[
https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497319#comment-17497319
]
Jark Wu commented on FLINK-26204:
-
[~jingzhang] do you want to have a look this problem?
> set
[
https://issues.apache.org/jira/browse/FLINK-26348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497317#comment-17497317
]
Jark Wu commented on FLINK-26348:
-
+1 for this. The project push down should also be able to pass
[
https://issues.apache.org/jira/browse/FLINK-26348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-26348:
Component/s: Table SQL / Planner
> Maybe ChangelogNormalize should ignore unused columns when deduplicate
Kenyore created FLINK-26348:
---
Summary: Maybe ChangelogNormalize should ignore unused columns
when deduplicate
Key: FLINK-26348
URL: https://issues.apache.org/jira/browse/FLINK-26348
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-26347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-26347:
Description: FLINK-25742 removed the redundant serialization of RPC
invocation at Flink side.
[
https://issues.apache.org/jira/browse/FLINK-26141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26141:
---
Labels: pull-request-available (was: )
> Support last-state upgrade mode
>
[
https://issues.apache.org/jira/browse/FLINK-26347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497288#comment-17497288
]
Yingjie Cao commented on FLINK-26347:
-
cc [~guoyangze] .
> Should use Flink system Classloader
Yingjie Cao created FLINK-26347:
---
Summary: Should use Flink system Classloader (AppClassloader) when
deserializing RPC message
Key: FLINK-26347
URL: https://issues.apache.org/jira/browse/FLINK-26347
[
https://issues.apache.org/jira/browse/FLINK-26331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497286#comment-17497286
]
Matthias Pohl commented on FLINK-26331:
---
Looking through different configuration parameters
[
https://issues.apache.org/jira/browse/FLINK-26331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-26331:
--
Description:
Right now, the retry mechanism is hard-coded to {{Integer.MAX_VALUE}}. We want
[
https://issues.apache.org/jira/browse/FLINK-26267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo resolved FLINK-26267.
--
Resolution: Done
Merged into master via d14e1f481ec3e8b154a46a003e3a4fd59614f34a
> Add
[
https://issues.apache.org/jira/browse/FLINK-26267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26267:
---
Labels: pull-request-available (was: )
> Add common params interface in ML Python API
>
HuangXingBo closed pull request #65:
URL: https://github.com/apache/flink-ml/pull/65
--
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-26160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul updated FLINK-26160:
Fix Version/s: 1.15.0
> Pulsar Connector: stopCursor description should be changed. Connector
[
https://issues.apache.org/jira/browse/FLINK-26160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul updated FLINK-26160:
Component/s: Documentation
> Pulsar Connector: stopCursor description should be changed.
[
https://issues.apache.org/jira/browse/FLINK-26160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul updated FLINK-26160:
Affects Version/s: 1.15.0
> Pulsar Connector: stopCursor description should be changed. Connector
[
https://issues.apache.org/jira/browse/FLINK-26160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul updated FLINK-26160:
Affects Version/s: 1.14.3
> Pulsar Connector: stopCursor description should be changed. Connector
[
https://issues.apache.org/jira/browse/FLINK-26160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497277#comment-17497277
]
Fabian Paul commented on FLINK-26160:
-
Merged in master: 6080c7885d02c11b7aef8f24a26f1c794b6953d7
>
[
https://issues.apache.org/jira/browse/FLINK-26331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-26331:
-
Assignee: Matthias Pohl
> Make max retries configurable
>
fapaul merged pull request #18780:
URL: https://github.com/apache/flink/pull/18780
--
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 pull request #18780:
URL: https://github.com/apache/flink/pull/18780#issuecomment-1049651600
@imaffe can you also backport this change to release-1.14?
--
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-24626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kenyore closed FLINK-24626.
---
Resolution: Abandoned
> Flink JDBC Sink may lose data in left join
>
Caizhi Weng created FLINK-26346:
---
Summary: Add statistics collecting to sst files
Key: FLINK-26346
URL: https://issues.apache.org/jira/browse/FLINK-26346
Project: Flink
Issue Type: Sub-task
flinkbot edited a comment on pull request #18345:
URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419
## CI report:
* 6a86accf9fa9592f21ceb1432eaf206526ab3097 Azure:
[
https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497019#comment-17497019
]
Jing Ge edited comment on FLINK-26301 at 2/24/22, 9:16 AM:
---
1. you are
fapaul commented on pull request #18781:
URL: https://github.com/apache/flink/pull/18781#issuecomment-1049640517
@imaffe Can you also backport this to the `release-1.14` branch? AFAIK the
PulsarSource was already part of 1.14
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-26159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497271#comment-17497271
]
Fabian Paul commented on FLINK-26159:
-
Merged in master: 52df489063ae90af73c663dc6abbe42e3794f1ac
>
JingGe commented on pull request #18896:
URL: https://github.com/apache/flink/pull/18896#issuecomment-1049638365
@Airblader Would you like to review this PR? Many thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
fapaul merged pull request #18781:
URL: https://github.com/apache/flink/pull/18781
--
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-26336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497266#comment-17497266
]
Yang Wang commented on FLINK-26336:
---
I think I get your point. If we update the state in the
flinkbot edited a comment on pull request #18904:
URL: https://github.com/apache/flink/pull/18904#issuecomment-1049624714
## CI report:
* 4d8363bb79758f96b2c88b3df15454873472a8ab Azure:
flinkbot commented on pull request #18904:
URL: https://github.com/apache/flink/pull/18904#issuecomment-1049625046
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
flinkbot commented on pull request #18904:
URL: https://github.com/apache/flink/pull/18904#issuecomment-1049624714
## CI report:
* 4d8363bb79758f96b2c88b3df15454873472a8ab UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
Tartarus0zm commented on pull request #18904:
URL: https://github.com/apache/flink/pull/18904#issuecomment-1049622831
@beyond1920 @wuchong please take a look, if you have time, thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
Tartarus0zm opened a new pull request #18904:
URL: https://github.com/apache/flink/pull/18904
## What is the purpose of the change
fix method name typos
## Brief change log
tesInvalidCastBetweenNumericAndTimestampLtz ->
testInvalidCastBetweenNumericAndTimestampLtz
[
https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-26204:
-
Attachment: output-of-window-tvf-test.png
> set table.optimizer.distinct-agg.split.enabled to true and
fapaul commented on a change in pull request #18345:
URL: https://github.com/apache/flink/pull/18345#discussion_r813658020
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497257#comment-17497257
]
Paul Lin edited comment on FLINK-26204 at 2/24/22, 8:43 AM:
I've reproduced
[
https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497257#comment-17497257
]
Paul Lin edited comment on FLINK-26204 at 2/24/22, 8:41 AM:
I've reproduced
[
https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497257#comment-17497257
]
Paul Lin commented on FLINK-26204:
--
I've reproduced the problem with minimum external dependencies.
[
https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-26204:
-
Attachment: WindowTvfTest.java
> set table.optimizer.distinct-agg.split.enabled to true and using
[
https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497256#comment-17497256
]
Till Rohrmann commented on FLINK-26086:
---
Thanks for fixing this issue [~nyingping].
> fixed some
[
https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-26086:
-
Assignee: nyingping
> fixed some causing ambiguities including the 'shit' comment
>
[
https://issues.apache.org/jira/browse/FLINK-26267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-26267:
Assignee: Huang Xingbo
> Add common params interface in ML Python API
>
[
https://issues.apache.org/jira/browse/FLINK-26266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo closed FLINK-26266.
Resolution: Fixed
Merged into master via 10cae7b7a656f68dc4ea9f5bdc32441c141e0bbf
> Support
[
https://issues.apache.org/jira/browse/FLINK-26266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-26266:
Assignee: Huang Xingbo
> Support Vector and Matrix
> -
>
>
flinkbot edited a comment on pull request #18780:
URL: https://github.com/apache/flink/pull/18780#issuecomment-1040253405
## CI report:
* ab7fd6e2e3ddf8597a88ed7bac2f1ce2a0af4f0c Azure:
flinkbot edited a comment on pull request #18345:
URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419
## CI report:
* 6a86accf9fa9592f21ceb1432eaf206526ab3097 Azure:
flinkbot edited a comment on pull request #18780:
URL: https://github.com/apache/flink/pull/18780#issuecomment-1040253405
## CI report:
* ab7fd6e2e3ddf8597a88ed7bac2f1ce2a0af4f0c Azure:
HuangXingBo closed pull request #64:
URL: https://github.com/apache/flink-ml/pull/64
--
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:
flinkbot edited a comment on pull request #18345:
URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419
## CI report:
* 6a86accf9fa9592f21ceb1432eaf206526ab3097 Azure:
imaffe commented on pull request #18780:
URL: https://github.com/apache/flink/pull/18780#issuecomment-1049607143
@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
imaffe commented on pull request #18345:
URL: https://github.com/apache/flink/pull/18345#issuecomment-1049607236
@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
[
https://issues.apache.org/jira/browse/FLINK-26340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-26340:
-
Assignee: Galen Warren
> Add ability in Golang SDK to create new statefun.Context from
fapaul commented on a change in pull request #18651:
URL: https://github.com/apache/flink/pull/18651#discussion_r813634648
##
File path:
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java
##
@@ -313,7 +329,14
[
https://issues.apache.org/jira/browse/FLINK-26266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26266:
---
Labels: pull-request-available (was: )
> Support Vector and Matrix
>
dianfu commented on a change in pull request #64:
URL: https://github.com/apache/flink-ml/pull/64#discussion_r813634159
##
File path: flink-ml-python/pyflink/ml/core/linalg.py
##
@@ -0,0 +1,544 @@
flinkbot edited a comment on pull request #18607:
URL: https://github.com/apache/flink/pull/18607#issuecomment-1027976960
## CI report:
* b19db486c3ddb25117a3aadda79002708db46d00 Azure:
[
https://issues.apache.org/jira/browse/FLINK-26178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-26178:
--
Assignee: Biao Geng
> Use the same enum for expected and observed jobstate (JobState /
>
[
https://issues.apache.org/jira/browse/FLINK-26327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497243#comment-17497243
]
Spongebob commented on FLINK-26327:
---
{code:java}
//代码占位符
Exception in thread "main"
flinkbot edited a comment on pull request #18641:
URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534
## CI report:
* 6d23d5651638281b39766cf214cbbb2b111a4da7 Azure:
501 - 561 of 561 matches
Mail list logo