[jira] [Assigned] (FLINK-7783) Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover()

2017-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-7783: --- Assignee: Aljoscha Krettek > Don't always remove checkpoints in

[jira] [Commented] (FLINK-7837) AggregatingFunction does not work with immutable types

2017-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205778#comment-16205778 ] Aljoscha Krettek commented on FLINK-7837: - This PR contains the fix:

[jira] [Commented] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal)

2017-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205643#comment-16205643 ] Aljoscha Krettek commented on FLINK-2747: - How do you mean? The problem is that the Scala compiler

[jira] [Commented] (FLINK-7368) MetricStore makes cpu spin at 100%

2017-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205633#comment-16205633 ] Aljoscha Krettek commented on FLINK-7368: - I think it's a blocker yes. But [~Zentol] is the expert

[jira] [Commented] (FLINK-7623) Detecting whether an operator is restored doesn't work with chained state

2017-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205634#comment-16205634 ] Aljoscha Krettek commented on FLINK-7623: - Yes, it's a blocker. > Detecting whether an operator

[jira] [Updated] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7845: Component/s: Network > Netty Exception when submitting batch job repeatedly >

[jira] [Updated] (FLINK-7838) Kafka 0.11 producer exactly-once test failure

2017-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7838: Fix Version/s: 1.4.0 > Kafka 0.11 producer exactly-once test failure >

[jira] [Commented] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

2017-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205594#comment-16205594 ] Aljoscha Krettek commented on FLINK-7839: - sounds good! > Creating Quickstart project for

[jira] [Updated] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

2017-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7839: Fix Version/s: 1.4.0 > Creating Quickstart project for SNAPSHOT version fails >

[jira] [Closed] (FLINK-7495) AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState()

2017-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7495. --- Resolution: Fixed Fix Version/s: 1.4.0 Fixed in

[jira] [Updated] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

2017-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7484: Fix Version/s: 1.3.3 > CaseClassSerializer.duplicate() does not perform proper deep copy >

[jira] [Closed] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

2017-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7484. --- Resolution: Fixed > CaseClassSerializer.duplicate() does not perform proper deep copy >

[jira] [Reopened] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

2017-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7484: - Reopen to fix {{fixVersion}}. > CaseClassSerializer.duplicate() does not perform proper deep

[jira] [Updated] (FLINK-7021) Flink Task Manager hangs on startup if one Zookeeper node is unresolvable

2017-10-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7021: Priority: Blocker (was: Major) > Flink Task Manager hangs on startup if one Zookeeper node

[jira] [Updated] (FLINK-7021) Flink Task Manager hangs on startup if one Zookeeper node is unresolvable

2017-10-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7021: Fix Version/s: 1.4.0 > Flink Task Manager hangs on startup if one Zookeeper node is

[jira] [Assigned] (FLINK-5808) Missing verification for setParallelism and setMaxParallelism

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-5808: --- Assignee: (was: Aljoscha Krettek) > Missing verification for setParallelism and

[jira] [Assigned] (FLINK-6113) Implement split/select with Side Outputs

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-6113: --- Assignee: (was: Aljoscha Krettek) > Implement split/select with Side Outputs >

[jira] [Assigned] (FLINK-5363) Fire timers when window state is currently empty

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-5363: --- Assignee: (was: Aljoscha Krettek) > Fire timers when window state is currently

[jira] [Closed] (FLINK-3582) Add Iterator over State for All Keys in Partitioned State

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-3582. --- Resolution: Fixed Fix Version/s: 1.4.0 Implemented in FLINK-7683 > Add Iterator over

[jira] [Closed] (FLINK-2706) Add support for streaming RollingFileSink to truncate / append on UNIX file systems

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2706. --- Resolution: Won't Fix This has been superseded by the work to make the {{BucketingSink}} our

[jira] [Assigned] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal)

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2747: --- Assignee: (was: Aljoscha Krettek) > TypeExtractor does not correctly analyze

[jira] [Closed] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2600. --- Resolution: Cannot Reproduce Hasn't occurred in about a year. > Failing

[jira] [Closed] (FLINK-2506) HBase connection closing down (table distributed over more than 1 region server - Flink Cluster-Mode)

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2506. --- Resolution: Won't Fix Closing after too much inactivity and code changed in between. > HBase

