Kurt Young created FLINK-5185:
-
Summary: Decouple BatchTableSourceScan with TableSourceTable
Key: FLINK-5185
URL: https://issues.apache.org/jira/browse/FLINK-5185
Project: Flink
Issue Type: Impro
godfrey he created FLINK-5184:
-
Summary: Error result of compareSerialized in RowComparator class
Key: FLINK-5184
URL: https://issues.apache.org/jira/browse/FLINK-5184
Project: Flink
Issue Type:
Geoffrey Mon created FLINK-5183:
---
Summary: [py] Support multiple jobs per Python plan file
Key: FLINK-5183
URL: https://issues.apache.org/jira/browse/FLINK-5183
Project: Flink
Issue Type: Impro
Eron Wright created FLINK-5182:
---
Summary: Implement SSL file-shipping
Key: FLINK-5182
URL: https://issues.apache.org/jira/browse/FLINK-5182
Project: Flink
Issue Type: Sub-task
Repo
Hi Minudika,
Welcome aboard! You are of course free to work on any issue, but the
following link will pull up open issues marked with the "starter" label.
https://issues.apache.org/jira/issues/?jql=project%20%3D%20FLINK%20AND%20status%20in%20%28Open%2C%20%22In%20Progress%22%2C%20Reopened%29%20AND
Aljoscha Krettek created FLINK-5181:
---
Summary: Add Tests in StateBackendTestBase that verify
Default-Value Behaviour
Key: FLINK-5181
URL: https://issues.apache.org/jira/browse/FLINK-5181
Project: Fl
Ufuk Celebi created FLINK-5180:
--
Summary: Include blocked on bounded queue length in back pressure
stats
Key: FLINK-5180
URL: https://issues.apache.org/jira/browse/FLINK-5180
Project: Flink
Iss
Chesnay Schepler created FLINK-5179:
---
Summary: MetricRegistry life-cycle issues with HA
Key: FLINK-5179
URL: https://issues.apache.org/jira/browse/FLINK-5179
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-5178:
--
Summary: allow BLOB_STORAGE_DIRECTORY_KEY to point to a
distributed file system
Key: FLINK-5178
URL: https://issues.apache.org/jira/browse/FLINK-5178
Project: Flink
There is no good reason why only Scala developers should have access to
this class. If we also want to read CSV files into Row objects, Row must
be in core.
Am 28/11/16 um 14:37 schrieb Anton Solovev:
What do you think about moving "Row" not into core module, but into Scala
module?
-Ori
What do you think about moving "Row" not into core module, but into Scala
module?
-Original Message-
From: Aljoscha Krettek [mailto:aljos...@apache.org]
Sent: Monday, November 28, 2016 3:00 PM
To: dev@flink.apache.org
Subject: Re: Move Row, RowInputFormat to core package
If we move it t
Timo Walther created FLINK-5177:
---
Summary: Improve nullability handling
Key: FLINK-5177
URL: https://issues.apache.org/jira/browse/FLINK-5177
Project: Flink
Issue Type: Improvement
C
Syinchwun,
Can you maybe share more technical details such as design docs/papers about
this approach, or is it confidential?
It sounds interesting but the details make a difference (i.e. partial
boundaries - bookkeeping).
Paris
> On 28 Nov 2016, at 13:01, liuxinchun wrote:
>
> Dear Aljoscha
Dear Aljoscha:
I'm the colleague of 时某人，and participate in the design of Checkpoint mechanism
of a certain Streaming Processing System, which refers to Flink's Checkpoint
mechanism. In my opinion, the most difficulty in stream's checkpoint is big
window's backup. In many applications, the win
Till Rohrmann created FLINK-5176:
Summary: Properly wait for component shutdown in Runner components
Key: FLINK-5176
URL: https://issues.apache.org/jira/browse/FLINK-5176
Project: Flink
Issue
shijinkui created FLINK-5175:
Summary: StreamExecutionEnvironment's set function return `this`
instead of void
Key: FLINK-5175
URL: https://issues.apache.org/jira/browse/FLINK-5175
Project: Flink
If 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
Hi,
this is indeed a bug (though I would see it more as a feature since I think
using the Checkpointed interface there can indeed be problematic, as Till
pointed out). The problem is that the Scala Wrapper functions have to
implement all kinds of interfaces so that they can forward to the wrapped
f
Kostas Kloudas created FLINK-5174:
-
Summary: Fix memory leak in the CEP library.
Key: FLINK-5174
URL: https://issues.apache.org/jira/browse/FLINK-5174
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-5173:
---
Summary: Upgrade RocksDB dependency
Key: FLINK-5173
URL: https://issues.apache.org/jira/browse/FLINK-5173
Project: Flink
Issue Type: Bug
Components:
Stephan Ewen created FLINK-5172:
---
Summary: In RocksDBStateBackend, set flink-core and
flink-streaming-java to "provided"
Key: FLINK-5172
URL: https://issues.apache.org/jira/browse/FLINK-5172
Project: Fl
Hi 时某人,
I think you've found an inconsistency in Flink's windowing API (but it's
the same in the Java API). Handling operator state in the context of
windows is a little bit delicate because you could have multiple windows in
flight, though. I've pulled Aljoscha in this thread who is more familiar
shuai.xu created FLINK-5171:
---
Summary: Wrong use of Preconditions.checkState in TaskManagerRunner
Key: FLINK-5171
URL: https://issues.apache.org/jira/browse/FLINK-5171
Project: Flink
Issue Type: Bu
shuai.xu created FLINK-5170:
---
Summary: getAkkaConfig will use localhost if hostname is specified
Key: FLINK-5170
URL: https://issues.apache.org/jira/browse/FLINK-5170
Project: Flink
Issue Type: Bu
Ufuk Celebi created FLINK-5169:
--
Summary: Make consumption of input channels fair
Key: FLINK-5169
URL: https://issues.apache.org/jira/browse/FLINK-5169
Project: Flink
Issue Type: Improvement
25 matches
Mail list logo
