[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438599#comment-15438599
]
Gabor Gevay commented on FLINK-3322:
Yes, I think Stephan meant that you would be main
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438609#comment-15438609
]
Zhijiang Wang commented on FLINK-4354:
--
Yes, so it would be started after flink-4478
shuai.xu created FLINK-4504:
---
Summary: Support user to decide whether the result of an operator
is presistent
Key: FLINK-4504
URL: https://issues.apache.org/jira/browse/FLINK-4504
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-4504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-4504:
---
Assignee: shuai.xu
> Support user to decide whether the result of an operator is presistent
> ---
[
https://issues.apache.org/jira/browse/FLINK-4489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438621#comment-15438621
]
Zhijiang Wang commented on FLINK-4489:
--
Does it refer to the slot manager in {{Resou
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2244
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438634#comment-15438634
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438661#comment-15438661
]
Aljoscha Krettek commented on FLINK-4486:
-
Or that a {{JobManager}} takes the job
[
https://issues.apache.org/jira/browse/FLINK-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438662#comment-15438662
]
Aljoscha Krettek commented on FLINK-4487:
-
This could also already be addressed by
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438680#comment-15438680
]
ASF GitHub Bot commented on FLINK-4271:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2305
The methods look good. They need a `@PublicEvolving` annotation and I think
we should mark them with `@Deprecated` and comment that they are a temporary
workaround while the `apply()` method has
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2422
Thanks for adding this.
I think that pure warning by the plugin will not be read and respected
really. So it makes only sense when a "bug" detected by the plugin fails the
build.
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2109
Hi,
I just saw that this was merged but I still have some comments. What is the
reason for the added Guava (test)-dependency? (Probably a leftover but should
nevertheless not be in this) And wha
[
https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438685#comment-15438685
]
Maximilian Michels commented on FLINK-4486:
---
The {{YarnClusterClient}} delays ch
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438684#comment-15438684
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438683#comment-15438683
]
ASF GitHub Bot commented on FLINK-4499:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-4486:
-
Assignee: Maximilian Michels
> JobManager not fully running when yarn-session.sh
[
https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4486:
--
Fix Version/s: 1.1.2
1.2.0
> JobManager not fully running when yarn-s
[
https://issues.apache.org/jira/browse/FLINK-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438690#comment-15438690
]
Stephan Ewen commented on FLINK-4487:
-
I think that the last changes for cluster manag
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438691#comment-15438691
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/4810910431e01bf143ae77a6e93a86f2fafbccd0#commitcomment-18789532
There is some followup discussion on this in the JIRA issue:
https://issues.apache.org/jira/browse/FLINK-3677
---
If your pro
[
https://issues.apache.org/jira/browse/FLINK-4494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438695#comment-15438695
]
Aljoscha Krettek commented on FLINK-4494:
-
+1 that would be a very good change
>
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438697#comment-15438697
]
Stephan Ewen commented on FLINK-3677:
-
I agree with Aljoscha.
I am against adding tha
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/abb4496781883937a935113c1e33ae1174aafa73#commitcomment-18789807
Can I re-iterate on this issue?
Do we need tests here that fire up Kafka clusters? Those are very time
intensive, they
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438710#comment-15438710
]
Stephan Ewen commented on FLINK-3874:
-
I think this needs some improvement. I also com
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438710#comment-15438710
]
Stephan Ewen edited comment on FLINK-3874 at 8/26/16 9:25 AM:
--
Github user mushketyk commented on the pull request:
https://github.com/apache/flink/commit/abb4496781883937a935113c1e33ae1174aafa73#commitcomment-18789946
Hi Stephan.
I think you are right.
I'll update the testing as soon as possible and create a different PR to
address
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438716#comment-15438716
]
Ivan Mushketyk commented on FLINK-3677:
---
Stephan, Aljoscha
Thank you for pointing t
Zhijiang Wang created FLINK-4505:
Summary: Implement abstract TaskManagerFactory to bring up
TaskManager for different modes
Key: FLINK-4505
URL: https://issues.apache.org/jira/browse/FLINK-4505
Proje
[
https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4505:
-
Summary: Implement TaskManagerFactory to bring up TaskManager for different
modes (was: Implement
[
https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4505:
Assignee: Zhijiang Wang
> Implement TaskManagerFactory to bring up TaskManager for differen
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438733#comment-15438733
]
ASF GitHub Bot commented on FLINK-4271:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2305
Hi @StephanEwen , comments addressed.
I'm not sure whether the comments are correct. Let me know if I'm wrong.
---
If your project is set up for it, you can reply to this email and have yo
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438745#comment-15438745
]
Zhijiang Wang commented on FLINK-4363:
--
Hi [~mxm], I have created the FLINK-4505 for
[
https://issues.apache.org/jira/browse/FLINK-4502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438754#comment-15438754
]
Chesnay Schepler commented on FLINK-4502:
-
Alright, so let's break this down point
Michael Wong created FLINK-4506:
---
Summary: CsvOutputFormat defaults allowNullValues to false, even
though doc and declaration says true
Key: FLINK-4506
URL: https://issues.apache.org/jira/browse/FLINK-4506
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2423
[FLINK-4486] detached YarnSession: wait until cluster startup is complete
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink FLINK-4486
Alte
[
https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438759#comment-15438759
]
ASF GitHub Bot commented on FLINK-4486:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4498:
Component/s: Cassandra Connector
> Better Cassandra sink documentation
> ---
[
https://issues.apache.org/jira/browse/FLINK-4502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4502:
Component/s: Cassandra Connector
> Cassandra connector documentation has misleading consiste
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2361
Could someone please take a look at this PR? It has been here without a
review for more than 2 weeks.
---
If your project is set up for it, you can reply to this email and have your
reply appear o
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438769#comment-15438769
]
ASF GitHub Bot commented on FLINK-3318:
---
Github user mushketyk commented on the issu
Github user joshfg commented on the issue:
https://github.com/apache/flink/pull/2269
Hi Aljoscha, just wanted to remind you about this - any idea when the
changes will be merged in? Thanks!
---
If your project is set up for it, you can reply to this email and have your
reply appear o
[
https://issues.apache.org/jira/browse/FLINK-4190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438770#comment-15438770
]
ASF GitHub Bot commented on FLINK-4190:
---
Github user joshfg commented on the issue:
Ufuk Celebi created FLINK-4507:
--
Summary: Deprecate savepoint backend config
Key: FLINK-4507
URL: https://issues.apache.org/jira/browse/FLINK-4507
Project: Flink
Issue Type: Sub-task
C
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2374#discussion_r76410073
--- Diff: docs/monitoring/metrics.md ---
@@ -155,6 +155,55 @@ public class MyMapper extends RichMapFunction {
}
{% endhighlight %}
+ Met
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438868#comment-15438868
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2374#discussion_r76410471
--- Diff:
flink-metrics/flink-metrics-dropwizard/src/test/java/org/apache/flink/dropwizard/metrics/DropwizardMeterWrapperTest.java
---
@@ -0,0 +1,60 @@
+/
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438875#comment-15438875
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438884#comment-15438884
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438883#comment-15438883
]
Maximilian Michels commented on FLINK-4487:
---
{quote}
1. If there is already a ya
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2374#discussion_r76411144
--- Diff:
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/Meter.java
---
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438935#comment-15438935
]
Maximilian Michels commented on FLINK-3677:
---
I reviewed the pull requests and I
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438936#comment-15438936
]
Maximilian Michels commented on FLINK-3677:
---
No worries. Your changes are not wr
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2109
@aljoscha As already pointed out in the JIRA issue, the method is not new.
A now obsolete method has been deprecated (the diff is hard to read).
---
If your project is set up for it, you can reply to th
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438938#comment-15438938
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mxm commented on the issue:
Stefan Richter created FLINK-4508:
-
Summary: Consolidate DummyEnvironment and MockEnvironment for Tests
Key: FLINK-4508
URL: https://issues.apache.org/jira/browse/FLINK-4508
Project: Flink
Is
Github user nielsbasjes commented on the issue:
https://github.com/apache/flink/pull/2330
I managed to resolve the problems with running these unit tests.
These problems were caused by version conflicts in guava.
Now we have a HBaseMiniCluster that is started, a table with mult
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439102#comment-15439102
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user nielsbasjes commented on the is
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2391
Thanks @fhueske. I will address your comments and 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
[
https://issues.apache.org/jira/browse/FLINK-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439108#comment-15439108
]
ASF GitHub Bot commented on FLINK-3580:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439112#comment-15439112
]
Maximilian Michels commented on FLINK-4487:
---
I totally forgot that there is also
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2391
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439125#comment-15439125
]
ASF GitHub Bot commented on FLINK-3580:
---
Github user asfgit closed the pull request
Ufuk Celebi created FLINK-4509:
--
Summary: Specify savepoint directory per savepoint
Key: FLINK-4509
URL: https://issues.apache.org/jira/browse/FLINK-4509
Project: Flink
Issue Type: Sub-task
Ufuk Celebi created FLINK-4510:
--
Summary: Always create CheckpointCoordinator
Key: FLINK-4510
URL: https://issues.apache.org/jira/browse/FLINK-4510
Project: Flink
Issue Type: Sub-task
Ufuk Celebi created FLINK-4511:
--
Summary: Schedule periodic savepoints
Key: FLINK-4511
URL: https://issues.apache.org/jira/browse/FLINK-4511
Project: Flink
Issue Type: Sub-task
Compone
[
https://issues.apache.org/jira/browse/FLINK-4508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439165#comment-15439165
]
Aljoscha Krettek commented on FLINK-4508:
-
Plus there's custom-mocked Environments
Ufuk Celebi created FLINK-4512:
--
Summary: Add option for persistent checkpoints
Key: FLINK-4512
URL: https://issues.apache.org/jira/browse/FLINK-4512
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439178#comment-15439178
]
Vasia Kalavri commented on FLINK-4440:
--
Alright, makes sense. Let's close this then.
[
https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439188#comment-15439188
]
Ivan Mushketyk commented on FLINK-4440:
---
It's ok with me. I'll close the JIRA issue
[
https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk closed FLINK-4440.
-
Resolution: Not A Problem
> Make API for edge/vertex creation less verbose
> -
[
https://issues.apache.org/jira/browse/FLINK-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439239#comment-15439239
]
ASF GitHub Bot commented on FLINK-4459:
---
GitHub user KurtYoung opened a pull request
GitHub user KurtYoung opened a pull request:
https://github.com/apache/flink/pull/2424
[FLINK-4459][Scheduler] Introduce SlotProvider for Scheduler
Introduce SlotProvider, prepare for the further slot allocation refactoring
You can merge this pull request into a Git repository by ru
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2269
Hi,
I'm very for the delays! I still have this sitting at the top of my list
and I'm hoping to get this in by beginning of next week.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-4190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439249#comment-15439249
]
ASF GitHub Bot commented on FLINK-4190:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439277#comment-15439277
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2109
@mxm @mushketyk Technically this change does add a new method that is the
now deprecated method minus the `FilePathFilter`. That's a good change, though,
since it simplifies the API in the long run.
Fabian Hueske created FLINK-4513:
Summary: Kafka connector documentation refers to Flink 1.1-SNAPSHOT
Key: FLINK-4513
URL: https://issues.apache.org/jira/browse/FLINK-4513
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439292#comment-15439292
]
Jark Wu commented on FLINK-4510:
Hi [~uce] , I would like to contribute this issue.
> Alw
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2109
Ah, got it too now. The diff only makes it appear like the deprecated
method is new. Then I take that back :-)
A followup on removing Guava would be nice, through...
---
If your project is s
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439303#comment-15439303
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4510:
Assignee: Jark Wu
> Always create CheckpointCoordinator
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439312#comment-15439312
]
Stephan Ewen commented on FLINK-4510:
-
[~jark] Thanks for helping out here. I assigned
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439315#comment-15439315
]
Stephan Ewen commented on FLINK-4512:
-
+1 that makes a lot of sense.
One thing to wat
[
https://issues.apache.org/jira/browse/FLINK-4509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439317#comment-15439317
]
Stephan Ewen commented on FLINK-4509:
-
I think this needs some pre-requisite changes t
[
https://issues.apache.org/jira/browse/FLINK-4419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439327#comment-15439327
]
Greg Hogan commented on FLINK-4419:
---
My apologies for being late to this discussion. Are
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2419
Our currents tests make it difficult to test such behavior. Added a check
to the `YarnTestBase`. Basically, I'm skipping the cluster shutdown to check if
the JobManager is still alive and hasn't been shu
[
https://issues.apache.org/jira/browse/FLINK-4488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439346#comment-15439346
]
ASF GitHub Bot commented on FLINK-4488:
---
Github user mxm commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2418
Looks good to me!
The only not-so-nice thing is that we have to convert the `Map` to a
`HashTable` for every metric. Given how we tried to optimize the metric
creation overhead, this it
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439348#comment-15439348
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439359#comment-15439359
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2418
Actually, it may be possible, and not too bad if we assume the Hashtable is
immutable. Something like this:
```java
public class HashtableWrapper extends Hashtable {
priv
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2109
@mxm @aljoscha @StephanEwen Thank you for your comments. Seems like this is
sorted out :)
I'll remove Guava calls today at the evening.
---
If your project is set up for it, you can reply to t
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439364#comment-15439364
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mushketyk commented on the issu
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2376
Very good work and very nice code!
Some comments after a joint review:
- The most critical issue is that there should not be any blocking on
async threads during task shutdown.
[
https://issues.apache.org/jira/browse/FLINK-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439372#comment-15439372
]
ASF GitHub Bot commented on FLINK-3755:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2388
Looks quite good all in all.
Be good to get this in, so that JobManager followup work can build on this.
I would take this, rebase it, and merge it. If I find some issues I would
crea
[
https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439373#comment-15439373
]
ASF GitHub Bot commented on FLINK-4347:
---
Github user StephanEwen commented on the is
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2383
---
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 enab
1 - 100 of 134 matches
Mail list logo
