[
https://issues.apache.org/jira/browse/FLINK-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704470#comment-14704470
]
Robert Metzger commented on FLINK-2541:
---
Mh, But if the PrimitiveArrayTypeInfo is
[
https://issues.apache.org/jira/browse/FLINK-2506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-2506:
---
Assignee: Aljoscha Krettek
HBase connection closing down (table distributed over
[
https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704565#comment-14704565
]
Till Rohrmann edited comment on FLINK-2549 at 8/20/15 9:17 AM:
[
https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704565#comment-14704565
]
Till Rohrmann commented on FLINK-2549:
--
I agree with [~StephanEwen]. Sorting the
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705286#comment-14705286
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-133077364
I fear that the PR cannot be merged in this state. It contains some serious
performance issues which first have to be addressed. Mainly they originate from
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705294#comment-14705294
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user tillrohrmann commented on a
Github user sachingoel0101 commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37554624
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/statistics/ContinuousHistogram.scala
---
@@ -0,0 +1,315 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705295#comment-14705295
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user sachingoel0101 commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37554555
--- Diff: docs/libs/ml/statistics.md ---
@@ -0,0 +1,69 @@
+---
+mathjax: include
+htmlTitle: FlinkML - Statistics
+title: a
Github user sachingoel0101 commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37554683
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/statistics/ContinuousHistogram.scala
---
@@ -0,0 +1,315 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705299#comment-14705299
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user sachingoel0101 commented on a
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705302#comment-14705302
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37554750
--- Diff: docs/libs/ml/statistics.md ---
@@ -0,0 +1,69 @@
+---
+mathjax: include
+htmlTitle: FlinkML - Statistics
+title: a
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705305#comment-14705305
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37554978
--- Diff: docs/libs/ml/statistics.md ---
@@ -0,0 +1,69 @@
+---
+mathjax: include
+htmlTitle: FlinkML - Statistics
+title: a
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705306#comment-14705306
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37555199
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/MLUtils.scala ---
@@ -119,4 +123,65 @@ object MLUtils {
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705314#comment-14705314
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37555313
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/statistics/ContinuousHistogram.scala
---
@@ -0,0 +1,315 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705309#comment-14705309
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37555399
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/statistics/OnlineHistogram.scala
---
@@ -0,0 +1,52 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37555463
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/statistics/ContinuousHistogram.scala
---
@@ -0,0 +1,315 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705320#comment-14705320
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705323#comment-14705323
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705318#comment-14705318
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r3737
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/statistics/ContinuousHistogram.scala
---
@@ -0,0 +1,315 @@
+/*
+ * Licensed
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37555777
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/statistics/ContinuousHistogram.scala
---
@@ -0,0 +1,315 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705329#comment-14705329
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37556169
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/statistics/ContinuousHistogram.scala
---
@@ -0,0 +1,315 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705337#comment-14705337
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user tillrohrmann commented on a
Github user sachingoel0101 commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37556403
--- Diff: docs/libs/ml/statistics.md ---
@@ -0,0 +1,69 @@
+---
+mathjax: include
+htmlTitle: FlinkML - Statistics
+title: a
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704428#comment-14704428
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user zentol commented on the pull
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-132917505
using clearsinks would cause the above example with collect() to fail,
since this clears sinks aswell. (the sinks are only not cleared when
getExecutionPlan is called,
[
https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704489#comment-14704489
]
Stephan Ewen commented on FLINK-2548:
-
(1) CoGrouping with the solution set is a
[
https://issues.apache.org/jira/browse/FLINK-2506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-2506:
Attachment: hbase-example.tar.gz
HBase connection closing down (table distributed over
Aljoscha Krettek created FLINK-2551:
---
Summary: Fix Several Bugs in Input/Output Formats
Key: FLINK-2551
URL: https://issues.apache.org/jira/browse/FLINK-2551
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704402#comment-14704402
]
Suminda Dharmasena commented on FLINK-2366:
---
Looks good. Once this gets merged
[
https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704437#comment-14704437
]
Chesnay Schepler commented on FLINK-2549:
-
is the only difference between topK()
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704479#comment-14704479
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user sachingoel0101 commented on the
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/885#issuecomment-132934697
Thank you for opening an issue for the shade plugin.
I didn't forget this issue here. I'll look into it once I have a bit more
time.
Sorry for the delay.
---
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704504#comment-14704504
]
ASF GitHub Bot commented on FLINK-2200:
---
Github user rmetzger commented on the pull
Github user nltran commented on the pull request:
https://github.com/apache/flink/pull/967#issuecomment-132935694
@StephanEwen
Both interfaces for the parameter and the parameter server are quite
similar. The things I see are the following:
- The parameter server code is
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-132958065
Okay. For now, I have modified all Test environments which were using a
context factory, except for the `PreviewPlanEnvironment` which cannot be done
as the test
[
https://issues.apache.org/jira/browse/FLINK-2551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704616#comment-14704616
]
Stephan Ewen commented on FLINK-2551:
-
Looks like good ideas!
There is the
[
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704621#comment-14704621
]
ASF GitHub Bot commented on FLINK-2077:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1035#issuecomment-132962489
@gallenvara, could you elaborate a little bit on why you've moved the
`makeQualified` method into the static `FileSystemUtil` class? What's the
benefit of it. Is
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-132927894
Ah yes, you're right. We cannot use `clearSinks`.
To answer the second part, the folder will still be added. It is only at
runtime that all the directories
[
https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704498#comment-14704498
]
Stephan Ewen commented on FLINK-2549:
-
You can implement topK on top if
[
https://issues.apache.org/jira/browse/FLINK-2543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704577#comment-14704577
]
Robert Metzger commented on FLINK-2543:
---
Just a quick update on this: I have a fix
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1033#discussion_r37513671
--- Diff:
flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/GraphAlgorithm.scala
---
@@ -0,0 +1,30 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704503#comment-14704503
]
Stephan Ewen commented on FLINK-2541:
-
[~rmetzger] True, the pre-flight checks seem
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704535#comment-14704535
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704601#comment-14704601
]
Aljoscha Krettek edited comment on FLINK-2551 at 8/20/15 9:47 AM:
[
https://issues.apache.org/jira/browse/FLINK-2551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704601#comment-14704601
]
Aljoscha Krettek commented on FLINK-2551:
-
All of them except
Github user ChengXiangLi commented on the pull request:
https://github.com/apache/flink/pull/949#issuecomment-132943122
OK, @tillrohrmann , great to hear that. Besides, I've created
[FLINK-2549](https://issues.apache.org/jira/browse/FLINK-2549) for topK
operator.
---
If your
Aljoscha Krettek created FLINK-2550:
---
Summary: Rework DataStream API
Key: FLINK-2550
URL: https://issues.apache.org/jira/browse/FLINK-2550
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704569#comment-14704569
]
ASF GitHub Bot commented on FLINK-2540:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1035#discussion_r37512972
--- Diff: flink-core/src/main/java/org/apache/flink/core/fs/Path.java ---
@@ -430,40 +296,127 @@ public int depth() {
}
/**
-
[
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704613#comment-14704613
]
ASF GitHub Bot commented on FLINK-2077:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704506#comment-14704506
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-132934917
I think the reason to not create a new environment every time was simply
that it was easier to write that way and it never hurt before. You can run
multiple
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704606#comment-14704606
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704739#comment-14704739
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user chiwanpark commented on the
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-132987549
Looks good to merge. If there is no opposition in few hours, I'll merge
this to master.
---
If your project is set up for it, you can reply to this email and have
Robert Metzger created FLINK-2552:
-
Summary: Sporadic failure of PartialConsumePipelinedResultTest
Key: FLINK-2552
URL: https://issues.apache.org/jira/browse/FLINK-2552
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2552:
--
Priority: Minor (was: Major)
Sporadic failure of PartialConsumePipelinedResultTest
[
https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704730#comment-14704730
]
Gabor Gevay commented on FLINK-2548:
{quote}
CoGrouping with the solution set is a
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704737#comment-14704737
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-132987393
It turns out the `JavaProgramTestBase` accesses the shared environment's
execution result. However, it is used nowhere. I have removed the unused code
and
[
https://issues.apache.org/jira/browse/FLINK-2550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704756#comment-14704756
]
Aljoscha Krettek commented on FLINK-2550:
-
One possibility I see is that the
Github user ChengXiangLi commented on the pull request:
https://github.com/apache/flink/pull/949#issuecomment-132972593
Move sample/sampleWithSize operator to DataSetUtil and update unit test.
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704676#comment-14704676
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user ChengXiangLi commented on the
[
https://issues.apache.org/jira/browse/FLINK-2552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2552:
--
Description:
This test https://travis-ci.org/apache/flink/jobs/76305055
failed with:
{code}
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-132991376
Ah. Great. :)
I'll rebase #1032 immediately after that.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1033#discussion_r37514284
--- Diff:
flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/MapEdgesITCase.scala
---
@@ -92,6 +92,30 @@
[
https://issues.apache.org/jira/browse/FLINK-2552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704744#comment-14704744
]
Stephan Ewen commented on FLINK-2552:
-
This looks like a corner case akka problem, on
[
https://issues.apache.org/jira/browse/FLINK-2552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-2552.
-
Resolution: Invalid
Okay, I'm closing it for now.
Sporadic failure of
[
https://issues.apache.org/jira/browse/FLINK-2551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704642#comment-14704642
]
Aljoscha Krettek commented on FLINK-2551:
-
Yes, but this is invoked at places
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1033#issuecomment-132966338
I'm not a Gelly expert, but conceptually I don't think that it is wrong to
call an algorithm which was developed with the Scala API from within the Java
API.
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704711#comment-14704711
]
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-132982117
Hi Max,
I am very sorry to bothered you.
I fixed some of my PRs and was waiting for your reply for days.
Otherwise, as your advice, I added a change about
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706059#comment-14706059
]
ASF GitHub Bot commented on FLINK-2536:
---
Github user HuangWHWHW commented on a diff
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/1030#discussion_r37598999
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706058#comment-14706058
]
ASF GitHub Bot commented on FLINK-2536:
---
Github user HuangWHWHW commented on a diff
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/1030#discussion_r37599021
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706060#comment-14706060
]
ASF GitHub Bot commented on FLINK-2536:
---
Github user HuangWHWHW commented on a diff
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/1030#discussion_r37599157
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/sink/SocketClientSinkTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706061#comment-14706061
]
ASF GitHub Bot commented on FLINK-2536:
---
Github user HuangWHWHW commented on the
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/1030#issuecomment-133238105
Could we also add a test case where we test that the SocketClientSink can
reconnect against a newly opened socket after it has been closed? This would be
great.
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/992#issuecomment-133238272
@tillrohrmann
Thank you for the info :-)
---
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
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705342#comment-14705342
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user sachingoel0101 commented on a
Github user sachingoel0101 commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37556594
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/statistics/ContinuousHistogram.scala
---
@@ -0,0 +1,315 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705347#comment-14705347
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user sachingoel0101 commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37557013
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/statistics/DiscreteHistogram.scala
---
@@ -0,0 +1,126 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705377#comment-14705377
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user sachingoel0101 commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1037#discussion_r37561072
--- Diff: docs/apis/storm_compatibility.md ---
@@ -224,4 +224,12 @@ DataStreamString rawInput = env.addSource(
You can find more examples in
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1030#discussion_r37563984
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705502#comment-14705502
]
ASF GitHub Bot commented on FLINK-2536:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1030#issuecomment-133111629
Hi @HuangWHWHW, I had some minor comments. Could we also add a test case
where we test that the `SocketClientSink` can reconnect against a newly opened
socket
1 - 100 of 350 matches
Mail list logo
