[
https://issues.apache.org/jira/browse/FLINK-21329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias updated FLINK-21329:
-
Component/s: Runtime / Checkpointing
> "Local recovery and sticky scheduling end-to-end test" does not
[
https://issues.apache.org/jira/browse/FLINK-21329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315987#comment-17315987
]
Matthias commented on FLINK-21329:
--
{quote}
I looked at the test and I don't see anything obvious that
flinkbot edited a comment on pull request #15494:
URL: https://github.com/apache/flink/pull/15494#issuecomment-814059954
## CI report:
* a0782bb05bb4283e4c56303b9c9ca8456de29bd8 Azure:
[
https://issues.apache.org/jira/browse/FLINK-22128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-22128:
-
Description: We should add match method in {{FlinkRelMdUniqueKeys for
Jingsong Lee created FLINK-22128:
Summary: Window aggregation should have unique keys
Key: FLINK-22128
URL: https://issues.apache.org/jira/browse/FLINK-22128
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315938#comment-17315938
]
wangzhihao edited comment on FLINK-22113 at 4/7/21, 5:01 AM:
-
[~jark] Will
flinkbot edited a comment on pull request #15497:
URL: https://github.com/apache/flink/pull/15497#issuecomment-814453955
## CI report:
* a6f5806464767495db8aa0dc737f0e977a6035d5 Azure:
Yingjie Cao created FLINK-22127:
---
Summary: Enrich error message of read buffer request timeout
exception
Key: FLINK-22127
URL: https://issues.apache.org/jira/browse/FLINK-22127
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fu Kai updated FLINK-22113:
---
Description:
Hi team,
We have a use case to join multiple data sources to generate a continuous
[
https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fu Kai updated FLINK-22113:
---
Description:
Hi team,
We have a use case to join multiple data sources to generate a continuous
flinkbot edited a comment on pull request #15497:
URL: https://github.com/apache/flink/pull/15497#issuecomment-814453955
## CI report:
* a6f5806464767495db8aa0dc737f0e977a6035d5 Azure:
[
https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fu Kai updated FLINK-22113:
---
Description:
Hi team,
We have a use case to join multiple data sources to generate a continuous
flinkbot edited a comment on pull request #15498:
URL: https://github.com/apache/flink/pull/15498#issuecomment-814575824
## CI report:
* c6fc2d4fa4d1149f364432891223779d23a8f6a2 Azure:
flinkbot edited a comment on pull request #15490:
URL: https://github.com/apache/flink/pull/15490#issuecomment-813862254
## CI report:
* ef852240e48c635f408892ed964e7f0d72616d98 Azure:
maosuhan commented on pull request #14376:
URL: https://github.com/apache/flink/pull/14376#issuecomment-814578490
@sv3ndk
Thanks for your detailed explanation of the issue.
I checked the MR you raised, it seems you ignore the case of protobuf
version 2. In protobuf 2, user can use
flinkbot commented on pull request #15498:
URL: https://github.com/apache/flink/pull/15498#issuecomment-814575824
## CI report:
* c6fc2d4fa4d1149f364432891223779d23a8f6a2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #15490:
URL: https://github.com/apache/flink/pull/15490#issuecomment-813862254
## CI report:
* ef852240e48c635f408892ed964e7f0d72616d98 Azure:
[
https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315938#comment-17315938
]
wangzhihao commented on FLINK-22113:
[~jark] Will it affect the correctness, or just performance?
[
https://issues.apache.org/jira/browse/FLINK-22010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315936#comment-17315936
]
zhou commented on FLINK-22010:
--
Im sure that resources is enough, set -ytm=20480, the error also occured. I
YikSanChan commented on pull request #15360:
URL: https://github.com/apache/flink/pull/15360#issuecomment-814572109
@dianfu Sure, that sounds good! Let me know when you add the page.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
dianfu commented on pull request #15360:
URL: https://github.com/apache/flink/pull/15360#issuecomment-814571639
@YikSanChan What about rebase this PR after that page is added. I can add
that page. Will let you know when it is ready. Thank you a lot~
--
This is an automated message from
flinkbot commented on pull request #15498:
URL: https://github.com/apache/flink/pull/15498#issuecomment-814570773
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
YikSanChan commented on pull request #15360:
URL: https://github.com/apache/flink/pull/15360#issuecomment-814569786
@dianfu I agree with the proposal, though I don't have much experience on
other udfs as well as logging/loading large dataset etc, therefore no sure what
to add, correctly.
[
https://issues.apache.org/jira/browse/FLINK-22121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22121:
---
Labels: pull-request-available (was: )
> FlinkLogicalRankRuleBase should check if name of
TsReaper opened a new pull request #15498:
URL: https://github.com/apache/flink/pull/15498
## What is the purpose of the change
Currently names of rank fields are all `w0$o0`, so if the input of a `Rank`
is another `Rank` some exception will occur. To solve this, we should check if
dianfu commented on pull request #15360:
URL: https://github.com/apache/flink/pull/15360#issuecomment-814565681
@YikSanChan I'm considering adding another page to hold this information
instead of putting it inside ScalarFunction as it applies also to other kinds
of user-defined functions.
YikSanChan commented on pull request #15360:
URL: https://github.com/apache/flink/pull/15360#issuecomment-814564163
@dianfu Feel free to let me know if you have any comments
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-22120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li updated FLINK-22120:
---
Issue Type: Bug (was: Improvement)
> Bug when generate code for map get
>
[
https://issues.apache.org/jira/browse/FLINK-22120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-22120:
--
Assignee: Zou
> Bug when generate code for map get
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-22120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315918#comment-17315918
]
Zou commented on FLINK-22120:
-
[~libenchao] Yes, I'd like to take it.
> Bug when generate code for map get
flinkbot edited a comment on pull request #15493:
URL: https://github.com/apache/flink/pull/15493#issuecomment-814016686
## CI report:
* c59ab4dddf05042cea220d55be25862ee595c02c Azure:
flinkbot edited a comment on pull request #15493:
URL: https://github.com/apache/flink/pull/15493#issuecomment-814016686
## CI report:
* c59ab4dddf05042cea220d55be25862ee595c02c Azure:
flinkbot edited a comment on pull request #15494:
URL: https://github.com/apache/flink/pull/15494#issuecomment-814059954
## CI report:
* feb716af24dd6257a488f9d2c4d63ff8e5e01f9c Azure:
[
https://issues.apache.org/jira/browse/FLINK-22124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-22124:
Description:
For the following job:
{code}
import logging
from pyflink.common import WatermarkStrategy,
flinkbot edited a comment on pull request #15494:
URL: https://github.com/apache/flink/pull/15494#issuecomment-814059954
## CI report:
* feb716af24dd6257a488f9d2c4d63ff8e5e01f9c Azure:
tonychan created FLINK-22126:
Summary: when i set ssl ,the jobmanager got certificate_unknown
exception
Key: FLINK-22126
URL: https://issues.apache.org/jira/browse/FLINK-22126
Project: Flink
klion26 edited a comment on pull request #8751:
URL: https://github.com/apache/flink/pull/8751#issuecomment-814131133
@StephanEwen sorry for the late reply.
IIUC, maybe we still need this feature after FLIP-158 has been
implemented(even if we cloud handle not to generate small sst files
klion26 commented on a change in pull request #386:
URL: https://github.com/apache/flink-web/pull/386#discussion_r607865198
##
File path: contributing/code-style-and-quality-preamble.zh.md
##
@@ -1,25 +1,23 @@
---
-title: "Apache Flink Code Style and Quality Guide —
hehuiyuan commented on pull request #15395:
URL: https://github.com/apache/flink/pull/15395#issuecomment-814514889
Hi @Myasuka ，please review.
--
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
flinkbot edited a comment on pull request #15497:
URL: https://github.com/apache/flink/pull/15497#issuecomment-814453955
## CI report:
* a6f5806464767495db8aa0dc737f0e977a6035d5 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Austin Cawley-Edwards updated FLINK-17859:
--
Fix Version/s: 1.8.0
> [flink-s3-fs-presto] Upgrade the dependent presto-hive
[
https://issues.apache.org/jira/browse/FLINK-17859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Austin Cawley-Edwards updated FLINK-17859:
--
Affects Version/s: 1.7.2
> [flink-s3-fs-presto] Upgrade the dependent
[
https://issues.apache.org/jira/browse/FLINK-17859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315886#comment-17315886
]
Austin Cawley-Edwards commented on FLINK-17859:
---
This has been updated as of Flink 1.8:
flinkbot edited a comment on pull request #15497:
URL: https://github.com/apache/flink/pull/15497#issuecomment-814453955
## CI report:
* a6f5806464767495db8aa0dc737f0e977a6035d5 Azure:
flinkbot edited a comment on pull request #15497:
URL: https://github.com/apache/flink/pull/15497#issuecomment-814453955
## CI report:
* a6f5806464767495db8aa0dc737f0e977a6035d5 Azure:
austince commented on pull request #15497:
URL: https://github.com/apache/flink/pull/15497#issuecomment-814484686
@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
austince removed a comment on pull request #15497:
URL: https://github.com/apache/flink/pull/15497#issuecomment-814446011
@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
sjwiesman opened a new pull request #220:
URL: https://github.com/apache/flink-statefun/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.
For queries about this
flinkbot edited a comment on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550
## CI report:
* 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN
* f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN
*
flinkbot edited a comment on pull request #15497:
URL: https://github.com/apache/flink/pull/15497#issuecomment-814453955
## CI report:
* a6f5806464767495db8aa0dc737f0e977a6035d5 Azure:
flinkbot commented on pull request #15497:
URL: https://github.com/apache/flink/pull/15497#issuecomment-814453955
## CI report:
* a6f5806464767495db8aa0dc737f0e977a6035d5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
austince commented on pull request #15497:
URL: https://github.com/apache/flink/pull/15497#issuecomment-814446011
@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
flinkbot commented on pull request #15497:
URL: https://github.com/apache/flink/pull/15497#issuecomment-814445574
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
[
https://issues.apache.org/jira/browse/FLINK-22084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22084:
---
Labels: pull-request-available test-stability (was: test-stability)
> RescalingITCase
austince opened a new pull request #15497:
URL: https://github.com/apache/flink/pull/15497
# What is the purpose of the change
Ensure that the same max parallelism value is used as the default in the
Adaptive Scheduler between submissions, even as the job scales in and out.
[
https://issues.apache.org/jira/browse/FLINK-21359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315828#comment-17315828
]
Siva commented on FLINK-21359:
--
Hi Flink Team
is there any Expected Time line for the fix as we are
flinkbot edited a comment on pull request #15480:
URL: https://github.com/apache/flink/pull/15480#issuecomment-812378052
## CI report:
* b866c12e5bade25f2624b5b9c9f01181b67ba3f4 Azure:
flinkbot edited a comment on pull request #15495:
URL: https://github.com/apache/flink/pull/15495#issuecomment-814224111
## CI report:
* 68ee1f63c2ca642d7ef6908d81250a5ec53b1cb8 Azure:
flinkbot edited a comment on pull request #15496:
URL: https://github.com/apache/flink/pull/15496#issuecomment-814224240
## CI report:
* 23153a97c61ce55427c1f0d864494938d656501c Azure:
flinkbot edited a comment on pull request #15493:
URL: https://github.com/apache/flink/pull/15493#issuecomment-814016686
## CI report:
* c59ab4dddf05042cea220d55be25862ee595c02c Azure:
flinkbot edited a comment on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550
## CI report:
* 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN
* f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN
*
flinkbot edited a comment on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550
## CI report:
* 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN
* f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN
*
flinkbot edited a comment on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550
## CI report:
* 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN
* f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN
*
flinkbot edited a comment on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550
## CI report:
* 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN
* f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN
*
flinkbot edited a comment on pull request #15393:
URL: https://github.com/apache/flink/pull/15393#issuecomment-808510341
## CI report:
* 6d3a5349e3babb3f5c12ba2629f70f23dd8cbdf8 Azure:
flinkbot edited a comment on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550
## CI report:
* 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN
* f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN
*
[
https://issues.apache.org/jira/browse/FLINK-22084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315716#comment-17315716
]
Austin Cawley-Edwards commented on FLINK-22084:
---
That is unfortunate, and yes I agree that
YuvalItzchakov commented on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-814268110
@fsk119 I resolved this by moving the instantiation of `util` into the
`setup` method.
--
This is an automated message from the Apache Git Service.
To respond to the
flinkbot edited a comment on pull request #15485:
URL: https://github.com/apache/flink/pull/15485#issuecomment-812897189
## CI report:
* 99f1c41eb70ddeff355829f59ec0649c6da64b0b Azure:
flinkbot edited a comment on pull request #15395:
URL: https://github.com/apache/flink/pull/15395#issuecomment-808844283
## CI report:
* 5d043b1bde696752f58e773239f37cf8e363e7ac Azure:
YuvalItzchakov edited a comment on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-814257612
@fsk119 To be honest I don't understand why we need the added complexity of
code inheritance here, these tests should be ran individually anyway. If each
one of
YuvalItzchakov commented on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-814257612
@fsk119 To be honest I don't understand why we need the added complexity of
code inheritance here, these tests should be ran individually. If each one of
them utilizes a
YuvalItzchakov commented on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-814253822
@fsk119 After registering the tables in
`PushFilterInCalcIntoTableSourceRuleTest`, now only one test fails from
`PushFilterIntoLegacyTableSourceScanRuleTest`:
flinkbot edited a comment on pull request #15495:
URL: https://github.com/apache/flink/pull/15495#issuecomment-814224111
## CI report:
* 68ee1f63c2ca642d7ef6908d81250a5ec53b1cb8 Azure:
flinkbot edited a comment on pull request #15494:
URL: https://github.com/apache/flink/pull/15494#issuecomment-814059954
## CI report:
* feb716af24dd6257a488f9d2c4d63ff8e5e01f9c Azure:
flinkbot edited a comment on pull request #15496:
URL: https://github.com/apache/flink/pull/15496#issuecomment-814224240
## CI report:
* 23153a97c61ce55427c1f0d864494938d656501c Azure:
flinkbot edited a comment on pull request #15480:
URL: https://github.com/apache/flink/pull/15480#issuecomment-812378052
## CI report:
* 8c7eca17544f157b58f4100af3527e346a63bbcb Azure:
flinkbot edited a comment on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550
## CI report:
* 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN
* f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN
*
[
https://issues.apache.org/jira/browse/FLINK-22003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan resolved FLINK-22003.
---
Fix Version/s: 1.13.0
Resolution: Fixed
Merged into master as
rkhachatryan closed pull request #15466:
URL: https://github.com/apache/flink/pull/15466
--
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.
For queries about this service,
rkhachatryan commented on pull request #15466:
URL: https://github.com/apache/flink/pull/15466#issuecomment-814237052
Thanks for reviewing @tillrohrmann , @gaoyunhaii !
Merged into master as
`a40dfe0438afe04d1ac68c30bb8d238be45232cf..9cb161005861365b9dadfd016fcc321475c3d890`.
--
flinkbot commented on pull request #15496:
URL: https://github.com/apache/flink/pull/15496#issuecomment-814224240
## CI report:
* 23153a97c61ce55427c1f0d864494938d656501c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #15495:
URL: https://github.com/apache/flink/pull/15495#issuecomment-814224111
## CI report:
* 68ee1f63c2ca642d7ef6908d81250a5ec53b1cb8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #15480:
URL: https://github.com/apache/flink/pull/15480#issuecomment-812378052
## CI report:
* 8c7eca17544f157b58f4100af3527e346a63bbcb Azure:
akalash commented on a change in pull request #15496:
URL: https://github.com/apache/flink/pull/15496#discussion_r607961267
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
##
@@ -946,41 +952,35 @@ private boolean
flinkbot commented on pull request #15496:
URL: https://github.com/apache/flink/pull/15496#issuecomment-814213793
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
[
https://issues.apache.org/jira/browse/FLINK-21990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21990:
---
Labels: pull-request-available (was: )
> SourceStreamTask will always hang if the
akalash opened a new pull request #15496:
URL: https://github.com/apache/flink/pull/15496
… failed
## What is the purpose of the change
*This PR adds the invocation of task cancel before clean up method when the
execution was failed which allows sending cancel signal
flinkbot commented on pull request #15495:
URL: https://github.com/apache/flink/pull/15495#issuecomment-814208132
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
wangyang0918 edited a comment on pull request #15480:
URL: https://github.com/apache/flink/pull/15480#issuecomment-814207158
@tillrohrmann I have pushed another commit for the documentation.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
wangyang0918 commented on pull request #15480:
URL: https://github.com/apache/flink/pull/15480#issuecomment-814207158
I have pushed another commit for the documentation.
--
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-21305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21305:
---
Labels: pull-request-available (was: )
> Fix Cumulative and Hopping window should
wuchong opened a new pull request #15495:
URL: https://github.com/apache/flink/pull/15495
## What is the purpose of the change
Currently, the CUMULATE window drops elements belonging to the cleaned
slices. This will lead to more inaccurate result than without slicing
flinkbot edited a comment on pull request #15493:
URL: https://github.com/apache/flink/pull/15493#issuecomment-814016686
## CI report:
* 6138eac2ea099ecedfa464d0cd06a05b6a47897f Azure:
flinkbot edited a comment on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550
## CI report:
* 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN
* f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN
*
fsk119 commented on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-814182307
You can reuse these codes in the `setup` between
`PushFilterInCalcIntoTableSourceRuleTest ` and
`PushFilterIntoTableSourceScanRuleTest `.
```
// name: STRING, id:
fsk119 commented on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-814180436
> After implementing the changes, the
`PushFilterIntoTableSourceScanRuleTest` now fail since I cant run the `setup`
code for them (due to use of batch vs stream):
>
> ```
YuvalItzchakov edited a comment on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-814173776
After implementing the changes, the `PushFilterIntoTableSourceScanRuleTest`
now fail since I cant run the `setup` code for them (due to use of batch vs
stream):
YuvalItzchakov commented on pull request #15307:
URL: https://github.com/apache/flink/pull/15307#issuecomment-814173776
After implementing the changes, the `PushFilterIntoTableSourceScanRuleTest`
now fail since I cant run the `setup` code for them (due to use of batch vs
stream):
[
https://issues.apache.org/jira/browse/FLINK-22084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315618#comment-17315618
]
Chesnay Schepler commented on FLINK-22084:
--
The test seems to use different maxParallelism
1 - 100 of 342 matches
Mail list logo
