[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131746#comment-15131746
]
ASF GitHub Bot commented on FLINK-2935:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1500#issuecomment-179643330
Failing test seems not related to this PR.
---
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 pro
[
https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131745#comment-15131745
]
Chiwan Park commented on FLINK-3330:
I think that adding {{SparseVector}} support requ
[
https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chiwan Park updated FLINK-3330:
---
Description:
A user reported the problem using {{GradientDescent}} algorithm with
{{SparseVector}}.
Chiwan Park created FLINK-3330:
--
Summary: Add SparseVector support to BLAS library in FlinkML
Key: FLINK-3330
URL: https://issues.apache.org/jira/browse/FLINK-3330
Project: Flink
Issue Type: Imp
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131661#comment-15131661
]
Subhobrata Dey commented on FLINK-2678:
---
[~till.rohrmann] Please help in reviewing t
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131659#comment-15131659
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user sbcd90 commented on the pull re
Github user sbcd90 commented on the pull request:
https://github.com/apache/flink/pull/1566#issuecomment-179599473
Hello @tillrohrmann ..I have made all the changes you have mentioned.
- support for CompositeType.
- added test cases for both primitive type & composite type
Ted Yu created FLINK-3329:
-
Summary: Unclosed BackupEngine in AbstractRocksDBState#snapshot()
Key: FLINK-3329
URL: https://issues.apache.org/jira/browse/FLINK-3329
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3254.
Resolution: Fixed
Fixed with aabb2688a3f4b69a95a87c773a4fe86c76b8ef0f
> CombineFunction interface n
[
https://issues.apache.org/jira/browse/FLINK-3161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3161.
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed with f7d1911518da4bd1b4f742e5b4525e7867665f51
>
[
https://issues.apache.org/jira/browse/FLINK-3293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3293.
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed with 934774f0d2005ed93feb3e688d60a06076b94e92
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1558
---
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-3293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131366#comment-15131366
]
ASF GitHub Bot commented on FLINK-3293:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1523
---
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-3161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131365#comment-15131365
]
ASF GitHub Bot commented on FLINK-3161:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131367#comment-15131367
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1568
---
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-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131222#comment-15131222
]
Greg Hogan commented on FLINK-3291:
---
Object reuse is active when object reuse is enabled
[
https://issues.apache.org/jira/browse/FLINK-3161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131121#comment-15131121
]
ASF GitHub Bot commented on FLINK-3161:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131122#comment-15131122
]
ASF GitHub Bot commented on FLINK-3293:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1558#issuecomment-179464954
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 does not have this feature
e
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1523#issuecomment-179464861
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 does not have this feature
e
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131119#comment-15131119
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1568#issuecomment-179464772
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 does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-3268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131071#comment-15131071
]
Robert Metzger commented on FLINK-3268:
---
Again: https://s3.amazonaws.com/archive.tra
[
https://issues.apache.org/jira/browse/FLINK-2719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131073#comment-15131073
]
Robert Metzger commented on FLINK-2719:
---
Again https://s3.amazonaws.com/archive.trav
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1558#issuecomment-179436819
+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 your project does not have this feature
e
[
https://issues.apache.org/jira/browse/FLINK-3293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131042#comment-15131042
]
ASF GitHub Bot commented on FLINK-3293:
---
Github user rmetzger commented on the pull
Github user rmetzger closed the pull request at:
https://github.com/apache/flink/pull/1576
---
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 en
Stephan Ewen created FLINK-3328:
---
Summary: Incorrectly shaded dependencies in flink-runtime
Key: FLINK-3328
URL: https://issues.apache.org/jira/browse/FLINK-3328
Project: Flink
Issue Type: Bug
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/1574#issuecomment-179434902
Thanks for the comments, updated the PR accordingly.
---
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 kl0u opened a pull request:
https://github.com/apache/flink/pull/1583
ExecutionConfig to JobGraph.
This makes the ExecutionConfig available to the Task. In a nutshell, the
ExecutionConfig is attached to the JobGraph which is sent to the JobManager.
The JobManager passes
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1582
---
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
Kostas created FLINK-3327:
-
Summary: Attach the ExecutionConfig to the JobGraph and make it
accessible to the AbstractInvocable.
Key: FLINK-3327
URL: https://issues.apache.org/jira/browse/FLINK-3327
Project:
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1582#issuecomment-179365728
Thanks Roberto!
---
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
en
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1582#issuecomment-179365545
Cherry picked to my local `release-0.10` branch and `mvn clean verify`
succeeds.
---
If your project is set up for it, you can reply to this email and have your
reply appea
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1582#issuecomment-179365564
I think the change is good to merge when travis has passed.
I tried it on GCE:
```
17:36:55,084 INFO org.apache.flink.yarn.YarnTaskManager
[
https://issues.apache.org/jira/browse/FLINK-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130714#comment-15130714
]
Robert Metzger commented on FLINK-3324:
---
I think before we document the flume connec
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130379#comment-15130379
]
Andrea Sella edited comment on FLINK-3311 at 2/3/16 4:40 PM:
-
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1582
[hotfix, yarn] Exit JVM after YARN actor system shut down
Addressed comments from #1576 and waiting for Travis. @rmetzger can you
easily re-test your GCE instance with this PR?
You can merge this pull
[
https://issues.apache.org/jira/browse/FLINK-3326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Farouk Salem closed FLINK-3326.
---
Resolution: Invalid
> Kafka Consumer doesn't retrieve messages after killing flink job which was
> us
[
https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130607#comment-15130607
]
ASF GitHub Bot commented on FLINK-3160:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1564#issuecomment-179313154
I did not look at the code, but the screenshots look very good.
+1 for renaming "Overview" to "Subtasks" and adding the TaskManager tab.
I'm OK with using ports f
[
https://issues.apache.org/jira/browse/FLINK-3161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130596#comment-15130596
]
ASF GitHub Bot commented on FLINK-3161:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1523#issuecomment-179308417
Hi @greghogan, thanks for the update!
Looks good to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHu
[
https://issues.apache.org/jira/browse/FLINK-3326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130590#comment-15130590
]
Farouk Salem commented on FLINK-3326:
-
Thanks for your super fast replies. Regarding u
[
https://issues.apache.org/jira/browse/FLINK-3326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130578#comment-15130578
]
Aljoscha Krettek commented on FLINK-3326:
-
What are you setting as your {{"group.i
[
https://issues.apache.org/jira/browse/FLINK-3326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130575#comment-15130575
]
Robert Metzger commented on FLINK-3326:
---
Did the first job use checkpointing?
Do you
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51737319
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/AggregateFunction.scala
---
@@ -0,0 +1,71 @@
+/*
+ * L
Farouk Salem created FLINK-3326:
---
Summary: Kafka Consumer doesn't retrieve messages after killing
flink job which was using the same topic
Key: FLINK-3326
URL: https://issues.apache.org/jira/browse/FLINK-3326
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51732524
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataset/DataSetJoinRule.scala
---
@@ -46,12 +57,93 @@ class DataSe
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51731066
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataset/DataSetJoinRule.scala
---
@@ -39,6 +46,10 @@ class DataSet
[
https://issues.apache.org/jira/browse/FLINK-3325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-3325.
--
Resolution: Fixed
Fixed via 077dd55885fc91b7dd4c96c07ee6853a97db1a49
> Unclosed InputStream in
[
https://issues.apache.org/jira/browse/FLINK-3325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-3325:
Assignee: Till Rohrmann
> Unclosed InputStream in CEPPatternOperator#restoreState()
> -
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51728841
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/AggregateFunction.scala
---
@@ -0,0 +1,71 @@
+/*
+ * L
Ted Yu created FLINK-3325:
-
Summary: Unclosed InputStream in CEPPatternOperator#restoreState()
Key: FLINK-3325
URL: https://issues.apache.org/jira/browse/FLINK-3325
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-3324:
---
Component/s: (was: Streaming Connectors)
> Flume connector not documented
> --
[
https://issues.apache.org/jira/browse/FLINK-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-3324:
---
Description: Add Flume-connector documentation to the "Data Stream /
Connectors" web page docs
[
https://issues.apache.org/jira/browse/FLINK-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-3324:
---
Component/s: Streaming Connectors
> Flume connector not documented
> -
[
https://issues.apache.org/jira/browse/FLINK-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-3324:
---
Description: Add Flume-connector documentation to the "Data Stream /
Connectors" web page docs
[
https://issues.apache.org/jira/browse/FLINK-3323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-3323:
---
Description: Add Nifi-connector documentation to the "Data Stream /
Connectors" web page docs.
Matthias J. Sax created FLINK-3323:
--
Summary: Nifi connector not documented
Key: FLINK-3323
URL: https://issues.apache.org/jira/browse/FLINK-3323
Project: Flink
Issue Type: Improvement
Matthias J. Sax created FLINK-3324:
--
Summary: Flume connector not documented
Key: FLINK-3324
URL: https://issues.apache.org/jira/browse/FLINK-3324
Project: Flink
Issue Type: Improvement
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51727237
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/SumAggregate.scala
---
@@ -0,0 +1,130 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51726723
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/MaxAggregate.scala
---
@@ -0,0 +1,136 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51726774
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/MaxAggregate.scala
---
@@ -0,0 +1,136 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51726618
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/MaxAggregate.scala
---
@@ -0,0 +1,136 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130452#comment-15130452
]
Gabor Gevay commented on FLINK-3291:
OK, sorry, I think I have now understood what you
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130446#comment-15130446
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on the p
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51725520
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/AvgAggregate.scala
---
@@ -0,0 +1,148 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51725411
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/AggregateFactory.scala
---
@@ -0,0 +1,135 @@
+/*
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/750#issuecomment-179261307
I think we can get this done today or tomorrow and then finally merge the
PR. Looking forward having this code in the master branch :-)
---
If your project is set u
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51724615
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/AggregateFactory.scala
---
@@ -0,0 +1,135 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130443#comment-15130443
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/750#issuecomment-179260525
Good work @mjsax. I had one last comment. It concerns stopping a job when
it's in the state `RESTARTING`. I think we have to allow the state transition
`RESTARTING`
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51724939
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/AggregateFactory.scala
---
@@ -0,0 +1,135 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130436#comment-15130436
]
ASF GitHub Bot commented on FLINK-3034:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1580#issuecomment-179257332
Please add documentation for the web page. For details, see here:
https://github.com/apache/flink/tree/master/docs
---
If your project is set up for it, you can reply to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51723549
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/FunctionUtils.scala
---
@@ -0,0 +1,37 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51723439
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/AggregateFunction.scala
---
@@ -0,0 +1,71 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130419#comment-15130419
]
ASF GitHub Bot commented on FLINK-3128:
---
Github user f-sander commented on a diff in
Github user f-sander commented on a diff in the pull request:
https://github.com/apache/flink/pull/1565#discussion_r51723047
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/regression/IsotonicRegression.scala
---
@@ -0,0 +1,282 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130415#comment-15130415
]
ASF GitHub Bot commented on FLINK-3128:
---
Github user f-sander commented on the pull
Github user f-sander commented on the pull request:
https://github.com/apache/flink/pull/1565#issuecomment-179247125
There is one advantage of this over using a single-node ML-Lib: This
implementation contains the compression procedure used in Spark that combines
data points with equa
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51722014
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/AggregateFunction.scala
---
@@ -0,0 +1,71 @@
+/*
+ * L
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1567#discussion_r51722041
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/AggregateFunction.scala
---
@@ -0,0 +1,71 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-3313.
--
Resolution: Fixed
Fixed via 4f8b9bb5e7f826a31e79b9c5670fb7225df6b984
> Kafka08ITCase.testOneSou
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130388#comment-15130388
]
ASF GitHub Bot commented on FLINK-3313:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1577
---
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
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1577#issuecomment-179231858
Addressed all comments and will merge this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130383#comment-15130383
]
ASF GitHub Bot commented on FLINK-3313:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1576#issuecomment-179231177
The `ActorSystem.shutdown` call is non-blocking. But the `ActorSystem` has
also a `awaitTermination(timeout)` call which could be used to await the
termination of t
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130379#comment-15130379
]
Andrea Sella commented on FLINK-3311:
-
Yes, I can share it.
How kind of interface I n
[
https://issues.apache.org/jira/browse/FLINK-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130373#comment-15130373
]
ASF GitHub Bot commented on FLINK-3128:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130372#comment-15130372
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on the
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130374#comment-15130374
]
Robert Metzger commented on FLINK-3311:
---
Hi, I didn't know you are working on this.
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1565#issuecomment-179225513
Yeah I thought so that your question on the mailing list was related to
this PR. It would be great to have a fully parallelized version of the
algorithm, beca
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1536#issuecomment-179225452
Branch recreated to remove merge commits, now opened as #1581.
---
If your project is set up for it, you can reply to this email and have your
reply appear on Git
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130367#comment-15130367
]
ASF GitHub Bot commented on FLINK-2021:
---
GitHub user stefanobaghino opened a pull re
1 - 100 of 169 matches
Mail list logo
