27;m curious what tests fail. I run the tests by using `mvn verify`
>>> in the flink-ml directory. My output is:
>>> http://pastebin.com/WmgGMb8g. I ran this against the current master.
>>>
>>> Cheers,
>>> Fokko
>>>
>>> 2017-01-27 9:2
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
Hi
Can we check connection to remote host before execution a program when start
flink-shell ?
For example, right after `bin/start-scala-shell.sh remote 35007` it
checks and will not start if it wrong connects
Best,
Anton
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
Anton Solovev created FLINK-5671:
Summary: Test ClassLoaderITCase#testJobsWithCustomClassLoader fails
Key: FLINK-5671
URL: https://issues.apache.org/jira/browse/FLINK-5671
Project: Flink
onday) pushed a fix for the
StochasticOutlierSelectionITSuite (32e1675aa38eec4a15272d62977dfe3ddbe92401).
If you have this commit and the test is still failing, then I have to look into
it again.
Cheers,
Till
On Wed, Jan 25, 2017 at 10:59 PM, Anton Solovev
wrote:
> Thank you
Hello guys,
I think there is a sense to tear apart TestBaseUtils into a number of util
classes which it keeps them.
Because some test classes can't extend this base test class, but need in its
result checkers
Best,
Anton
surefire-plugin/examples/single-test.html
On Wed, Jan 25, 2017 at 2:24 PM, Anton Solovev
wrote:
> Hi folk,
>
> I have a failed integration test on travis in flink-ml package.
> How can I run specific IT Class of this on my local machine wit
Hi folk,
I have a failed integration test on travis in flink-ml package.
How can I run specific IT Class of this on my local machine with console logs
output?
Thanks,
Anton Solovev
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
Hi, Alexey
I will check abandoned PRs to reduce obviously outdated ones and add them to a
cleanup list https://issues.apache.org/jira/browse/FLINK-5384
-Original Message-
From: Alexey Demin [mailto:diomi...@gmail.com]
Sent: Monday, January 16, 2017 5:05 PM
To: dev@flink.apache.org
Sub
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
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
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
Anton Solovev created FLINK-5384:
Summary: clean up jira issues
Key: FLINK-5384
URL: https://issues.apache.org/jira/browse/FLINK-5384
Project: Flink
Issue Type: Improvement
Hi folks
I found a lot of non-relevant issues:
https://issues.apache.org/jira/browse/FLINK-37 -> from stratosphere;
https://issues.apache.org/jira/browse/FLINK-87 -> from stratosphere;
https://issues.apache.org/jira/browse/FLINK-481 -> from stratosphere;
https://issues.apache.org/jira/browse/FLIN
Anton Solovev created FLINK-5358:
Summary: Support Row in TypeExtractor
Key: FLINK-5358
URL: https://issues.apache.org/jira/browse/FLINK-5358
Project: Flink
Issue Type: Improvement
Anton Solovev created FLINK-5189:
Summary: deprecate and delete Row in table api
Key: FLINK-5189
URL: https://issues.apache.org/jira/browse/FLINK-5189
Project: Flink
Issue Type: Sub-task
Anton Solovev created FLINK-5188:
Summary: Redirect dependencies
Key: FLINK-5188
URL: https://issues.apache.org/jira/browse/FLINK-5188
Project: Flink
Issue Type: Sub-task
Anton Solovev created FLINK-5187:
Summary: Create analog of Row in core
Key: FLINK-5187
URL: https://issues.apache.org/jira/browse/FLINK-5187
Project: Flink
Issue Type: Sub-task
Anton Solovev created FLINK-5186:
Summary: Move Row and RowTypeInfo into Flink core
Key: FLINK-5186
URL: https://issues.apache.org/jira/browse/FLINK-5186
Project: Flink
Issue Type
we move it to core, we have to untangle it from Scala, as Timo said. The
reason is that we would like to remove Scala from any user facing API maven
packages and if we had it in core everyone would have to suffix maven packages
with the Scala version.
On Fri, 25 Nov 2016 at 16:47 Anton Solovev w
ot inherit from Scala classes.
>
> Regards,
> Timo
>
> Am 24/11/16 um 16:46 schrieb Anton Solovev:
>
>> Hello,
>>
>>
>>
>> In Scala case classes can store huge count of fields, it's really
>> helpful for reading wide csv files, but It us
Sorry, wrong thread
-Original Message-
From: Anton Solovev [mailto:anton_solo...@epam.com]
Sent: Friday, November 25, 2016 7:20 PM
To: dev@flink.apache.org
Subject: RE: Flink using Yarn on MapR
I agree that we should improve RowTypeInfo. But why not to keep it in Scala?
In case flink
I agree that we should improve RowTypeInfo. But why not to keep it in Scala?
In case flink-2186 that the "Row" is a "Product" is a reason of supporting wide
columns indeed.
Just for example I tried to move the "Row" to flink-scala module
(https://github.com/apache/flink/compare/master...tonycox:F
Hello,
In Scala case classes can store huge count of fields, it's really helpful for
reading wide csv files, but It uses only in table api.
what about this issue (https://issues.apache.org/jira/browse/FLINK-2186),
should we use table api in machine learning library?
To solve the issue #readC
Hi,
I'm working on https://issues.apache.org/jira/browse/FLINK-2186
As I understand, Flink cannot read wide-column files in tuple, but pojo
So far we must create that pojo manually, it's convenient when count of columns
not so many
When it's over thousand - hardly seems possible
To solve this i
with a ProjectableTableSource would be a JDBC
database which pushes a query to a JDBC connected database, a Parquet file, or
an ORC file.
Best, Fabian
2016-11-02 13:53 GMT+01:00 Anton Solovev :
> Hi folks,
>
> Can you explain me what ProjectableTableSource is ?
> What is it be
Hi folks,
Can you explain me what ProjectableTableSource is ?
What is it being invented for?
Best,
Anton
also add this
cast in the test).
In addition we should make sure that the error message helps the user to add
the necessary cast.
What do you think?
Best, Fabian
2016-10-28 11:42 GMT+02:00 Anton Solovev :
>
> I'm working on flink-4743 issue
> I tried write tests as Fabian
I'm working on flink-4743 issue
I tried write tests as Fabian suggested me
https://github.com/apache/flink/pull/2686#discussion_r85218584
and figure out that there is no implicit conversion of bigDecimal to double in
table api.
"power" function accept only double as operands.
all is okay when r
() method.
The stream execution plan will probably contain different information than the
batch execution plan, but I think that is fine.
Please let me know if you have more questions.
Best, Fabian
2016-10-26 10:59 GMT+02:00 Anton Solovev :
> Sorry, wrong issue number
>
> Question is ab
Sorry, wrong issue number
Question is about https://issues.apache.org/jira/browse/FLINK-4623
And in subject should be StreamExecutionEnvironment#explain actually
-Original Message-
From: Anton Solovev [mailto:anton_solo...@epam.com]
Sent: Wednesday, October 26, 2016 12:30 PM
To: dev
Hello,
I have started doing https://issues.apache.org/jira/browse/FLINK-4743
What should explain of DataStream look like?
Best regards,
Anton
Anton Solovev would like to recall the message, "Assign issue".
Hi folks.
I want to do something for flink. As the first step I have started doing
https://issues.apache.org/jira/browse/FLINK-4743, could you assign it for me in
JIRA.
Thanks.
Best regards,
Anton Solovev
Anton Solovev would like to recall the message, "Assign issue".
Hi folks.
I want to do something for flink. As the first step I have started doing
https://issues.apache.org/jira/browse/FLINK-4743, could you assign it for me in
JIRA.
Thanks.
Anton Solovev
Junior Software Engineer
Office: +7 846 200 09 70 x 55621
Email: anton_solo...@epam.com
40 matches
Mail list logo
