[jira] [Created] (FLINK-8227) Optimize the performance of SharedBufferSerializer

Dian Fu created FLINK-8227: -- Summary: Optimize the performance of SharedBufferSerializer Key: FLINK-8227 URL: https://issues.apache.org/jira/browse/FLINK-8227 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8226) Dangling reference generated after NFA clean up timed out SharedBufferEntry

Dian Fu created FLINK-8226: -- Summary: Dangling reference generated after NFA clean up timed out SharedBufferEntry Key: FLINK-8226 URL: https://issues.apache.org/jira/browse/FLINK-8226 Project: Flink

TaskManager job lifecycle hooks

(Continuing previous thread because I made the mistake of subscribing to the digest rather than direct emails.) Thanks, Eron. RichFunction seems to be a step in the right direction (the docs imply that the lifecycle is per set of tasks on a TaskManager per high-level function rather than per task)

Re: [VOTE] Release 1.4.0, release candidate #3

@Eron Given that this is actually an undocumented "internal" feature at this point, I would not expect that it is used heavily beyond Pravega. Unless you feel strongly that this is a major issue, I would go ahead with the release... On Fri, Dec 8, 2017 at 3:18 PM, Aljoscha Krettek wrote: > Than

Re: Test conflicts in JoinTest

Hi, Finally, the cause is revealed. There's a global (concurrentMap formed) cache in org.apache.calcite.rel.type.RelDataTypeFactoryImpl. The locally used *RelDataType*s will be cached as both the keys and values. For the following two *RelDataType*s, 1. RecordType(BIGINT d, INTEGER e, VARCHAR(655

Re: [VOTE] Release 1.4.0, release candidate #3

Thanks for the update! I would also say it's not a blocker but we should make sure that we don't break this after 1.4, then. > On 7. Dec 2017, at 22:37, Eron Wright wrote: > > Just discovered: the removal of Flink's Future (FLINK-7252) causes a > breaking change in connectors that use > `org.a

Test conflicts in JoinTest

Hi all, Recently I'm trying to add some tests to *org.apache.flink.table.api.stream.table.JoinTest*, but encountered a strange problem. A test case could successfully run in an isolated mode, but failed (threw an *CannotPlanException* in *TableEnvironment.runVolcanoPlanner()*) when ran with anoth

[jira] [Created] (FLINK-8225) Use JsonRowDeserializationSchema without Kafka connector dependency

Sendoh created FLINK-8225: - Summary: Use JsonRowDeserializationSchema without Kafka connector dependency Key: FLINK-8225 URL: https://issues.apache.org/jira/browse/FLINK-8225 Project: Flink Issue T

[jira] [Created] (FLINK-8224) Should shudownApplication when job terminated in job mode

shuai.xu created FLINK-8224: --- Summary: Should shudownApplication when job terminated in job mode Key: FLINK-8224 URL: https://issues.apache.org/jira/browse/FLINK-8224 Project: Flink Issue Type: Bug