[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

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

[GitHub] flink issue #2965: [FLINK-5303] [table] Support for SQL GROUPING SETS clause...

2016-12-08 Thread chermenin
Github user chermenin commented on the issue: https://github.com/apache/flink/pull/2965 PR closed to rename the 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

[GitHub] flink pull request #2965: [FLINK-5303] [table] Support for SQL GROUPING SETS...

2016-12-08 Thread chermenin
Github user chermenin closed the pull request at: https://github.com/apache/flink/pull/2965 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15734598#comment-15734598 ] ASF GitHub Bot commented on FLINK-5303: --- GitHub user chermenin opened a pull request:

[GitHub] flink pull request #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS...

2016-12-08 Thread chermenin
GitHub user chermenin opened a pull request: https://github.com/apache/flink/pull/2976 [FLINK-5303] [table] Support for SQL GROUPING SETS clause. Support for operators GROUPING SETS / ROLLUP / CUBE was added in this PR. Also added some tests for check execution of SQL queries

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

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

[jira] [Commented] (FLINK-5220) Flink SQL projection pushdown

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

[GitHub] flink issue #2923: [FLINK-5220] [Table API & SQL] Flink SQL projection pushd...

2016-12-08 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/2923 Hi @fhueske, this PR 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 feature

[jira] [Created] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2016-12-08 Thread Alexander Chermenin (JIRA)
Alexander Chermenin created FLINK-5303: -- Summary: Add CUBE/ROLLUP/GROUPING SETS operator in SQL Key: FLINK-5303 URL: https://issues.apache.org/jira/browse/FLINK-5303 Project: Flink

[jira] [Assigned] (FLINK-5188) Adjust all the imports referencing Row

2016-12-08 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5188: Assignee: Anton Solovev > Adjust all the imports referencing Row >

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-12-08 Thread Philipp von dem Bussche (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15734537#comment-15734537 ] Philipp von dem Bussche commented on FLINK-2821: Thanks [~mxm] this is working for me now.

[jira] [Commented] (FLINK-5299) DataStream support for arrays as keys

2016-12-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15734216#comment-15734216 ] Aljoscha Krettek commented on FLINK-5299: - A {{KeySelector}} that calls

[jira] [Commented] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15734203#comment-15734203 ] ASF GitHub Bot commented on FLINK-5266: --- Github user KurtYoung commented on the issue:

[GitHub] flink issue #2961: [FLINK-5266] [table] eagerly project unused fields when s...

2016-12-08 Thread KurtYoung
Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/2961 rebased to latest 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 enabled and

[jira] [Commented] (FLINK-5187) Create analog of Row in core

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

[GitHub] flink issue #2968: [FLINK-5187] [core] Create analog of Row and RowTypeInfo ...

2016-12-08 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2968 Hi @tonycox , thanks for your reviewing. I addressed some of your comments. --- 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

[jira] [Commented] (FLINK-5187) Create analog of Row in core

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

[jira] [Commented] (FLINK-5187) Create analog of Row in core

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

[GitHub] flink pull request #2968: [FLINK-5187] [core] Create analog of Row and RowTy...

2016-12-08 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2968#discussion_r91652189 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowComparator.java --- @@ -0,0 +1,698 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-5187) Create analog of Row in core

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

[GitHub] flink pull request #2968: [FLINK-5187] [core] Create analog of Row and RowTy...

2016-12-08 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2968#discussion_r91652223 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowComparator.java --- @@ -0,0 +1,698 @@ +/* + * Licensed to the

[GitHub] flink pull request #2968: [FLINK-5187] [core] Create analog of Row and RowTy...

2016-12-08 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2968#discussion_r91652178 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java --- @@ -0,0 +1,176 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #2961: [FLINK-5266] [table] eagerly project unused fields...

2016-12-08 Thread KurtYoung
Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/2961#discussion_r91641034 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala --- @@ -881,24 +883,21 @@ class GroupWindowedTable( *

[jira] [Commented] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields

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

[jira] [Created] (FLINK-5302) Log failure cause at Execution

2016-12-08 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5302: -- Summary: Log failure cause at Execution Key: FLINK-5302 URL: https://issues.apache.org/jira/browse/FLINK-5302 Project: Flink Issue Type: Improvement

[GitHub] flink pull request #2975: [backport] [FLINK-5114] [network] Handle partition...

2016-12-08 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/2975 [backport] [FLINK-5114] [network] Handle partition producer state check for unregistered executions Reverted some changes made in #2913 after a discussion with @StephanEwen and decided to close the

[jira] [Commented] (FLINK-5114) PartitionState update with finished execution fails

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15733668#comment-15733668 ] ASF GitHub Bot commented on FLINK-5114: --- GitHub user uce opened a pull request:

[jira] [Commented] (FLINK-5114) PartitionState update with finished execution fails

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

[jira] [Commented] (FLINK-5114) PartitionState update with finished execution fails

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15733663#comment-15733663 ] ASF GitHub Bot commented on FLINK-5114: --- Github user uce commented on the issue:

[GitHub] flink pull request #2913: [backport] [FLINK-5114] [network] Handle partition...

2016-12-08 Thread uce
Github user uce closed the pull request at: https://github.com/apache/flink/pull/2913 --- 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 #2913: [backport] [FLINK-5114] [network] Handle partition produc...

2016-12-08 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2913 Closing in favour of #2975. --- 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

[GitHub] flink pull request #2972: [FLINK-5211] [metrics] [docs] Include example repo...

2016-12-08 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2972#discussion_r91626592 --- Diff: docs/monitoring/metrics.md --- @@ -335,6 +345,21 @@ Parameters: - `ttl` - time-to-live for transmitted UDP packets - `addressingMode` - UDP

[jira] [Commented] (FLINK-5211) Include an example configuration for all reporters

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15733650#comment-15733650 ] ASF GitHub Bot commented on FLINK-5211: --- Github user uce commented on a diff in the pull request:

[jira] [Commented] (FLINK-5211) Include an example configuration for all reporters

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15733563#comment-15733563 ] ASF GitHub Bot commented on FLINK-5211: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #2972: [FLINK-5211] [metrics] [docs] Include example repo...

2016-12-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2972#discussion_r91620174 --- Diff: docs/monitoring/metrics.md --- @@ -335,6 +345,21 @@ Parameters: - `ttl` - time-to-live for transmitted UDP packets - `addressingMode` - UDP

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15733544#comment-15733544 ] ASF GitHub Bot commented on FLINK-2254: --- Github user mushketyk commented on the issue:

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-12-08 Thread mushketyk
Github user mushketyk commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r91618485 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java --- @@ -480,16 +480,22 @@ protected static

[GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class

2016-12-08 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2564 Hi @greghogan , I've fixed the PR according to your review. --- 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-2254) Add Bipartite Graph Support for Gelly

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

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-12-08 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r91613888 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java --- @@ -480,16 +480,22 @@ protected static

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15733425#comment-15733425 ] ASF GitHub Bot commented on FLINK-2254: --- Github user mushketyk commented on the issue:

[GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class

2016-12-08 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2564 @vasia , @greghogan I've created a new package, moved new classes there and update PR according to your latest comments. Best regards, Ivan. --- If your project is set up for it, you

[jira] [Closed] (FLINK-5039) Avro GenericRecord support is broken

2016-12-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5039. Resolution: Fixed Assignee: Robert Metzger Fixed for 1.1.4 with

[jira] [Updated] (FLINK-5288) Flakey ConnectedComponentsITCase#testConnectedComponentsExample unit test

2016-12-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5288: - Labels: test-stability (was: ) > Flakey ConnectedComponentsITCase#testConnectedComponentsExample

[jira] [Assigned] (FLINK-5280) Extend TableSource to support nested data

2016-12-08 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-5280: - Assignee: Ivan Mushketyk > Extend TableSource to support nested data >

[jira] [Commented] (FLINK-5211) Include an example configuration for all reporters

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15733382#comment-15733382 ] ASF GitHub Bot commented on FLINK-5211: --- Github user uce commented on the issue:

[GitHub] flink issue #2972: [FLINK-5211] [metrics] [docs] Include example reporter co...

2016-12-08 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2972 Very good idea! This will definitely be helpful for users. --- 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] [Resolved] (FLINK-3921) StringParser not specifying encoding to use

2016-12-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-3921. -- Resolution: Implemented Fix Version/s: 1.2.0 Implemented for 1.2.0 with

[jira] [Closed] (FLINK-5226) Eagerly project unused attributes

2016-12-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5226. Resolution: Fixed Fix Version/s: 1.2.0 Fixed for 1.2.0 with

[GitHub] flink pull request #2060: [FLINK-3921] StringParser encoding

2016-12-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2060 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #2926: [FLINK-5226] [table] Use correct DataSetCostFactor...

2016-12-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2926 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-5039) Avro GenericRecord support is broken

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

[jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use

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

[jira] [Commented] (FLINK-5226) Eagerly project unused attributes

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

[jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use

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

[GitHub] flink pull request #2953: [FLINK-5039] Bump Avro version

2016-12-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2953 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #2901: [FLINK-3921] StringParser encoding

2016-12-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2901 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15733296#comment-15733296 ] Fabian Hueske commented on FLINK-5280: -- Sure, you can work on this [~ivan.mushketyk]. I think it

[jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly

2016-12-08 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15733284#comment-15733284 ] Vasia Kalavri commented on FLINK-1536: -- The idea is what [~greghogan] describes. In a distributed

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class

2016-12-08 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2564 Yes, you are right, `bipartite`. --- 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

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15733224#comment-15733224 ] ASF GitHub Bot commented on FLINK-2254: --- Github user vasia commented on the issue:

[GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class

2016-12-08 Thread vasia
Github user vasia commented on the issue: https://github.com/apache/flink/pull/2564 I would go for `org.apache.flink.graph.bipartite`. I think that `bidirectional` simply suggests that each edge exists in both directions. --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class

2016-12-08 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2564 @mushketyk @vasia, thoughts on package naming? Should we create a new `org.apache.flink.bigraph` package? Another option would be `org.apache.flink.graph.bidirectional` which would suggest future

[jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly

2016-12-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15733195#comment-15733195 ] Greg Hogan commented on FLINK-1536: --- As I understand, these can be implemented as a {{GraphAlgorithm}}

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-12-08 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r91585475 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java --- @@ -480,7 +480,8 @@ protected static

[jira] [Commented] (FLINK-5298) TaskManager crashes when TM log not existant

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15733003#comment-15733003 ] ASF GitHub Bot commented on FLINK-5298: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #2974: [FLINK-5298] TM checks that log file exists

2016-12-08 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2974 [FLINK-5298] TM checks that log file exists This PR slightly modifies the `TaskManager#handleRequestTaskManagerLog`. For one it verifies that the log file actually exists before opening it. Second,

[jira] [Commented] (FLINK-5206) Flakey PythonPlanBinderTest

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732997#comment-15732997 ] ASF GitHub Bot commented on FLINK-5206: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #2973: [FLINK-5206] [py] Use random file names in tests

2016-12-08 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2973 [FLINK-5206] [py] Use random file names in tests This PR modifies the python tests to use random file names. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-5211) Include an example configuration for all reporters

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732980#comment-15732980 ] ASF GitHub Bot commented on FLINK-5211: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #2972: [FLINK-5211] [metrics] [docs] Include example repo...

2016-12-08 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2972 [FLINK-5211] [metrics] [docs] Include example reporter configuration CC @tillrohrmann You can merge this pull request into a Git repository by running: $ git pull

[jira] [Updated] (FLINK-5298) TaskManager crashes when TM log not existant

2016-12-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5298: Component/s: Webfrontend TaskManager > TaskManager crashes when TM log not

[jira] [Closed] (FLINK-3902) Discarded FileSystem checkpoints are lingering around

2016-12-08 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3902. -- Resolution: Not A Bug This is actually an artifact of the way we try to delete fiiles and how this

[jira] [Commented] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732934#comment-15732934 ] ASF GitHub Bot commented on FLINK-5300: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #2971: [backport] [FLINK-5300] Add more gentle file delet...

2016-12-08 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2971 [backport] [FLINK-5300] Add more gentle file deletion procedure Backport of #2970 to the release-1.1 branch. Before deleting a parent directory always check the directory whether it

[jira] [Updated] (FLINK-5298) TaskManager crashes when TM log not existant

2016-12-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5298: Affects Version/s: 1.2.0 1.1.0 > TaskManager crashes when TM log not

[jira] [Updated] (FLINK-5298) TaskManager crashes when TM log not existant

2016-12-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5298: Fix Version/s: 1.2.0 > TaskManager crashes when TM log not existant >

[jira] [Updated] (FLINK-5298) TaskManager crashes when TM log not existant

2016-12-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5298: Priority: Trivial (was: Major) > TaskManager crashes when TM log not existant >

[GitHub] flink pull request #2970: [FLINK-5300] Add more gentle file deletion procedu...

2016-12-08 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2970 [FLINK-5300] Add more gentle file deletion procedure Before deleting a parent directory always check the directory whether it contains some files. If not, then try to delete the parent

[jira] [Commented] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732927#comment-15732927 ] ASF GitHub Bot commented on FLINK-5300: --- GitHub user tillrohrmann opened a pull request:

[jira] [Assigned] (FLINK-5298) TaskManager crashes when TM log not existant

2016-12-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-5298: --- Assignee: Chesnay Schepler > TaskManager crashes when TM log not existant >

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

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

[GitHub] flink issue #2917: [FLINK-2821] use custom Akka build to listen on all inter...

2016-12-08 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2917 @StephanEwen I've updated the pull request to incorporate your suggestions. When an IPv6 address is specified, we format it like in the current code base. When a hostname is specified, we do some simple

[jira] [Comment Edited] (FLINK-1536) Graph partitioning operators for Gelly

2016-12-08 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732898#comment-15732898 ] Ivan Mushketyk edited comment on FLINK-1536 at 12/8/16 6:02 PM: Do I

[jira] [Comment Edited] (FLINK-1536) Graph partitioning operators for Gelly

2016-12-08 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732898#comment-15732898 ] Ivan Mushketyk edited comment on FLINK-1536 at 12/8/16 6:01 PM: Do I

[jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly

2016-12-08 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732898#comment-15732898 ] Ivan Mushketyk commented on FLINK-1536: --- Do I understand correctly that as the result of this issue

[jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use

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

[GitHub] flink issue #2901: [FLINK-3921] StringParser encoding

2016-12-08 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2901 I'm not quite following but I think we have the same idea. --- 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] [Assigned] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory

2016-12-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-5300: Assignee: Till Rohrmann > FileStateHandle#discard & FsCheckpointStateOutputStream#close

[jira] [Created] (FLINK-5301) Can't upload job via Web UI when using a proxy

2016-12-08 Thread JIRA
Mischa Krüger created FLINK-5301: Summary: Can't upload job via Web UI when using a proxy Key: FLINK-5301 URL: https://issues.apache.org/jira/browse/FLINK-5301 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-08 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732870#comment-15732870 ] Ivan Mushketyk commented on FLINK-5280: --- If this is not urgent and nobody has started working on

[jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732859#comment-15732859 ] ASF GitHub Bot commented on FLINK-3921: --- Github user fhueske commented on the issue:

[GitHub] flink issue #2901: [FLINK-3921] StringParser encoding

2016-12-08 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2901 I thought, I'll merge the original commit and squash yours on top. OK? --- 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-3921) StringParser not specifying encoding to use

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

[GitHub] flink issue #2901: [FLINK-3921] StringParser encoding

2016-12-08 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2901 I had planned to squash these into the original commit (#2060), but whatever you think is best. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-5226) Eagerly project unused attributes

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732843#comment-15732843 ] ASF GitHub Bot commented on FLINK-5226: --- Github user fhueske commented on the issue:

  1   2   3   >