[jira] [Created] (FLINK-14067) Decouple PlanExecutor from JSON plan generation

2019-09-12 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-14067: Summary: Decouple PlanExecutor from JSON plan generation Key: FLINK-14067 URL: https://issues.apache.org/jira/browse/FLINK-14067 Project: Flink Issue

[jira] [Created] (FLINK-14130) Remove ClusterClient.run() methods

2019-09-19 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-14130: Summary: Remove ClusterClient.run() methods Key: FLINK-14130 URL: https://issues.apache.org/jira/browse/FLINK-14130 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run"

2019-09-27 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-14250: Summary: Introduce separate "bin/flink runpy" and remove python support from "bin/flink run" Key: FLINK-14250 URL: https://issues.apache.org/jira/browse/FLINK-14250

[jira] [Created] (FLINK-14290) Decouple plan translation from job execution/ClusterClient

2019-09-30 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-14290: Summary: Decouple plan translation from job execution/ClusterClient Key: FLINK-14290 URL: https://issues.apache.org/jira/browse/FLINK-14290 Project: Flink

[jira] [Created] (FLINK-14391) Remove FlinkPlan Interface

2019-10-14 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-14391: Summary: Remove FlinkPlan Interface Key: FLINK-14391 URL: https://issues.apache.org/jira/browse/FLINK-14391 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14412) Rename ML Pipeline to MLPipeline

2019-10-16 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-14412: Summary: Rename ML Pipeline to MLPipeline Key: FLINK-14412 URL: https://issues.apache.org/jira/browse/FLINK-14412 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-14840) Use new Executor interface in SQL cli

2019-11-18 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-14840: Summary: Use new Executor interface in SQL cli Key: FLINK-14840 URL: https://issues.apache.org/jira/browse/FLINK-14840 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-14854) Add executeAsync() method to environments

2019-11-19 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-14854: Summary: Add executeAsync() method to environments Key: FLINK-14854 URL: https://issues.apache.org/jira/browse/FLINK-14854 Project: Flink Issue Type:

[jira] [Created] (FLINK-14968) Kerberized YARN on Docker test (custom fs plugin) fails on Travis

2019-11-27 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-14968: Summary: Kerberized YARN on Docker test (custom fs plugin) fails on Travis Key: FLINK-14968 URL: https://issues.apache.org/jira/browse/FLINK-14968 Project: Fl

[jira] [Created] (FLINK-14992) Add job submission listener to execution environments

2019-11-29 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-14992: Summary: Add job submission listener to execution environments Key: FLINK-14992 URL: https://issues.apache.org/jira/browse/FLINK-14992 Project: Flink

[jira] [Created] (FLINK-15007) Flink on YARN does not request required TaskExecutors in some cases

2019-12-02 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15007: Summary: Flink on YARN does not request required TaskExecutors in some cases Key: FLINK-15007 URL: https://issues.apache.org/jira/browse/FLINK-15007 Project:

[jira] [Created] (FLINK-15013) Flink (on YARN) sometimes needs too many slots

2019-12-02 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15013: Summary: Flink (on YARN) sometimes needs too many slots Key: FLINK-15013 URL: https://issues.apache.org/jira/browse/FLINK-15013 Project: Flink Issue

[jira] [Created] (FLINK-15116) Make JobClient stateless, remove AutoCloseable

2019-12-06 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15116: Summary: Make JobClient stateless, remove AutoCloseable Key: FLINK-15116 URL: https://issues.apache.org/jira/browse/FLINK-15116 Project: Flink Issue

[jira] [Created] (FLINK-15121) Add public constructor/getter for execution environments that takes Configuration

2019-12-06 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15121: Summary: Add public constructor/getter for execution environments that takes Configuration Key: FLINK-15121 URL: https://issues.apache.org/jira/browse/FLINK-15121

[jira] [Created] (FLINK-15129) Return JobClient instead of JobClient Future from executeAsync()

2019-12-08 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15129: Summary: Return JobClient instead of JobClient Future from executeAsync() Key: FLINK-15129 URL: https://issues.apache.org/jira/browse/FLINK-15129 Project: Fli

