[jira] [Assigned] (FLINK-3849) Add FilterableTableSource interface and translation rule

2017-03-09 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-3849: Assignee: (was: Anton Solovev) > Add FilterableTableSource interface and translation

[jira] [Assigned] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture

2017-02-17 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5402: Assignee: Dawid Wysakowicz > Fails AkkaRpcServiceTest#testTerminationFuture >

[jira] [Updated] (FLINK-5481) Simplify Row creation

2017-02-13 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5481: - Summary: Simplify Row creation (was: Cannot create Collection of Row ) > Simplify Row creation >

[jira] [Updated] (FLINK-5744) Check remote connection in Flink-shell

2017-02-13 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5744: - Description: I wish to check connection to remote host before execution a program when starting

[jira] [Updated] (FLINK-5744) Check remote connection in Flink-shell

2017-02-08 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5744: - Summary: Check remote connection in Flink-shell (was: Checking remote connection in Flink-shell)

[jira] [Created] (FLINK-5744) Checking remote connection in Flink-shell

2017-02-08 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5744: Summary: Checking remote connection in Flink-shell Key: FLINK-5744 URL: https://issues.apache.org/jira/browse/FLINK-5744 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-5431) time format for akka status

2017-02-07 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855939#comment-15855939 ] Anton Solovev edited comment on FLINK-5431 at 2/7/17 1:07 PM: -- How should I

[jira] [Commented] (FLINK-5431) time format for akka status

2017-02-07 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855939#comment-15855939 ] Anton Solovev commented on FLINK-5431: -- How should I make it configurable? for example through cli -

[jira] [Updated] (FLINK-5384) clean up jira issues

2017-02-06 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: h4. must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Closed] (FLINK-1398) A new DataSet function: extractElementFromTuple

2017-02-06 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-1398. Resolution: Won't Fix > A new DataSet function: extractElementFromTuple >

[jira] [Updated] (FLINK-5698) Add NestedFieldsProjectableTableSource interface

2017-02-06 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5698: - Description: Add a NestedFieldsProjectableTableSource interface for some TableSource

[jira] [Assigned] (FLINK-5698) Add NestedFieldsProjectableTableSource interface

2017-02-06 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5698: Assignee: Anton Solovev > Add NestedFieldsProjectableTableSource interface >

[jira] [Updated] (FLINK-5698) Add NestedFieldsProjectableTableSource interface

2017-02-02 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5698: - Issue Type: New Feature (was: Improvement) > Add NestedFieldsProjectableTableSource interface >

[jira] [Created] (FLINK-5698) Add NestedFieldsProjectableTableSource interface

2017-02-02 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5698: Summary: Add NestedFieldsProjectableTableSource interface Key: FLINK-5698 URL: https://issues.apache.org/jira/browse/FLINK-5698 Project: Flink Issue Type:

[jira] [Updated] (FLINK-2168) Add HBaseTableSource

2017-02-01 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-2168: - Labels: (was: starter) > Add HBaseTableSource > > > Key:

[jira] [Updated] (FLINK-5671) Test ClassLoaderITCase#testJobsWithCustomClassLoader fails

2017-01-27 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5671: - Environment: Ubuntu 16.04 > Test ClassLoaderITCase#testJobsWithCustomClassLoader fails >

[jira] [Closed] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-27 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-5592. Resolution: Not A Problem > Wrong number of RowSerializers with nested Rows in Collection mode >

[jira] [Created] (FLINK-5671) Test ClassLoaderITCase#testJobsWithCustomClassLoader fails

2017-01-27 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5671: Summary: Test ClassLoaderITCase#testJobsWithCustomClassLoader fails Key: FLINK-5671 URL: https://issues.apache.org/jira/browse/FLINK-5671 Project: Flink

[jira] [Updated] (FLINK-5336) Make Path immutable

2017-01-25 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5336: - Assignee: (was: Anton Solovev) > Make Path immutable > --- > >

[jira] [Updated] (FLINK-5384) clean up jira issues

2017-01-25 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Assignee: (was: Anton Solovev) > clean up jira issues > > >

[jira] [Updated] (FLINK-5384) clean up jira issues

2017-01-25 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: h4. must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Updated] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5592: - Priority: Minor (was: Major) > Wrong number of RowSerializers with nested Rows in Collection

[jira] [Comment Edited] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15834697#comment-15834697 ] Anton Solovev edited comment on FLINK-5592 at 1/23/17 3:07 PM: --- [ Hi

