GitHub user petervandenabeele opened a pull request:
https://github.com/apache/flink/pull/1463
Trivial typo in docker-flink/README.md
* trivial typo
* not making a JIRA for this _trivial_ fix, as suggested in
http://flink.apache.org/contribute-code.html
You can merge this pull
Fabian Hueske created FLINK-3179:
Summary: Combiner is not injected if Reduce or GroupReduce input
is explicitly partitioned
Key: FLINK-3179
URL: https://issues.apache.org/jira/browse/FLINK-3179
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1462
[FLINK-2716] [gelly java scala] New checksum method on DataSet and Graph
This implementation aggregates using `Object.hashCode`. As noted in
FLINK-2716, `TypeComparator` has a hash function,
[
https://issues.apache.org/jira/browse/FLINK-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15060402#comment-15060402
]
ASF GitHub Bot commented on FLINK-2716:
---
GitHub user greghogan opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15060984#comment-15060984
]
ASF GitHub Bot commented on FLINK-3166:
---
GitHub user greghogan opened a pull request:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1464
[FLINK-3166] [runtime] The first program in ObjectReuseITCase has the wrong
expected result, and it succeeds
- TestEnvironment now honors configuration of object reuse
- Fixed reduce
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15061322#comment-15061322
]
Chengxiang Li commented on FLINK-2871:
--
I would like to contribute on this. There are 4 reserved
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengxiang Li reassigned FLINK-2871:
Assignee: Chengxiang Li
> Add OuterJoin strategy with HashTable on outer side
>
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r4748
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/HeapStateStore.java
---
@@ -0,0 +1,84 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15059996#comment-15059996
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r4758
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/Savepoint.java
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15059997#comment-15059997
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15059962#comment-15059962
]
ASF GitHub Bot commented on FLINK-3050:
---
GitHub user uce opened a pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r4988
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
---
@@ -440,4 +478,226 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15060001#comment-15060001
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user uce commented on a diff in the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1434#issuecomment-165116732
I think this is good behavior, it is conservative and if users want it
differently they can manually specify the ID.
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15060013#comment-15060013
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user aljoscha commented on the pull request:
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1434#issuecomment-165115785
I've addressed the last comments.
Regarding the deterministic hashing and ordering of the graph: changing
anything but the user function changes the hash (if not
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15060008#comment-15060008
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user uce commented on the pull request:
Aljoscha Krettek created FLINK-3178:
---
Summary: Make Closing Behavior of Window Operators Configurable
Key: FLINK-3178
URL: https://issues.apache.org/jira/browse/FLINK-3178
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-3050:
--
Assignee: Ufuk Celebi
> Add custom Exception type to suppress job restarts
>
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1460
[FLINK-3174] Add merging WindowAssigner
After triggering and before emitting the window contents the window
assigner is given the change to merge existing windows. The trigger is
then given
[
https://issues.apache.org/jira/browse/FLINK-3174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15059956#comment-15059956
]
ASF GitHub Bot commented on FLINK-3174:
---
GitHub user aljoscha opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1461
[FLINK-3050] [runtime] Add UnrecoverableException to suppress job restarts
I need this to address a comment in #1434.
Adds `UnrecoverableException`, which suppresses job restarts if it is the
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1427#issuecomment-165171199
Hi,
I had a look and have some comments as well
- `ExecutionConfig`: Do we want to make the whole class public? Are we sure
that we do not change the
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15060278#comment-15060278
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user fhueske commented on the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1450#issuecomment-165042507
If no objections, I'd like to merge this soon. Travis failures are
unrelated to Yarn.
---
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-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15059729#comment-15059729
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user mxm commented on the pull request:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1439
---
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 uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1451#discussion_r47753669
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ZookeeperOffsetHandler.java
---
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1451#discussion_r47753777
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java
---
@@ -632,6
[
https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15059755#comment-15059755
]
ASF GitHub Bot commented on FLINK-3067:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1451#issuecomment-165047710
With Aljoscha's test +1 to merge (minus two trivial comments).
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15059756#comment-15059756
]
ASF GitHub Bot commented on FLINK-3067:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15059757#comment-15059757
]
ASF GitHub Bot commented on FLINK-3067:
---
Github user uce commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1459#issuecomment-165031211
Hi @guochuanzhi, it looks like your PR does not include any commits of you
but just already committed changes. It does also not have a description. Can
you please close
Aljoscha Krettek created FLINK-3177:
---
Summary: Add Stream Operator that Discards Late Elements
Key: FLINK-3177
URL: https://issues.apache.org/jira/browse/FLINK-3177
Project: Flink
Issue
37 matches
Mail list logo
