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

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

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

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 an

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

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 e

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

[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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...

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 wit

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

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

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

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 enable

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

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

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

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 Issue

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15734537#comment-15734537 ] Philipp von dem Bussche commented on FLINK-2821: Thanks [~mxm] this is wor

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

[ https://issues.apache.org/jira/browse/FLINK-5299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15734216#comment-15734216 ] Aljoscha Krettek commented on FLINK-5299: - A {{KeySelector}} that calls {{Arrays.h

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

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

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

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 wishe

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

[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 ...

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 pro

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

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

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

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

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

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 Apach

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

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

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

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 Apach

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

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 Software

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

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

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

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

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...

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 oth

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

[ https://issues.apache.org/jira/browse/FLINK-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/FLINK-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/FLINK-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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...

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 enabled

[GitHub] flink issue #2913: [backport] [FLINK-5114] [network] Handle partition produc...

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 s

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

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 add

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

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

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

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

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

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

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

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

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 F

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

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

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

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

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

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

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 F

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

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

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

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

[ 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 3ae6e9e09ba74f88fe87d1ac130b3c

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

[ 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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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...

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 th

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

[ 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 f2186af6702c9fe48

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

[ 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 677d0d9073952b6f4c745ac242ba41083

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

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 enab

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

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 enab

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

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

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

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

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

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

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

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

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

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 enab

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

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 enab

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

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15733296#comment-15733296 ] Fabian Hueske commented on FLINK-5280: -- Sure, you can work on this [~ivan.mushketyk].

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

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15733284#comment-15733284 ] Vasia Kalavri commented on FLINK-1536: -- The idea is what [~greghogan] describes. In a

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

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

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

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 a

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

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

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 em

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

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

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

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 p

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

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15733195#comment-15733195 ] Greg Hogan commented on FLINK-1536: --- As I understand, these can be implemented as a {{Gr

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

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

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

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 Fil

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

[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

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

[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

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 https://

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

[ https://issues.apache.org/jira/browse/FLINK-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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...

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 https://github.com/zentol/flin

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

[ 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

[ 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 inte

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

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

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

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 co

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

[ 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

[ 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

[ 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...

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 dire

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

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

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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...

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

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732898#comment-15732898 ] Ivan Mushketyk edited comment on FLINK-1536 at 12/8/16 6:02 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732898#comment-15732898 ] Ivan Mushketyk edited comment on FLINK-1536 at 12/8/16 6:01 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732898#comment-15732898 ] Ivan Mushketyk commented on FLINK-1536: --- Do I understand correctly that as the resul

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

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

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

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 h

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

[ 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 tri

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

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

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732870#comment-15732870 ] Ivan Mushketyk commented on FLINK-5280: --- If this is not urgent and nobody has starte

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

[ https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

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

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

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

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 GitH

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

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

  1   2   3   >