[jira] [Created] (FLINK-15157) Make ScalaShell ensureYarnConfig() and fetchConnectionInfo() public

2019-12-09 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15157: Summary: Make ScalaShell ensureYarnConfig() and fetchConnectionInfo() public Key: FLINK-15157 URL: https://issues.apache.org/jira/browse/FLINK-15157 Project:

[jira] [Created] (FLINK-12015) TaskManagerRunnerTest is unstable

2019-03-25 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-12015: Summary: TaskManagerRunnerTest is unstable Key: FLINK-12015 URL: https://issues.apache.org/jira/browse/FLINK-12015 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12019) ZooKeeperHaServicesTest.testCloseAndCleanupAllDataWithUncle is unstable

2019-03-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-12019: Summary: ZooKeeperHaServicesTest.testCloseAndCleanupAllDataWithUncle is unstable Key: FLINK-12019 URL: https://issues.apache.org/jira/browse/FLINK-12019 Proje

[jira] [Created] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable

2019-03-27 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-12030: Summary: KafkaITCase.testMultipleSourcesOnePartition is unstable Key: FLINK-12030 URL: https://issues.apache.org/jira/browse/FLINK-12030 Project: Flink

[jira] [Created] (FLINK-12164) JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable

2019-04-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-12164: Summary: JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable Key: FLINK-12164 URL: https://issues.apache.org/jira/browse/FLINK-12164 Proj

[jira] [Created] (FLINK-12501) AvroTypeSerializer does not work with types generated by avrohugger

2019-05-13 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-12501: Summary: AvroTypeSerializer does not work with types generated by avrohugger Key: FLINK-12501 URL: https://issues.apache.org/jira/browse/FLINK-12501 Project:

[jira] [Created] (FLINK-12587) Add pure-API Watermark class

2019-05-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-12587: Summary: Add pure-API Watermark class Key: FLINK-12587 URL: https://issues.apache.org/jira/browse/FLINK-12587 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12606) Move SourceFunction to flink-core

2019-05-23 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-12606: Summary: Move SourceFunction to flink-core Key: FLINK-12606 URL: https://issues.apache.org/jira/browse/FLINK-12606 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-12613) Move SinkFunction to flink-core

2019-05-24 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-12613: Summary: Move SinkFunction to flink-core Key: FLINK-12613 URL: https://issues.apache.org/jira/browse/FLINK-12613 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-12832) Enhance StreamGraphGenerator/StreamGraph for Blink Table Runner

2019-06-13 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-12832: Summary: Enhance StreamGraphGenerator/StreamGraph for Blink Table Runner Key: FLINK-12832 URL: https://issues.apache.org/jira/browse/FLINK-12832 Project: Flin

[jira] [Created] (FLINK-13041) Make ScheduleMode configurable on ExecutionConfig

2019-07-01 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-13041: Summary: Make ScheduleMode configurable on ExecutionConfig Key: FLINK-13041 URL: https://issues.apache.org/jira/browse/FLINK-13041 Project: Flink Iss

[jira] [Created] (FLINK-13062) Set ScheduleMode based on boundedness of streaming Pipeline

2019-07-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-13062: Summary: Set ScheduleMode based on boundedness of streaming Pipeline Key: FLINK-13062 URL: https://issues.apache.org/jira/browse/FLINK-13062 Project: Flink

[jira] [Created] (FLINK-13396) Deprecate BucketingSink

2019-07-24 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-13396: Summary: Deprecate BucketingSink Key: FLINK-13396 URL: https://issues.apache.org/jira/browse/FLINK-13396 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-13397) Remove RollingSink

2019-07-24 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-13397: Summary: Remove RollingSink Key: FLINK-13397 URL: https://issues.apache.org/jira/browse/FLINK-13397 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-13601) RegionFailoverITCase is unstable

2019-08-06 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-13601: Summary: RegionFailoverITCase is unstable Key: FLINK-13601 URL: https://issues.apache.org/jira/browse/FLINK-13601 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-10563) Expose shaded Presto S3 filesystem under "s3p" scheme

