[
https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133753#comment-15133753
]
ASF GitHub Bot commented on FLINK-3234:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1585#issuecomment-180224231
@fhueske I addressed your comments.
To reduce modifying original code, I added some variables for key selector
only. But this make the source code quite messy
Shikhar Bhushan created FLINK-3341:
--
Summary: Kafka connector's 'auto.offset.reset' inconsistent with
Kafka
Key: FLINK-3341
URL: https://issues.apache.org/jira/browse/FLINK-3341
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133568#comment-15133568
]
Chiwan Park commented on FLINK-1733:
Oh, you can continue work for it, [~thang]. Sorry
[
https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133521#comment-15133521
]
Thang Nguyen edited comment on FLINK-1733 at 2/5/16 2:14 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133521#comment-15133521
]
Thang Nguyen commented on FLINK-1733:
-
| I'm not sure that {{DenseMatrix}} fits for sP
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133490#comment-15133490
]
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-180152337
Hello @tillrohrmann please review the commit as the work to be done is
nearly complete I believe. Please comment.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133485#comment-15133485
]
Chiwan Park commented on FLINK-1873:
Hi [~liaoyuxi], could you tell me about progress
[
https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133465#comment-15133465
]
Chiwan Park commented on FLINK-1733:
Hi [~thang],
You can use {{breeze.linalg.DenseMa
[
https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133447#comment-15133447
]
Thang Nguyen commented on FLINK-1733:
-
Thanks [~till.rohrmann], I've been flipping thr
[
https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133436#comment-15133436
]
Chiwan Park commented on FLINK-3330:
[~till.rohrmann] Thanks! I assigned this issue to
[
https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133436#comment-15133436
]
Chiwan Park edited comment on FLINK-3330 at 2/5/16 12:54 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chiwan Park updated FLINK-3330:
---
Summary: Add SparseVector support to GradientDescent in FlinkML (was: Add
SparseVector support to BLA
[
https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chiwan Park updated FLINK-3330:
---
Assignee: Till Rohrmann (was: Chiwan Park)
> Add SparseVector support to BLAS library in FlinkML
> --
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133300#comment-15133300
]
ASF GitHub Bot commented on FLINK-2721:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1591#issuecomment-180098460
@mxm I would like to get this into 1.0 release. Would be great if you could
review it.
---
If your project is set up for it, you can reply to this email and have your
rep
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133293#comment-15133293
]
ASF GitHub Bot commented on FLINK-2721:
---
GitHub user mjsax opened a pull request:
GitHub user mjsax opened a pull request:
https://github.com/apache/flink/pull/1591
[FLINK-2721] [Storm Compatibility] Add Tuple meta information
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/flink flink-2721-tupleMetaInfo
Greg Hogan created FLINK-3340:
-
Summary: Fix object juggling in reduce drivers
Key: FLINK-3340
URL: https://issues.apache.org/jira/browse/FLINK-3340
Project: Flink
Issue Type: Bug
Compo
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132975#comment-15132975
]
ASF GitHub Bot commented on FLINK-3338:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1590#issuecomment-180038020
Change looks good.
+1
---
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
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132957#comment-15132957
]
ASF GitHub Bot commented on FLINK-3338:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1590
[FLINK-3338] [kafka] Use proper classloader when cloning the
deserialization schema
Fixes a class not found exception reported by a user.
You can merge this pull request into a Git repository b
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-3338:
---
Assignee: Stephan Ewen
> Kafka deserialization issue - ClassNotFoundException
> -
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1589#issuecomment-180031529
Changes look good (including the test). I'm OK with the current name. I
understand why it is up for discussion but I can't come up with a better name
at the moment. ;)
--
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132950#comment-15132950
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user uce commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132890#comment-15132890
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1589#discussion_r51929574
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
---
@@ -443,6 +443,35 @@ public ExecutionConfig getExecuti
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1589#discussion_r51928539
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
---
@@ -443,6 +443,35 @@ public ExecutionConfig getExecuti
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132920#comment-15132920
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1589#discussion_r51930125
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/partitioner/SemiRebalancePartitionerTest.java
---
@@ -0,0 +1,202 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132906#comment-15132906
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1589#discussion_r51929634
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
---
@@ -443,6 +443,35 @@ public ExecutionConfig getExecuti
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132905#comment-15132905
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132896#comment-15132896
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1589#discussion_r51929032
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
---
@@ -443,6 +443,35 @@ public ExecutionConfig getEx
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132894#comment-15132894
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1589#discussion_r51928771
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
---
@@ -371,6 +371,30 @@ class DataStream[T](stream: JavaStr
[
https://issues.apache.org/jira/browse/FLINK-3339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132853#comment-15132853
]
Aljoscha Krettek commented on FLINK-3339:
-
The problem is that the recent change t
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132830#comment-15132830
]
ASF GitHub Bot commented on FLINK-3336:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1589
[FLINK-3336] Add Semi-Rebalance Data Shipping for DataStream
The name of this is still up for discussion but I'm opening this so that
people can look at the implementation and especially, the unit
Shikhar Bhushan created FLINK-3339:
--
Summary: Checkpointing NPE when using filterWithState
Key: FLINK-3339
URL: https://issues.apache.org/jira/browse/FLINK-3339
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-3329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3329.
-
Resolution: Fixed
Fixed in
https://github.com/apache/flink/commit/5d7595448c005ef73179843
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/1586
---
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
[
https://issues.apache.org/jira/browse/FLINK-3329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132770#comment-15132770
]
ASF GitHub Bot commented on FLINK-3329:
---
Github user aljoscha closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132740#comment-15132740
]
Stephan Ewen edited comment on FLINK-3338 at 2/4/16 6:40 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132740#comment-15132740
]
Stephan Ewen commented on FLINK-3338:
-
The stack trace says that the class is cloned u
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shikhar Bhushan updated FLINK-3338:
---
Description:
I get this error when running a JAR submitted using the web UI on a production
s
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132726#comment-15132726
]
Shikhar Bhushan commented on FLINK-3338:
(this is on 1.0-SNAPSHOT)
> Kafka deseri
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/1588
FLINK-2213 Makes the number of vcores per YARN container configurable.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink vcores_param
Alt
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132694#comment-15132694
]
ASF GitHub Bot commented on FLINK-2213:
---
GitHub user kl0u opened a pull request:
Shikhar Bhushan created FLINK-3338:
--
Summary: Kafka deserialization issue - ClassNotFoundException
Key: FLINK-3338
URL: https://issues.apache.org/jira/browse/FLINK-3338
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132673#comment-15132673
]
ASF GitHub Bot commented on FLINK-3330:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/1587#discussion_r51910120
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala
---
@@ -192,10 +190,18 @@ abstract class GradientDe
[
https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132672#comment-15132672
]
ASF GitHub Bot commented on FLINK-3330:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/1587#discussion_r51909968
--- Diff:
flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/regression/RegressionData.scala
---
@@ -27,6 +27,21 @@ object RegressionData {
Greg Hogan created FLINK-3337:
-
Summary: mvn test fails on flink-runtime because curator classes
not found
Key: FLINK-3337
URL: https://issues.apache.org/jira/browse/FLINK-3337
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132650#comment-15132650
]
Aljoscha Krettek commented on FLINK-3336:
-
I'm open for suggestions on the name.
Aljoscha Krettek created FLINK-3336:
---
Summary: Add Semi-Rebalance Data Shipping for DataStream
Key: FLINK-3336
URL: https://issues.apache.org/jira/browse/FLINK-3336
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132602#comment-15132602
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on the
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1581#issuecomment-179949096
Following your suggestions, thanks.
* squash: should I squash the commits coming from the review as well?
* tests: I thought it was about some Travis config
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1574
---
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-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132529#comment-15132529
]
Robert Metzger commented on FLINK-3332:
---
Here is the link to the documentation:
htt
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132521#comment-15132521
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1428#issuecomment-179926670
I went through all the classes in the relevant modules outside `flink-core`
with @fhueske and annotated them properly.
I've rebased the changes and checked with the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/f8f747f2290ad623bd8a4f0d8ff4708fada6792a#commitcomment-15890284
So, actually is that exception comes, we can safely ignore it?
---
If your project is set up for it, you can reply to this ema
[
https://issues.apache.org/jira/browse/FLINK-2845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-2845.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed in
https://github.com/apache/flink/co
[
https://issues.apache.org/jira/browse/FLINK-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132453#comment-15132453
]
Gabor Gevay commented on FLINK-3335:
Are you sure that adding that copy is the best so
Github user uce commented on the pull request:
https://github.com/apache/flink/commit/f8f747f2290ad623bd8a4f0d8ff4708fada6792a#commitcomment-15888699
Thanks for looking into it.
`ZKPaths.deleteChildren` actually looks like it already handles this. The
`KeeperException.NoNodeE
[
https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132430#comment-15132430
]
ASF GitHub Bot commented on FLINK-3330:
---
GitHub user tillrohrmann opened a pull requ
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1574#issuecomment-179895516
Thanks, 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
[
https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132411#comment-15132411
]
Till Rohrmann commented on FLINK-3330:
--
Hi [~chiwanpark], yes the problem is that the
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1587
[FLINK-3330] [ml] Fix SparseVector support in GradientDescent
The GradientDescent implementation did not work with sparse input data
because it requires the gradient to be dense. This patch
[
https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132412#comment-15132412
]
Till Rohrmann commented on FLINK-3330:
--
I just tried this as a fix and it seems to so
[
https://issues.apache.org/jira/browse/FLINK-3268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3268.
-
Resolution: Fixed
Assignee: Stephan Ewen (was: Ufuk Celebi)
Fixed via f8f747f2290ad623bd8a4
[
https://issues.apache.org/jira/browse/FLINK-3268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3268.
---
> Unstable test JobManagerSubmittedJobGraphsRecoveryITCase
> -
[
https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3328.
---
Resolution: Fixed
Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/7378f014
>
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132379#comment-15132379
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1581#issuecomment-179867266
OK, let's do it.
+1 for @rmetzger's suggestion.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If y
[
https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132380#comment-15132380
]
ASF GitHub Bot commented on FLINK-3328:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1584
---
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-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132372#comment-15132372
]
ASF GitHub Bot commented on FLINK-3328:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132378#comment-15132378
]
ASF GitHub Bot commented on FLINK-3328:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1584#issuecomment-179866261
It works with CDH 5.4.2, which uses Hadoop 2.6.0.
I'll merge it.
---
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-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132374#comment-15132374
]
ASF GitHub Bot commented on FLINK-3310:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1578#issuecomment-179863296
We can still move the tab in the UI later.
I don't think there is a thing like "breaking changes" in the UI ;-)
---
If your project is set up for it, you can rep
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1584#issuecomment-179861292
Cool, thanks for fixing this.
Changes look good to me!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1581#issuecomment-179859441
I just checked out your pull request locally and looked through it.
I think the following things need to be fixed before we can merge it:
- Squash the 60+ co
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132369#comment-15132369
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user rmetzger commented on the pull
Github user stefanobaghino commented on a diff in the pull request:
https://github.com/apache/flink/pull/1581#discussion_r51875652
--- Diff:
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/distcp/DistCp.java
---
@@ -62,18 +63,32 @@
public s
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132358#comment-15132358
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on a d
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132348#comment-15132348
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1581#discussion_r51874764
--- Diff:
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/distcp/DistCp.java
---
@@ -62,18 +63,32 @@
public static
Greg Hogan created FLINK-3335:
-
Summary: DataSourceTask object reuse when disabled
Key: FLINK-3335
URL: https://issues.apache.org/jira/browse/FLINK-3335
Project: Flink
Issue Type: Bug
C
[
https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132335#comment-15132335
]
ASF GitHub Bot commented on FLINK-3234:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1585#issuecomment-179843708
Thanks for review @fhueske! I'll address your comments.
---
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 fhueske commented on the pull request:
https://github.com/apache/flink/pull/1585#issuecomment-179835764
Hi @chiwanpark, thanks for picking up this issue and filling this gap in
the DataSet API.
Would be nice, if it could make it into the 1.0 release, IMO.
However,
[
https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132317#comment-15132317
]
ASF GitHub Bot commented on FLINK-3234:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132309#comment-15132309
]
ASF GitHub Bot commented on FLINK-3234:
---
Github user fhueske commented on a diff in
1 - 100 of 157 matches
Mail list logo