[jira] [Assigned] (FLINK-987) Extend TypeSerializers and -Comparators to work directly on Memory Segments

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-987: -- Assignee: (was: Aljoscha Krettek) > Extend TypeSerializers and -Comparators to work

[jira] [Assigned] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-4072: --- Assignee: (was: Aljoscha Krettek) >

[jira] [Closed] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7830. --- Resolution: Fixed > Problematic interaction of CEP and asynchronous snapshots >

[jira] [Created] (FLINK-7837) AggregatingFunction does not work with immutable types

2017-10-13 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7837: --- Summary: AggregatingFunction does not work with immutable types Key: FLINK-7837 URL: https://issues.apache.org/jira/browse/FLINK-7837 Project: Flink

[jira] [Assigned] (FLINK-5968) Document WindowedStream.aggregate()

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-5968: --- Assignee: Aljoscha Krettek > Document WindowedStream.aggregate() >

[jira] [Closed] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7484. --- Resolution: Fixed Fixed on release-1.3 in 664a04c8977c04698576d788b878b4c89f16acc6 Fixed on

[jira] [Assigned] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-7484: --- Assignee: Aljoscha Krettek > CaseClassSerializer.duplicate() does not perform proper

[jira] [Closed] (FLINK-7414) Hardcode scala.version to 2.11 in flink-quickstart-scala

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7414. --- Resolution: Fixed Fixed in 85b2f27067ce2fe5b16b3126c816b27e916477d8 > Hardcode scala.version

[jira] [Closed] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-6273. --- Resolution: Duplicate This has been superseded by FLINK-7540 > Client can't connect to

