Stephan Ewen created FLINK-2520:
---
Summary: StreamFaultToleranceTestBase does not allow for multiple
tests
Key: FLINK-2520
URL: https://issues.apache.org/jira/browse/FLINK-2520
Project: Flink
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1013
---
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
[
https://issues.apache.org/jira/browse/FLINK-2517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2517.
-
Resolution: Fixed
Fix Version/s: 0.10
Fixed via 51872d73b83a86603fd1f2e8e481d3cceb755e38
[
https://issues.apache.org/jira/browse/FLINK-2519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2519.
---
BarrierBuffers get stuck infinitely when some inputs end early
[
https://issues.apache.org/jira/browse/FLINK-2519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2519.
-
Resolution: Fixed
Fixed via e1d1bd0a224b32f6a488e400f5f07e4ab4b65869
BarrierBuffers get stuck
[
https://issues.apache.org/jira/browse/FLINK-2517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696902#comment-14696902
]
ASF GitHub Bot commented on FLINK-2517:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2515.
-
Resolution: Fixed
Assignee: Stephan Ewen
Fixed via 06e2da352fb63f7922f634e6aaf5381d89de57a5
[
https://issues.apache.org/jira/browse/FLINK-2515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2515.
---
CheckpointCoordinator triggers checkpoints even if not all sources are
running any more
[
https://issues.apache.org/jira/browse/FLINK-2516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696922#comment-14696922
]
ASF GitHub Bot commented on FLINK-2516:
---
Github user chiwanpark commented on the
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/977#issuecomment-131001646
@StephanEwen
Hi, I did some changes few days ago.
Could you take a look again?
Thank you!
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696622#comment-14696622
]
ASF GitHub Bot commented on FLINK-2477:
---
Github user HuangWHWHW commented on the
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696619#comment-14696619
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user ChengXiangLi commented on the
Github user ChengXiangLi commented on the pull request:
https://github.com/apache/flink/pull/949#issuecomment-131001106
Thanks for the review, @thvasilo , fixed all comments in latest commit.
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/949#discussion_r37054584
--- Diff:
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/SampleITCase.scala
---
@@ -0,0 +1,166 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696632#comment-14696632
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696603#comment-14696603
]
ASF GitHub Bot commented on FLINK-2480:
---
Github user HuangWHWHW commented on a diff
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/991#issuecomment-130999180
Hi, I have done a new changes.
---
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
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/991#discussion_r37053652
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/PrintSinkFunctionTest.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696607#comment-14696607
]
ASF GitHub Bot commented on FLINK-2480:
---
Github user HuangWHWHW commented on the
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696610#comment-14696610
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user HuangWHWHW commented on the
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/992#issuecomment-130999638
Hi , I did a new change.
---
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
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1015
[FLINK-2521] [tests] Adds automatic test name and reason of failure logging
Adds TestLogger class which automatically logs the currently executed test
names and the reasons for a failure. The
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/696#issuecomment-131112793
I agree that exact k-NN does not scale well. However, we can use your PR as
a baseline implementation to compare the approximate algorithm against.
---
If your
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697027#comment-14697027
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696979#comment-14696979
]
ASF GitHub Bot commented on FLINK-2521:
---
GitHub user tillrohrmann opened a pull
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/696#issuecomment-131107449
+1 for closing this and focusing on approximate kNN instead.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697000#comment-14697000
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user thvasilo commented on the pull
GitHub user nezihyigitbasi opened a pull request:
https://github.com/apache/flink/pull/1013
Minor fix to streaming guide
For the `KafkaSink` example in the streaming guide, the doc says zookeeper
host/port should be specified in the constructor. But it should be the list of
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/967#issuecomment-131030134
Hi @nltran,
thanks for updating the PR!
I don't have time for a thorough review now, but I'll answer your last
question.
ASF homepage states: *[The ASF
[
https://issues.apache.org/jira/browse/FLINK-2517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696759#comment-14696759
]
ASF GitHub Bot commented on FLINK-2517:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696758#comment-14696758
]
Stephan Ewen commented on FLINK-2517:
-
Thanks for the pointer!
[~rmetzger] and me are
Nezih Yigitbasi created FLINK-2517:
--
Summary: Wrong KafkaSink arguments in streaming guide
Key: FLINK-2517
URL: https://issues.apache.org/jira/browse/FLINK-2517
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697106#comment-14697106
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user kno10 commented on the pull
Stephan Ewen created FLINK-2523:
---
Summary: Increase interrupt timeout in Task Canceling
Key: FLINK-2523
URL: https://issues.apache.org/jira/browse/FLINK-2523
Project: Flink
Issue Type:
Stephan Ewen created FLINK-2524:
---
Summary: Add getTaskNameWithSubtasks() to RuntimeContext
Key: FLINK-2524
URL: https://issues.apache.org/jira/browse/FLINK-2524
Project: Flink
Issue Type:
Github user kno10 commented on the pull request:
https://github.com/apache/flink/pull/696#issuecomment-131123325
On low-dimensional data, exact kNN may be feasible using grid-based
approaches even for very large data sets. It's not very sexy to implement
this, but its also not very
[
https://issues.apache.org/jira/browse/FLINK-2524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-2524:
Labels: easyfix starter (was: )
Add getTaskNameWithSubtasks() to RuntimeContext
[
https://issues.apache.org/jira/browse/FLINK-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697170#comment-14697170
]
Stephan Ewen commented on FLINK-2393:
-
Added the documentation in
[
https://issues.apache.org/jira/browse/FLINK-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2393.
-
Resolution: Fixed
Completed with the addition of the documentation in
[
https://issues.apache.org/jira/browse/FLINK-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2393.
---
Add a stateless at-least-once mode for streaming
--
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/977#discussion_r37086314
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/SocketClientSinkTest.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697195#comment-14697195
]
ASF GitHub Bot commented on FLINK-2477:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697200#comment-14697200
]
ASF GitHub Bot commented on FLINK-2306:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/977#issuecomment-131144157
I think this is good, minus two small comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/977#discussion_r37086274
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/SocketClientSinkTest.java
---
@@ -0,0
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1009#issuecomment-131148157
All tests are failing though, not sure if bc this patch
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1004#issuecomment-131148744
Wow, looks like a good piece of work. Nicely with tests and everything.
Build also passes, style looks good.
+1 to merge this from my side. I'd like to
[
https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697229#comment-14697229
]
ASF GitHub Bot commented on FLINK-2457:
---
Github user StephanEwen commented on the
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1016
[FLINK-2291] [runtime] Adds high availability support via ZooKeeper
## Idea
This PR introduces cluster high availability via ZooKeeper. The idea is to
use ZooKeeper to do leader
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/983#issuecomment-131150367
Looks good, will merge this.
Will make slight adjustments in the merge (for code style consistency),
like naming the single instance uppercase `INSTANCE`.
[
https://issues.apache.org/jira/browse/FLINK-2291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697230#comment-14697230
]
ASF GitHub Bot commented on FLINK-2291:
---
GitHub user tillrohrmann opened a pull
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/996#issuecomment-131148950
I am in the middle of polishing this, adding more tests, and fixing quite a
few remaining bugs. Will hopefully open a new pull request soon.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697223#comment-14697223
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697196#comment-14697196
]
ASF GitHub Bot commented on FLINK-2477:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1011#issuecomment-131144983
Looks like an issue with shaded dependencies.
Have a look here for some background on shading:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1009#issuecomment-131146003
Looks good, will merge 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 does
[
https://issues.apache.org/jira/browse/FLINK-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697194#comment-14697194
]
ASF GitHub Bot commented on FLINK-2477:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697210#comment-14697210
]
ASF GitHub Bot commented on FLINK-2512:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697224#comment-14697224
]
ASF GitHub Bot commented on FLINK-2512:
---
Github user hsaputra commented on a diff in
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/1009#discussion_r37087438
--- Diff:
flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/api/FlinkSubmitter.java
---
[
https://issues.apache.org/jira/browse/FLINK-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697219#comment-14697219
]
ASF GitHub Bot commented on FLINK-2512:
---
Github user hsaputra commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697222#comment-14697222
]
ASF GitHub Bot commented on FLINK-1962:
---
Github user StephanEwen commented on the
Github user PieterJanVanAeken commented on the pull request:
https://github.com/apache/flink/pull/1004#issuecomment-131156825
I would postpone adding the completeness check as it will currently fail.
Since I started working on this, the Java Gelly API has changed and while I
modified
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697258#comment-14697258
]
ASF GitHub Bot commented on FLINK-1962:
---
Github user PieterJanVanAeken commented on
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/934#issuecomment-131208713
I will have a look in a bit.
Am currently stuck with some streaming runtime fixes and the Kafka
integration. Overflowing a bit with issues right now.
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-2523:
Summary: Make task canceling interrupt interval configurable (was:
Increase interrupt timeout in
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/934#issuecomment-131208217
Just rebased with the new version of the master.
Please have a look.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/934#issuecomment-131209661
No problem!
This message was just a reminder.
Thanks a lot!
---
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-2431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2431.
-
Resolution: Fixed
Fix Version/s: 0.10
Fixed via f350e45d97015c5d36a1d0f02025e6c6eeca44fe
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697527#comment-14697527
]
Stephan Ewen commented on FLINK-2523:
-
Initially increased to 30 seconds in
[
https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697522#comment-14697522
]
ASF GitHub Bot commented on FLINK-2457:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697521#comment-14697521
]
ASF GitHub Bot commented on FLINK-2431:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2457.
---
Integrate Tuple0
Key: FLINK-2457
URL:
[
https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2457.
-
Resolution: Fixed
Fix Version/s: 0.10
Implemented in
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/961
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/983
---
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
[
https://issues.apache.org/jira/browse/FLINK-2431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2431.
---
[py] refactor PlanBinder/OperationInfo
--
Key:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/961#issuecomment-131167834
Will merge 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 does not have this
[
https://issues.apache.org/jira/browse/FLINK-2431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697321#comment-14697321
]
ASF GitHub Bot commented on FLINK-2431:
---
Github user StephanEwen commented on the
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1004#issuecomment-131169939
+1 from me too. Thanks for your great work @PieterJanVanAeken!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/989#issuecomment-131165838
Sorry for catching this so late.
I actually put such sanity checks in a lot of places in the code I write,
and they have served well.
In the case where
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697327#comment-14697327
]
ASF GitHub Bot commented on FLINK-1962:
---
Github user vasia commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697838#comment-14697838
]
ASF GitHub Bot commented on FLINK-2521:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1015#issuecomment-131248356
Looks very nice!
I would actually make the log statements about start and stop more
prominent (for example frame them with an ascii ruler) to make them
[
https://issues.apache.org/jira/browse/FLINK-2495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2495.
---
Add a null point check in API DataStream.union
--
[
https://issues.apache.org/jira/browse/FLINK-2495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2495.
-
Resolution: Won't Fix
Fix Version/s: (was: 0.10)
Decided to not fix (see issue
[
https://issues.apache.org/jira/browse/FLINK-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-2462:
---
Assignee: Stephan Ewen
Wrong exception reporting in streaming jobs
[
https://issues.apache.org/jira/browse/FLINK-2482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697802#comment-14697802
]
Stephan Ewen commented on FLINK-2482:
-
A lot is done as of
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1016#issuecomment-131246273
Big piece of work.
I'd like to have a look at this, but it may take a few days...
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-2291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697831#comment-14697831
]
ASF GitHub Bot commented on FLINK-2291:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697839#comment-14697839
]
ASF GitHub Bot commented on FLINK-2291:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1016#issuecomment-131249089
From a first glance this looks super nice! Very excited to get this in and
try it out seriously on a cluster!
Good day, today :-)
---
If your project is
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1017
[FLINK-2462] [streaming] Major cleanup of streaming task structure
This pull request addresses exception handling, code duplication, and
missed resource cleanups in the streaming operators.
[
https://issues.apache.org/jira/browse/FLINK-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697827#comment-14697827
]
ASF GitHub Bot commented on FLINK-2462:
---
GitHub user StephanEwen opened a pull
Github user ffbin closed the pull request at:
https://github.com/apache/flink/pull/989
---
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
Github user ffbin commented on the pull request:
https://github.com/apache/flink/pull/989#issuecomment-131276961
@StephanEwen Thanks.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14698042#comment-14698042
]
ASF GitHub Bot commented on FLINK-2486:
---
Github user ffbin closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14698035#comment-14698035
]
ASF GitHub Bot commented on FLINK-2516:
---
Github user ffbin commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14698036#comment-14698036
]
ASF GitHub Bot commented on FLINK-2516:
---
Github user ffbin closed the pull request
Github user ffbin closed the pull request at:
https://github.com/apache/flink/pull/1012
---
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
1 - 100 of 125 matches
Mail list logo
