[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156330#comment-15156330
]
Dongwon Kim commented on FLINK-1502:
[~jgrier] Thank you for sharing the link :-) The
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1685#issuecomment-186948795
It is pretty crucial that different hash functions are used for the
partitioning across machines, and the internal partitioning of data structures.
If the same hash
[
https://issues.apache.org/jira/browse/FLINK-3422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156306#comment-15156306
]
ASF GitHub Bot commented on FLINK-3422:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156257#comment-15156257
]
ASF GitHub Bot commented on FLINK-3422:
---
GitHub user Xazax-hun opened a pull request
GitHub user Xazax-hun opened a pull request:
https://github.com/apache/flink/pull/1685
[WIP][FLINK-3422][streaming][api-breaking] Scramble HashPartitioner hashes.
This pull request contains a fix for FLINK-3422. Some of the tests are
failing at the moment, because they utilized prio
[
https://issues.apache.org/jira/browse/FLINK-3416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156221#comment-15156221
]
ASF GitHub Bot commented on FLINK-3416:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1674#discussion_r53573047
--- Diff: flink-dist/src/main/flink-bin/bin/pyflink2.bat ---
@@ -22,4 +22,4 @@ setlocal EnableDelayedExpansion
SET bin=%~dp0
SET FLINK_ROOT_DIR=%bin%.
[
https://issues.apache.org/jira/browse/FLINK-3416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156179#comment-15156179
]
ASF GitHub Bot commented on FLINK-3416:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1674#discussion_r53571627
--- Diff: flink-dist/src/main/flink-bin/bin/pyflink2.bat ---
@@ -22,4 +22,4 @@ setlocal EnableDelayedExpansion
SET bin=%~dp0
SET FLINK_ROOT_DIR=%bi
[
https://issues.apache.org/jira/browse/FLINK-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156147#comment-15156147
]
Subhobrata Dey commented on FLINK-3387:
---
Hello [~StephanEwen],
I see that each cla
[
https://issues.apache.org/jira/browse/FLINK-3440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-3440:
-
Assignee: Robert Metzger
> Kafka should also checkpoint partitions where no initial offse
[
https://issues.apache.org/jira/browse/FLINK-3455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156049#comment-15156049
]
ASF GitHub Bot commented on FLINK-3455:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1684
[FLINK-3455] Bump Kafka to 0.9.0.1 and 0.8.2.2
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink flink3455
Alternatively you can
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1588#issuecomment-186835009
The expected output of the test is the following
```
Test testQueryCluster(org.apache.flink.yarn.YARNSessionFIFOITCase) is
running.
---
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156048#comment-15156048
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156041#comment-15156041
]
Greg Hogan commented on FLINK-3385:
---
Pull request is [here|https://github.com/apache/fli
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/1588#issuecomment-186832973
@rmetzger I am trying to reproduce it but so far I cannot. I will keep you
posted.
---
If your project is set up for it, you can reply to this email and have your
reply ap
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156039#comment-15156039
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user kl0u commented on the pull requ
[
https://issues.apache.org/jira/browse/FLINK-3443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156021#comment-15156021
]
ASF GitHub Bot commented on FLINK-3443:
---
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/1669#discussion_r5359
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1487,7 +1487,7 @@ class JobManager(
}
[
https://issues.apache.org/jira/browse/FLINK-3460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156020#comment-15156020
]
ASF GitHub Bot commented on FLINK-3460:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1683
[FLINK-3460] [build] Set Flink dependencies in flink-streaming-connectors
to provided
The flink-streaming-connectors all depend on flink-streaming-java in
compile scope.
This entails that
[
https://issues.apache.org/jira/browse/FLINK-3459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156019#comment-15156019
]
ASF GitHub Bot commented on FLINK-3459:
---
GitHub user tillrohrmann opened a pull requ
Till Rohrmann created FLINK-3460:
Summary: Make flink-streaming-connectors' flink dependencies
provided
Key: FLINK-3460
URL: https://issues.apache.org/jira/browse/FLINK-3460
Project: Flink
I
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1682
[FLINK-3459] [build] Fix conflicting dependencies commons-collections
commons-beanutils and commons-beanutils-core
The Hadoop dependencies have a dependency on commons-configuration which
pull
Till Rohrmann created FLINK-3459:
Summary: Make build SBT compatible
Key: FLINK-3459
URL: https://issues.apache.org/jira/browse/FLINK-3459
Project: Flink
Issue Type: Improvement
Affects V
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1681
[FLINK-3458] [build] Disable shade-flink execution in flink-shaded-hadoop
The `shade-flink` execution of the parent pom caused the problem that the
guava
dependencies were relocated twice i
[
https://issues.apache.org/jira/browse/FLINK-3458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15156017#comment-15156017
]
ASF GitHub Bot commented on FLINK-3458:
---
GitHub user tillrohrmann opened a pull requ
Till Rohrmann created FLINK-3458:
Summary: Shading broken in flink-shaded-hadoop
Key: FLINK-3458
URL: https://issues.apache.org/jira/browse/FLINK-3458
Project: Flink
Issue Type: Bug
Affec
Slim Baltagi created FLINK-3457:
---
Summary: Link to Apache Flink meetups from the 'Community' section
of the website
Key: FLINK-3457
URL: https://issues.apache.org/jira/browse/FLINK-3457
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15155982#comment-15155982
]
ASF GitHub Bot commented on FLINK-3443:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1669#discussion_r53564976
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1487,7 +1487,7 @@ class JobManager(
}
[
https://issues.apache.org/jira/browse/FLINK-3238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15155979#comment-15155979
]
Robert Metzger commented on FLINK-3238:
---
Again: https://s3.amazonaws.com/archive.tra
33 matches
Mail list logo
