[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15627353#comment-15627353 ] ASF GitHub Bot commented on FLINK-4743: --- Github user wuchong commented on a diff in the pull

[GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th...

2016-11-01 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2686#discussion_r86061549 --- Diff: flink-libraries/flink-table/src/main/java/org/apache/flink/api/table/functions/utils/MathFunctions.java --- @@ -0,0 +1,29 @@ +/* + *

[jira] [Commented] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-01 Thread Jamie Grier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626962#comment-15626962 ] Jamie Grier commented on FLINK-3659: I would like to suggest that rather than adding a new API method,

[GitHub] flink issue #2734: Keytab & TLS support for Flink on Mesos Setup

2016-11-01 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2734 @mxm - Could you please take a look? --- 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-4990) Remove JAR option from savepoint disposal

2016-11-01 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4990: -- Summary: Remove JAR option from savepoint disposal Key: FLINK-4990 URL: https://issues.apache.org/jira/browse/FLINK-4990 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4977) Enum serialization does not work in all cases

2016-11-01 Thread Sean Winard (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626568#comment-15626568 ] Sean Winard commented on FLINK-4977: Would love to! Unfortunately, I'm not approved yet by my employer

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

2016-11-01 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626549#comment-15626549 ] Fabian Hueske commented on FLINK-4832: -- Currently, a {{DataSetAggregate}} is translated into a

[jira] [Updated] (FLINK-4944) Replace Akka's death watch with own heartbeat on the TM side

2016-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4944: - Summary: Replace Akka's death watch with own heartbeat on the TM side (was: Replace Akka's

[jira] [Commented] (FLINK-4447) Include NettyConfig options on Configurations page

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626538#comment-15626538 ] ASF GitHub Bot commented on FLINK-4447: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-4447) Include NettyConfig options on Configurations page

2016-11-01 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4447. - Resolution: Implemented Implemented in 4955441fd0a222f75ad604cf19a568f4a89e44c1 > Include NettyConfig

[GitHub] flink pull request #2465: [FLINK-4447] [docs] Include NettyConfig options on...

2016-11-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2465 --- 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 issue #2723: [FLINK-3617] Simple fix for OptionSerializer.

2016-11-01 Thread chermenin
Github user chermenin commented on the issue: https://github.com/apache/flink/pull/2723 I see. I will change this code in the near future. --- 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-3617) NPE from CaseClassSerializer when dealing with null Option field

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626495#comment-15626495 ] ASF GitHub Bot commented on FLINK-3617: --- Github user chermenin commented on the issue:

[GitHub] flink issue #2723: [FLINK-3617] Simple fix for OptionSerializer.

2016-11-01 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2723 Yes, deepEquals() is a nice way to do this (and could be added to the tests). Still, no pull requests should ever change (especially weaken) any unrelated tests. We need to enforce that

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626474#comment-15626474 ] ASF GitHub Bot commented on FLINK-3617: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2723: [FLINK-3617] Simple fix for OptionSerializer.

2016-11-01 Thread chermenin
Github user chermenin commented on the issue: https://github.com/apache/flink/pull/2723 @StephanEwen I think `deepEquals` method must be used for this and not `toString`. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626449#comment-15626449 ] ASF GitHub Bot commented on FLINK-3617: --- Github user chermenin commented on the issue:

[jira] [Commented] (FLINK-4977) Enum serialization does not work in all cases

2016-11-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626443#comment-15626443 ] Stephan Ewen commented on FLINK-4977: - Nice, thanks for diagnosing this. Would be great if you could

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

2016-11-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626399#comment-15626399 ] Stephan Ewen commented on FLINK-3617: - I think the problem is in the {{CaseClassSerializer}}, not in

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626376#comment-15626376 ] ASF GitHub Bot commented on FLINK-3617: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2723: [FLINK-3617] Simple fix for OptionSerializer.

2016-11-01 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2723 -1 to merging this, for the reason that this removes alters unrelated tests by removing lines. I think that calling `toString()` was introduced as a way to test if the copies made by

[jira] [Closed] (FLINK-4884) Eagerly Store MergingWindowSet in State in WindowOperator

2016-11-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4884. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented in

[GitHub] flink pull request #2685: [FLINK-4884] Eagerly Store MergingWindowSet in Sta...

2016-11-01 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/2685 --- 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 issue #2664: [FLINK-4861] [build] Package optional project artifacts

2016-11-01 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2664 @StephanEwen the latest commit uses a separate module to prevent the optional packages and dependencies from being included in the `flink-dist` uber jar. `flink-dist-opt` assembles the

[jira] [Commented] (FLINK-4861) Package optional project artifacts

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625939#comment-15625939 ] ASF GitHub Bot commented on FLINK-4861: --- Github user greghogan commented on the issue:

[jira] [Commented] (FLINK-4983) Web UI: Add favicon

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625891#comment-15625891 ] ASF GitHub Bot commented on FLINK-4983: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2737: [FLINK-4983] Web UI: Add favicon

2016-11-01 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2737 Could we enhance the favicon itself? I tried `http://realfavicongenerator.net/` and there are many other 'favicon generators'. I used this image:

[jira] [Updated] (FLINK-4977) Enum serialization does not work in all cases

2016-11-01 Thread Sean Winard (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Winard updated FLINK-4977: --- Summary: Enum serialization does not work in all cases (was: Enum serialization does not work

[jira] [Commented] (FLINK-4977) Enum serialization does not work properly

2016-11-01 Thread Sean Winard (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625810#comment-15625810 ] Sean Winard commented on FLINK-4977: It looks like changing the access modifier of the enum can make

[jira] [Updated] (FLINK-4369) EvictingWindowOperator Must Actually Evict Elements

2016-11-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4369: Assignee: vishnu viswanath (was: Aljoscha Krettek) > EvictingWindowOperator Must Actually

[jira] [Commented] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625748#comment-15625748 ] Aljoscha Krettek commented on FLINK-3659: - [~gyfora] Yes, access to keyed state would throw an

[jira] [Commented] (FLINK-4983) Web UI: Add favicon

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625663#comment-15625663 ] ASF GitHub Bot commented on FLINK-4983: --- Github user siliconcat commented on the issue:

[GitHub] flink issue #2737: [FLINK-4983] Web UI: Add favicon

2016-11-01 Thread siliconcat
Github user siliconcat commented on the issue: https://github.com/apache/flink/pull/2737 Now, the index file with the modification is there. Sorry for that. --- 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-4983) Web UI: Add favicon

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625659#comment-15625659 ] ASF GitHub Bot commented on FLINK-4983: --- Github user siliconcat commented on the issue:

[GitHub] flink issue #2737: [FLINK-4983] Web UI: Add favicon

2016-11-01 Thread siliconcat
Github user siliconcat commented on the issue: https://github.com/apache/flink/pull/2737 It does, let me see why the file does not apear in the PR --- 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] [Commented] (FLINK-4983) Web UI: Add favicon

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625647#comment-15625647 ] ASF GitHub Bot commented on FLINK-4983: --- Github user Makman2 commented on the issue:

[GitHub] flink issue #2737: [FLINK-4983] Web UI: Add favicon

2016-11-01 Thread Makman2
Github user Makman2 commented on the issue: https://github.com/apache/flink/pull/2737 Not a web-dev, though doesn't need this some modifications in the according HTMLs to properly perenst the favicon? --- If your project is set up for it, you can reply to this email and have your

[jira] [Created] (FLINK-4989) Completed job -> Properties: Misleading label

2016-11-01 Thread JIRA
Mischa Krüger created FLINK-4989: Summary: Completed job -> Properties: Misleading label Key: FLINK-4989 URL: https://issues.apache.org/jira/browse/FLINK-4989 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4982) quickstart example: Can't see the output

2016-11-01 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625611#comment-15625611 ] Mischa Krüger commented on FLINK-4982: -- I only have a single task manager, and its stdout is empty.

[jira] [Commented] (FLINK-4983) Web UI: Add favicon

2016-11-01 Thread Bruno Aranda (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625566#comment-15625566 ] Bruno Aranda commented on FLINK-4983: - Hi, I have created a PR for this:

[jira] [Commented] (FLINK-4983) Web UI: Add favicon

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625563#comment-15625563 ] ASF GitHub Bot commented on FLINK-4983: --- GitHub user siliconcat opened a pull request:

[GitHub] flink pull request #2737: [FLINK-4983] Web UI: Add favicon

2016-11-01 Thread siliconcat
GitHub user siliconcat opened a pull request: https://github.com/apache/flink/pull/2737 [FLINK-4983] Web UI: Add favicon Adds favicon.ico to the Flink dashboard. Uses same icon than main site You can merge this pull request into a Git repository by running: $ git pull

[jira] [Closed] (FLINK-4889) Make InstanceManager independent of ActorRef

2016-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4889. Resolution: Fixed Fixed via

[jira] [Updated] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3659: Description: We should add a new operation that has a main input that can be keyed (but

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

2016-11-01 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625448#comment-15625448 ] Anton Mushin commented on FLINK-4832: - Hi everyone. I want to implement this issue and I have some

[jira] [Updated] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3659: Description: We should add a new operation that has a main input that can be keyed (but

[jira] [Updated] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3659: Description: We should add a new operation that has a main input that can be keyed (but

[jira] [Commented] (FLINK-4933) ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625387#comment-15625387 ] ASF GitHub Bot commented on FLINK-4933: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-4932) Don't let ExecutionGraph fail when in state Restarting

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625390#comment-15625390 ] ASF GitHub Bot commented on FLINK-4932: --- Github user tillrohrmann closed the pull request at:

[jira] [Commented] (FLINK-4932) Don't let ExecutionGraph fail when in state Restarting

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625389#comment-15625389 ] ASF GitHub Bot commented on FLINK-4932: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-4933) ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625388#comment-15625388 ] ASF GitHub Bot commented on FLINK-4933: --- Github user tillrohrmann closed the pull request at:

[GitHub] flink issue #2701: [backport] [FLINK-4933] [exec graph] Don't let the EG fai...

2016-11-01 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2701 Has been merged to the release branch 1.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

[GitHub] flink pull request #2711: [backport] [FLINK-4932] [exec graph] Failing in st...

2016-11-01 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2711 --- 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

[GitHub] flink issue #2711: [backport] [FLINK-4932] [exec graph] Failing in state RES...

2016-11-01 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2711 Closing this because it has been merged into the release 1.1 branch. --- 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 #2701: [backport] [FLINK-4933] [exec graph] Don't let the...

2016-11-01 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2701 --- 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

[jira] [Comment Edited] (FLINK-3551) Sync Scala and Java Streaming Examples

2016-11-01 Thread Lim Chee Hau (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15619447#comment-15619447 ] Lim Chee Hau edited comment on FLINK-3551 at 11/1/16 12:21 PM: --- Hi, I'm

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625226#comment-15625226 ] ASF GitHub Bot commented on FLINK-4743: --- Github user wuchong commented on the issue:

[GitHub] flink issue #2686: [FLINK-4743] The sqrt/power function not accept the real ...

2016-11-01 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2686 @tonycox Yes, the second option support BigDecimal only in SQL. I think we could put the new `power` function in `BuiltInMethods`. Or create a util class in

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625157#comment-15625157 ] ASF GitHub Bot commented on FLINK-4743: --- Github user tonycox commented on the issue:

[jira] [Commented] (FLINK-4272) Create a JobClient for job control and monitoring

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625151#comment-15625151 ] ASF GitHub Bot commented on FLINK-4272: --- Github user mxm commented on the issue:

[GitHub] flink issue #2732: [FLINK-4272] Create a JobClient for job control and monit...

2016-11-01 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2732 CC @rmetzger @aljoscha Could you take a look at the changes? --- 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

[GitHub] flink issue #2732: [FLINK-4272] Create a JobClient for job control and monit...

2016-11-01 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2732 Rebased to the latest changes on the master. --- 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] [Commented] (FLINK-4272) Create a JobClient for job control and monitoring

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625144#comment-15625144 ] ASF GitHub Bot commented on FLINK-4272: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-01 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625089#comment-15625089 ] Gyula Fora commented on FLINK-3659: --- (I have a workshop after lunch so might be slow to responds :() >

[jira] [Commented] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-01 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625086#comment-15625086 ] Gyula Fora commented on FLINK-3659: --- Hi, Would this work in a way as connected streams work now but

[jira] [Commented] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15625003#comment-15625003 ] Aljoscha Krettek commented on FLINK-3659: - [~gyfora] I updated the issue, what do you think about

[jira] [Updated] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3659: Description: We should add a new operation that has a main input that can be keyed (but

[jira] [Updated] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3659: Description: We should add a new operation that has a main input that can be keyed (but

[jira] [Updated] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3659: Description: We should add a new operation that has a main input that can be keyed (but

[jira] [Updated] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3659: Summary: Add ConnectWithBroadcast Operation (was: Allow One Input of ConnectedStream to be

[jira] [Updated] (FLINK-4940) Add Support for Broadcast/Global State

2016-11-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4940: Assignee: Stefan Richter > Add Support for Broadcast/Global State >

[jira] [Closed] (FLINK-4958) Send slot report to RM when registering

2016-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4958. Resolution: Fixed Fixed via 360268c0b894234b37744579303e9fa1d989e830 > Send slot report to RM when

[GitHub] flink issue #2721: [FLINK-4958] [tm] Send slot report to RM when registering

2016-11-01 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2721 Merged with flip-6 branch. --- 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

[jira] [Commented] (FLINK-4958) Send slot report to RM when registering

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15624806#comment-15624806 ] ASF GitHub Bot commented on FLINK-4958: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-4958) Send slot report to RM when registering

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15624805#comment-15624805 ] ASF GitHub Bot commented on FLINK-4958: --- Github user tillrohrmann closed the pull request at:

[GitHub] flink pull request #2721: [FLINK-4958] [tm] Send slot report to RM when regi...

2016-11-01 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2721 --- 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

[jira] [Resolved] (FLINK-4986) Harden JobMaster logic

2016-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4986. -- Resolution: Fixed Fixed via e28711394de0cbba5ae840ff8b7cb4854a382d79 > Harden JobMaster logic

[jira] [Resolved] (FLINK-4987) Harden slot pool logic

2016-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4987. -- Resolution: Fixed Fixed via 8b2731a03681b9b74f5a640b3be14d53d22328cf > Harden slot pool logic

[jira] [Commented] (FLINK-4887) Replace ActorGateway by TaskManagerGateway interface

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15624791#comment-15624791 ] ASF GitHub Bot commented on FLINK-4887: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-4887) Replace ActorGateway by TaskManagerGateway interface

2016-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4887. Resolution: Fixed Fixed via cfb3790fb6feb6c771bccbd05d3b12c69f53657d > Replace ActorGateway by

[GitHub] flink pull request #2699: [FLINK-4887] [execution graph] Introduce TaskManag...

2016-11-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2699 --- 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 issue #2699: [FLINK-4887] [execution graph] Introduce TaskManagerGatew...

2016-11-01 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2699 Thanks for the review @zentol. I've rebased it, tested it and Travis gives green light. Will merge it now. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-4887) Replace ActorGateway by TaskManagerGateway interface

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15624780#comment-15624780 ] ASF GitHub Bot commented on FLINK-4887: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-4193) Task manager JVM crashes while deploying cancelling jobs

2016-11-01 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15624754#comment-15624754 ] Gyula Fora commented on FLINK-4193: --- These issues usually happened inside the RocksDB.open(...) method

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

2016-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15624701#comment-15624701 ] ASF GitHub Bot commented on FLINK-4743: --- Github user tonycox commented on the issue:

[GitHub] flink issue #2686: [FLINK-4743] The sqrt/power function not accept the real ...

2016-11-01 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/2686 I agree with @wuchong that we need create a new issue in JIRA for supporting `BigDecimal` in functions (`log`,`ln`,`exp` etc), but I suppose that if problem in calcite with `DECIMAL` is done we will