2018-10-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-10563: Summary: Expose shaded Presto S3 filesystem under "s3p" scheme Key: FLINK-10563 URL: https://issues.apache.org/jira/browse/FLINK-10563 Project: Flink

[jira] [Created] (FLINK-10740) Refactor Source Interface

2018-10-31 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-10740: Summary: Refactor Source Interface Key: FLINK-10740 URL: https://issues.apache.org/jira/browse/FLINK-10740 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-11539) Add TypeSerializerSnapshot for TraversableSerializer

2019-02-06 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-11539: Summary: Add TypeSerializerSnapshot for TraversableSerializer Key: FLINK-11539 URL: https://issues.apache.org/jira/browse/FLINK-11539 Project: Flink

[jira] [Created] (FLINK-11693) Add KafkaSerializationSchema that directly uses ProducerRecord

2019-02-20 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-11693: Summary: Add KafkaSerializationSchema that directly uses ProducerRecord Key: FLINK-11693 URL: https://issues.apache.org/jira/browse/FLINK-11693 Project: Flink

[jira] [Created] (FLINK-11751) Extend release notes for Flink 1.8

2019-02-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-11751: Summary: Extend release notes for Flink 1.8 Key: FLINK-11751 URL: https://issues.apache.org/jira/browse/FLINK-11751 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-11780) Change version scheme of Hadoop-based modules to conform to SNAPSHOT guidelines

2019-02-28 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-11780: Summary: Change version scheme of Hadoop-based modules to conform to SNAPSHOT guidelines Key: FLINK-11780 URL: https://issues.apache.org/jira/browse/FLINK-11780

[jira] [Created] (FLINK-11791) Describe how to build Flink with Hadoop in build guide

2019-03-01 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-11791: Summary: Describe how to build Flink with Hadoop in build guide Key: FLINK-11791 URL: https://issues.apache.org/jira/browse/FLINK-11791 Project: Flink

[jira] [Created] (FLINK-11836) Update NOTICE-binary and licenses-binary for Flink 1.8.0

2019-03-06 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-11836: Summary: Update NOTICE-binary and licenses-binary for Flink 1.8.0 Key: FLINK-11836 URL: https://issues.apache.org/jira/browse/FLINK-11836 Project: Flink

[jira] [Created] (FLINK-11865) Code generation in TraversableSerializer is prohibitively slow

2019-03-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-11865: Summary: Code generation in TraversableSerializer is prohibitively slow Key: FLINK-11865 URL: https://issues.apache.org/jira/browse/FLINK-11865 Project: Flink

[jira] [Created] (FLINK-11889) Remove "stop" signal along with Stoppable interfaces

2019-03-12 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-11889: Summary: Remove "stop" signal along with Stoppable interfaces Key: FLINK-11889 URL: https://issues.apache.org/jira/browse/FLINK-11889 Project: Flink

[jira] [Created] (FLINK-12006) ZooKeeperHaServicesTest is unstable

2019-03-25 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-12006: Summary: ZooKeeperHaServicesTest is unstable Key: FLINK-12006 URL: https://issues.apache.org/jira/browse/FLINK-12006 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15251) Fabric8FlinkKubeClient doesn't work if ingress has hostname but no IP

2019-12-13 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15251: Summary: Fabric8FlinkKubeClient doesn't work if ingress has hostname but no IP Key: FLINK-15251 URL: https://issues.apache.org/jira/browse/FLINK-15251 Project

[jira] [Created] (FLINK-15265) Remove "-executor" suffix from executor names

2019-12-15 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15265: Summary: Remove "-executor" suffix from executor names Key: FLINK-15265 URL: https://issues.apache.org/jira/browse/FLINK-15265 Project: Flink Issue T

[jira] [Created] (FLINK-15474) In TypeSerializerUpgradeTestBase, create serializer snapshots "on demand"

2020-01-03 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15474: Summary: In TypeSerializerUpgradeTestBase, create serializer snapshots "on demand" Key: FLINK-15474 URL: https://issues.apache.org/jira/browse/FLINK-15474 Pro

