[
https://issues.apache.org/jira/browse/FLINK-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514698#comment-16514698
]
Till Rohrmann commented on FLINK-9552:
--
You could add the checkpoint lock around the
[
https://issues.apache.org/jira/browse/FLINK-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514674#comment-16514674
]
Truong Duc Kien commented on FLINK-9552:
Hi [~till.rohrmann] , FLINK-3257 seems t
[
https://issues.apache.org/jira/browse/FLINK-9380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Deepak Sharma reassigned FLINK-9380:
Assignee: Deepak Sharma
> Failing end-to-end tests should not clean up logs
>
Elias Levy created FLINK-9600:
-
Summary: Add DataStream transformation variants that pass
timestamp to the user function
Key: FLINK-9600
URL: https://issues.apache.org/jira/browse/FLINK-9600
Project: Flin
Github user eliaslevy commented on the issue:
https://github.com/apache/flink/pull/6076
Something else missing from this page is a discussion of what happens to
the timestamp attached to records when they go through different operations.
E.g. what happens to a record timestamp when i
[
https://issues.apache.org/jira/browse/FLINK-9593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514611#comment-16514611
]
ASF GitHub Bot commented on FLINK-9593:
---
Github user Aitozi commented on the issue:
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/6171
Hi, @dawidwys can you explain a little about how does the semantics of
`AfterMatch` differ from previous implementation, I read the doc and feel a
lille confused. thx ;-)
---
[
https://issues.apache.org/jira/browse/FLINK-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-9487.
-
Resolution: Implemented
Merged in:
master: 7e0eafa74d
> Prepare InternalTimerHeap for asynchrono
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514262#comment-16514262
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user deepaks4077 commented on the i
Github user deepaks4077 commented on the issue:
https://github.com/apache/flink/pull/6170
@zentol , thanks for your comments. I'll take a look soon!
---
[
https://issues.apache.org/jira/browse/FLINK-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514247#comment-16514247
]
ASF GitHub Bot commented on FLINK-9487:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6159
---
Chesnay Schepler created FLINK-9599:
---
Summary: Implement generic mechanism to receive files via rest
Key: FLINK-9599
URL: https://issues.apache.org/jira/browse/FLINK-9599
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-9599:
---
Assignee: Chesnay Schepler
> Implement generic mechanism to receive files via rest
>
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514212#comment-16514212
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user zentol commented on a diff in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r195826270
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -708,10 +724,32 @@ public boolean filter(Tuple2 rec)
throws Exce
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514210#comment-16514210
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6170
env.execute() should block until the job has finished execution, so your
analysis may be incorrect.
I can take a deeper look at possible semantic changes, but there are some
conceptual issues
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514203#comment-16514203
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user zentol commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514202#comment-16514202
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user zentol commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514200#comment-16514200
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user zentol commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514204#comment-16514204
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user zentol commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514201#comment-16514201
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user zentol commented on a diff in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r195824665
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -658,20 +668,26 @@ public String select(Map>
pattern) {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r195823948
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -360,27 +345,30 @@ public boolean filter(Event value) throws Exce
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r195824079
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -504,20 +498,30 @@ public String select(Map>
pattern) {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r195824130
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -573,19 +577,25 @@ public String select(Map>
pattern) {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r195824580
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -708,10 +724,32 @@ public boolean filter(Tuple2 rec)
throws Exce
[
https://issues.apache.org/jira/browse/FLINK-9594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514196#comment-16514196
]
ASF GitHub Bot commented on FLINK-9594:
---
Github user zentol commented on a diff in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6172#discussion_r195823386
--- Diff: flink-end-to-end-tests/README.md ---
@@ -33,6 +33,53 @@ $ FLINK_DIR=
flink-end-to-end-tests/test-scripts/test_batch_wordcount
## Writing
[
https://issues.apache.org/jira/browse/FLINK-9594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514195#comment-16514195
]
ASF GitHub Bot commented on FLINK-9594:
---
Github user zentol commented on a diff in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6172#discussion_r195823151
--- Diff: flink-end-to-end-tests/README.md ---
@@ -33,6 +33,53 @@ $ FLINK_DIR=
flink-end-to-end-tests/test-scripts/test_batch_wordcount
## Writing
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514124#comment-16514124
]
Fabian Hueske commented on FLINK-9597:
--
Hi [~yow],
To be honest, this seems to be r
[
https://issues.apache.org/jira/browse/FLINK-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-9545.
---
Resolution: Won't Fix
> Support read a file multiple times in Flink DataStream
> ---
[
https://issues.apache.org/jira/browse/FLINK-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514109#comment-16514109
]
ASF GitHub Bot commented on FLINK-9545:
---
Github user bowenli86 closed the pull requ
Github user bowenli86 closed the pull request at:
https://github.com/apache/flink/pull/6130
---
[
https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514087#comment-16514087
]
Chesnay Schepler commented on FLINK-8946:
-
AFAIK this only affected legacy mode.
[
https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514056#comment-16514056
]
Mahesh Senniappan commented on FLINK-5860:
--
Thanks. I'll start working on it and
[
https://issues.apache.org/jira/browse/FLINK-9382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514050#comment-16514050
]
Till Rohrmann commented on FLINK-9382:
--
Ah ok, it was introduce with FLINK-8620, rig
[
https://issues.apache.org/jira/browse/FLINK-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7697:
-
Priority: Major (was: Critical)
> Add metrics for Elasticsearch Sink
> -
[
https://issues.apache.org/jira/browse/FLINK-7881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-7881.
--
Resolution: Cannot Reproduce
> flink can't deployed on yarn with ha
> -
[
https://issues.apache.org/jira/browse/FLINK-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514035#comment-16514035
]
ASF GitHub Bot commented on FLINK-9588:
---
Github user Aitozi commented on a diff in
Github user Aitozi commented on a diff in the pull request:
https://github.com/apache/flink/pull/6168#discussion_r195792448
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -609,7 +611,7 @@ public void close() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514028#comment-16514028
]
Till Rohrmann commented on FLINK-8163:
--
Any news [~kkl0u]?
> NonHAQueryableStateFsB
[
https://issues.apache.org/jira/browse/FLINK-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514025#comment-16514025
]
Till Rohrmann commented on FLINK-8418:
--
Ping [~tzulitai]
> Kafka08ITCase.testStartF
[
https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514021#comment-16514021
]
Till Rohrmann commented on FLINK-8521:
--
Any news on this issue [~pnowojski]?
> Flin
[
https://issues.apache.org/jira/browse/FLINK-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-8770:
-
Priority: Major (was: Critical)
> CompletedCheckPoints stored on ZooKeeper is not up-to-date, wh
[
https://issues.apache.org/jira/browse/FLINK-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514019#comment-16514019
]
Till Rohrmann commented on FLINK-8770:
--
Downgrading the severity since the reporter
[
https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514015#comment-16514015
]
Till Rohrmann commented on FLINK-8946:
--
Was this also a problem for the non-legacy m
[
https://issues.apache.org/jira/browse/FLINK-9382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514011#comment-16514011
]
Chesnay Schepler commented on FLINK-9382:
-
I disagree, this behavior is new in 1.
[
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
]
Fabian Hueske updated FLINK-9597:
-
Summary: Flink application does not scale as expected (was: Flink fail to
scale!)
> Flink appli
[
https://issues.apache.org/jira/browse/FLINK-9579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz resolved FLINK-9579.
-
Resolution: Fixed
Fix Version/s: 1.6.0
> Remove unnecessary clear with cep element
[
https://issues.apache.org/jira/browse/FLINK-9551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz resolved FLINK-9551.
-
Resolution: Fixed
Fix Version/s: 1.6.0
> FlinkCEP Scala Combining Patterns table h
[
https://issues.apache.org/jira/browse/FLINK-9366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513976#comment-16513976
]
ASF GitHub Bot commented on FLINK-9366:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513977#comment-16513977
]
ASF GitHub Bot commented on FLINK-9579:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6107
---
[
https://issues.apache.org/jira/browse/FLINK-9366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz resolved FLINK-9366.
-
Resolution: Fixed
> Distribute Cache only works for client-accessible files
> ---
[
https://issues.apache.org/jira/browse/FLINK-9551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513978#comment-16513978
]
ASF GitHub Bot commented on FLINK-9551:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6162
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6139
---
[
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-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513958#comment-16513958
]
Till Rohrmann commented on FLINK-9080:
--
Downgrading to major since user no longer re
[
https://issues.apache.org/jira/browse/FLINK-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9080:
-
Fix Version/s: (was: 1.5.1)
(was: 1.6.0)
> Flink Scheduler goes OOM, s
[
https://issues.apache.org/jira/browse/FLINK-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9080:
-
Priority: Major (was: Critical)
> Flink Scheduler goes OOM, suspecting a memory leak
> -
[
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
>
Prem Santosh created FLINK-9598:
---
Summary: [Checkpoints] The config Minimum Pause Between
Checkpoints doesn't work when there's a checkpoint failure
Key: FLINK-9598
URL: https://issues.apache.org/jira/browse/FLINK-9
[
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-9098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9098:
-
Fix Version/s: 1.6.0
> ClassLoaderITCase unstable
> --
>
>
[
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-9580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513951#comment-16513951
]
ASF GitHub Bot commented on FLINK-9580:
---
Github user pnowojski commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513952#comment-16513952
]
ASF GitHub Bot commented on FLINK-9580:
---
Github user pnowojski commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513954#comment-16513954
]
ASF GitHub Bot commented on FLINK-9487:
---
Github user StefanRRichter commented on th
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/6159
@azagrebin @sihuazhou I have addressed the comments and also slightly
refactored the PR. Please take another look if you want.
---
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6166#discussion_r195774052
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java ---
@@ -292,30 +292,49 @@ private void readRawResponse(FullHttpResponse
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6166#discussion_r195774420
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java ---
@@ -292,30 +292,49 @@ private void readRawResponse(FullHttpResponse
[
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=16513950#comment-16513950
]
Fabian Hueske edited comment on FLINK-9597 at 6/15/18 3:17 PM:
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513950#comment-16513950
]
Fabian Hueske commented on FLINK-9597:
--
Can add a few more details about the environ
[
https://issues.apache.org/jira/browse/FLINK-9468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9468.
--
Resolution: Fixed
Fixed via
1.5.1: 144ebba8cdf42133ba0a3db3d7cb1ca181be
1.6.0: 1ea02a998479
[
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-9006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9006:
-
Priority: Blocker (was: Critical)
> Cluster test: Run general purpose job with failures with Yar
[
https://issues.apache.org/jira/browse/FLINK-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9000:
-
Fix Version/s: 1.6.0
> Add automated cluster framework tests
> --
[
https://issues.apache.org/jira/browse/FLINK-9005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9005:
-
Fix Version/s: 1.6.0
> Cluster test: Run general purpose job with failures with Mesos
> -
[
https://issues.apache.org/jira/browse/FLINK-9006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9006:
-
Fix Version/s: 1.6.0
> Cluster test: Run general purpose job with failures with Yarn and per-job
[
https://issues.apache.org/jira/browse/FLINK-9005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9005:
-
Priority: Blocker (was: Critical)
> Cluster test: Run general purpose job with failures with Mes
[
https://issues.apache.org/jira/browse/FLINK-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9000:
-
Priority: Blocker (was: Critical)
> Add automated cluster framework tests
>
[
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-9159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9159:
-
Fix Version/s: 1.6.0
> Sanity check default timeout values
> ---
1 - 100 of 210 matches
Mail list logo
