[
https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694854#comment-14694854
]
Stephan Ewen commented on FLINK-2493:
-
Still, seeking consensus on the dev list is a
[
https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694852#comment-14694852
]
Márton Balassi commented on FLINK-2493:
---
Ok, fair enough then.
Simplify names of
[
https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694842#comment-14694842
]
Márton Balassi commented on FLINK-2493:
---
Hey [~chenliang], please do not combine the
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694894#comment-14694894
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694850#comment-14694850
]
ASF GitHub Bot commented on FLINK-2306:
---
GitHub user mjsax opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1745:
-
Assignee: (was: Till Rohrmann)
Add exact k-nearest-neighbours algorithm to machine learning
[
https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694851#comment-14694851
]
Stephan Ewen commented on FLINK-2493:
-
I think there was a discussion about combining
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694886#comment-14694886
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user thvasilo commented on a diff in
GitHub user mjsax opened a pull request:
https://github.com/apache/flink/pull/1011
[FLINK-2306] Add support for named streams in Storm compatibility layer
- enabled .declareStream() and connect via stream name
- enabled multiplt output streams
- added .split()
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694935#comment-14694935
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694936#comment-14694936
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694939#comment-14694939
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694938#comment-14694938
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on a diff in the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/696#issuecomment-130574663
@kno10 thanks for the pointer. Judging from the abstract it sounds really
promising and it seems definitely worth exploring. Unfortunately, I don't have
access to
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r36955259
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694981#comment-14694981
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694934#comment-14694934
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on a diff in the
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/949#discussion_r36955515
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/operators/util/BernoulliSampler.java
---
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695031#comment-14695031
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user thvasilo commented on a diff in
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r36955189
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
---
@@
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/949#discussion_r36960527
--- Diff:
flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java ---
@@ -451,6 +454,53 @@ protected static File asFile(String path) {
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694932#comment-14694932
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694940#comment-14694940
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694943#comment-14694943
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user thvasilo commented on a diff in
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r36955316
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694974#comment-14694974
]
ASF GitHub Bot commented on FLINK-1819:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694989#comment-14694989
]
Ufuk Celebi commented on FLINK-2373:
Andreas, did you have a look at this? I have a
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695034#comment-14695034
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695003#comment-14695003
]
ASF GitHub Bot commented on FLINK-1901:
---
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/949#discussion_r36960080
--- Diff:
flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java ---
@@ -451,6 +454,53 @@ protected static File asFile(String path) {
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695069#comment-14695069
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user HuangWHWHW commented on the
[
https://issues.apache.org/jira/browse/FLINK-2451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695067#comment-14695067
]
ASF GitHub Bot commented on FLINK-2451:
---
Github user vasia commented on a diff in
Github user samk3211 commented on the pull request:
https://github.com/apache/flink/pull/883#issuecomment-130632285
closed
---
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
Github user samk3211 closed the pull request at:
https://github.com/apache/flink/pull/883
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/949#discussion_r36958345
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/operators/util/BernoulliSampler.java
---
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r36955334
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695196#comment-14695196
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user HuangWHWHW commented on the
Ufuk Celebi created FLINK-2513:
--
Summary: Extend state handle provider interface to list all state
handles
Key: FLINK-2513
URL: https://issues.apache.org/jira/browse/FLINK-2513
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695192#comment-14695192
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user HuangWHWHW commented on the
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695211#comment-14695211
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695212#comment-14695212
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695133#comment-14695133
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on the pull
Stephan Ewen created FLINK-2514:
---
Summary: Local and Remote environment behave differently when
re-triggering execution.
Key: FLINK-2514
URL: https://issues.apache.org/jira/browse/FLINK-2514
Project:
[
https://issues.apache.org/jira/browse/FLINK-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-2514:
Priority: Critical (was: Major)
Local and Remote environment behave differently when
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695166#comment-14695166
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user thvasilo commented on a diff in
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r36955221
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
---
@@
Github user ffbin commented on the pull request:
https://github.com/apache/flink/pull/1009#issuecomment-130509029
@uce @hsaputra Thanks. I have move the try up and rely on finally to close
the client.
---
If your project is set up for it, you can reply to this email and have your
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/949#discussion_r36950634
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala ---
@@ -1182,6 +1184,60 @@ class DataSet[T: ClassTag](set: JavaDataSet[T]) {
[
https://issues.apache.org/jira/browse/FLINK-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695231#comment-14695231
]
ASF GitHub Bot commented on FLINK-1819:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695232#comment-14695232
]
ASF GitHub Bot commented on FLINK-1819:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-2514:
--
Fix Version/s: 0.10
Local and Remote environment behave differently when re-triggering
[
https://issues.apache.org/jira/browse/FLINK-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-2514:
-
Assignee: Márton Balassi
Local and Remote environment behave differently when
[
https://issues.apache.org/jira/browse/FLINK-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-1819.
-
Resolution: Implemented
Fix Version/s: (was: 0.9)
0.10
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/883#issuecomment-130623223
I've actually included this in #1000. Could you close this PR @samk3211?
Thanks!
---
If your project is set up for it, you can reply to this email and have your
reply
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/992#issuecomment-130644950
`StringBuilder` is only for single-threaded while `StringBuffer` enables
multi-thread access. If you use `StringBuffer` in a single-threaded scenario it
has worse
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695215#comment-14695215
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-2508:
-
Assignee: Márton Balassi
Confusing sharing of StreamExecutionEnvironment
[
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695236#comment-14695236
]
Fabian Hueske commented on FLINK-2077:
--
Hi Lun,
{{//host/dir1/dir2}} is an example
Github user kno10 commented on the pull request:
https://github.com/apache/flink/pull/696#issuecomment-130469648
R-trees are hard to parallelize.
For distributed and gigabyte size data, an approximative approach is
preferable, like the one we discuss in this article:
E.
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/949#discussion_r36955412
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/operators/util/BernoulliSampler.java
---
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/992#issuecomment-130588652
Thanks for your changes. I think we should use `read()` instead of
`readLine()` because we are using a custom delimiter and not necessarily \n
(newline symbol). The danger
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1010#issuecomment-130633384
Thanks Henry, please add this rule. :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1000#discussion_r36963490
--- Diff:
flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyITCase.java
---
@@ -86,26 +72,35 @@ public void
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/992#issuecomment-130524804
@mxm
Hi, I fixed the StringBuffer and add the test.
Take a look whether it`s correct.
Thank you!
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695213#comment-14695213
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on a diff in the
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/992#issuecomment-130626843
Hi Max,
I fixed all as your reviews.
And I retained the change of StringBuffer to StringBuilder.
There is a question that as I see the StringBuilder just do
[
https://issues.apache.org/jira/browse/FLINK-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695280#comment-14695280
]
ASF GitHub Bot commented on FLINK-2306:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695292#comment-14695292
]
ASF GitHub Bot commented on FLINK-2306:
---
Github user mjsax commented on the pull
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/992#issuecomment-130664351
@mxm
Otherwise, I found the SocketClientSink didn`t have the retry.
Is it necessary to get a retry?
---
If your project is set up for it, you can reply to
Stephan Ewen created FLINK-2515:
---
Summary: CheckpointCoordinator triggers checkpoints even if not
all sources are running any more
Key: FLINK-2515
URL: https://issues.apache.org/jira/browse/FLINK-2515
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/949#discussion_r36969808
--- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java
---
@@ -1057,7 +1061,68 @@ public long count() throws Exception {
public
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r36973279
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunctionTest.java
---
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r36973254
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunctionTest.java
---
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r36973430
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
---
@@
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r36973377
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695604#comment-14695604
]
Sheetal Parade commented on FLINK-2314:
---
Can you provide some guidance?
As I
Github user nltran commented on the pull request:
https://github.com/apache/flink/pull/967#issuecomment-130734997
The code now passes all the checks :smiley: I have addressed the previous
comments you made previously. @StephanEwen , @fhueske could you give it a
another review?
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/991#discussion_r36990804
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/PrintSinkFunctionTest.java
---
@@ -0,0 +1,234
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/966#issuecomment-130677380
Thanks for the contribution @sachingoel0101!
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/966
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695941#comment-14695941
]
Sheetal Parade commented on FLINK-2314:
---
I added split information in the checkpoint
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r37042816
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
---
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/991#discussion_r37046489
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/PrintSinkFunctionTest.java
---
@@ -0,0
GitHub user ffbin opened a pull request:
https://github.com/apache/flink/pull/1012
[FLINK-2516]Remove unwanted log.isInfoEnabled check
The function has call log.info() at the head of it.So i think the check of
log.isInfoEnabled after call log.info() is unwanted.
You can merge
[
https://issues.apache.org/jira/browse/FLINK-2516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696321#comment-14696321
]
ASF GitHub Bot commented on FLINK-2516:
---
GitHub user ffbin opened a pull request:
Github user ChengXiangLi commented on a diff in the pull request:
https://github.com/apache/flink/pull/949#discussion_r37046195
--- Diff:
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/SampleITCase.scala
---
@@ -0,0 +1,166 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696369#comment-14696369
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user ChengXiangLi commented on a
[
https://issues.apache.org/jira/browse/FLINK-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696375#comment-14696375
]
ASF GitHub Bot commented on FLINK-2480:
---
Github user HuangWHWHW commented on a diff
fangfengbin created FLINK-2516:
--
Summary: Remove unwanted log.isInfoEnabled check
Key: FLINK-2516
URL: https://issues.apache.org/jira/browse/FLINK-2516
Project: Flink
Issue Type: Bug
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1011#issuecomment-130692637
The CU reports 3 failures.
2 failures in storm-compatibility-core
1 failure in YARN (yarn not responding)
---
If your project is set up for it, you
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1011#issuecomment-130694237
Yes. It a weird compile error and it builds locally... The error is:
`[ERROR]
[
https://issues.apache.org/jira/browse/FLINK-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696519#comment-14696519
]
ASF GitHub Bot commented on FLINK-1819:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/966#issuecomment-130979827
Sure. :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
[
https://issues.apache.org/jira/browse/FLINK-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695412#comment-14695412
]
ASF GitHub Bot commented on FLINK-2480:
---
Github user mxm commented on a diff in the
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/992#issuecomment-130663511
Ok, I add two cases(retry 10 and 0) since I thought retry 1 time just same
as 10.
And would you please take a look with another two
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/992#issuecomment-130672880
Otherwise, I found the SocketClientSink didn`t have the retry.
Is it necessary to get a retry?
Yes, that might be an issue but let's keep it separate from our
[
https://issues.apache.org/jira/browse/FLINK-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695410#comment-14695410
]
ASF GitHub Bot commented on FLINK-2480:
---
Github user mxm commented on a diff in the
97 matches
Mail list logo
