[
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
[
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
>
[
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
>
[
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
[
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)
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:
[
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
[
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 -
[
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;
[
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
>
[
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
[
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
>
[
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
>
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:
[
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:
[
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
>
[
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
>
Anton Solovev created FLINK-5671:
Summary: Test ClassLoaderITCase#testJobsWithCustomClassLoader fails
Key: FLINK-5671
URL: https://issues.apache.org/jira/browse/FLINK-5671
Project: Flink
[
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
> ---
>
>
[
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
>
>
>
[
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;
[
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
[
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
[
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
>
[
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
>
[
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
[
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
[
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
[
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
[
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
[
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
[
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
>
[
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
[
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 =
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
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
[
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
[
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.
>
[
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;
[
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;
[
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;
[
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:
---
[
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
>
[
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
[
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}}
[
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
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
[
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
[
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)}}
[
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;
[
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
>
>
>
[
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
>
>
>
[
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
> ---
>
>
[
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
[
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;
[
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;
[
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
[
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
>
[
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
>
[
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
>
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
Anton Solovev created FLINK-5401:
Summary: Fails
ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics
Key: FLINK-5401
URL: https://issues.apache.org/jira/browse/FLINK-5401
Project: Flink
[
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
>
[
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
[
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
>
[
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
>
[
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
[
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
[
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;
[
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
>
[
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
[
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
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
[
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
[
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
[
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
>
[
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
>
[
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
>
[
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
[
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
[
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
>
[
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
[
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;
[
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;
[
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
[
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
[
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
[
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
[
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
>
[
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
>
[
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
[
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
> ---
>
>
[
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;
[
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]
[
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
[
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
>
[
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
[
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;
[
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;
[
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 - 100 of 190 matches
Mail list logo