[jira] [Created] (FLINK-15518) Don't hide web frontend side pane automatically

2020-01-08 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15518: Summary: Don't hide web frontend side pane automatically Key: FLINK-15518 URL: https://issues.apache.org/jira/browse/FLINK-15518 Project: Flink Issue

[jira] [Created] (FLINK-15735) Too many warnings when running bin/start-cluster.sh

2020-01-23 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15735: Summary: Too many warnings when running bin/start-cluster.sh Key: FLINK-15735 URL: https://issues.apache.org/jira/browse/FLINK-15735 Project: Flink I

[jira] [Created] (FLINK-15904) Make Kafka Consumer work with activated "disableGenericTypes()"

2020-02-04 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15904: Summary: Make Kafka Consumer work with activated "disableGenericTypes()" Key: FLINK-15904 URL: https://issues.apache.org/jira/browse/FLINK-15904 Project: Flin

[jira] [Created] (FLINK-15993) Add timeout to 404 documentation redirect, add explanation

2020-02-11 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15993: Summary: Add timeout to 404 documentation redirect, add explanation Key: FLINK-15993 URL: https://issues.apache.org/jira/browse/FLINK-15993 Project: Flink

[jira] [Created] (FLINK-15997) Make documentation 404 page look like a documentation page

2020-02-11 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15997: Summary: Make documentation 404 page look like a documentation page Key: FLINK-15997 URL: https://issues.apache.org/jira/browse/FLINK-15997 Project: Flink

[jira] [Created] (FLINK-15998) Revert rename of "Job Cluster" to "Application Cluster" in documentation

2020-02-11 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15998: Summary: Revert rename of "Job Cluster" to "Application Cluster" in documentation Key: FLINK-15998 URL: https://issues.apache.org/jira/browse/FLINK-15998 Proj

[jira] [Created] (FLINK-15999) Extract “Concepts” material from API/Library sections and start proper concepts section

2020-02-11 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15999: Summary: Extract “Concepts” material from API/Library sections and start proper concepts section Key: FLINK-15999 URL: https://issues.apache.org/jira/browse/FLINK-15999

[jira] [Created] (FLINK-16000) Move "Project Build Setup" to "Getting Started" in documentation

2020-02-11 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16000: Summary: Move "Project Build Setup" to "Getting Started" in documentation Key: FLINK-16000 URL: https://issues.apache.org/jira/browse/FLINK-16000 Project: Fli

[jira] [Created] (FLINK-16041) Expand "popular" documentation sections by default

2020-02-13 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16041: Summary: Expand "popular" documentation sections by default Key: FLINK-16041 URL: https://issues.apache.org/jira/browse/FLINK-16041 Project: Flink Is

[jira] [Created] (FLINK-16045) Extract connectors documentation to a top-level section

2020-02-13 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16045: Summary: Extract connectors documentation to a top-level section Key: FLINK-16045 URL: https://issues.apache.org/jira/browse/FLINK-16045 Project: Flink

[jira] [Created] (FLINK-16044) Extract libraries documentation to a top-level section

2020-02-13 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16044: Summary: Extract libraries documentation to a top-level section Key: FLINK-16044 URL: https://issues.apache.org/jira/browse/FLINK-16044 Project: Flink

[jira] [Created] (FLINK-16049) Remove outdated "Best Pracatices" section from Application Development Section

2020-02-13 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16049: Summary: Remove outdated "Best Pracatices" section from Application Development Section Key: FLINK-16049 URL: https://issues.apache.org/jira/browse/FLINK-16049

[jira] [Created] (FLINK-16144) Add client.timeout setting and use that for CLI operations

2020-02-18 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16144: Summary: Add client.timeout setting and use that for CLI operations Key: FLINK-16144 URL: https://issues.apache.org/jira/browse/FLINK-16144 Project: Flink

[jira] [Created] (FLINK-16207) In stream processing concepts section, rework distribution patterns description

