[jira] [Commented] (FLINK-2115) TableAPI throws ExpressionException for "Dangling GroupBy operation"

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

[GitHub] flink pull request: [FLINK-2115] [Table API] support no aggregatio...

Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1377#issuecomment-157932844 @aljoscha , it's a very interesting topic, should we add a limitation that only allow key fields to be no aggregated function field in `select` clause? Oracle ha

[jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD

[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15012510#comment-15012510 ] Trevor Grant commented on FLINK-1994: - A little git necromancy here. This issue is do

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-157901595 Stop in WebUI is now working. After rebase, I realized that cancel was changed to GET for yarn. Do we need to implement stop the same way for yarn @mxm ? --- If your proj

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

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

[GitHub] flink pull request: [FLINK-2429] [streaming] Deprecate the "enable...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1382 [FLINK-2429] [streaming] Deprecate the "enableCheckpointing()" method with no interval argument. The default checkpoint interval is a bit intransparent. Dropping that method makes the user thin

[jira] [Commented] (FLINK-2429) Remove the "enableCheckpointing()" without interval variant

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

[jira] [Created] (FLINK-3044) In YARN mode, configure FsStateBackend by default.

Stephan Ewen created FLINK-3044: --- Summary: In YARN mode, configure FsStateBackend by default. Key: FLINK-3044 URL: https://issues.apache.org/jira/browse/FLINK-3044 Project: Flink Issue Type: Im

[jira] [Commented] (FLINK-3006) TypeExtractor fails on custom type

[ https://issues.apache.org/jira/browse/FLINK-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15012180#comment-15012180 ] Gyula Fora commented on FLINK-3006: --- Weird, I am having a hard time reproducing it as we

[GitHub] flink pull request: FLINK-3005 Commons-collections object deserial...

GitHub user tedyu opened a pull request: https://github.com/apache/flink/pull/1381 FLINK-3005 Commons-collections object deserialization remote command … …execution vulnerability You can merge this pull request into a Git repository by running: $ git pull https://github.com

[jira] [Commented] (FLINK-3005) Commons-collections object deserialization remote command execution vulnerability

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

[jira] [Commented] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15011917#comment-15011917 ] Chesnay Schepler commented on FLINK-2692: - Implemented in bd61f2dbdf1a0215363ffa84

[jira] [Closed] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2692. --- Resolution: Fixed > Untangle CsvInputFormat into PojoTypeCsvInputFormat and > TupleTypeCsvInp

[GitHub] flink pull request: [FLINK-2692] Untangle CsvInputFormat

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1266 --- 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] [Commented] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat

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

[jira] [Commented] (FLINK-3002) Add an EitherType to the Java API

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

[GitHub] flink pull request: [FLINK-3002] Add Either type to the Java API

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1371#discussion_r45251503 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/Either.java --- @@ -0,0 +1,147 @@ +/* + * Licensed to the Apache Software F

[GitHub] flink pull request: [FLINK-3002] Add Either type to the Java API

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1371#discussion_r45251332 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/Either.java --- @@ -0,0 +1,147 @@ +/* + * Licensed to the Apache Software F

[jira] [Commented] (FLINK-3002) Add an EitherType to the Java API

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

[jira] [Commented] (FLINK-3002) Add an EitherType to the Java API

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

[GitHub] flink pull request: [FLINK-3002] Add Either type to the Java API

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1371#discussion_r45250671 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/EitherSerializer.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to the Apac

[GitHub] flink pull request: [FLINK-3002] Add Either type to the Java API

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1371#discussion_r45250469 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/Either.java --- @@ -0,0 +1,147 @@ +/* + * Licensed to the Apache Software Foundat

[jira] [Commented] (FLINK-3002) Add an EitherType to the Java API

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

[jira] [Commented] (FLINK-3002) Add an EitherType to the Java API

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

[GitHub] flink pull request: [FLINK-3002] Add Either type to the Java API

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1371#issuecomment-157839083 Concerning the docs, we have often talked about "special types", which would also include Scala's Option, Either, and Try. Would be great to add that section. ---

[GitHub] flink pull request: [FLINK-3002] Add Either type to the Java API

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1371#issuecomment-157838535 Some small comments, otherwise +1 to merge. Integration into the TypeExctractor can be a separate issue, in my opinion. --- If your project is set up for it

[jira] [Commented] (FLINK-3002) Add an EitherType to the Java API

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

[jira] [Commented] (FLINK-3002) Add an EitherType to the Java API

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

[GitHub] flink pull request: [FLINK-3002] Add Either type to the Java API

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1371#discussion_r45249202 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/Either.java --- @@ -0,0 +1,147 @@ +/* + * Licensed to the Apache Software F

[GitHub] flink pull request: [FLINK-3002] Add Either type to the Java API

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1371#discussion_r45248963 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/EitherSerializer.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to th

[jira] [Commented] (FLINK-3002) Add an EitherType to the Java API

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

[GitHub] flink pull request: [FLINK-3002] Add Either type to the Java API

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1371#discussion_r45248629 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/Either.java --- @@ -0,0 +1,147 @@ +/* + * Licensed to the Apache Software F

[jira] [Commented] (FLINK-3002) Add an EitherType to the Java API

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

[jira] [Commented] (FLINK-3002) Add an EitherType to the Java API

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

[GitHub] flink pull request: [FLINK-3002] Add Either type to the Java API

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1371#discussion_r45248610 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/Either.java --- @@ -0,0 +1,147 @@ +/* + * Licensed to the Apache Software F

[jira] [Commented] (FLINK-3043) Kafka Connector description in Streaming API guide is wrong/outdated

[ https://issues.apache.org/jira/browse/FLINK-3043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15011772#comment-15011772 ] Robert Metzger commented on FLINK-3043: --- I'm addressing some of the issues here: ht

[jira] [Commented] (FLINK-3043) Kafka Connector description in Streaming API guide is wrong/outdated

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

[GitHub] flink pull request: [FLINK-3043] [docs] Fix description of Kafka C...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1380 [FLINK-3043] [docs] Fix description of Kafka Consumer and Producer. This also adds to the deprecated classes pointers forward to the designated classes. You can merge this pull request into a G

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

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

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-157834943 How could I miss this...?? Sorry. My own fault... --- 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] [Created] (FLINK-3043) Kafka Connector description in Streaming API guide is wrong/outdated

Stephan Ewen created FLINK-3043: --- Summary: Kafka Connector description in Streaming API guide is wrong/outdated Key: FLINK-3043 URL: https://issues.apache.org/jira/browse/FLINK-3043 Project: Flink

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

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

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-157833952 There is a readme: https://github.com/apache/flink/tree/master/flink-runtime-web --- If your project is set up for it, you can reply to this email and have your reply a

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

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

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-157832022 Thanks. Great. It works now. I was not aware the I have to build the UI manually. Would it be possible to integrate it into maven build? At least we should provide a README

[jira] [Commented] (FLINK-2978) Integrate web submission interface into the new dashboard

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

[GitHub] flink pull request: [FLINK-2978][web-dashboard][webclient] Integra...

Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1338#discussion_r45245432 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/HttpRequestHandler.java --- @@ -0,0 +1,131 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext

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

[GitHub] flink pull request: [FLINK-2488][FLINK-2496] Expose Task Manager c...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1026#issuecomment-157826454 Agreed. I also would like to cleanup the several getter functions for these fields. We can just add a `getTaskInfo` in the `TDD`, `Task` and `Environment`. Th

[GitHub] flink pull request: [FLINK-2978][web-dashboard][webclient] Integra...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1338#discussion_r45244344 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/HttpRequestHandler.java --- @@ -0,0 +1,131 @@ +/* + * Licensed to t

[jira] [Commented] (FLINK-2978) Integrate web submission interface into the new dashboard

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

[GitHub] flink pull request: [FLINK-2488][FLINK-2496] Expose Task Manager c...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1026#issuecomment-157824468 Yes, a TaskInfo is a good idea. It can be handed also to the `RuntimeEnvironment` (from there to the `RuntimeContext`), and is created once in the Task const

[jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext

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

[jira] [Commented] (FLINK-3006) TypeExtractor fails on custom type

[ https://issues.apache.org/jira/browse/FLINK-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15011682#comment-15011682 ] Timo Walther commented on FLINK-3006: - The bottom "map" is a lambda method. I just use

[jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext

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

[GitHub] flink pull request: [FLINK-2488][FLINK-2496] Expose Task Manager c...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1026#issuecomment-157818292 Yes. That's why I closed it. :') I'm thinking of having a construct named `TaskInfo`, which contains information like name, index, parallel tasks, attempt numb

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-157817216 Hi @mjsax , your change to coffeescript aren't ported to the actual javascript. It appears you forgot to run `gulp`. --- If your project is set up for it, you can

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

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

[jira] [Commented] (FLINK-3006) TypeExtractor fails on custom type

[ https://issues.apache.org/jira/browse/FLINK-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15011630#comment-15011630 ] Gyula Fora commented on FLINK-3006: --- This only occurs when the udf is a java 8 lambda me

[jira] [Commented] (FLINK-2978) Integrate web submission interface into the new dashboard

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

[GitHub] flink pull request: [FLINK-2978][web-dashboard][webclient] Integra...

Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1338#discussion_r45240771 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/HttpRequestHandler.java --- @@ -0,0 +1,131 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-1945) Make python tests less verbose

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

[GitHub] flink pull request: [FLINK-1945][py] Python Tests less verbose

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1376#discussion_r45240517 --- Diff: flink-libraries/flink-python/src/test/python/org/apache/flink/python/api/test_type_deduction.py --- @@ -58,5 +58,5 @@ msg.output()

[jira] [Commented] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin

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

[GitHub] flink pull request: [FLINK-2897] [runtime] Use distinct initial in...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1292#issuecomment-157807317 Yes, +1 for merging. Thanks for your contribution @greghogan. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Resolved] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic)

[ https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2942. - Resolution: Fixed Assignee: Piotr Godek Fix Version/s: 0.10.1 Fixed in - 0.10.1

[jira] [Closed] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic)

[ https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2942. --- > Dangling operators in web UI's program visualization (non-deterministic) > -

[jira] [Commented] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic)

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

[GitHub] flink pull request: Fixed FLINK-2942

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1346 --- 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] [Commented] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin

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

[GitHub] flink pull request: [FLINK-2897] [runtime] Use distinct initial in...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1292#issuecomment-157803640 Aside from till's comment (simplification of the "robin()" case), this looks good. --- If your project is set up for it, you can reply to this email and have your r

[GitHub] flink pull request:

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/commit/08318e1a7649b6f78b2c2d4fba7004c547d05961#commitcomment-14478619 BTW: I think the usual style for git commit messages is to write what the commit does, not what the original problem was. So so

[jira] [Resolved] (FLINK-2989) Job Cancel button doesn't work on Yarn

[ https://issues.apache.org/jira/browse/FLINK-2989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2989. --- Resolution: Fixed Fix Version/s: 0.10.1 1.0.0 master: 08318e

[jira] [Created] (FLINK-3042) Define a way to let types create their own TypeInformation

Stephan Ewen created FLINK-3042: --- Summary: Define a way to let types create their own TypeInformation Key: FLINK-3042 URL: https://issues.apache.org/jira/browse/FLINK-3042 Project: Flink Issue

[jira] [Commented] (FLINK-3041) Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal'

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

[GitHub] flink pull request: FLINK-3041: Twitter Streaming Description sect...

GitHub user smarthi opened a pull request: https://github.com/apache/flink/pull/1379 FLINK-3041: Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal' You can merge this pull request into a Git repository by running:

[jira] [Created] (FLINK-3041) Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal'

Suneel Marthi created FLINK-3041: Summary: Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal' Key: FLINK-3041 URL: https://issues.apache.org/jira/bro

[GitHub] flink pull request: [FLINK-2989] job cancel button doesn't work on...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1344 --- 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] [Commented] (FLINK-2989) Job Cancel button doesn't work on Yarn

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

[jira] [Created] (FLINK-3040) Add docs describing how to configure State Backends

Stephan Ewen created FLINK-3040: --- Summary: Add docs describing how to configure State Backends Key: FLINK-3040 URL: https://issues.apache.org/jira/browse/FLINK-3040 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin

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

[GitHub] flink pull request: [FLINK-2897] [runtime] Use distinct initial in...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1292#discussion_r45231684 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/shipping/OutputEmitter.java --- @@ -143,16 +148,24 @@ public OutputEmitter(Ship

[jira] [Commented] (FLINK-3002) Add an EitherType to the Java API

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

[GitHub] flink pull request: [FLINK-3002] Add Either type to the Java API

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1371#issuecomment-157784970 Integrating it with the TypeExtractor means that the APIs recognize the type and choose the type info properly. I think @twalthr is probably the best to give

[GitHub] flink pull request: fix pos assignment of instance

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1345#issuecomment-157783778 Thanks for spotting the error @fangmu. I assume that this error never occurred because we rarely start multiple instances on the same host. It is a crucial

[jira] [Commented] (FLINK-1945) Make python tests less verbose

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

[GitHub] flink pull request: [FLINK-1945][py] Python Tests less verbose

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1376#discussion_r45227781 --- Diff: flink-libraries/flink-python/src/test/python/org/apache/flink/python/api/test_type_deduction.py --- @@ -58,5 +58,5 @@ msg.output()

[GitHub] flink pull request: [FLINK-2989] job cancel button doesn't work on...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1344#issuecomment-157775857 LGTM --- 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 enab

[jira] [Commented] (FLINK-2989) Job Cancel button doesn't work on Yarn

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

[jira] [Commented] (FLINK-1945) Make python tests less verbose

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

[GitHub] flink pull request: [FLINK-1945][py] Python Tests less verbose

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1376#issuecomment-157772432 Changes look good. I had only a minor comment. Besides that +1 for merging. --- If your project is set up for it, you can reply to this email and have your reply ap

[GitHub] flink pull request: [FLINK-1945][py] Python Tests less verbose

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1376#discussion_r45224052 --- Diff: flink-libraries/flink-python/src/test/python/org/apache/flink/python/api/test_type_deduction.py --- @@ -58,5 +58,5 @@ msg.outpu

[jira] [Commented] (FLINK-1945) Make python tests less verbose

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

[jira] [Created] (FLINK-3039) Trigger KeyValueState cannot be Scala Int

Fabian Hueske created FLINK-3039: Summary: Trigger KeyValueState cannot be Scala Int Key: FLINK-3039 URL: https://issues.apache.org/jira/browse/FLINK-3039 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-1945) Make python tests less verbose

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

[GitHub] flink pull request: [FLINK-1945][py] Python Tests less verbose

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1376#discussion_r45222496 --- Diff: flink-libraries/flink-python/pom.xml --- @@ -48,6 +48,14 @@ under the License. +

[jira] [Commented] (FLINK-1945) Make python tests less verbose

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

[GitHub] flink pull request: [FLINK-1945][py] Python Tests less verbose

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1376#discussion_r45221988 --- Diff: flink-libraries/flink-python/pom.xml --- @@ -48,6 +48,14 @@ under the License. +

[jira] [Commented] (FLINK-1945) Make python tests less verbose

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

[GitHub] flink pull request: [FLINK-3002] Add Either type to the Java API

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1371#issuecomment-157767153 Thanks a lot for the review. I've updated the PR. @gyfora @StephanEwen what do you mean by adding this to the type extractor? What do I need to do? Also, any commen

  1   2   3   >