[jira] [Reopened] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reopened FLINK-5592: -- > Wrong number of RowSerializers with nested Rows in Collection mode >

[jira] [Closed] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-5592. Resolution: Not A Problem > Wrong number of RowSerializers with nested Rows in Collection mode >

[jira] [Commented] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15834697#comment-15834697 ] Anton Solovev commented on FLINK-5592: -- [ Hi [~jark], thank you for helping me. I want exactly a row

[jira] [Issue Comment Deleted] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5592: - Comment: was deleted (was: Hi [~jark], thank you for helping me. I want exactly a row of a number

[jira] [Comment Edited] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15834337#comment-15834337 ] Anton Solovev edited comment on FLINK-5592 at 1/23/17 12:40 PM: Hi

[jira] [Comment Edited] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15834337#comment-15834337 ] Anton Solovev edited comment on FLINK-5592 at 1/23/17 12:03 PM: Hi

[jira] [Comment Edited] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15834337#comment-15834337 ] Anton Solovev edited comment on FLINK-5592 at 1/23/17 12:02 PM: Hi

[jira] [Commented] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15834337#comment-15834337 ] Anton Solovev commented on FLINK-5592: -- Hi [~jark], thank you fro helping me. I want exactly a row of

[jira] [Closed] (FLINK-5554) Add sql operator to table api for getting columns from HBase

2017-01-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-5554. Resolution: Not A Problem > Add sql operator to table api for getting columns from HBase >

[jira] [Assigned] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-20 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5592: Assignee: (was: Anton Solovev) > Wrong number of RowSerializers with nested Rows in

[jira] [Updated] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-20 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5592: - Description: {code} @Test def testNestedRowTypes(): Unit = { val env =

[jira] [Created] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-20 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5592: Summary: Wrong number of RowSerializers with nested Rows in Collection mode Key: FLINK-5592 URL: https://issues.apache.org/jira/browse/FLINK-5592 Project: Flink

[jira] [Created] (FLINK-5554) Add sql operator to table api for getting columns from HBase

2017-01-18 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5554: Summary: Add sql operator to table api for getting columns from HBase Key: FLINK-5554 URL: https://issues.apache.org/jira/browse/FLINK-5554 Project: Flink

[jira] [Updated] (FLINK-5554) Add sql operator to table api for getting columns from HBase

2017-01-18 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5554: - Description: example of select query {code} table.select("f1:q1, f1:q2, f1:q3"); {code} or/and

[jira] [Updated] (FLINK-4682) Add TumbleRow row-windows for batch tables.

2017-01-18 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-4682: - Assignee: (was: Anton Solovev) > Add TumbleRow row-windows for batch tables. >

[jira] [Updated] (FLINK-5384) clean up jira issues

2017-01-16 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: h4. must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Updated] (FLINK-5384) clean up jira issues

2017-01-16 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: h4. must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Updated] (FLINK-5384) clean up jira issues

2017-01-16 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: h4. must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Comment Edited] (FLINK-5345) IOManager failed to properly clean up temp file directory

2017-01-16 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15824116#comment-15824116 ] Anton Solovev edited comment on FLINK-5345 at 1/16/17 3:02 PM: ---

[jira] [Commented] (FLINK-5345) IOManager failed to properly clean up temp file directory

2017-01-16 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15824116#comment-15824116 ] Anton Solovev commented on FLINK-5345: -- [~StephanEwen] I see, I will assign the issue on you >

[jira] [Updated] (FLINK-5345) IOManager failed to properly clean up temp file directory

2017-01-16 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5345: - Assignee: Stephan Ewen (was: Anton Solovev) > IOManager failed to properly clean up temp file

[jira] [Commented] (FLINK-5345) IOManager failed to properly clean up temp file directory

2017-01-16 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15824013#comment-15824013 ] Anton Solovev commented on FLINK-5345: -- [~rmetzger] [~StephanEwen] How about using {{#deleteQuietly}}

[jira] [Updated] (FLINK-5481) Cannot create Collection of Row

2017-01-13 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5481: - Priority: Trivial (was: Major) Affects Version/s: 1.2.0 > Cannot create Collection

[jira] [Created] (FLINK-5481) Cannot create Collection of Row

2017-01-13 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5481: Summary: Cannot create Collection of Row Key: FLINK-5481 URL: https://issues.apache.org/jira/browse/FLINK-5481 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-3849) Add FilterableTableSource interface and translation rule