2020-02-21 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16207: Summary: In stream processing concepts section, rework distribution patterns description Key: FLINK-16207 URL: https://issues.apache.org/jira/browse/FLINK-16207

[jira] [Created] (FLINK-16208) Add introduction to timely stream processing concepts documentation

2020-02-21 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16208: Summary: Add introduction to timely stream processing concepts documentation Key: FLINK-16208 URL: https://issues.apache.org/jira/browse/FLINK-16208 Project:

[jira] [Created] (FLINK-16209) Add Latency and Completeness section in timely stream processing concepts

2020-02-21 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16209: Summary: Add Latency and Completeness section in timely stream processing concepts Key: FLINK-16209 URL: https://issues.apache.org/jira/browse/FLINK-16209 Pro

[jira] [Created] (FLINK-16210) Add section about applications and clusters/session in concepts documentation

2020-02-21 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16210: Summary: Add section about applications and clusters/session in concepts documentation Key: FLINK-16210 URL: https://issues.apache.org/jira/browse/FLINK-16210

[jira] [Created] (FLINK-16211) Add introduction to stream processing concepts documentation

2020-02-21 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16211: Summary: Add introduction to stream processing concepts documentation Key: FLINK-16211 URL: https://issues.apache.org/jira/browse/FLINK-16211 Project: Flink

[jira] [Created] (FLINK-16212) Describe how Flink is a unified batch/stream processing system in concepts documentation

2020-02-21 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16212: Summary: Describe how Flink is a unified batch/stream processing system in concepts documentation Key: FLINK-16212 URL: https://issues.apache.org/jira/browse/FLINK-16212

[jira] [Created] (FLINK-16213) Add "What Is State" section in concepts documentation

2020-02-21 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16213: Summary: Add "What Is State" section in concepts documentation Key: FLINK-16213 URL: https://issues.apache.org/jira/browse/FLINK-16213 Project: Flink

[jira] [Created] (FLINK-16214) Describe how state is different for stream/batch programs in concepts documentation

2020-02-21 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16214: Summary: Describe how state is different for stream/batch programs in concepts documentation Key: FLINK-16214 URL: https://issues.apache.org/jira/browse/FLINK-16214

[jira] [Created] (FLINK-16216) Describe end-to-end exactly once programs in stateful stream processing concepts documentation

2020-02-21 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16216: Summary: Describe end-to-end exactly once programs in stateful stream processing concepts documentation Key: FLINK-16216 URL: https://issues.apache.org/jira/browse/FLINK-1

[jira] [Created] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

2020-03-12 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-16572: Summary: CheckPubSubEmulatorTest is flaky on Azure Key: FLINK-16572 URL: https://issues.apache.org/jira/browse/FLINK-16572 Project: Flink Issue Type:

[jira] [Created] (FLINK-2891) Key for Keyed State is not set upon Window Evaluation

2015-10-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2891: --- Summary: Key for Keyed State is not set upon Window Evaluation Key: FLINK-2891 URL: https://issues.apache.org/jira/browse/FLINK-2891 Project: Flink Iss

[jira] [Created] (FLINK-2922) Add Queryable Window Operator

2015-10-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2922: --- Summary: Add Queryable Window Operator Key: FLINK-2922 URL: https://issues.apache.org/jira/browse/FLINK-2922 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation

2015-11-10 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2991: --- Summary: Extend Window Operators to Allow Efficient Fold Operation Key: FLINK-2991 URL: https://issues.apache.org/jira/browse/FLINK-2991 Project: Flink

[jira] [Created] (FLINK-3024) TimestampExtractor Does not Work When returning Long.MIN_VALUE

2015-11-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3024: --- Summary: TimestampExtractor Does not Work When returning Long.MIN_VALUE Key: FLINK-3024 URL: https://issues.apache.org/jira/browse/FLINK-3024 Project: Flink

[jira] [Created] (FLINK-3174) Add merging WindowAssigner

2015-12-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3174: --- Summary: Add merging WindowAssigner Key: FLINK-3174 URL: https://issues.apache.org/jira/browse/FLINK-3174 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3177) Add Stream Operator that Discards Late Elements

