[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy closed FLINK-9597.
--
Resolution: Later
> Flink application does not scale as expected
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514727#comment-16514727
]
swy edited comment on FLINK-9597 at 6/16/18 9:27 AM:
-
Hi [~fhueske] D
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514727#comment-16514727
]
swy commented on FLINK-9597:
Hi [~fhueske] Do you mind to share your experience any other rea
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Description:
Hi, we found that our Flink application with simple logic, which using process
function is not scale-ab
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Attachment: sample.png
> Flink fail to scale!
>
>
> Key: FLINK-9597
>
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Description:
Hi, we found that our Flink application with simple logic, which using process
function is not scale-ab
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Description:
Hi, we found that our Flink application with simple logic, which using process
function is not scale-ab
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Description:
Hi, we found that our Flink application with simple logic, which using process
function is not scale-ab
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513963#comment-16513963
]
swy commented on FLINK-9597:
Hi [~fhueske], information updated.
> Flink fail to scale!
> --
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Attachment: TM.png
> Flink fail to scale!
>
>
> Key: FLINK-9597
>
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Attachment: JM.png
> Flink fail to scale!
>
>
> Key: FLINK-9597
>
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Description:
Hi, we found that our Flink application with simple logic, which using process
function is not scale-ab
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Attachment: (was: TM.png)
> Flink fail to scale!
>
>
> Key: FLINK-9597
>
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Attachment: TM.png
> Flink fail to scale!
>
>
> Key: FLINK-9597
>
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Description:
Hi, we found that our Flink application with simple logic, which using process
function is not scale-ab
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Attachment: (was: JM.png)
> Flink fail to scale!
>
>
> Key: FLINK-9597
>
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Attachment: JM.png
> Flink fail to scale!
>
>
> Key: FLINK-9597
>
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Description:
Hi, we found that our Flink application with simple logic, which using process
function is not scale-ab
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Description:
Hi, we found that our Flink application with simple logic, which using process
function is not scale-ab
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Description:
Hi, we found that our Flink application with simple logic, which using process
function is not scale-ab
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Description:
Hi, we found that our Flink application with simple logic, which using process
function is not scale-ab
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Attachment: flink_app_parser_git.zip
> Flink fail to scale!
>
>
> Key: FLINK-959
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Description:
Hi, we found that our Flink application with simple logic, which using process
function is not scale-ab
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9597:
---
Attachment: scaleNotWork.png
> Flink fail to scale!
>
>
> Key: FLINK-9597
>
swy created FLINK-9597:
--
Summary: Flink fail to scale!
Key: FLINK-9597
URL: https://issues.apache.org/jira/browse/FLINK-9597
Project: Flink
Issue Type: Bug
Components: Core
Affects Version
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510872#comment-16510872
]
swy commented on FLINK-9506:
no problem an email also sent to ML.
> Flink ReducingState.add
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510864#comment-16510864
]
swy commented on FLINK-9506:
Hi [~sihuazhou] I just sent an email to your personal mail box.
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510789#comment-16510789
]
swy commented on FLINK-9506:
Hi [~sihuazhou] an email is sent to "u...@flink.apache.org" with
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510752#comment-16510752
]
swy commented on FLINK-9506:
Alright i am ok to close the ticket. Do you mind to share me the
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510746#comment-16510746
]
swy commented on FLINK-9506:
Hi [~sihuazhou] it surprise me as well. Please advice if somethi
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510715#comment-16510715
]
swy commented on FLINK-9506:
Hi [~sihuazhou] please download source from
https://github.com/
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510704#comment-16510704
]
swy commented on FLINK-9506:
Hi [~sihuazhou] the picture is captured without any line being c
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9506:
---
Attachment: input_stop_when_timer_run.png
> Flink ReducingState.add causing more than 100% performance drop
> ---
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510632#comment-16510632
]
swy commented on FLINK-9506:
Hi [~sihuazhou] to your questions,
1. Checkpoint is disable at t
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510575#comment-16510575
]
swy commented on FLINK-9506:
Hi [~sihuazhou] you are right. Fluctuation only happened when "k
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16509808#comment-16509808
]
swy edited comment on FLINK-9506 at 6/12/18 4:10 PM:
-
Hi [~sihuazhou]
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9506:
---
Attachment: keyby.png
> Flink ReducingState.add causing more than 100% performance drop
> ---
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16509808#comment-16509808
]
swy commented on FLINK-9506:
Hi [~sihuazhou] I hope to close the ticket too but the problem s
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16504820#comment-16504820
]
swy commented on FLINK-9506:
thank for response [~sihuazhou], the key length is around 50 cha
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16504675#comment-16504675
]
swy commented on FLINK-9506:
[~sihuazhou] your idea is brilliant, but the first test result i
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16503426#comment-16503426
]
swy commented on FLINK-9506:
[~kkrugler] please don't close the ticket yet. Because the perfo
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16503284#comment-16503284
]
swy commented on FLINK-9506:
[~srichter] Thanks for tips, after implement Rocksdb the perform
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500211#comment-16500211
]
swy commented on FLINK-9506:
[~srichter] Really appreciated your help. To your points,
*[Fir
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499972#comment-16499972
]
swy commented on FLINK-9506:
[~srichter] thanks for good explanation. We have no choice but n
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499869#comment-16499869
]
swy commented on FLINK-9506:
Any workaround would be appreciated, do you think using rocksdb
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499859#comment-16499859
]
swy edited comment on FLINK-9506 at 6/4/18 8:03 AM:
[~sihuazhou] Your
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499859#comment-16499859
]
swy commented on FLINK-9506:
[~sihuazhou] Your tricks quite promising as the performance has
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9506:
---
Attachment: KeyNoHash_VS_KeyHash.png
> Flink ReducingState.add causing more than 100% performance drop
>
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499667#comment-16499667
]
swy commented on FLINK-9506:
Thanks for pointing out, this is a mistake in the sample. In rea
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499445#comment-16499445
]
swy edited comment on FLINK-9506 at 6/3/18 3:04 PM:
what we want to k
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499445#comment-16499445
]
swy edited comment on FLINK-9506 at 6/3/18 3:03 PM:
what we want to k
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499445#comment-16499445
]
swy commented on FLINK-9506:
what we want to know is: Is this something expected or something
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499412#comment-16499412
]
swy commented on FLINK-9506:
Hi [~sihuazhou] the keyby is comes from one of the private membe
[
https://issues.apache.org/jira/browse/FLINK-9442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9442:
---
Comment: was deleted
(was: ok will post to mailing list as well. thanks.
by the way once we change to RichParallelSou
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499393#comment-16499393
]
swy commented on FLINK-9506:
Hi Fabian,
1. Yes.
2. Yes. The state is suppose to store in Task
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9506:
---
Attachment: flink.png
> Flink ReducingState.add causing more than 100% performance drop
> ---
swy created FLINK-9506:
--
Summary: Flink ReducingState.add causing more than 100%
performance drop
Key: FLINK-9506
URL: https://issues.apache.org/jira/browse/FLINK-9506
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-9442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491720#comment-16491720
]
swy commented on FLINK-9442:
ok will post to mailing list as well. thanks.
by the way once we
[
https://issues.apache.org/jira/browse/FLINK-9442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9442:
---
Affects Version/s: 1.4.2
> Flink Scaling not working
> -
>
> Key: FLINK-9442
>
[
https://issues.apache.org/jira/browse/FLINK-9442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9442:
---
Description:
Hi,
We are in the middle of testing scaling ability of Flink. But we found that
scaling not working,
[
https://issues.apache.org/jira/browse/FLINK-9442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9442:
---
Description:
Hi,
We are in the middle of testing scaling ability of Flink. But we found that
scaling not working,
[
https://issues.apache.org/jira/browse/FLINK-9442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy updated FLINK-9442:
---
Description:
Hi,
We are in the middle of testing scaling ability of Flink. But we found that
scaling not working,
62 matches
Mail list logo