Is there some State backend and checkpoint design architecture document?
ChengXiang Li have some sharing about checkout on Hangzhou Flink Meetup.
https://github.com/pusuo/streaming-resource/blob/master/flink-meetup-hz-20161105/Flink%E5%88%86%E5%B8%83%E5%BC%8F%E5%BF%AB%E7%85%A7%E6%B7%B1%E5%85%A5
Hi all:
I am paying attention to Flink, and encounter a problem about user defined
window with checkpoint. My code like this:
class WindowStatistics extends WindowFunction[Event, Int, Tuple, TimeWindow]
with Checkpointed[Option[Int]]: Unit = {
private var count = 0
override def apply
shijinkui created FLINK-5167:
Summary: StreamExecutionEnvironment's set function return `this`
instead of void
Key: FLINK-5167
URL: https://issues.apache.org/jira/browse/FLINK-5167
Project: Flink
shijinkui created FLINK-5166:
Summary: TextInputFormatTest.testNestedFileRead
Key: FLINK-5166
URL: https://issues.apache.org/jira/browse/FLINK-5166
Project: Flink
Issue Type: Bug
Compon
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:FL
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-21
Chesnay Schepler created FLINK-5165:
---
Summary: Checkpointing tests using FsStatebackend fail on Windows
Key: FLINK-5165
URL: https://issues.apache.org/jira/browse/FLINK-5165
Project: 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
Chesnay Schepler created FLINK-5164:
---
Summary: Hadoop-compat IOFormat tests fail on Windows
Key: FLINK-5164
URL: https://issues.apache.org/jira/browse/FLINK-5164
Project: Flink
Issue Type:
Fix is now in the master and everything should run smooth with MapR
Hadoop. I'd be happy if you gave it another try.
-Max
On Thu, Nov 24, 2016 at 6:22 PM, Maximilian Michels wrote:
> Hi Naveen,
>
> The new Kerberos authentication code in Flink assumes that we're
> running against vanilla Hadoop
Fully agree with Timo :)
On Fri, Nov 25, 2016 at 2:30 PM, Timo Walther wrote:
> Hi Anton,
>
> I would also support the idea of moving Row and RowTypeInfo to Flink core.
> I think there are many real-world use cases where a variable-length record
> that supports null values is required. However,
Hi Anton,
I would also support the idea of moving Row and RowTypeInfo to Flink
core. I think there are many real-world use cases where a
variable-length record that supports null values is required. However, I
think that those classes needs to be reworked before. They should not
depend on Sca
Hi all,
I am interested in stream processing and willing to contribute for the
development of Apache Flink.
Could you please provide some suitable jira tickets for me to get started.
Your help is much appriciated.
BR
Minudika
Kostas Kloudas created FLINK-5163:
-
Summary: Make the production functions rescalable (apart from the
Rolling/Bucketing Sinks)
Key: FLINK-5163
URL: https://issues.apache.org/jira/browse/FLINK-5163
Pro
Chesnay Schepler created FLINK-5162:
---
Summary: BlobRecoveryItCase#testBlobServerRecovery fails on Windows
Key: FLINK-5162
URL: https://issues.apache.org/jira/browse/FLINK-5162
Project: Flink
wouter ligtenberg created FLINK-5161:
Summary: accepting NullValue for VV in Gelly examples and GSA
Key: FLINK-5161
URL: https://issues.apache.org/jira/browse/FLINK-5161
Project: Flink
Is
Chesnay Schepler created FLINK-5160:
---
Summary: SecurityContextTest#testCreateInsecureHadoopCtx fails on
windows
Key: FLINK-5160
URL: https://issues.apache.org/jira/browse/FLINK-5160
Project: Flink
Alexander Shoshin created FLINK-5159:
Summary: Improve perfomance of inner joins with a single row input
Key: FLINK-5159
URL: https://issues.apache.org/jira/browse/FLINK-5159
Project: Flink
18 matches
Mail list logo