2015-12-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3177: --- Summary: Add Stream Operator that Discards Late Elements Key: FLINK-3177 URL: https://issues.apache.org/jira/browse/FLINK-3177 Project: Flink Issue Typ

[jira] [Created] (FLINK-3178) Make Closing Behavior of Window Operators Configurable

2015-12-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3178: --- Summary: Make Closing Behavior of Window Operators Configurable Key: FLINK-3178 URL: https://issues.apache.org/jira/browse/FLINK-3178 Project: Flink Is

[jira] [Created] (FLINK-3200) Use Partitioned State Abstraction in WindowOperator

2016-01-05 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3200: --- Summary: Use Partitioned State Abstraction in WindowOperator Key: FLINK-3200 URL: https://issues.apache.org/jira/browse/FLINK-3200 Project: Flink Issue

[jira] [Created] (FLINK-3201) Enhance Partitioned State Interface with State Types

2016-01-05 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3201: --- Summary: Enhance Partitioned State Interface with State Types Key: FLINK-3201 URL: https://issues.apache.org/jira/browse/FLINK-3201 Project: Flink Issu

[jira] [Created] (FLINK-3202) Make Timer/Trigger Service Scoped to Key/Namespace

2016-01-05 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3202: --- Summary: Make Timer/Trigger Service Scoped to Key/Namespace Key: FLINK-3202 URL: https://issues.apache.org/jira/browse/FLINK-3202 Project: Flink Issue

[jira] [Created] (FLINK-3242) User-specified StateBackend is not Respected if Checkpointing is Disabled

2016-01-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3242: --- Summary: User-specified StateBackend is not Respected if Checkpointing is Disabled Key: FLINK-3242 URL: https://issues.apache.org/jira/browse/FLINK-3242 Project

[jira] [Created] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows

2016-01-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3243: --- Summary: Fix Interplay of TimeCharacteristic and Time Windows Key: FLINK-3243 URL: https://issues.apache.org/jira/browse/FLINK-3243 Project: Flink Issu

[jira] [Created] (FLINK-3278) Add Partitioned State Backend Based on RocksDB

2016-01-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3278: --- Summary: Add Partitioned State Backend Based on RocksDB Key: FLINK-3278 URL: https://issues.apache.org/jira/browse/FLINK-3278 Project: Flink Issue Type

[jira] [Created] (FLINK-3315) Fix Slot Sharing in Streaming API

2016-02-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3315: --- Summary: Fix Slot Sharing in Streaming API Key: FLINK-3315 URL: https://issues.apache.org/jira/browse/FLINK-3315 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3336) Add Semi-Rebalance Data Shipping for DataStream

2016-02-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3336: --- Summary: Add Semi-Rebalance Data Shipping for DataStream Key: FLINK-3336 URL: https://issues.apache.org/jira/browse/FLINK-3336 Project: Flink Issue Typ

[jira] [Created] (FLINK-3400) RocksDB Backend does not work when not in Flink lib folder

2016-02-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3400: --- Summary: RocksDB Backend does not work when not in Flink lib folder Key: FLINK-3400 URL: https://issues.apache.org/jira/browse/FLINK-3400 Project: Flink

[jira] [Created] (FLINK-3402) Refactor Common Parts of Stream/Batch Documentation

2016-02-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3402: --- Summary: Refactor Common Parts of Stream/Batch Documentation Key: FLINK-3402 URL: https://issues.apache.org/jira/browse/FLINK-3402 Project: Flink Issue

[jira] [Created] (FLINK-3403) Create Section "Working with Time" in Streaming Guide

2016-02-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3403: --- Summary: Create Section "Working with Time" in Streaming Guide Key: FLINK-3403 URL: https://issues.apache.org/jira/browse/FLINK-3403 Project: Flink Iss

[jira] [Created] (FLINK-3417) Add RocksDB StateBackendFactory and integrate with Flink Config

