[
https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sachin Goel closed FLINK-2404.
--
> LongCounters should have an "addValue()" method for primitive longs
>
[
https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14645267#comment-14645267
]
Sachin Goel commented on FLINK-2404:
Fixed via 571084152f81f984fa4cdfc2122c3edcf5b62ab
Ufuk Celebi created FLINK-2424:
--
Summary: InstantiationUtil.serializeObject(Object) does not close
output stream
Key: FLINK-2424
URL: https://issues.apache.org/jira/browse/FLINK-2424
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14645199#comment-14645199
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/948#issuecomment-125782171
Hey Ankur! Welcome to the Flink community. I didn't have a proper look at
your PR yet, but regarding the question you've asked in the issue: @StephanEwen
kicked off a discuss
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14645190#comment-14645190
]
Ankur Chauhan commented on FLINK-1984:
--
I just opened a pull request https://github.c
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14645173#comment-14645173
]
ASF GitHub Bot commented on FLINK-1984:
---
GitHub user ankurcha opened a pull request:
GitHub user ankurcha opened a pull request:
https://github.com/apache/flink/pull/948
[FLINK-1984] Integrate Flink with Apache Mesos
This pull requests adds a mesos scheduler and an executor (inspired from
the work done in, now abandoned, PR #251). The highlights are as follows:
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14645055#comment-14645055
]
Fabian Hueske commented on FLINK-992:
-
Hi [~nrai],
thanks for picking up this issue.
[
https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14645035#comment-14645035
]
ASF GitHub Bot commented on FLINK-2406:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/938#issuecomment-125751865
Out of curiosity: why was it failing sometimes on Travis and not locally?
And how did you discover this? From the program level logs?
Another thing that came to my mi
[
https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644962#comment-14644962
]
ASF GitHub Bot commented on FLINK-2419:
---
GitHub user gyfora opened a pull request:
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/947
[FLINK-2419] Add test for sinks after keyBy and groupBy
Adds a missing test for FLINK-2419
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/gyfora/f
[
https://issues.apache.org/jira/browse/FLINK-2399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644933#comment-14644933
]
ASF GitHub Bot commented on FLINK-2399:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/945#issuecomment-125734265
I had decided to work with my own understanding of what version means since
nobody replied to the JIRA comment.
getClass.getPackage.getImplementationVersion wou
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/945#issuecomment-125732043
I think we need to decide first what we actually mean by version and what
is supposed to match what.
What is actually the value
`getClass().getPackage().getI
[
https://issues.apache.org/jira/browse/FLINK-2399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644909#comment-14644909
]
ASF GitHub Bot commented on FLINK-2399:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644884#comment-14644884
]
ASF GitHub Bot commented on FLINK-2406:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/938#issuecomment-125726012
Think I found it. It actually sometimes failed infinitely often on close()
calls (due to outdated sanity checks) and recovered every time, so the test
took longer tha
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644819#comment-14644819
]
niraj rai commented on FLINK-992:
-
Hi Fabian,
Can you please provide more details about thi
[
https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644787#comment-14644787
]
ASF GitHub Bot commented on FLINK-2406:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/938#issuecomment-125700729
Unfortunately I also cannot reproduce it locally.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your p
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/938#issuecomment-125692765
It is strange that some tests take forever now. I cannot see why this test
causes this. I also cannot reproduce this locally, it only occurs on Travis.
But I
[
https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644754#comment-14644754
]
ASF GitHub Bot commented on FLINK-2406:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644692#comment-14644692
]
ASF GitHub Bot commented on FLINK-2406:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/938#issuecomment-125684625
But if you think this is some random issue occuring for me, go ahead. It
looks good and is a critical fix.
---
If your project is set up for it, you can reply to this ema
[
https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644679#comment-14644679
]
ASF GitHub Bot commented on FLINK-2406:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/938#issuecomment-125683207
That it causes the issue i wrote :P
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does no
[
https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644676#comment-14644676
]
ASF GitHub Bot commented on FLINK-2406:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/938#issuecomment-125682711
Any reservations against merging this?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
[
https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644674#comment-14644674
]
Gyula Fora commented on FLINK-2419:
---
I added an issue for this: https://issues.apache.or
Gyula Fora created FLINK-2423:
-
Summary: Properly test checkpoint notifications
Key: FLINK-2423
URL: https://issues.apache.org/jira/browse/FLINK-2423
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644666#comment-14644666
]
Robert Metzger commented on FLINK-2419:
---
I see that its tricky to implement a test f
[
https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martin Junghanns updated FLINK-2411:
Description:
Graph summarization determines a structural grouping of similar vertices and
e
[
https://issues.apache.org/jira/browse/FLINK-2422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644585#comment-14644585
]
ASF GitHub Bot commented on FLINK-2422:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/946#issuecomment-125665625
Thank you for the contribution.
+1 to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-2422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644584#comment-14644584
]
ASF GitHub Bot commented on FLINK-2422:
---
GitHub user buzdin opened a pull request:
GitHub user buzdin opened a pull request:
https://github.com/apache/flink/pull/946
[FLINK-2422] [web client] adding redirect link
- added explicit link in case browser is not redirecting properly
You can merge this pull request into a Git repository by running:
$ git pull https
[
https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644581#comment-14644581
]
ASF GitHub Bot commented on FLINK-2406:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/938#issuecomment-125664433
It's the same problem I guess, if you look at this Thread:
```
"Custom Source (6/6)" daemon prio=10 tid=0x7f96a80c9800 nid=0x112cf
runnable [0x7f9684
[
https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644576#comment-14644576
]
Stephan Ewen commented on FLINK-2361:
-
A fast way to check this is to run a variant wh
[
https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644565#comment-14644565
]
ASF GitHub Bot commented on FLINK-2406:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/938#issuecomment-125660687
You can observe it on this build for instance:
https://travis-ci.org/gyfora/flink/builds/73018512
---
If your project is set up for it, you can reply to this email and ha
Github user jkovacs commented on the pull request:
https://github.com/apache/flink/pull/907#issuecomment-125657216
Thanks @fhueske and @chiwanpark for the comprehensive review. I have pushed
our updated branch, addressing your comments. @r-pogalz will also contribute a
microbenchmark
[
https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644554#comment-14644554
]
ASF GitHub Bot commented on FLINK-2105:
---
Github user jkovacs commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-2404:
--
Assignee: Sachin Goel
> LongCounters should have an "addValue()" method for primitive lo
[
https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644531#comment-14644531
]
ASF GitHub Bot commented on FLINK-2404:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/942#issuecomment-125654972
Sure. :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-2422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2422:
--
Summary: Web client is showing a blank page if "Meta refresh" is disabled
in browser (was: Web
Robert Metzger created FLINK-2422:
-
Summary: Web client is showing a blank page if "Meta refresh" is
disabled
Key: FLINK-2422
URL: https://issues.apache.org/jira/browse/FLINK-2422
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2422:
--
Labels: starter (was: )
> Web client is showing a blank page if "Meta refresh" is disabled in b
[
https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-2404.
---
Resolution: Fixed
> LongCounters should have an "addValue()" method for primitive long
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/942#issuecomment-125653547
Thanks for the pull request!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have thi
[
https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644527#comment-14644527
]
ASF GitHub Bot commented on FLINK-2404:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/942
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabl
[
https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644510#comment-14644510
]
Robert Metzger commented on FLINK-2419:
---
Okay, I suspect its this one: https://githu
[
https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644526#comment-14644526
]
Gyula Fora commented on FLINK-2419:
---
Alright, it's going to be a tricky test due to the
[
https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644528#comment-14644528
]
ASF GitHub Bot commented on FLINK-2404:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644523#comment-14644523
]
ASF GitHub Bot commented on FLINK-2404:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/942#issuecomment-125652591
For the cases, where we add a primitive type on a Long/Int/DoubleCounter,
the optimization will automatically be used.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reopened FLINK-2419:
---
> DataStream sinks lose key information
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644503#comment-14644503
]
Gyula Fora commented on FLINK-2419:
---
I added a test in my other PR for the sinks.
> Dat
[
https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644487#comment-14644487
]
Robert Metzger edited comment on FLINK-2419 at 7/28/15 2:59 PM:
[
https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644487#comment-14644487
]
Robert Metzger commented on FLINK-2419:
---
Do you agree to reopen the issue until a te
[
https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-2419.
---
Resolution: Fixed
https://github.com/apache/flink/commit/78fd2146dd00da1130910d9f23f09e2504854ef7
> D
Stephan Ewen created FLINK-2421:
---
Summary: StreamRecordSerializer incorrectly duplicates and misses
tests
Key: FLINK-2421
URL: https://issues.apache.org/jira/browse/FLINK-2421
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644458#comment-14644458
]
Ufuk Celebi commented on FLINK-2412:
Thanks for reporting the issue. Looks like a bug
[
https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2412:
---
Component/s: (was: Local Runtime)
Distributed Runtime
> Index Out of Bounds Excep
[
https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2412:
---
Priority: Critical (was: Major)
> Index Out of Bounds Exception
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2412:
---
Fix Version/s: 0.9.1
0.10
> Index Out of Bounds Exception
> ---
[
https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2412:
---
Affects Version/s: 0.9
> Index Out of Bounds Exception
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-2412:
--
Assignee: Ufuk Celebi
> Index Out of Bounds Exception
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644429#comment-14644429
]
ASF GitHub Bot commented on FLINK-2406:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/938#issuecomment-125626437
Interesting... I had the same issue on my builds when I rebased on this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644405#comment-14644405
]
ASF GitHub Bot commented on FLINK-2406:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/938#issuecomment-125622275
Actually, the failure is not a deadlock. It just seems that the run is so
slow that the test takes more than 5 minutes. The stack trace indicates that
various tasks a
Stephan Ewen created FLINK-2420:
---
Summary: OutputFlush thread in stream writers does not propagate
exceptions
Key: FLINK-2420
URL: https://issues.apache.org/jira/browse/FLINK-2420
Project: Flink
Gyula Fora created FLINK-2419:
-
Summary: DataStream sinks lose key information
Key: FLINK-2419
URL: https://issues.apache.org/jira/browse/FLINK-2419
Project: Flink
Issue Type: Bug
Compo
[
https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644368#comment-14644368
]
ASF GitHub Bot commented on FLINK-2324:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/937#issuecomment-125604960
I am adding an IT case to this PR that tests partitioned states
independently.
---
If your project is set up for it, you can reply to this email and have your
reply appea
[
https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644358#comment-14644358
]
ASF GitHub Bot commented on FLINK-2404:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/942#issuecomment-125604252
No one will actually find out unless they specifically went through the
documentation for these. Most people would only ever see the docs for
Accumulator interface
[
https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644353#comment-14644353
]
ASF GitHub Bot commented on FLINK-2404:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/942#issuecomment-125603184
We can add a comment that the new ones are faster on primitives. It is not
possible to deprecate the older ones because they are inherited from the
Accumulator interface whic
[
https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644351#comment-14644351
]
Andra Lungu commented on FLINK-2412:
19:17:33,944 WARN org.apache.hadoop.util.NativeC
Stephan Ewen created FLINK-2418:
---
Summary: Add an end-to-end streaming fault tolerance test for the
Checkpointed interface
Key: FLINK-2418
URL: https://issues.apache.org/jira/browse/FLINK-2418
Project:
[
https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644346#comment-14644346
]
ASF GitHub Bot commented on FLINK-2324:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/937#issuecomment-125600663
Yes, I have written this above (that's why I replaced it with one using the
partitioned states). But that's not the only problem. If you introduce a
shuffle between two ma
[
https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644333#comment-14644333
]
ASF GitHub Bot commented on FLINK-2404:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644334#comment-14644334
]
ASF GitHub Bot commented on FLINK-2324:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/937#issuecomment-125597692
So, the `StreamCheckpointingITCase` actually has the problem that is uses
this reducer that is implicitly on an infinite window. Since that is not
checkpointed, all r
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/942#issuecomment-125597443
Should we add some kind of annotation to suggest the usage of the primitive
functions? We can't deprecate the older ones probably.
---
If your project is set up f
[
https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644255#comment-14644255
]
Maximilian Michels commented on FLINK-2412:
---
Do you have the log file of the tas
[
https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-2412:
--
Description:
When running a code as simple as:
{noformat}
ExecutionEnv
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/934#issuecomment-125561321
All in all, nice work @kl0u. Do you think we could change this pull request
such that we can handle "small/large" or "message/blobcached" accumulators more
transparently? It
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/934#discussion_r35635490
--- Diff:
flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingJobManager.scala
---
@@ -181,7 +181,7 @@ trait TestingJobManager extends Flink
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/934#discussion_r35635471
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/misc/MiscellaneousIssuesITCase.java
---
@@ -174,4 +177,52 @@ public void flatMap(Long value, Collector o
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/934#discussion_r35635421
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -911,6 +953,8 @@ class JobManager(
try {
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/934#discussion_r35635418
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -516,6 +545,19 @@ class JobManager(
}
/**
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/934#discussion_r35635383
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala ---
@@ -421,4 +421,16 @@ object AkkaUtils {
val duration = Duration(C
1 - 100 of 164 matches
Mail list logo