2017-01-13 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15821676#comment-15821676 ] Anton Solovev edited comment on FLINK-3849 at 1/13/17 11:41 AM: Hi

[jira] [Commented] (FLINK-3849) Add FilterableTableSource interface and translation rule

2017-01-13 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15821676#comment-15821676 ] Anton Solovev commented on FLINK-3849: -- Hi [~fhueske], so {{setPredicate(predicate: Expression)}}

[jira] [Updated] (FLINK-5384) clean up jira issues

2017-01-11 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: h4. must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Updated] (FLINK-5384) clean up jira issues

2017-01-11 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Assignee: (was: Anton Solovev) > clean up jira issues > > >

[jira] [Assigned] (FLINK-5384) clean up jira issues

2017-01-11 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5384: Assignee: Anton Solovev > clean up jira issues > > >

[jira] [Assigned] (FLINK-5431) time format for akka status

2017-01-09 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5431: Assignee: Anton Solovev > time format for akka status > --- > >

[jira] [Commented] (FLINK-5336) Make Path immutable

2017-01-09 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15811585#comment-15811585 ] Anton Solovev commented on FLINK-5336: -- My approach

[jira] [Updated] (FLINK-5384) clean up jira issues

2017-01-06 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Updated] (FLINK-5384) clean up jira issues

2017-01-06 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Commented] (FLINK-5388) Remove private access of edges and vertices of Gelly Graph class

2017-01-04 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15798384#comment-15798384 ] Anton Solovev commented on FLINK-5388: -- after reviewing this pull request by committers it will be

[jira] [Updated] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails

2016-12-30 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5389: - Affects Version/s: 1.2.0 > Fails #testAnswerFailureWhenSavepointReadFails >

[jira] [Updated] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture

2016-12-30 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5402: - Environment: macOS > Fails AkkaRpcServiceTest#testTerminationFuture >

[jira] [Updated] (FLINK-5401) Fails ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics

2016-12-30 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5401: - Environment: macOS > Fails ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics >

[jira] [Created] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture

2016-12-30 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5402: Summary: Fails AkkaRpcServiceTest#testTerminationFuture Key: FLINK-5402 URL: https://issues.apache.org/jira/browse/FLINK-5402 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5401) Fails ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics

2016-12-30 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5401: Summary: Fails ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics Key: FLINK-5401 URL: https://issues.apache.org/jira/browse/FLINK-5401 Project: Flink

[jira] [Updated] (FLINK-5400) Add accessor to folding states in RuntimeContext

2016-12-30 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5400: - Assignee: Xiaogang Shi > Add accessor to folding states in RuntimeContext >

[jira] [Commented] (FLINK-3849) Add FilterableTableSource interface and translation rule

2016-12-29 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15785078#comment-15785078 ] Anton Solovev commented on FLINK-3849: -- Yes, one rule for pushing them together. But, I`ve just

[jira] [Commented] (FLINK-5345) IOManager failed to properly clean up temp file directory

2016-12-29 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15785037#comment-15785037 ] Anton Solovev commented on FLINK-5345: -- 1.1.3 RC3 ? I only see 1.1.3 RC2 on github branches >

[jira] [Assigned] (FLINK-5345) IOManager failed to properly clean up temp file directory

2016-12-29 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5345: Assignee: Anton Solovev > IOManager failed to properly clean up temp file directory >

[jira] [Commented] (FLINK-3849) Add FilterableTableSource interface and translation rule

2016-12-26 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15778448#comment-15778448 ] Anton Solovev commented on FLINK-3849: -- I think there is needed to create PushFilterProjectRule to

[jira] [Comment Edited] (FLINK-3849) Add FilterableTableSource interface and translation rule

2016-12-26 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15778448#comment-15778448 ] Anton Solovev edited comment on FLINK-3849 at 12/26/16 2:53 PM: I think

[jira] [Updated] (FLINK-5384) clean up jira issues

2016-12-25 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Closed] (FLINK-4042) TwitterStream example does not work

2016-12-25 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-4042. Resolution: Won't Fix outdated > TwitterStream example does not work >

[jira] [Updated] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5389: - Description: {{testAnswerFailureWhenSavepointReadFails}} fails in {{JobSubmitTest}} when

[jira] [Updated] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5389: - Environment: macOS sierra Labels: test (was: ) > Fails

[jira] [Created] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails

2016-12-23 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5389: Summary: Fails #testAnswerFailureWhenSavepointReadFails Key: FLINK-5389 URL: https://issues.apache.org/jira/browse/FLINK-5389 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-5388) Remove private access of edges and vertices of Gelly Graph class

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5388: Assignee: Anton Solovev > Remove private access of edges and vertices of Gelly Graph class

[jira] [Commented] (FLINK-5388) Remove private access of edges and vertices of Gelly Graph class

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15773126#comment-15773126 ] Anton Solovev commented on FLINK-5388: -- [~otherwise777] could you provide an example of your

[jira] [Closed] (FLINK-4313) Inconsistent code for Key/Value in the CheckpointCoordinator

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-4313. Resolution: Won't Fix outdated > Inconsistent code for Key/Value in the CheckpointCoordinator >

[jira] [Assigned] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-4228: Assignee: Anton Solovev > RocksDB semi-async snapshot to S3AFileSystem fails >

[jira] [Updated] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-4228: - Assignee: (was: Anton Solovev) > RocksDB semi-async snapshot to S3AFileSystem fails >

[jira] [Commented] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15773024#comment-15773024 ] Anton Solovev commented on FLINK-4228: -- so do you want to continue on this? > RocksDB semi-async

[jira] [Assigned] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState()

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5282: Assignee: Anton Solovev > CheckpointStateOutputStream should be closed in finally block in

[jira] [Closed] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState()

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-5282. > CheckpointStateOutputStream should be closed in finally block in >

[jira] [Updated] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState()

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5282: - Assignee: Stefan Richter (was: Anton Solovev) > CheckpointStateOutputStream should be closed in

[jira] [Updated] (FLINK-5384) clean up jira issues

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Updated] (FLINK-5384) clean up jira issues

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Commented] (FLINK-4313) Inconsistent code for Key/Value in the CheckpointCoordinator

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15772799#comment-15772799 ] Anton Solovev commented on FLINK-4313: -- [~StephanEwen] I see, I will add the issue to clean up list

[jira] [Updated] (FLINK-4313) Inconsistent code for Key/Value in the CheckpointCoordinator

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-4313: - Assignee: (was: Anton Solovev) > Inconsistent code for Key/Value in the CheckpointCoordinator

[jira] [Commented] (FLINK-4042) TwitterStream example does not work

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15772779#comment-15772779 ] Anton Solovev commented on FLINK-4042: -- Hi [~till.rohrmann] What exactly doesn't work? On my local

[jira] [Comment Edited] (FLINK-4042) TwitterStream example does not work

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15772779#comment-15772779 ] Anton Solovev edited comment on FLINK-4042 at 12/23/16 12:25 PM: - Hi

[jira] [Assigned] (FLINK-4313) Inconsistent code for Key/Value in the CheckpointCoordinator

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-4313: Assignee: Anton Solovev > Inconsistent code for Key/Value in the CheckpointCoordinator >

[jira] [Assigned] (FLINK-4042) TwitterStream example does not work

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-4042: Assignee: Anton Solovev > TwitterStream example does not work >

[jira] [Commented] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15772388#comment-15772388 ] Anton Solovev commented on FLINK-4228: -- what happens with this issue, is still relevant? > RocksDB

[jira] [Updated] (FLINK-4719) KryoSerializer random exception

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-4719: - Assignee: Nico Kruber > KryoSerializer random exception > --- > >

[jira] [Updated] (FLINK-5384) clean up jira issues

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Comment Edited] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState()

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15772332#comment-15772332 ] Anton Solovev edited comment on FLINK-5282 at 12/23/16 8:45 AM: [~tedyu]

[jira] [Commented] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState()

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15772332#comment-15772332 ] Anton Solovev commented on FLINK-5282: -- [~tedyu] what do ypu mean exactly? {{keyedStateOut}} is

[jira] [Updated] (FLINK-5360) Fix arguments names in WindowedStream

2016-12-23 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5360: - Assignee: Ivan Mushketyk > Fix arguments names in WindowedStream >

[jira] [Commented] (FLINK-3849) Add FilterableTableSource interface and translation rule

2016-12-22 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15772202#comment-15772202 ] Anton Solovev commented on FLINK-3849: -- I think we need to parse an {{Expression}} from

[jira] [Updated] (FLINK-5384) clean up jira issues

2016-12-22 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Updated] (FLINK-5384) clean up jira issues

2016-12-22 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[jira] [Updated] (FLINK-5384) clean up jira issues

2016-12-22 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: must be closed: FLINK-37 -> from stratosphere;

  1   2   >