2016-02-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3417: --- Summary: Add RocksDB StateBackendFactory and integrate with Flink Config Key: FLINK-3417 URL: https://issues.apache.org/jira/browse/FLINK-3417 Project: Flink

[jira] [Created] (FLINK-3419) Drop partitionByHash from DataStream

2016-02-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3419: --- Summary: Drop partitionByHash from DataStream Key: FLINK-3419 URL: https://issues.apache.org/jira/browse/FLINK-3419 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-3430) Remove "no POJO" warning in TypeAnalyzer

2016-02-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3430: --- Summary: Remove "no POJO" warning in TypeAnalyzer Key: FLINK-3430 URL: https://issues.apache.org/jira/browse/FLINK-3430 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-3436) Remove ComplexIntegrationITCase

2016-02-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3436: --- Summary: Remove ComplexIntegrationITCase Key: FLINK-3436 URL: https://issues.apache.org/jira/browse/FLINK-3436 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3439) Remove final Long.MAX_VALUE Watermark in StreamSource

2016-02-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3439: --- Summary: Remove final Long.MAX_VALUE Watermark in StreamSource Key: FLINK-3439 URL: https://issues.apache.org/jira/browse/FLINK-3439 Project: Flink Iss

[jira] [Created] (FLINK-3450) RocksDB Backed Window Fails with KryoSerializer

2016-02-19 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3450: --- Summary: RocksDB Backed Window Fails with KryoSerializer Key: FLINK-3450 URL: https://issues.apache.org/jira/browse/FLINK-3450 Project: Flink Issue Typ

[jira] [Created] (FLINK-3512) Savepoint backend should not revert to "jobmanager"

2016-02-25 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3512: --- Summary: Savepoint backend should not revert to "jobmanager" Key: FLINK-3512 URL: https://issues.apache.org/jira/browse/FLINK-3512 Project: Flink Issue

[jira] [Created] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator

2016-02-25 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3513: --- Summary: Fix interplay of automatic Operator UID and Changing name of WindowOperator Key: FLINK-3513 URL: https://issues.apache.org/jira/browse/FLINK-3513 Proje

[jira] [Created] (FLINK-3521) Make Iterable part of method signature for WindowFunction

2016-02-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3521: --- Summary: Make Iterable part of method signature for WindowFunction Key: FLINK-3521 URL: https://issues.apache.org/jira/browse/FLINK-3521 Project: Flink

[jira] [Created] (FLINK-3527) Scala DataStream has no transform method

2016-02-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3527: --- Summary: Scala DataStream has no transform method Key: FLINK-3527 URL: https://issues.apache.org/jira/browse/FLINK-3527 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-3528) Add Incremental Fold for Non-Keyed Window Operator

2016-02-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3528: --- Summary: Add Incremental Fold for Non-Keyed Window Operator Key: FLINK-3528 URL: https://issues.apache.org/jira/browse/FLINK-3528 Project: Flink Issue

[jira] [Created] (FLINK-3548) Remove unnecessary generic parameter from SingleOutputStreamOperator

2016-02-29 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3548: --- Summary: Remove unnecessary generic parameter from SingleOutputStreamOperator Key: FLINK-3548 URL: https://issues.apache.org/jira/browse/FLINK-3548 Project: Fli

[jira] [Created] (FLINK-3565) FlinkKafkaConsumer does not work with Scala 2.11

2016-03-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3565: --- Summary: FlinkKafkaConsumer does not work with Scala 2.11 Key: FLINK-3565 URL: https://issues.apache.org/jira/browse/FLINK-3565 Project: Flink Issue T

[jira] [Created] (FLINK-3575) Update Working With State Section in Doc

2016-03-03 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3575: --- Summary: Update Working With State Section in Doc Key: FLINK-3575 URL: https://issues.apache.org/jira/browse/FLINK-3575 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-3581) Add Non-Keyed Window Trigger

2016-03-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3581: --- Summary: Add Non-Keyed Window Trigger Key: FLINK-3581 URL: https://issues.apache.org/jira/browse/FLINK-3581 Project: Flink Issue Type: Improvement

  1   2   3   4   5   >