[jira] [Created] (FLINK-1849) Refactor StreamingRuntimeContext

Márton Balassi created FLINK-1849: - Summary: Refactor StreamingRuntimeContext Key: FLINK-1849 URL: https://issues.apache.org/jira/browse/FLINK-1849 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [FLINK-1670] Made DataStream iterable

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/581#issuecomment-91082306 Thanks for picking up the issue, @ggevay. I would like to add to the list Stephan mentioned: I personally prefer the name collect for the method, it can still ret

[jira] [Commented] (FLINK-1670) Collect method for streaming

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

[GitHub] flink pull request: [FLINK-1670] Made DataStream iterable

Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/581#discussion_r28028612 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java --- @@ -1165,6 +1168,7 @

[jira] [Commented] (FLINK-1670) Collect method for streaming

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

[jira] [Commented] (FLINK-1793) Streaming File Source cannot be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486181#comment-14486181 ] Gyula Fora commented on FLINK-1793: --- I pushed a fix to a bug in the file source cancelli

[GitHub] flink pull request: [FLINK-1694] [gelly] added IterationConfigurat...

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/547#issuecomment-91048962 Thanks so much for the review @fhueske, @StephanEwen! I'll make the suggested changes and merge :-) --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-1694) Change the split between create/run of a vertex-centric iteration

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

[jira] [Resolved] (FLINK-1813) Barrier broadcast sometimes causes illegal state exception in source RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-1813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1813. --- Resolution: Fixed > Barrier broadcast sometimes causes illegal state exception in source > RecordWrit

[jira] [Commented] (FLINK-1670) Collect method for streaming

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

[GitHub] flink pull request: [FLINK-1670] Made DataStream iterable

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/581#issuecomment-90987769 It is an interesting idea to collect back a data stream. This solution here has, however, quite a few limitations and implications (I assume it was only locally tested

[GitHub] flink pull request: [FLINK-1670] Made DataStream iterable

GitHub user ggevay opened a pull request: https://github.com/apache/flink/pull/581 [FLINK-1670] Made DataStream iterable I created a DataStreamIterator class, and added an iterator() method to DataStream, which returns an instance of it. The iterator creates a TCP server on which i

[jira] [Commented] (FLINK-1670) Collect method for streaming

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

[jira] [Commented] (FLINK-1823) Rename linq.md to something like table.md to avoid potential trademark issue

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

[GitHub] flink pull request: [FLINK-1823] Remove linq from Table API docume...

Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/580#issuecomment-90951956 SHIP IT :+1: --- 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 e

[jira] [Commented] (FLINK-1793) Streaming File Source cannot be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485390#comment-14485390 ] Maximilian Michels commented on FLINK-1793: --- Some more debug information. Upon c

[GitHub] flink pull request: [FLINK-1823] Remove linq from Table API docume...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/580#issuecomment-90949839 Fixed @hsaputra's remark. --- 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 th

[jira] [Commented] (FLINK-1823) Rename linq.md to something like table.md to avoid potential trademark issue

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

[jira] [Commented] (FLINK-1793) Streaming File Source cannot be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485355#comment-14485355 ] Márton Balassi commented on FLINK-1793: --- Ok, let me look into it. > Streaming File

[jira] [Assigned] (FLINK-1793) Streaming File Source cannot be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1793: - Assignee: Márton Balassi > Streaming File Source cannot be canceled > ---

[jira] [Commented] (FLINK-1823) Rename linq.md to something like table.md to avoid potential trademark issue

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

