[GitHub] flink pull request: Fix handling of receiver and sender task failu...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/746#issuecomment-107337457 Merging now. --- 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

[jira] [Created] (FLINK-2125) String delimiter for SocketTextStream

Márton Balassi created FLINK-2125: - Summary: String delimiter for SocketTextStream Key: FLINK-2125 URL: https://issues.apache.org/jira/browse/FLINK-2125 Project: Flink Issue Type:

[jira] [Created] (FLINK-2126) Scala shell tests sporadically fail on travis

Robert Metzger created FLINK-2126: - Summary: Scala shell tests sporadically fail on travis Key: FLINK-2126 URL: https://issues.apache.org/jira/browse/FLINK-2126 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2120) Rename AbstractJobVertex to JobVertex

[ https://issues.apache.org/jira/browse/FLINK-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567209#comment-14567209 ] Maximilian Michels commented on FLINK-2120: --- +1 Rename AbstractJobVertex to

[GitHub] flink pull request: [FLINK-2037] Provide flink-python.jar in lib/

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/691 --- 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-2037) Unable to start Python API using ./bin/pyflink*.sh

[ https://issues.apache.org/jira/browse/FLINK-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567216#comment-14567216 ] ASF GitHub Bot commented on FLINK-2037: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567225#comment-14567225 ] ASF GitHub Bot commented on FLINK-1319: --- Github user uce commented on the pull

[GitHub] flink pull request: [FLINK-1319][core] Add static code analysis fo...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/729#issuecomment-107422340 +1 for the annotation. I'm against using stdout. Logging frameworks are much better at controlling the output. The quickstart mvn archetype provides a

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567244#comment-14567244 ] ASF GitHub Bot commented on FLINK-1319: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/695#issuecomment-107422496 Is this good to merge now? I'm rewriting all the sources (again) and this should probably go in. --- If your project is set up for it, you can reply to this email and

[jira] [Assigned] (FLINK-1430) Add test for streaming scala api completeness

[ https://issues.apache.org/jira/browse/FLINK-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1430: - Assignee: Márton Balassi (was: Mingliang Qi) Add test for streaming scala api

[GitHub] flink pull request: New operator state interfaces

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/747#discussion_r31420656 --- Diff:

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567146#comment-14567146 ] ASF GitHub Bot commented on FLINK-1319: --- Github user StephanEwen commented on the

[jira] [Resolved] (FLINK-2037) Unable to start Python API using ./bin/pyflink*.sh

[ https://issues.apache.org/jira/browse/FLINK-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2037. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/2f347a03

[jira] [Resolved] (FLINK-1954) Task Failures and Error Handling

[ https://issues.apache.org/jira/browse/FLINK-1954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1954. Resolution: Fixed Fix Version/s: 0.9 Fixed in 1aad5b759432f0b59a9dcc366a4b66c2681626f1,

[jira] [Updated] (FLINK-1955) Improve error handling of sender task failures

[ https://issues.apache.org/jira/browse/FLINK-1955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-1955: --- Fix Version/s: 0.9 Improve error handling of sender task failures

[jira] [Updated] (FLINK-1941) Add documentation for Gelly-GSA

[ https://issues.apache.org/jira/browse/FLINK-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-1941: --- Fix Version/s: 0.9 Add documentation for Gelly-GSA ---

[jira] [Created] (FLINK-2123) Fix CLI client logging

Ufuk Celebi created FLINK-2123: -- Summary: Fix CLI client logging Key: FLINK-2123 URL: https://issues.apache.org/jira/browse/FLINK-2123 Project: Flink Issue Type: Bug Components: Core

[jira] [Commented] (FLINK-2076) Bug in re-openable hash join

[ https://issues.apache.org/jira/browse/FLINK-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567143#comment-14567143 ] ASF GitHub Bot commented on FLINK-2076: --- Github user StephanEwen commented on the

[jira] [Commented] (FLINK-2004) Memory leak in presence of failed checkpoints in KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567144#comment-14567144 ] ASF GitHub Bot commented on FLINK-2004: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2076] [runtime] Fix memory leakage in M...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/751#issuecomment-107392568 Awesome, thanks a lot @chiwanpark --- 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] flink pull request: [FLINK-2004] Fix memory leak in presence of fa...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/674#issuecomment-107392647 Looks good! Will merge this.. --- 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

[GitHub] flink pull request: [FLINK-2037] Provide flink-python.jar in lib/

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/691#issuecomment-107391906 I'm going to merge this ... --- 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

[jira] [Created] (FLINK-2122) Make all internal streaming operators Checkpointable

Aljoscha Krettek created FLINK-2122: --- Summary: Make all internal streaming operators Checkpointable Key: FLINK-2122 URL: https://issues.apache.org/jira/browse/FLINK-2122 Project: Flink

[jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567126#comment-14567126 ] ASF GitHub Bot commented on FLINK-2098: --- Github user aljoscha commented on the pull

[jira] [Created] (FLINK-2124) FromElementsFunction is not really Serializable

Aljoscha Krettek created FLINK-2124: --- Summary: FromElementsFunction is not really Serializable Key: FLINK-2124 URL: https://issues.apache.org/jira/browse/FLINK-2124 Project: Flink Issue

[GitHub] flink pull request: [FLINK-2098] Ensure checkpoints and element em...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/742#issuecomment-107388477 As per the discussion on the mailing list I'm rewriting the Source interface to only have the run()/cancel() variant. --- If your project is set up for it, you can

[jira] [Resolved] (FLINK-1958) Improve error handling of receiver task failures

[ https://issues.apache.org/jira/browse/FLINK-1958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1958. Resolution: Fixed Fixed in dce1be1. Improve error handling of receiver task failures

[jira] [Updated] (FLINK-1958) Improve error handling of receiver task failures

[ https://issues.apache.org/jira/browse/FLINK-1958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-1958: --- Fix Version/s: 0.9 Improve error handling of receiver task failures

[jira] [Resolved] (FLINK-1955) Improve error handling of sender task failures

[ https://issues.apache.org/jira/browse/FLINK-1955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1955. Resolution: Fixed Fixed in f75c16b. Improve error handling of sender task failures

[GitHub] flink pull request: [FLINK-1319][core] Add static code analysis fo...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/729#issuecomment-107393190 Let us merge this for 0.9 and have it deactivated by default. Let's gradually activate it in the next releases as it gets exposure --- If your project is

[jira] [Commented] (FLINK-2037) Unable to start Python API using ./bin/pyflink*.sh

[ https://issues.apache.org/jira/browse/FLINK-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567139#comment-14567139 ] ASF GitHub Bot commented on FLINK-2037: --- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-1993) Replace MultipleLinearRegression's custom SGD with optimization framework's SGD

[ https://issues.apache.org/jira/browse/FLINK-1993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567399#comment-14567399 ] ASF GitHub Bot commented on FLINK-1993: --- Github user thvasilo closed the pull

[jira] [Commented] (FLINK-2101) Scheme Inference doesn't work for Tuple5

[ https://issues.apache.org/jira/browse/FLINK-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567536#comment-14567536 ] Ufuk Celebi commented on FLINK-2101: I think there is no problem, but Robert wanted to

[jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567445#comment-14567445 ] ASF GitHub Bot commented on FLINK-2098: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-2121] Fix the summation in FileInputFor...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/752 --- 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-2101) Scheme Inference doesn't work for Tuple5

[ https://issues.apache.org/jira/browse/FLINK-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567489#comment-14567489 ] Stephan Ewen commented on FLINK-2101: - So, is there any problem remaining, or can this

[GitHub] flink pull request: [FLINK-2098] Ensure checkpoints and element em...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/742#issuecomment-107613541 I'll make a pass --- 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

[jira] [Commented] (FLINK-2127) The GSA Documentation has trailing /p s

[ https://issues.apache.org/jira/browse/FLINK-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567396#comment-14567396 ] Ufuk Celebi commented on FLINK-2127: Building it locally works fine. I guess it's a

[jira] [Commented] (FLINK-1430) Add test for streaming scala api completeness

[ https://issues.apache.org/jira/browse/FLINK-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567410#comment-14567410 ] ASF GitHub Bot commented on FLINK-1430: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-2098] Ensure checkpoints and element em...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/742#issuecomment-107589378 I reworked the sources now. Could someone please have another pass over this. I think this is very critical code. --- If your project is set up for it, you can reply

[jira] [Closed] (FLINK-2121) FileInputFormat.addFilesInDir miscalculates total size

[ https://issues.apache.org/jira/browse/FLINK-2121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2121. --- FileInputFormat.addFilesInDir miscalculates total size

[jira] [Resolved] (FLINK-2121) FileInputFormat.addFilesInDir miscalculates total size

[ https://issues.apache.org/jira/browse/FLINK-2121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2121. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 033409190235f93ed6d4e652214e7f35a34c3fe3

[jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567498#comment-14567498 ] ASF GitHub Bot commented on FLINK-2098: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [WIP] [FLINK-1993] [ml] - Replace MultipleLine...

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/725#issuecomment-107563713 Closing as it gets super-seeded by the optimization framework [refactoring](https://github.com/apache/flink/pull/740) --- If your project is set up for it, you can

[GitHub] flink pull request: [WIP] [FLINK-1993] [ml] - Replace MultipleLine...

Github user thvasilo closed the pull request at: https://github.com/apache/flink/pull/725 --- 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] flink pull request: [FLINK-1430] [streaming] Scala API completenes...

GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/753 [FLINK-1430] [streaming] Scala API completeness for streaming Added the necessary checks and missing methods for streaming. Created an abstract base class for these completeness tests to

[jira] [Closed] (FLINK-2004) Memory leak in presence of failed checkpoints in KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2004. --- Memory leak in presence of failed checkpoints in KafkaSource

[jira] [Commented] (FLINK-2004) Memory leak in presence of failed checkpoints in KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567475#comment-14567475 ] ASF GitHub Bot commented on FLINK-2004: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-2004] Fix memory leak in presence of fa...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/674 --- 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-2127) The GSA Documentation has trailing /p s

[ https://issues.apache.org/jira/browse/FLINK-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567378#comment-14567378 ] Andra Lungu commented on FLINK-2127: Hi Ufuk, Nope, that's not what I meant :) If

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567304#comment-14567304 ] ASF GitHub Bot commented on FLINK-1319: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-1319][core] Add static code analysis fo...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/729#issuecomment-107482998 The concern about logging is that, when using the local mode inside the IDE, the system logs a lot and the hints get lost. If you don't want sysoutput, you

[jira] [Resolved] (FLINK-2114) PunctuationPolicy.toString() throws NullPointerException if extractor is null

[ https://issues.apache.org/jira/browse/FLINK-2114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay resolved FLINK-2114. Resolution: Fixed PunctuationPolicy.toString() throws NullPointerException if extractor is null

[GitHub] flink pull request: [FLINK-2076] [runtime] Fix memory leakage in M...

Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/751#issuecomment-107478713 I fixed the bug related to non-null memory segment. The bug was caused by non-clearing `writeBehindBuffersAvailable` variable in `close()` method of

[jira] [Commented] (FLINK-2111) Add terminate signal to cleanly stop streaming jobs

[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567386#comment-14567386 ] ASF GitHub Bot commented on FLINK-2111: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2111] Add terminate signal to cleanly...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-107549742 Good idea! Given the fact that we are stabilizing at the moment (and this is introducing new functionality), I vote to postpone that to after the 0.9

[jira] [Created] (FLINK-2127) The GSA Documentation has trailing /p s

Andra Lungu created FLINK-2127: -- Summary: The GSA Documentation has trailing /p s Key: FLINK-2127 URL: https://issues.apache.org/jira/browse/FLINK-2127 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-2127) The GSA Documentation has trailing /p s

[ https://issues.apache.org/jira/browse/FLINK-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-2127: --- Component/s: Documentation The GSA Documentation has trailing /p s

[jira] [Commented] (FLINK-2076) Bug in re-openable hash join

[ https://issues.apache.org/jira/browse/FLINK-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567296#comment-14567296 ] ASF GitHub Bot commented on FLINK-2076: --- Github user chiwanpark commented on the

[jira] [Commented] (FLINK-2120) Rename AbstractJobVertex to JobVertex

[ https://issues.apache.org/jira/browse/FLINK-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567329#comment-14567329 ] Stephan Ewen commented on FLINK-2120: - +1 Rename AbstractJobVertex to JobVertex

[jira] [Commented] (FLINK-2121) FileInputFormat.addFilesInDir miscalculates total size

[ https://issues.apache.org/jira/browse/FLINK-2121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567328#comment-14567328 ] ASF GitHub Bot commented on FLINK-2121: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2121] Fix the summation in FileInputFor...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/752#issuecomment-107498384 +1, should go into the release candidate. Will merge this now... --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

Github user HilmiYildirim commented on the pull request: https://github.com/apache/flink/pull/695#issuecomment-107551663 I think it is good. --- 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

[jira] [Commented] (FLINK-2127) The GSA Documentation has trailing /p s

[ https://issues.apache.org/jira/browse/FLINK-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567661#comment-14567661 ] Andra Lungu commented on FLINK-2127: Yep, building it locally works :). Nevertheless,

[jira] [Commented] (FLINK-1727) Add decision tree to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567676#comment-14567676 ] Sachin Goel commented on FLINK-1727: A complete implementation, with both Gini gain

[GitHub] flink pull request: [FLINK-2098] Ensure checkpoints and element em...

Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/742#discussion_r31461903 --- Diff:

[jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567853#comment-14567853 ] ASF GitHub Bot commented on FLINK-2098: --- Github user mbalassi commented on a diff in

[GitHub] flink pull request: [FLINK-2098] Ensure checkpoints and element em...

Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/742#discussion_r31460859 --- Diff:

[jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567868#comment-14567868 ] ASF GitHub Bot commented on FLINK-2098: --- Github user mbalassi commented on a diff in

[jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

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

[jira] [Commented] (FLINK-2101) Scheme Inference doesn't work for Tuple5

[ https://issues.apache.org/jira/browse/FLINK-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567813#comment-14567813 ] Robert Metzger commented on FLINK-2101: --- Yes, will do. Scheme Inference doesn't

[jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567848#comment-14567848 ] ASF GitHub Bot commented on FLINK-2098: --- Github user mbalassi commented on a diff in

[GitHub] flink pull request: [FLINK-2098] Ensure checkpoints and element em...

Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/742#discussion_r31460503 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java --- @@ -19,66

[jira] [Created] (FLINK-2128) ScalaShellITSuite failing

Ufuk Celebi created FLINK-2128: -- Summary: ScalaShellITSuite failing Key: FLINK-2128 URL: https://issues.apache.org/jira/browse/FLINK-2128 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-2127) The GSA Documentation has trailing /p s

[ https://issues.apache.org/jira/browse/FLINK-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567976#comment-14567976 ] Ufuk Celebi commented on FLINK-2127: This is definitely a bug. I didn't say that we

[jira] [Resolved] (FLINK-2089) Buffer recycled IllegalStateException during cancelling

[ https://issues.apache.org/jira/browse/FLINK-2089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-2089. Resolution: Fixed Fix Version/s: 0.9 Fixed in 28eb274. Buffer recycled

[jira] [Resolved] (FLINK-1724) TestingCluster uses local communication with multiple task managers

[ https://issues.apache.org/jira/browse/FLINK-1724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1724. Resolution: Fixed Fix Version/s: 0.9 This has been fixed as I've said. The point you've

[jira] [Commented] (FLINK-1747) Remove deadlock detection and pipeline breaker placement in optimizer

[ https://issues.apache.org/jira/browse/FLINK-1747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568078#comment-14568078 ] Ufuk Celebi commented on FLINK-1747: [~StephanEwen], was this a duplicate of

[GitHub] flink pull request: [FLINK-2119] Add ExecutionGraph support for ba...

GitHub user uce opened a pull request: https://github.com/apache/flink/pull/754 [FLINK-2119] Add ExecutionGraph support for batch scheduling This PR adds support for a newly introduced scheduling mode `BATCH_FROM_SOURCES`. The goal for me was to make this change *minimally

[jira] [Closed] (FLINK-1747) Remove deadlock detection and pipeline breaker placement in optimizer

[ https://issues.apache.org/jira/browse/FLINK-1747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1747. --- Remove deadlock detection and pipeline breaker placement in optimizer

[jira] [Resolved] (FLINK-1747) Remove deadlock detection and pipeline breaker placement in optimizer

[ https://issues.apache.org/jira/browse/FLINK-1747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1747. - Resolution: Duplicate Duplicate of FLINK-2041 Remove deadlock detection and pipeline breaker

[GitHub] flink pull request: [FLINK-2098] Ensure checkpoints and element em...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/742#issuecomment-107751723 Looks good all in all. I am preparing a followup pull request that cleans up a few things, adds comments, and addresses Marton's comments. One thing I

[jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568279#comment-14568279 ] ASF GitHub Bot commented on FLINK-2098: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2098] Improvements on checkpoint-aligne...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/755 [FLINK-2098] Improvements on checkpoint-aligned sources Based on #742 , include multiple cleanups and fixes on top. You can merge this pull request into a Git repository by running: $ git

[jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568362#comment-14568362 ] ASF GitHub Bot commented on FLINK-2098: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2098] Ensure checkpoints and element em...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/742#issuecomment-107768981 Some important comments: - Exceptions should always propagate, and exceptions during cancelling can be thrown. The `Task` class filters out exceptions that

[jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568363#comment-14568363 ] ASF GitHub Bot commented on FLINK-2098: --- Github user StephanEwen commented on the

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568392#comment-14568392 ] Sachin Goel commented on FLINK-1731: I'm creating a separate issue for Initialization

[jira] [Created] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements

Stephan Ewen created FLINK-2130: --- Summary: RabbitMQ source does not fail when failing to retrieve elements Key: FLINK-2130 URL: https://issues.apache.org/jira/browse/FLINK-2130 Project: Flink

[jira] [Created] (FLINK-2131) Add Initialization schemes for K-means clustering

Sachin Goel created FLINK-2131: -- Summary: Add Initialization schemes for K-means clustering Key: FLINK-2131 URL: https://issues.apache.org/jira/browse/FLINK-2131 Project: Flink Issue Type: Task

[GitHub] flink pull request: [FLINK-2098] Ensure checkpoints and element em...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/742#issuecomment-107811407 I will fix the remaining cancel() races. The twitter stuff I just commented out because I assumed that the new TwitterSource could be merged right away and I was