[jira] [Updated] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7484: Summary: CaseClassSerializer.duplicate() does not perform proper deep copy (was:

[jira] [Updated] (FLINK-4812) Report Watermark metrics in all operators

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4812: Priority: Critical (was: Blocker) > Report Watermark metrics in all operators >

[jira] [Commented] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203320#comment-16203320 ] Aljoscha Krettek commented on FLINK-4228: - [~cresny] Do you know if upload of YARN artefacts via

[jira] [Updated] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4228: Summary: YARN artifact upload does not work with S3AFileSystem (was: YARN artefact upload

[jira] [Updated] (FLINK-4228) YARN artefact upload does not work with S3AFileSystem

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4228: Summary: YARN artefact upload does not work with S3AFileSystem (was: RocksDB semi-async

[jira] [Updated] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7737: Priority: Blocker (was: Major) > On HCFS systems, FSDataOutputStream does not issue hsync

[jira] [Updated] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7737: Fix Version/s: 1.4.0 > On HCFS systems, FSDataOutputStream does not issue hsync only hflush

[jira] [Commented] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202513#comment-16202513 ] Aljoscha Krettek commented on FLINK-7830: - I think [~kkl0u]'s discovery in the {{NFASerializer}}

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202510#comment-16202510 ] Aljoscha Krettek commented on FLINK-7756: - I think the symptom could be the same as for the other

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202509#comment-16202509 ] Aljoscha Krettek commented on FLINK-6321: - It's probably the same underlying problem as for the

[jira] [Commented] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202503#comment-16202503 ] Aljoscha Krettek commented on FLINK-7435: - In addition to the {{NFASerializer}} there is a bug

[jira] [Commented] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202501#comment-16202501 ] Aljoscha Krettek commented on FLINK-7484: - The problem is this change:

[jira] [Commented] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202159#comment-16202159 ] Aljoscha Krettek commented on FLINK-7830: - I suspect that there is some issue with asynchronicity

[jira] [Updated] (FLINK-6318) NFA serialisation doesn't work with TypeSerializers that load classes

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6318: Issue Type: Sub-task (was: Improvement) Parent: FLINK-7830 > NFA serialisation

[jira] [Commented] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202154#comment-16202154 ] Aljoscha Krettek commented on FLINK-7830: - [~shashank734] and [~lidaiqing1993]: I created this as

[jira] [Updated] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6321: Issue Type: Sub-task (was: Bug) Parent: FLINK-7830 > RocksDB state backend

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7756: Issue Type: Sub-task (was: Bug) Parent: FLINK-7830 > RocksDB state backend

[jira] [Updated] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7484: Issue Type: Sub-task (was: Bug) Parent: FLINK-7830 >

[jira] [Updated] (FLINK-7760) Restore failing from external checkpointing metadata.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7760: Issue Type: Sub-task (was: Bug) Parent: FLINK-7830 > Restore failing from external

[jira] [Updated] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7435: Issue Type: Sub-task (was: Bug) Parent: FLINK-7830 > FsStateBackend with

[jira] [Created] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-12 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7830: --- Summary: Problematic interaction of CEP and asynchronous snapshots Key: FLINK-7830 URL: https://issues.apache.org/jira/browse/FLINK-7830 Project: Flink

[jira] [Commented] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202139#comment-16202139 ] Aljoscha Krettek commented on FLINK-7435: - [~lidaiqing1993] When you say incremental, did you mean

[jira] [Updated] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7435: Priority: Blocker (was: Major) > FsStateBackend with incremental backup enable does not

[jira] [Updated] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7435: Fix Version/s: 1.4.0 > FsStateBackend with incremental backup enable does not work with

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7756: Fix Version/s: 1.4.0 > RocksDB state backend Checkpointing (Async and Incremental) is not

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7756: Priority: Blocker (was: Major) > RocksDB state backend Checkpointing (Async and

[jira] [Commented] (FLINK-7760) Restore failing from external checkpointing metadata.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202112#comment-16202112 ] Aljoscha Krettek commented on FLINK-7760: - Are you using exactly the same jar when trying to

[jira] [Commented] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16201975#comment-16201975 ] Aljoscha Krettek commented on FLINK-7484: - If somehow the serialiser is not properly duplicated,

[jira] [Updated] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7484: Fix Version/s: 1.4.0 > com.esotericsoftware.kryo.KryoException:

[jira] [Updated] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7484: Priority: Blocker (was: Major) > com.esotericsoftware.kryo.KryoException:

[jira] [Commented] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16201974#comment-16201974 ] Aljoscha Krettek commented on FLINK-7484: - There has been an ML thread with another user where the

[jira] [Created] (FLINK-7829) Remove (or at least deprecate) DataStream.writeToFile/Csv

2017-10-12 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7829: --- Summary: Remove (or at least deprecate) DataStream.writeToFile/Csv Key: FLINK-7829 URL: https://issues.apache.org/jira/browse/FLINK-7829 Project: Flink

[jira] [Commented] (FLINK-7820) remove text related to FoldingState and FoldingStateDescriptor from doc

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16201881#comment-16201881 ] Aljoscha Krettek commented on FLINK-7820: - They are only deprecated, not removed yet, though. >

[jira] [Created] (FLINK-7828) Improve object copying/reuse mode for streaming runtime

2017-10-12 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7828: --- Summary: Improve object copying/reuse mode for streaming runtime Key: FLINK-7828 URL: https://issues.apache.org/jira/browse/FLINK-7828 Project: Flink

[jira] [Updated] (FLINK-5564) Add User Defined Aggregates in Table API

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5564: Summary: Add User Defined Aggregates in Table API (was: User Defined Aggregates) > Add

[jira] [Updated] (FLINK-5627) Allow job specific externalized checkpoint dir

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5627: Priority: Blocker (was: Major) > Allow job specific externalized checkpoint dir >

[jira] [Updated] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5015: Priority: Blocker (was: Critical) > Add Tests/ITCase for Kafka Per-Partition Watermarks >

[jira] [Assigned] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-5372: --- Assignee: (was: Aljoscha Krettek) > Fix

[jira] [Updated] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5704: Priority: Blocker (was: Major) > Deprecate FlinkKafkaConsumer constructors in favor of

[jira] [Updated] (FLINK-5763) Make savepoints self-contained and relocatable

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5763: Priority: Blocker (was: Major) > Make savepoints self-contained and relocatable >

[jira] [Commented] (FLINK-5920) Make port (range) of queryable state server configurable

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16201857#comment-16201857 ] Aljoscha Krettek commented on FLINK-5920: - This issue is now about the internal queryable state

[jira] [Updated] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5789: Priority: Blocker (was: Major) > Make Bucketing Sink independent of Hadoop's FileSystem >

[jira] [Updated] (FLINK-5920) Make port (range) of queryable state server configurable

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5920: Priority: Blocker (was: Major) > Make port (range) of queryable state server configurable

[jira] [Updated] (FLINK-5920) Make port (range) of queryable state server configurable

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5920: Summary: Make port (range) of queryable state server configurable (was: port range support

[jira] [Updated] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5823: Priority: Blocker (was: Major) > Store Checkpoint Root Metadata in StateBackend (not in HA

[jira] [Updated] (FLINK-5820) Extend State Backend Abstraction to support Global Cleanup Hooks

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5820: Priority: Blocker (was: Major) > Extend State Backend Abstraction to support Global

[jira] [Updated] (FLINK-5920) port range support for config query.server.port

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5920: Issue Type: Sub-task (was: Improvement) Parent: FLINK-5675 > port range support

[jira] [Updated] (FLINK-6163) Document per-window state in ProcessWindowFunction

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6163: Priority: Blocker (was: Critical) > Document per-window state in ProcessWindowFunction >

[jira] [Updated] (FLINK-5968) Document WindowedStream.aggregate()

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5968: Priority: Blocker (was: Critical) > Document WindowedStream.aggregate() >

[jira] [Updated] (FLINK-7540) Akka hostnames are not normalised consistently

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7540: Priority: Blocker (was: Critical) > Akka hostnames are not normalised consistently >

[jira] [Updated] (FLINK-7540) Akka hostnames are not normalised consistently

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7540: Fix Version/s: 1.4.0 > Akka hostnames are not normalised consistently >

[jira] [Updated] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6273: Priority: Blocker (was: Major) > Client can't connect to jobmanager whose hostname

[jira] [Updated] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6321: Priority: Blocker (was: Critical) > RocksDB state backend Checkpointing is not working

[jira] [Updated] (FLINK-6318) NFA serialisation doesn't work with TypeSerializers that load classes

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6318: Priority: Blocker (was: Critical) > NFA serialisation doesn't work with TypeSerializers

[jira] [Updated] (FLINK-6546) Fix dependencies of flink-mesos

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6546: Priority: Blocker (was: Major) > Fix dependencies of flink-mesos >

[jira] [Updated] (FLINK-6605) Allow users to specify a default name for processing time in Table API

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6605: Summary: Allow users to specify a default name for processing time in Table API (was:

[jira] [Updated] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6805: Priority: Blocker (was: Major) > Flink Cassandra connector dependency on Netty disagrees

[jira] [Updated] (FLINK-6861) Use OperatorID in metric system

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6861: Priority: Blocker (was: Major) > Use OperatorID in metric system >

[jira] [Updated] (FLINK-6963) Add User Defined Operator in Table API

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6963: Summary: Add User Defined Operator in Table API (was: User Defined Operator) > Add User

[jira] [Updated] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6944: Priority: Blocker (was: Major) > Introduce DefaultTypeSerializerConfigSnapshot as a base

[jira] [Updated] (FLINK-7100) TaskManager metrics are registered twice

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7100: Priority: Blocker (was: Major) > TaskManager metrics are registered twice >

[jira] [Updated] (FLINK-7266) Don't attempt to delete parent directory on S3

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7266: Priority: Blocker (was: Critical) > Don't attempt to delete parent directory on S3 >

[jira] [Commented] (FLINK-7266) Don't attempt to delete parent directory on S3

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16201823#comment-16201823 ] Aljoscha Krettek commented on FLINK-7266: - For 1.4, this will be resolved by only deleting the

[jira] [Updated] (FLINK-7778) Relocate ZooKeeper

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7778: Fix Version/s: 1.4.0 > Relocate ZooKeeper > -- > > Key:

[jira] [Updated] (FLINK-7418) Replace all uses of jackson with flink-shaded-jackson

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7418: Priority: Blocker (was: Major) > Replace all uses of jackson with flink-shaded-jackson >

[jira] [Updated] (FLINK-7417) Create flink-shaded-jackson

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7417: Priority: Blocker (was: Major) > Create flink-shaded-jackson > ---

[jira] [Updated] (FLINK-7779) Relocate Curator

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7779: Fix Version/s: 1.4.0 > Relocate Curator > > > Key:

[jira] [Updated] (FLINK-7779) Relocate Curator

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7779: Priority: Blocker (was: Minor) > Relocate Curator > > >

  1   2   3   4   5   6   7   8   9   10   >