[jira] [Updated] (FLINK-37354) Kubernetes Operator HealthCheck compatibility

2025-02-19 Thread Anton Solovev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-37354: -- Description: Kubernetes Operator HealthCheck is not aligned with checkpoint interval when it

[jira] [Created] (FLINK-37354) Kubernetes Operator HealthCheck compatibility

2025-02-19 Thread Anton Solovev (Jira)
Anton Solovev created FLINK-37354: - Summary: Kubernetes Operator HealthCheck compatibility Key: FLINK-37354 URL: https://issues.apache.org/jira/browse/FLINK-37354 Project: Flink Issue Type: B

[jira] [Updated] (FLINK-36650) ConfluentRegistryAvroSerializationSchema always tries to register the schema on serialize even if it already exists

2025-02-13 Thread Anton Solovev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-36650: -- Affects Version/s: 1.18.1 1.17.2 > ConfluentRegistryAvroSerializationSc

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

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

[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: Improveme

[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&focusedCommentId=15855939#comment-15855939 ] Anton Solovev edited comment on FLINK-5431 at 2/7/17 1:07 PM: --

[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&focusedCommentId=15855939#comment-15855939 ] Anton Solovev commented on FLINK-5431: -- How should I make it configurable? for exampl

[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; FLI

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

[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: Im

[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: FL

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

[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; FLI

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

[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&focusedCommentId=15834697#comment-15834697 ] Anton Solovev edited comment on FLINK-5592 at 1/23/17 3:07 PM: -

[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&focusedCommentId=15834697#comment-15834697 ] Anton Solovev commented on FLINK-5592: -- [ Hi [~jark], thank you for helping me. I wan

[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&focusedCommentId=15834337#comment-15834337 ] Anton Solovev edited comment on FLINK-5592 at 1/23/17 12:40 PM:

[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&focusedCommentId=15834337#comment-15834337 ] Anton Solovev edited comment on FLINK-5592 at 1/23/17 12:03 PM:

[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&focusedCommentId=15834337#comment-15834337 ] Anton Solovev edited comment on FLINK-5592 at 1/23/17 12:02 PM:

[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&focusedCommentId=15834337#comment-15834337 ] Anton Solovev commented on FLINK-5592: -- Hi [~jark], thank you fro helping me. I want

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

[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 = ExecutionEnvironmen

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

[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 {co

[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; FLI

[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; FLI

[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; FLI

[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&focusedCommentId=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&focusedCommentId=15824116#comment-15824116 ] Anton Solovev commented on FLINK-5345: -- [~StephanEwen] I see, I will assign the issue

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

[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&focusedCommentId=15824013#comment-15824013 ] Anton Solovev commented on FLINK-5345: -- [~rmetzger] [~StephanEwen] How about using {{

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

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

[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&focusedCommentId=15821676#comment-15821676 ] Anton Solovev edited comment on FLINK-3849 at 1/13/17 11:41 AM:

[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&focusedCommentId=15821676#comment-15821676 ] Anton Solovev commented on FLINK-3849: -- Hi [~fhueske], so {{setPredicate(predicate: E

[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; FLI

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

[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&focusedCommentId=15811585#comment-15811585 ] Anton Solovev commented on FLINK-5336: -- My approach https://github.com/tonycox/flink/

[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; FLINK-4

[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; FLINK-4

[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&focusedCommentId=15798384#comment-15798384 ] Anton Solovev commented on FLINK-5388: -- after reviewing this pull request by committe

[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&focusedCommentId=15785078#comment-15785078 ] Anton Solovev commented on FLINK-3849: -- Yes, one rule for pushing them together. But,

[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&focusedCommentId=15785037#comment-15785037 ] Anton Solovev commented on FLINK-5345: -- 1.1.3 RC3 ? I only see 1.1.3 RC2 on github br

[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&focusedCommentId=15778448#comment-15778448 ] Anton Solovev commented on FLINK-3849: -- I think there is needed to create PushFilterP

[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&focusedCommentId=15778448#comment-15778448 ] Anton Solovev edited comment on FLINK-3849 at 12/26/16 2:53 PM:

[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; FLINK-4

[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 {{timeou

[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 #testAnswerFailureWhenSavepointRe

[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&focusedCommentId=15773126#comment-15773126 ] Anton Solovev commented on FLINK-5388: -- [~otherwise777] could you provide an example

[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&focusedCommentId=15773024#comment-15773024 ] Anton Solovev commented on FLINK-4228: -- so do you want to continue on this? > RocksD

[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 > SavepointV0Serializer#convertKeyed

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

[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; FLINK-4

[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; FLINK-4

[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&focusedCommentId=15772799#comment-15772799 ] Anton Solovev commented on FLINK-4313: -- [~StephanEwen] I see, I will add the issue to

[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&focusedCommentId=15772779#comment-15772779 ] Anton Solovev commented on FLINK-4042: -- Hi [~till.rohrmann] What exactly doesn't work

[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&focusedCommentId=15772779#comment-15772779 ] Anton Solovev edited comment on FLINK-4042 at 12/23/16 12:25 PM: ---

[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&focusedCommentId=15772388#comment-15772388 ] Anton Solovev commented on FLINK-4228: -- what happens with this issue, is still releva

[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; FLINK-4

[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&focusedCommentId=15772332#comment-15772332 ] Anton Solovev edited comment on FLINK-5282 at 12/23/16 8:45 AM:

[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&focusedCommentId=15772332#comment-15772332 ] Anton Solovev commented on FLINK-5282: -- [~tedyu] what do ypu mean exactly? {{keyedSta

[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&focusedCommentId=15772202#comment-15772202 ] Anton Solovev commented on FLINK-3849: -- I think we need to parse an {{Expression}} fr

  1   2   >