[
https://issues.apache.org/jira/browse/FLINK-2347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625937#comment-14625937
]
Henry Saputra commented on FLINK-2347:
--
I believe this is also happening in Chrome br
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/905#issuecomment-121119196
@pp86 It seems okay but we need to check this change with some test cases.
Could you add some test cases into `DistinctITCase` in `flink-tests` module?
---
If your pr
[
https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625746#comment-14625746
]
ASF GitHub Bot commented on FLINK-1963:
---
Github user chiwanpark commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625600#comment-14625600
]
pietro pinoli commented on FLINK-1963:
--
[~fhueske] Dear Fabian,
I made the changes to
[
https://issues.apache.org/jira/browse/FLINK-2353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625537#comment-14625537
]
ASF GitHub Bot commented on FLINK-2353:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/908
[FLINK-2353] Respect JobConfigurable interface in Hadoop mapred wrappers
Hadoop's mapred API features the `JobConfigurable` interface which offers a
function `configure(JobConf)` to configure user-de
Fabian Hueske created FLINK-2353:
Summary: Hadoop mapred IOFormat wrappers do not respect
JobConfigurable interface
Key: FLINK-2353
URL: https://issues.apache.org/jira/browse/FLINK-2353
Project: Flin
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/847#issuecomment-121072347
Still an overkill I think... Could another way be to have only `types(K,
VV, EV)` with all 3 arguments and expect `NullValue` if a value is missing?
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625425#comment-14625425
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user vasia commented on the pull req
GitHub user r-pogalz opened a pull request:
https://github.com/apache/flink/pull/907
FLINK-2105: Implement Sort-Merge Outer Join algorithm
This pull request relates to
[FLINK-2105](https://issues.apache.org/jira/browse/FLINK-2105) and includes:
* Extraction of the MergeMatchIter
[
https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625409#comment-14625409
]
ASF GitHub Bot commented on FLINK-2105:
---
GitHub user r-pogalz opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625376#comment-14625376
]
Enrique Bautista Barahona commented on FLINK-2300:
--
Sure, I'll submit a P
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625278#comment-14625278
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/896#issuecomment-121046784
Nice piece of work! I agree with Stephan's points. I think it was good to
address them. :) I've added some minor comments inline.
Regarding the high-level comments:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/906#issuecomment-121040843
These are the results of my performance tests:
https://docs.google.com/spreadsheets/d/1mXcy25UOiZ4lEJOia1OM-K-U6np2bWv3x4q5nSnUMdg/edit?usp=sharing
Some numbers
[
https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625255#comment-14625255
]
ASF GitHub Bot commented on FLINK-1967:
---
Github user aljoscha commented on the pull
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/847#issuecomment-121039562
Yes, but then you would have the following methods: `types`,
`typesNoEdgeValue`, `typesNoVertexValue` and again `types`. So, even if it's
not 100% needed I'd try to ke
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625250#comment-14625250
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on the pul
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r34504919
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java
---
@@ -0,0 +1,462 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625246#comment-14625246
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625244#comment-14625244
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on a diff
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r34504887
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java
---
@@ -0,0 +1,462 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625236#comment-14625236
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay reassigned FLINK-2148:
--
Assignee: Gabor Gevay
> Approximately calculate the number of distinct elements of a stream
> -
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34504410
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -400,13 +398,22 @@ class JobManager(protected val flinkConfigur
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625232#comment-14625232
]
ASF GitHub Bot commented on FLINK-2292:
---
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/896#discussion_r34504087
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorEvent.java
---
@@ -18,32 +18,60 @@
package org.apache.flink.runt
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625227#comment-14625227
]
ASF GitHub Bot commented on FLINK-2292:
---
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/896#discussion_r34503896
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorRegistry.java
---
@@ -0,0 +1,140 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625224#comment-14625224
]
ASF GitHub Bot commented on FLINK-1967:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625223#comment-14625223
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user uce commented on a diff in the
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/906#discussion_r34503798
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/io/StreamInputProcessor.java
---
@@ -0,0 +1,186
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34503752
--- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java
---
@@ -408,14 +408,16 @@ public long count() throws Exception {
JobExecu
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625220#comment-14625220
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625219#comment-14625219
]
ASF GitHub Bot commented on FLINK-1967:
---
Github user aljoscha commented on a diff in
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34503586
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java
---
@@ -53,32 +53,34 @@
private final E
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/906#discussion_r34503537
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecordSerializer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625216#comment-14625216
]
ASF GitHub Bot commented on FLINK-2292:
---
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/896#discussion_r34503354
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
---
@@ -101,9 +101,9 @@
/**
* For system inter
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625209#comment-14625209
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/847#issuecomment-121033796
I hadn't realized that they would both need to be called in my previous
comment, my bad.
Any idea for decent method names? `typesNoEdgeValue` and
`typesNoVertexValue` s
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625201#comment-14625201
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on the pul
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/847#issuecomment-121032514
Hi @vasia,
I also saw the types issue, but I had a feeling that this is the way it was
decided in the previous comment. I would rather have different names fo
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/906#discussion_r34501525
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/io/StreamInputProcessor.java
---
@@ -0,0 +1,186 @
[
https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625196#comment-14625196
]
ASF GitHub Bot commented on FLINK-1967:
---
Github user gyfora commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625186#comment-14625186
]
ASF GitHub Bot commented on FLINK-1967:
---
Github user gyfora commented on a diff in t
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/906#discussion_r34500553
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecordSerializer.java
---
@@ -
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/847#issuecomment-121025189
Hi @andralungu,
do you mean support for POJOs as vertex / edge values?
I guess that's a limitation we can't easily overcome, I agree.
Still though, a nicely
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625177#comment-14625177
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user vasia commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-2343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625066#comment-14625066
]
ASF GitHub Bot commented on FLINK-2343:
---
Github user uce commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-2343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625064#comment-14625064
]
Yanping Wang commented on FLINK-2343:
-
Yes, G1 for jdk8+ is a good choice. If we hit f
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/901#issuecomment-121009426
Looks good. +1.
Maybe we can move the JAVA_VERSION to the env/config script to have it only
in one place while merging. I'm merging this. Thanks.
---
If your projec
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/878#issuecomment-120999607
Update this PR (-> added documentation). Should be ready to get merged.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
[
https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2235.
-
Resolution: Fixed
Assignee: Maximilian Michels
Fix Version/s: 0.10
Fixed via 910e8
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/906
[FLINK-1967] Introduce (Event)time in Streaming
## [FLINK-1967] Introduce (Event)time in Streaming
This introduces an additional timestamp field in StreamRecord. When using a
SourceF
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/906#issuecomment-120992739
This is a rework of #879. I reworked it to not use jodi-time anymore. Now
timestamps are just long fields. Also, watermarks are now transmitted in band
with the records,
[
https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624992#comment-14624992
]
ASF GitHub Bot commented on FLINK-2304:
---
Github user mjsax commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-2300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624930#comment-14624930
]
Maximilian Michels commented on FLINK-2300:
---
[~ebautistabar], would you like to
[
https://issues.apache.org/jira/browse/FLINK-2329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2329.
---
> Refactor RPCs from within the ExecutionGraph
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624937#comment-14624937
]
ASF GitHub Bot commented on FLINK-1967:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2329.
-
Resolution: Implemented
Implemented in 2ccb5fdb47aa0e3766fd7fbd17a41feaca29fcbc
> Refactor RPCs f
[
https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2235.
---
> Local Flink cluster allocates too much memory
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624941#comment-14624941
]
ASF GitHub Bot commented on FLINK-1967:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2296.
---
> Checkpoint committing broken
>
>
> Key: FLINK-2296
>
[
https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2296.
-
Resolution: Fixed
Fix Version/s: 0.10
Fixed via aa5e5b3087a68f2aac792c0b0fc64b4f9c707e9b
>
[
https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2008.
-
Resolution: Fixed
Fix Version/s: 0.10
Fixed via aa5e5b3087a68f2aac792c0b0fc64b4f9c707e9b
>
[
https://issues.apache.org/jira/browse/FLINK-2300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-2300.
---
Resolution: Fixed
Thanks for the patch. Merged with a715a56.
> Links on FAQ page not
[
https://issues.apache.org/jira/browse/FLINK-2300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-2300:
-
Assignee: Maximilian Michels
> Links on FAQ page not rendered correctly
> ---
[
https://issues.apache.org/jira/browse/FLINK-2343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624854#comment-14624854
]
ASF GitHub Bot commented on FLINK-2343:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/901#issuecomment-120979141
I updated the pull request to use G1 in Java 8+ and CMS in Java 7.
Per discussion in the JIRA issue with Yanping Wang (Intel Java Contributor)
---
If your pr
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/877
---
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-2141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624842#comment-14624842
]
ASF GitHub Bot commented on FLINK-2141:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624839#comment-14624839
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624843#comment-14624843
]
ASF GitHub Bot commented on FLINK-1085:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624844#comment-14624844
]
ASF GitHub Bot commented on FLINK-2305:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624840#comment-14624840
]
ASF GitHub Bot commented on FLINK-2337:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624841#comment-14624841
]
ASF GitHub Bot commented on FLINK-2328:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/884
---
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 enabl
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/900
---
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 enabl
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/872
---
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 enabl
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/903
---
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 enabl
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/854
---
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2337.
-
Resolution: Fixed
Fix Version/s: 0.10
Fixed via 8d1efa04528cacc442470bb41bcfe59574bf8e7a
>
[
https://issues.apache.org/jira/browse/FLINK-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2337.
---
> Multiple SLF4J bindings using Storm compatibility layer
> --
[
https://issues.apache.org/jira/browse/FLINK-1085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1085.
---
> Unnecessary failing of GroupReduceCombineDriver
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-1085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1085.
-
Resolution: Fixed
Fix Version/s: 0.10
Fixed via 7271881163d240ad1106a77036dce981dafb82f3 an
[
https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624825#comment-14624825
]
ASF GitHub Bot commented on FLINK-1963:
---
Github user pp86 commented on the pull requ
Github user pp86 commented on the pull request:
https://github.com/apache/flink/pull/905#issuecomment-120974750
@chiwanpark ok tnx!
What do you think about the current implementation?
---
If your project is set up for it, you can reply to this email and have your
reply appea
[
https://issues.apache.org/jira/browse/FLINK-2343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624784#comment-14624784
]
Maximilian Michels commented on FLINK-2343:
---
+1
G1 for JDK >= 8
> Change defa
GitHub user pp86 reopened a pull request:
https://github.com/apache/flink/pull/905
[FLINK-1963] Improve distinct() transformation
- add the possibility to use distinct() on Atomic data types
- add the possibility to use distinct("_")/distinct("*") on Atomic data
types
You
[
https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624771#comment-14624771
]
ASF GitHub Bot commented on FLINK-1963:
---
GitHub user pp86 reopened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624750#comment-14624750
]
ASF GitHub Bot commented on FLINK-2218:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/904#issuecomment-120958268
Just updated this PR:
- renamed "Options" to "Flink Options" and "Arguments" to "Program
Arguments" in WebUI
- removed redundant code and integrated CliFrontend
[
https://issues.apache.org/jira/browse/FLINK-2023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624724#comment-14624724
]
PJ Van Aeken commented on FLINK-2023:
-
I am back as of today ;-) Adding the overloaded
[
https://issues.apache.org/jira/browse/FLINK-2023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624709#comment-14624709
]
Aljoscha Krettek commented on FLINK-2023:
-
I think right now it's not an issue. Bu
[
https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624697#comment-14624697
]
ASF GitHub Bot commented on FLINK-2235:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624690#comment-14624690
]
ASF GitHub Bot commented on FLINK-2305:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/884#issuecomment-120940126
@gyfora merged this already! PR is not closed because Github is behind
aft-git!
---
If your project is set up for it, you can reply to this email and have your
reply appea
[
https://issues.apache.org/jira/browse/FLINK-2305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2305.
-
Resolution: Done
Fix Version/s: 0.10
Added in ea4f339d76574c8499f3588524bb174ec3283a2d
> A
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/859#issuecomment-120942293
Looks good. Merging this with a modification of the tests that they permit
the runtime exception in some cases.
---
If your project is set up for it, you can reply t
1 - 100 of 138 matches
Mail list logo
