[jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode()

[ https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3222: -- Description: Here is related code: {code} result = 31 * result + (int) (subTaskStats.length ^ (subTaskStats.

[jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3734: -- Description: {code} DataInputView in = inputState.getState(getUserCodeClassloader()); final long nextEv

[jira] [Created] (FLINK-3939) Prevent distinct aggregates and grouping sets from being translated

Fabian Hueske created FLINK-3939: Summary: Prevent distinct aggregates and grouping sets from being translated Key: FLINK-3939 URL: https://issues.apache.org/jira/browse/FLINK-3939 Project: Flink

[jira] [Updated] (FLINK-3801) Upgrade Joda-Time library to 2.9.3

[ https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3801: -- Description: Currently yoda-time 2.5 is used which was very old. We should upgrade to 2.9.3 was: Currently y

[GitHub] flink pull request: [script] Simple fix of typo from JobManager to...

Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/2001#issuecomment-220454866 Thanks @StephanEwen , have merged the change. --- 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 pr

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15292153#comment-15292153 ] ASF GitHub Bot commented on FLINK-3780: --- Github user greghogan commented on a diff i

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63956013 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java --- @@ -0,0 +1,462 @@ +/* + * Licen

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63951105 --- Diff: flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/JaccardIndex.java --- @@ -0,0 +1,132 @@ +/* + * Licens

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15292103#comment-15292103 ] ASF GitHub Bot commented on FLINK-3780: --- Github user greghogan commented on a diff i

[GitHub] flink pull request: [script] Simple fix of typo from JobManager to...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2001 --- 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 enab

[jira] [Closed] (FLINK-3935) Invalid check of key and ordering fields in PartitionNode

[ https://issues.apache.org/jira/browse/FLINK-3935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3935. Resolution: Fixed Fixed with 853a5359eb76a987f3fee33065b34051c2fa6094 > Invalid check of key and or

[jira] [Closed] (FLINK-3934) Prevent translation of non-equi joins in DataSetJoinRule

[ https://issues.apache.org/jira/browse/FLINK-3934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3934. Resolution: Fixed Fix Version/s: 1.1.0 Fixed with 3d6ce294123d90ca7bb029d4041f29a1ae1ccd81 >

[jira] [Commented] (FLINK-3836) Change Histogram to enable Long counters

[ https://issues.apache.org/jira/browse/FLINK-3836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291594#comment-15291594 ] ASF GitHub Bot commented on FLINK-3836: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-3836] Add LongHistogram accumulator

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1966#issuecomment-220395032 I think for now, we should add a `@Deprecated` annotation to the `Histogram` and its related method on `RuntimeContext` and mention in the comment that we encourage

[jira] [Commented] (FLINK-3909) Maven Failsafe plugin may report SUCCESS on failed tests

[ https://issues.apache.org/jira/browse/FLINK-3909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291517#comment-15291517 ] ASF GitHub Bot commented on FLINK-3909: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-3909] update Maven Failsafe version

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/2003#issuecomment-220388275 I get segfaults from RocksDB in my Travis tests: https://travis-ci.org/mxm/flink/builds/131412162 Let's see how the builds here go. All in all, looks ready to be me

[jira] [Commented] (FLINK-3927) TaskManager registration may fail if Yarn versions don't match

[ https://issues.apache.org/jira/browse/FLINK-3927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291484#comment-15291484 ] ASF GitHub Bot commented on FLINK-3927: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request: [FLINK-3927][yarn] make container id consisten...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2013 [FLINK-3927][yarn] make container id consistent across Hadoop versions Fixes a bug where the container id generation would vary across Hadoop versions of the client/cluster. The ResourceManager assumes

[jira] [Commented] (FLINK-3190) Retry rate limits for DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291431#comment-15291431 ] ASF GitHub Bot commented on FLINK-3190: --- Github user fijolekProjects closed the pull

[jira] [Commented] (FLINK-3190) Retry rate limits for DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291432#comment-15291432 ] ASF GitHub Bot commented on FLINK-3190: --- GitHub user fijolekProjects reopened a pull

[GitHub] flink pull request: [FLINK-3190] failure rate restart strategy

GitHub user fijolekProjects reopened a pull request: https://github.com/apache/flink/pull/1954 [FLINK-3190] failure rate restart strategy Failure rate restart strategy - job should only die, if it fails too often in a given time frame You can merge this pull request into a Git repo

[GitHub] flink pull request: [FLINK-3190] failure rate restart strategy

Github user fijolekProjects closed the pull request at: https://github.com/apache/flink/pull/1954 --- 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 featur

[jira] [Commented] (FLINK-3938) Yarn tests don't run on the current master

[ https://issues.apache.org/jira/browse/FLINK-3938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291368#comment-15291368 ] ASF GitHub Bot commented on FLINK-3938: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request: [FLINK-3938] re-enable Yarn tests

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2012 [FLINK-3938] re-enable Yarn tests Fixes a regression of #1915. You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink FLINK-3938 Alternatively yo

[jira] [Updated] (FLINK-3932) Implement State Backend Security

[ https://issues.apache.org/jira/browse/FLINK-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-3932: Description: _This issue is part of a series of improvements detailed in the [Secure Data Access|ht

[jira] [Updated] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-3931: Description: _This issue is part of a series of improvements detailed in the [Secure Data Access|ht

[jira] [Updated] (FLINK-3930) Implement Service-Level Authorization

[ https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-3930: Description: _This issue is part of a series of improvements detailed in the [Secure Data Access|ht

[jira] [Updated] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-3929: Description: _This issue is part of a series of improvements detailed in the [Secure Data Access|ht

[jira] [Commented] (FLINK-3922) Infinite recursion on TypeExtractor

[ https://issues.apache.org/jira/browse/FLINK-3922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291351#comment-15291351 ] Flavio Pompermaier commented on FLINK-3922: --- I think that if you can run the cod

[jira] [Created] (FLINK-3938) Yarn tests don't run on the current master

Maximilian Michels created FLINK-3938: - Summary: Yarn tests don't run on the current master Key: FLINK-3938 URL: https://issues.apache.org/jira/browse/FLINK-3938 Project: Flink Issue Type

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291312#comment-15291312 ] ASF GitHub Bot commented on FLINK-3780: --- Github user greghogan commented on a diff i

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63901325 --- Diff: flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/similarity/JaccardIndexTest.java --- @@ -0,0 +1,136 @@ +/* + * L

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291289#comment-15291289 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63899403 --- Diff: flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/similarity/JaccardIndexTest.java --- @@ -0,0 +1,136 @@ +/* + * Licen

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291281#comment-15291281 ] ASF GitHub Bot commented on FLINK-3780: --- Github user greghogan commented on a diff i

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63898835 --- Diff: flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/similarity/JaccardIndexTest.java --- @@ -0,0 +1,136 @@ +/* + * L

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291259#comment-15291259 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-3922) Infinite recursion on TypeExtractor

[ https://issues.apache.org/jira/browse/FLINK-3922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291260#comment-15291260 ] Timo Walther commented on FLINK-3922: - [~f.pompermaier] I have opened a PR. Can you co

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63896459 --- Diff: flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/similarity/JaccardIndexTest.java --- @@ -0,0 +1,136 @@ +/* + * Licen

[jira] [Commented] (FLINK-3922) Infinite recursion on TypeExtractor

[ https://issues.apache.org/jira/browse/FLINK-3922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291251#comment-15291251 ] ASF GitHub Bot commented on FLINK-3922: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request: [FLINK-3922] [types] Infinite recursion on Typ...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2011 [FLINK-3922] [types] Infinite recursion on TypeExtractor - [x] General - The pull request references the related JIRA issue ("[FLINK-XXX] Jira title text") - The pull request addresses o

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291243#comment-15291243 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63895157 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java --- @@ -0,0 +1,462 @@ +/* + * Licensed

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291232#comment-15291232 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63894471 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java --- @@ -0,0 +1,462 @@ +/* + * Licensed

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291228#comment-15291228 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63894348 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java --- @@ -0,0 +1,462 @@ +/* + * Licensed

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63894239 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java --- @@ -0,0 +1,462 @@ +/* + * Licensed

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291227#comment-15291227 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63894069 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java --- @@ -0,0 +1,462 @@ +/* + * Licensed

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291225#comment-15291225 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291205#comment-15291205 ] ASF GitHub Bot commented on FLINK-3780: --- Github user greghogan commented on a diff i

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63893564 --- Diff: docs/apis/batch/libs/gelly.md --- @@ -2051,6 +2052,26 @@ The algorithm takes a directed, vertex (and possibly edge) attributed graph as i vertex

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291219#comment-15291219 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63893365 --- Diff: docs/apis/batch/libs/gelly.md --- @@ -2051,6 +2052,26 @@ The algorithm takes a directed, vertex (and possibly edge) attributed graph as i ver

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291217#comment-15291217 ] ASF GitHub Bot commented on FLINK-3780: --- Github user greghogan commented on a diff i

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291216#comment-15291216 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63893177 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/TranslateEdgeDegreeToIntValue.java --- @@ -0,0 +1,51 @@ +/*

[jira] [Updated] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

[ https://issues.apache.org/jira/browse/FLINK-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Klemke updated FLINK-3937: Attachment: improve_flink_cli_yarn_integration.patch Patch that implements -yid option. Appl

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291213#comment-15291213 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63892449 --- Diff: flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/JaccardIndex.java --- @@ -0,0 +1,132 @@ +/* + * Licensed t

[jira] [Created] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

Sebastian Klemke created FLINK-3937: --- Summary: Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters Key: FLINK-3937 URL: https://issues.apache.org/jira/browse/FLINK-3937 Pr

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291206#comment-15291206 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63892035 --- Diff: docs/apis/batch/libs/gelly.md --- @@ -2051,6 +2052,26 @@ The algorithm takes a directed, vertex (and possibly edge) attributed graph as i ver

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63892061 --- Diff: flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/JaccardIndex.java --- @@ -0,0 +1,132 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291192#comment-15291192 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291197#comment-15291197 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63891097 --- Diff: docs/apis/batch/libs/gelly.md --- @@ -2051,6 +2052,26 @@ The algorithm takes a directed, vertex (and possibly edge) attributed graph as i vertex

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291195#comment-15291195 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63890887 --- Diff: docs/apis/batch/libs/gelly.md --- @@ -2051,6 +2052,26 @@ The algorithm takes a directed, vertex (and possibly edge) attributed graph as i vertex

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291193#comment-15291193 ] ASF GitHub Bot commented on FLINK-3780: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63890630 --- Diff: docs/apis/batch/libs/gelly.md --- @@ -2051,6 +2052,26 @@ The algorithm takes a directed, vertex (and possibly edge) attributed graph as i vertex

[GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1980#discussion_r63890500 --- Diff: docs/apis/batch/libs/gelly.md --- @@ -2051,6 +2052,26 @@ The algorithm takes a directed, vertex (and possibly edge) attributed graph as i vertex

[jira] [Assigned] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan reassigned FLINK-3929: -- Assignee: Vijay Srinivasaraghavan (was: Eron Wright ) > Support for Ke

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291134#comment-15291134 ] ASF GitHub Bot commented on FLINK-1745: --- Github user danielblazevski commented on a

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

Github user danielblazevski commented on a diff in the pull request: https://github.com/apache/flink/pull/1220#discussion_r63882747 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/nn/KNN.scala --- @@ -0,0 +1,353 @@ +/* + * Licensed to the Apache Softwa

[GitHub] flink pull request: [FLINK-3909] update Maven Failsafe version

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/2003#issuecomment-220321817 Thanks for looking into the problem and providing a detailed explanation @markreddy. I think we're good to go with the newest version of the Surefire plugin. I verified the

[jira] [Commented] (FLINK-3909) Maven Failsafe plugin may report SUCCESS on failed tests

[ https://issues.apache.org/jira/browse/FLINK-3909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291081#comment-15291081 ] ASF GitHub Bot commented on FLINK-3909: --- Github user mxm commented on the pull reque

[jira] [Created] (FLINK-3936) Add MIN / MAX aggregations function for BOOLEAN types

Fabian Hueske created FLINK-3936: Summary: Add MIN / MAX aggregations function for BOOLEAN types Key: FLINK-3936 URL: https://issues.apache.org/jira/browse/FLINK-3936 Project: Flink Issue Typ

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291073#comment-15291073 ] ASF GitHub Bot commented on FLINK-1502: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1502] [WIP] Basic Metric System

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1947#issuecomment-220319335 Let me grab the token for this one. There are a few things still, like resource leaks, in this code. I'll pass you back the token as soon as I am done... --- If

[jira] [Commented] (FLINK-2220) Join on Pojo without hashCode() silently fails

[ https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291048#comment-15291048 ] ASF GitHub Bot commented on FLINK-2220: --- Github user gallenvara closed the pull requ

[GitHub] flink pull request: [FLINK-2220] Join on Pojo without hashCode() s...

Github user gallenvara closed the pull request at: https://github.com/apache/flink/pull/1940 --- 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

[jira] [Commented] (FLINK-2220) Join on Pojo without hashCode() silently fails

[ https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291045#comment-15291045 ] ASF GitHub Bot commented on FLINK-2220: --- Github user gallenvara commented on the pul

[GitHub] flink pull request: [FLINK-2220] Join on Pojo without hashCode() s...

Github user gallenvara commented on the pull request: https://github.com/apache/flink/pull/1940#issuecomment-220316125 @fhueske i can't reproduce the issue in another computer. And I'm not sure if it's because I forgot the default constructor (no parameter) that led to the problem exi

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291038#comment-15291038 ] ASF GitHub Bot commented on FLINK-3311: --- Github user zentol commented on a diff in t

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r63871737 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java --- @@ -0

[jira] [Commented] (FLINK-3933) Add an auto-type-extracting DeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-3933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291024#comment-15291024 ] ASF GitHub Bot commented on FLINK-3933: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request: [FLINK-3933] [streaming API] Add AbstractDeser...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2010#discussion_r63869803 --- Diff: docs/apis/streaming/connectors/kafka.md --- @@ -142,18 +142,24 @@ for querying the list of topics and partitions. For this to work, the consume

[GitHub] flink pull request: [FLINK-2220] Join on Pojo without hashCode() s...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1940#issuecomment-220310633 Any update for this PR, @gallenvara? --- 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

[jira] [Commented] (FLINK-2220) Join on Pojo without hashCode() silently fails

[ https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291021#comment-15291021 ] ASF GitHub Bot commented on FLINK-2220: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r63869055 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java ---

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291020#comment-15291020 ] ASF GitHub Bot commented on FLINK-3311: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-3933) Add an auto-type-extracting DeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-3933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291017#comment-15291017 ] ASF GitHub Bot commented on FLINK-3933: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-3933] [streaming API] Add AbstractDeser...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2010#discussion_r63868527 --- Diff: docs/apis/streaming/connectors/kafka.md --- @@ -142,18 +142,24 @@ for querying the list of topics and partitions. For this to work, the cons

[jira] [Commented] (FLINK-2147) Approximate calculation of frequencies in data streams

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291006#comment-15291006 ] Gabor Gevay commented on FLINK-2147: > From a first look, something like StreamGrouped

[jira] [Commented] (FLINK-3909) Maven Failsafe plugin may report SUCCESS on failed tests

[ https://issues.apache.org/jira/browse/FLINK-3909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291005#comment-15291005 ] ASF GitHub Bot commented on FLINK-3909: --- Github user markreddy commented on the pull

[GitHub] flink pull request: [FLINK-3909] update Maven Failsafe version

Github user markreddy commented on the pull request: https://github.com/apache/flink/pull/2003#issuecomment-220307660 I took a look at the root issue of upgrading to 2.19.1. I'm able to reliably reproduce this issue on my laptop. When I bump the version I get the same as @til

[jira] [Created] (FLINK-3935) Invalid check of key and ordering fields in PartitionNode

Fabian Hueske created FLINK-3935: Summary: Invalid check of key and ordering fields in PartitionNode Key: FLINK-3935 URL: https://issues.apache.org/jira/browse/FLINK-3935 Project: Flink Issue

[jira] [Created] (FLINK-3934) Prevent translation of non-equi joins in DataSetJoinRule

Fabian Hueske created FLINK-3934: Summary: Prevent translation of non-equi joins in DataSetJoinRule Key: FLINK-3934 URL: https://issues.apache.org/jira/browse/FLINK-3934 Project: Flink Issue

  1   2   >