[jira] [Updated] (FLINK-1793) Streaming File Source cannot be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1793: Summary: Streaming File Source cannot be canceled (was: Streaming jobs can't be canceled) > Stream

[jira] [Updated] (FLINK-1793) Streaming jobs can't be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1793: Priority: Critical (was: Major) > Streaming jobs can't be canceled > --

[GitHub] flink pull request: [FLINK-1823] Remove linq from Table API docume...

Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/580#issuecomment-90941421 Looks like there is accidental file included in this PR: flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/Table.scala --- If your project is set u

[jira] [Commented] (FLINK-1793) Streaming jobs can't be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485339#comment-14485339 ] Stephan Ewen commented on FLINK-1793: - Okay, this looks like the source is actually no

[jira] [Reopened] (FLINK-1793) Streaming jobs can't be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reopened FLINK-1793: - Okay, this looks like the source is actually not canceled, but just waits for the input to be finishe

[jira] [Commented] (FLINK-1793) Streaming jobs can't be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485320#comment-14485320 ] Maximilian Michels commented on FLINK-1793: --- Here's an example of a cancellation

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/579#issuecomment-90936379 Hi Faye, I made some annotations. Ping me when you've addressed them. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485309#comment-14485309 ] Fabian Hueske commented on FLINK-1848: -- That gives {{file:/c:/my/dir}}. If I use that

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27975475 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocess/Standardizer.scala --- @@ -0,0 +1,101 @@ +/* + * Licensed to the A

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27975352 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocess/Standardizer.scala --- @@ -0,0 +1,101 @@ +/* + * Licensed to the A

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27974957 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocess/Standardizer.scala --- @@ -0,0 +1,101 @@ +/* + * Licensed to the A

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27974938 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocess/Standardizer.scala --- @@ -0,0 +1,101 @@ +/* + * Licensed to the A

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27974882 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocess/Standardizer.scala --- @@ -0,0 +1,101 @@ +/* + * Licensed to the A

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27974561 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocess/Standardizer.scala --- @@ -0,0 +1,101 @@ +/* + * Licensed to the A

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973978 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27974019 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973958 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973935 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973910 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973879 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973815 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[jira] [Closed] (FLINK-1793) Streaming jobs can't be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-1793. - Resolution: Not A Problem My bad, they are cancelled eventually. It can take up to several

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973786 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973695 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973680 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973639 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973555 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973465 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485278#comment-14485278 ] Stephan Ewen commented on FLINK-1848: - Agree... What is the result of {{new File("c:\

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485260#comment-14485260 ] Fabian Hueske commented on FLINK-1848: -- Yes, thought so as well and tried that actual

[jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies

[ https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485261#comment-14485261 ] Flavio Pompermaier commented on FLINK-1827: --- I know that the problem is in flink

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485252#comment-14485252 ] Stephan Ewen commented on FLINK-1848: - I think that is legit. If java.net.URI rejects

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

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

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-90921879 The timeout measures how long java or python are stuck in a blocking udp operation. this generally means how long it takes for the python side to compute one chunk of data.

[jira] [Created] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

Fabian Hueske created FLINK-1848: Summary: Paths containing a Windows drive letter cannot be used in FileOutputFormats Key: FLINK-1848 URL: https://issues.apache.org/jira/browse/FLINK-1848 Project: Fl

[jira] [Commented] (FLINK-1847) Change Scala collect() method to return a Seq

[ https://issues.apache.org/jira/browse/FLINK-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485228#comment-14485228 ] Stephan Ewen commented on FLINK-1847: - I am actually seeing a common Scala pitfall her

[jira] [Commented] (FLINK-1847) Change Scala collect() method to return a Seq

[ https://issues.apache.org/jira/browse/FLINK-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485225#comment-14485225 ] Stephan Ewen commented on FLINK-1847: - Same holds for {{count()}}. Both changes are A

[jira] [Commented] (FLINK-1813) Barrier broadcast sometimes causes illegal state exception in source RecordWriter

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

[GitHub] flink pull request: [FLINK-1813] Avoid illegalstate exception when...

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

[jira] [Commented] (FLINK-1847) Change Scala collect() method to return a Seq

[ https://issues.apache.org/jira/browse/FLINK-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485217#comment-14485217 ] Stephan Ewen commented on FLINK-1847: - Also, {{collect}} should have parenthesis. It i

[jira] [Created] (FLINK-1847) Change Scala collect() method to return a Seq

Stephan Ewen created FLINK-1847: --- Summary: Change Scala collect() method to return a Seq Key: FLINK-1847 URL: https://issues.apache.org/jira/browse/FLINK-1847 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-1841) WindowJoinITCase fails

[ https://issues.apache.org/jira/browse/FLINK-1841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1841. - Resolution: Fixed Fix Version/s: 0.9 Fixed via b566884 > WindowJoinITCase fails >

[jira] [Commented] (FLINK-1823) Rename linq.md to something like table.md to avoid potential trademark issue

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

[GitHub] flink pull request: [FLINK-1823] Remove linq from Table API docume...

GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/580 [FLINK-1823] Remove linq from Table API documentation You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink fix-table-doc Alternativel

[jira] [Commented] (FLINK-1846) Sinks inside of iterations

[ https://issues.apache.org/jira/browse/FLINK-1846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485198#comment-14485198 ] Markus Holzemer commented on FLINK-1846: I used my reworking of the iteration hand

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

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

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-90903241 What does the timeout measure? The time while no data was coming? Can the protocol send heartbeats if no data is available? Would it be simpler to switch to TC

[jira] [Created] (FLINK-1846) Sinks inside of iterations

Markus Holzemer created FLINK-1846: -- Summary: Sinks inside of iterations Key: FLINK-1846 URL: https://issues.apache.org/jira/browse/FLINK-1846 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [FLINK-1800][docs] Add beta badge to component...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/555#issuecomment-90901571 +1 for Ufuk's suggestion I would remove "Beta" from Spargel, it is actually very stable. Question is whether it stays or gets subsumed by Gelly --- If your p

[jira] [Created] (FLINK-1845) NonReusingSortMergeCoGroupIterator uses ReusingKeyGroupedIterator

Stephan Ewen created FLINK-1845: --- Summary: NonReusingSortMergeCoGroupIterator uses ReusingKeyGroupedIterator Key: FLINK-1845 URL: https://issues.apache.org/jira/browse/FLINK-1845 Project: Flink

[jira] [Commented] (FLINK-1800) Add a "Beta" badge in the documentation to components in flink-staging

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

[GitHub] flink pull request: [docs] Add custom search (backport)

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/564#issuecomment-90900980 Very good, +1 --- 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 featur

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

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

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-90900778 Yeah, and several minutes doesn't cut it, as we've seen. On a WordCount example on not very large data a 5 minute timeout was not enough. --- If your project is set up f

[jira] [Commented] (FLINK-1812) TaskManager shell scripts restart JVMs on process failures

[ https://issues.apache.org/jira/browse/FLINK-1812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485167#comment-14485167 ] Stephan Ewen commented on FLINK-1812: - Exactly. The wrapping shell script would restar

[jira] [Commented] (FLINK-1818) Provide API to cancel running job

[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485166#comment-14485166 ] Stephan Ewen commented on FLINK-1818: - Given that this follows the code in the CliFron

[jira] [Updated] (FLINK-1818) Provide API to cancel running job

[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1818: Labels: starter (was: ) > Provide API to cancel running job > - > >

[jira] [Commented] (FLINK-1819) Allow access to RuntimeContext from Input and OutputFormats

[ https://issues.apache.org/jira/browse/FLINK-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485163#comment-14485163 ] Stephan Ewen commented on FLINK-1819: - I agree, that would be a very good addition. S

[jira] [Commented] (FLINK-1818) Provide API to cancel running job

[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485164#comment-14485164 ] Stephan Ewen commented on FLINK-1818: - This is basically a simple addition to the {{Cl

[jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies

[ https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485153#comment-14485153 ] Stephan Ewen commented on FLINK-1827: - I agree, that would be a good fix. Is that pro

[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-tabpanel&focusedCommentId=14485131#comment-14485131 ] Stephan Ewen commented on FLINK-1319: - In principle this is good, but I would put it i

[GitHub] flink pull request: [FLINK-1694] [gelly] added IterationConfigurat...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/547#issuecomment-90883704 I like the change as well! Good to go! --- 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

[jira] [Commented] (FLINK-1694) Change the split between create/run of a vertex-centric iteration

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

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

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

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-90883545 Yeah, it happens frequently that the Java side dies without calling `close()`, for example when the TaskManager encounters an unrecoverable error and terminates.

[GitHub] flink pull request: [FLINK-1813] Avoid illegalstate exception when...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/577#issuecomment-90882862 Looks good to me --- 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 fea

[jira] [Commented] (FLINK-1843) Job History gets cleared too fast

[ https://issues.apache.org/jira/browse/FLINK-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485084#comment-14485084 ] Stephan Ewen commented on FLINK-1843: - Keeping the Execution graph on the JobManager i

[jira] [Commented] (FLINK-1813) Barrier broadcast sometimes causes illegal state exception in source RecordWriter

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

[jira] [Created] (FLINK-1844) Add Normaliser to ML library

Faye Beligianni created FLINK-1844: -- Summary: Add Normaliser to ML library Key: FLINK-1844 URL: https://issues.apache.org/jira/browse/FLINK-1844 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1809) Add standard scaler to ML library

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

[GitHub] flink pull request: Ml branch

GitHub user fobeligi opened a pull request: https://github.com/apache/flink/pull/579 Ml branch Implementation of StandardScaler and respective tests for FLINK-1809 JIRA. You can merge this pull request into a Git repository by running: $ git pull https://github.com/fobeligi/in

[jira] [Commented] (FLINK-703) Use complete element as join key.

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

[jira] [Commented] (FLINK-951) Reworking of Iteration Synchronization, Accumulators and Aggregators

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

[GitHub] flink pull request: [FLINK-951] Reworking of Iteration Synchroniza...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/570#issuecomment-90865992 Have the latest commits fixed it? :) --- 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 h

[GitHub] flink pull request: [FLINK-703] Use complete element as join key

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/572#issuecomment-90865966 Thanks @chiwanpark for the PR! Using an IdentityKeySelector is not the best solution in this case. A KeySelector transparently converts a `DataSet` into a `DataSe

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

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

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-90865196 i guess it's nice to have in case the java side dies *somehow* without calling close() on the java function. --- If your project is set up for it, you can reply to this em

[jira] [Commented] (FLINK-703) Use complete element as join key.

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

[GitHub] flink pull request: [FLINK-703] Use complete element as join key

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/572#issuecomment-90863864 Looks good @chiwanpark. Could you add some documentation besides the java doc? For example, here: http://ci.apache.org/projects/flink/flink-docs-master/programming_guide.html#

  1   2   >