[jira] [Created] (FLINK-3481) KafkaShortRetention08ITCase.testAutoOffsetReset failed on Travis

Till Rohrmann created FLINK-3481: Summary: KafkaShortRetention08ITCase.testAutoOffsetReset failed on Travis Key: FLINK-3481 URL: https://issues.apache.org/jira/browse/FLINK-3481 Project: Flink

[jira] [Created] (FLINK-3484) Add setSlotSharingGroup documentation

Till Rohrmann created FLINK-3484: Summary: Add setSlotSharingGroup documentation Key: FLINK-3484 URL: https://issues.apache.org/jira/browse/FLINK-3484 Project: Flink Issue Type: Task Affe

[jira] [Created] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis

Till Rohrmann created FLINK-3488: Summary: Kafka08ITCase.testBigRecordJob fails on Travis Key: FLINK-3488 URL: https://issues.apache.org/jira/browse/FLINK-3488 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis

Till Rohrmann created FLINK-3530: Summary: Kafka09ITCase.testBigRecordJob fails on Travis Key: FLINK-3530 URL: https://issues.apache.org/jira/browse/FLINK-3530 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3531) KafkaShortRetention09ITCase.testAutoOffsetReset fails on Travis

Till Rohrmann created FLINK-3531: Summary: KafkaShortRetention09ITCase.testAutoOffsetReset fails on Travis Key: FLINK-3531 URL: https://issues.apache.org/jira/browse/FLINK-3531 Project: Flink

[jira] [Created] (FLINK-3532) Flink-gelly-examples jar contains an underscore instead of an hyphen

Till Rohrmann created FLINK-3532: Summary: Flink-gelly-examples jar contains an underscore instead of an hyphen Key: FLINK-3532 URL: https://issues.apache.org/jira/browse/FLINK-3532 Project: Flink

[jira] [Created] (FLINK-3536) Make clearer distinction between event time and processing time

Till Rohrmann created FLINK-3536: Summary: Make clearer distinction between event time and processing time Key: FLINK-3536 URL: https://issues.apache.org/jira/browse/FLINK-3536 Project: Flink

[jira] [Created] (FLINK-3538) DataStream join API does not enforce consistent usage

Till Rohrmann created FLINK-3538: Summary: DataStream join API does not enforce consistent usage Key: FLINK-3538 URL: https://issues.apache.org/jira/browse/FLINK-3538 Project: Flink Issue Typ

[jira] [Created] (FLINK-3541) Clean up workaround in FlinkKafkaConsumer09

Till Rohrmann created FLINK-3541: Summary: Clean up workaround in FlinkKafkaConsumer09 Key: FLINK-3541 URL: https://issues.apache.org/jira/browse/FLINK-3541 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-3542) FlinkKafkaConsumer09 cannot handle changing number of partitions

Till Rohrmann created FLINK-3542: Summary: FlinkKafkaConsumer09 cannot handle changing number of partitions Key: FLINK-3542 URL: https://issues.apache.org/jira/browse/FLINK-3542 Project: Flink

[jira] [Created] (FLINK-3553) Don't include watermarks in record count

Till Rohrmann created FLINK-3553: Summary: Don't include watermarks in record count Key: FLINK-3553 URL: https://issues.apache.org/jira/browse/FLINK-3553 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-3555) Web interface does not render job information properly

Till Rohrmann created FLINK-3555: Summary: Web interface does not render job information properly Key: FLINK-3555 URL: https://issues.apache.org/jira/browse/FLINK-3555 Project: Flink Issue Ty

[jira] [Created] (FLINK-3557) Scala DataStream fold method should take fold function in secondary parameter list

Till Rohrmann created FLINK-3557: Summary: Scala DataStream fold method should take fold function in secondary parameter list Key: FLINK-3557 URL: https://issues.apache.org/jira/browse/FLINK-3557 Proj

[jira] [Created] (FLINK-3560) Examples shouldn't always print usage statement

Till Rohrmann created FLINK-3560: Summary: Examples shouldn't always print usage statement Key: FLINK-3560 URL: https://issues.apache.org/jira/browse/FLINK-3560 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-3570) Replace random NIC selection heuristic by InetAddress.getLocalHost

Till Rohrmann created FLINK-3570: Summary: Replace random NIC selection heuristic by InetAddress.getLocalHost Key: FLINK-3570 URL: https://issues.apache.org/jira/browse/FLINK-3570 Project: Flink

[jira] [Created] (FLINK-3571) SavepointITCase.testRestoreFailure fails on Travis

Till Rohrmann created FLINK-3571: Summary: SavepointITCase.testRestoreFailure fails on Travis Key: FLINK-3571 URL: https://issues.apache.org/jira/browse/FLINK-3571 Project: Flink Issue Type:

[jira] [Created] (FLINK-3572) SourceStreamTaskTest.testCheckpointing fails on Travis

Till Rohrmann created FLINK-3572: Summary: SourceStreamTaskTest.testCheckpointing fails on Travis Key: FLINK-3572 URL: https://issues.apache.org/jira/browse/FLINK-3572 Project: Flink Issue Ty

[jira] [Created] (FLINK-3633) Job submission silently fails when using user code types

Till Rohrmann created FLINK-3633: Summary: Job submission silently fails when using user code types Key: FLINK-3633 URL: https://issues.apache.org/jira/browse/FLINK-3633 Project: Flink Issue

[jira] [Created] (FLINK-3641) Document registerCachedFile API call

Till Rohrmann created FLINK-3641: Summary: Document registerCachedFile API call Key: FLINK-3641 URL: https://issues.apache.org/jira/browse/FLINK-3641 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3642) Disentangle ExecutionConfig

Till Rohrmann created FLINK-3642: Summary: Disentangle ExecutionConfig Key: FLINK-3642 URL: https://issues.apache.org/jira/browse/FLINK-3642 Project: Flink Issue Type: Improvement Affects

[jira] [Created] (FLINK-3649) Document stable API methods maxBy/minBy

Till Rohrmann created FLINK-3649: Summary: Document stable API methods maxBy/minBy Key: FLINK-3649 URL: https://issues.apache.org/jira/browse/FLINK-3649 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

Till Rohrmann created FLINK-3650: Summary: Add maxBy/minBy to Scala DataSet API Key: FLINK-3650 URL: https://issues.apache.org/jira/browse/FLINK-3650 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3681) CEP library does not support Java 8 lambdas as select function

Till Rohrmann created FLINK-3681: Summary: CEP library does not support Java 8 lambdas as select function Key: FLINK-3681 URL: https://issues.apache.org/jira/browse/FLINK-3681 Project: Flink

[jira] [Created] (FLINK-3682) CEP operator does not set the processing timestamp correctly

Till Rohrmann created FLINK-3682: Summary: CEP operator does not set the processing timestamp correctly Key: FLINK-3682 URL: https://issues.apache.org/jira/browse/FLINK-3682 Project: Flink I

[jira] [Created] (FLINK-3684) CEP operator does not forward watermarks properly

Till Rohrmann created FLINK-3684: Summary: CEP operator does not forward watermarks properly Key: FLINK-3684 URL: https://issues.apache.org/jira/browse/FLINK-3684 Project: Flink Issue Type: B

[jira] [Created] (FLINK-3694) Document stoppable function interface for custom sources

Till Rohrmann created FLINK-3694: Summary: Document stoppable function interface for custom sources Key: FLINK-3694 URL: https://issues.apache.org/jira/browse/FLINK-3694 Project: Flink Issue

[jira] [Created] (FLINK-3703) Add sequence matching semantics to discard matched events

Till Rohrmann created FLINK-3703: Summary: Add sequence matching semantics to discard matched events Key: FLINK-3703 URL: https://issues.apache.org/jira/browse/FLINK-3703 Project: Flink Issue

[jira] [Created] (FLINK-3707) Add missing Rich(Flat)JoinCoGroupFunction

Till Rohrmann created FLINK-3707: Summary: Add missing Rich(Flat)JoinCoGroupFunction Key: FLINK-3707 URL: https://issues.apache.org/jira/browse/FLINK-3707 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-3708) Scala API for CEP

Till Rohrmann created FLINK-3708: Summary: Scala API for CEP Key: FLINK-3708 URL: https://issues.apache.org/jira/browse/FLINK-3708 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-3755) Introduce key groups for key-value state to support dynamic scaling

Till Rohrmann created FLINK-3755: Summary: Introduce key groups for key-value state to support dynamic scaling Key: FLINK-3755 URL: https://issues.apache.org/jira/browse/FLINK-3755 Project: Flink

[jira] [Created] (FLINK-3756) Introduce state hierarchy in CheckpointCoordinator

Till Rohrmann created FLINK-3756: Summary: Introduce state hierarchy in CheckpointCoordinator Key: FLINK-3756 URL: https://issues.apache.org/jira/browse/FLINK-3756 Project: Flink Issue Type:

[jira] [Created] (FLINK-3761) Introduce key group state backend

Till Rohrmann created FLINK-3761: Summary: Introduce key group state backend Key: FLINK-3761 URL: https://issues.apache.org/jira/browse/FLINK-3761 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3764) LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification fails on Travis

Till Rohrmann created FLINK-3764: Summary: LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification fails on Travis Key: FLINK-3764 URL: https://issues.apache.org/jira/browse/FLINK-3764

[jira] [Created] (FLINK-3765) ScalaShellITCase deadlocks spuriously

Till Rohrmann created FLINK-3765: Summary: ScalaShellITCase deadlocks spuriously Key: FLINK-3765 URL: https://issues.apache.org/jira/browse/FLINK-3765 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment

Till Rohrmann created FLINK-3774: Summary: Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment Key: FLINK-3774 URL: https://issues.apache.org/jira/browse/FLINK-3774

[jira] [Created] (FLINK-3775) Flink Scala shell does not respect Flink configuration

Till Rohrmann created FLINK-3775: Summary: Flink Scala shell does not respect Flink configuration Key: FLINK-3775 URL: https://issues.apache.org/jira/browse/FLINK-3775 Project: Flink Issue Ty

[jira] [Created] (FLINK-3776) Flink Scala shell does not allow to set configuration for local execution

Till Rohrmann created FLINK-3776: Summary: Flink Scala shell does not allow to set configuration for local execution Key: FLINK-3776 URL: https://issues.apache.org/jira/browse/FLINK-3776 Project: Flin

[jira] [Created] (FLINK-3778) ScalaShellRemoteStreamEnvironment cannot be forwarded a user configuration

Till Rohrmann created FLINK-3778: Summary: ScalaShellRemoteStreamEnvironment cannot be forwarded a user configuration Key: FLINK-3778 URL: https://issues.apache.org/jira/browse/FLINK-3778 Project: Fli

[jira] [Created] (FLINK-3787) Yarn client does not report unfulfillable container constraints

Till Rohrmann created FLINK-3787: Summary: Yarn client does not report unfulfillable container constraints Key: FLINK-3787 URL: https://issues.apache.org/jira/browse/FLINK-3787 Project: Flink

[jira] [Created] (FLINK-3800) ExecutionGraphs can become orphans

Till Rohrmann created FLINK-3800: Summary: ExecutionGraphs can become orphans Key: FLINK-3800 URL: https://issues.apache.org/jira/browse/FLINK-3800 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-3804) Update YARN documentation

Till Rohrmann created FLINK-3804: Summary: Update YARN documentation Key: FLINK-3804 URL: https://issues.apache.org/jira/browse/FLINK-3804 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-3807) FastFailuresITCase deadlocks on Travis

Till Rohrmann created FLINK-3807: Summary: FastFailuresITCase deadlocks on Travis Key: FLINK-3807 URL: https://issues.apache.org/jira/browse/FLINK-3807 Project: Flink Issue Type: Bug Affe

[jira] [Created] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis

Till Rohrmann created FLINK-3813: Summary: YARNSessionFIFOITCase.testDetachedMode failed on Travis Key: FLINK-3813 URL: https://issues.apache.org/jira/browse/FLINK-3813 Project: Flink Issue T

[jira] [Created] (FLINK-3820) ScalaShellITCase.testPreventRecreationBatch deadlocks on Travis

Till Rohrmann created FLINK-3820: Summary: ScalaShellITCase.testPreventRecreationBatch deadlocks on Travis Key: FLINK-3820 URL: https://issues.apache.org/jira/browse/FLINK-3820 Project: Flink

[jira] [Created] (FLINK-3823) Kafka08ITCase.testOffsetInZookeeper failed on Travis

Till Rohrmann created FLINK-3823: Summary: Kafka08ITCase.testOffsetInZookeeper failed on Travis Key: FLINK-3823 URL: https://issues.apache.org/jira/browse/FLINK-3823 Project: Flink Issue Type

[jira] [Created] (FLINK-3825) Update CEP documentation to include Scala API

Till Rohrmann created FLINK-3825: Summary: Update CEP documentation to include Scala API Key: FLINK-3825 URL: https://issues.apache.org/jira/browse/FLINK-3825 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-3827) Flink modules include unused dependencies

Till Rohrmann created FLINK-3827: Summary: Flink modules include unused dependencies Key: FLINK-3827 URL: https://issues.apache.org/jira/browse/FLINK-3827 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-3829) flink-java

Till Rohrmann created FLINK-3829: Summary: flink-java Key: FLINK-3829 URL: https://issues.apache.org/jira/browse/FLINK-3829 Project: Flink Issue Type: Sub-task Reporter: Till Rohr

[jira] [Created] (FLINK-3828) flink-runtime

Till Rohrmann created FLINK-3828: Summary: flink-runtime Key: FLINK-3828 URL: https://issues.apache.org/jira/browse/FLINK-3828 Project: Flink Issue Type: Sub-task Reporter: Till R

[jira] [Created] (FLINK-3830) flink-scala

Till Rohrmann created FLINK-3830: Summary: flink-scala Key: FLINK-3830 URL: https://issues.apache.org/jira/browse/FLINK-3830 Project: Flink Issue Type: Sub-task Reporter: Till Roh

[jira] [Created] (FLINK-3831) flink-streaming-java

Till Rohrmann created FLINK-3831: Summary: flink-streaming-java Key: FLINK-3831 URL: https://issues.apache.org/jira/browse/FLINK-3831 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-3832) flink-streaming-scala

Till Rohrmann created FLINK-3832: Summary: flink-streaming-scala Key: FLINK-3832 URL: https://issues.apache.org/jira/browse/FLINK-3832 Project: Flink Issue Type: Sub-task Reporter

[jira] [Created] (FLINK-3833) flink-test-utils

Till Rohrmann created FLINK-3833: Summary: flink-test-utils Key: FLINK-3833 URL: https://issues.apache.org/jira/browse/FLINK-3833 Project: Flink Issue Type: Sub-task Reporter: Til

[jira] [Created] (FLINK-3834) flink-statebackend-rocksdb

Till Rohrmann created FLINK-3834: Summary: flink-statebackend-rocksdb Key: FLINK-3834 URL: https://issues.apache.org/jira/browse/FLINK-3834 Project: Flink Issue Type: Sub-task Rep

[jira] [Created] (FLINK-3862) Restructure community slide

Till Rohrmann created FLINK-3862: Summary: Restructure community slide Key: FLINK-3862 URL: https://issues.apache.org/jira/browse/FLINK-3862 Project: Flink Issue Type: Task Componen

[jira] [Created] (FLINK-3885) Revisit parallelism logic

Till Rohrmann created FLINK-3885: Summary: Revisit parallelism logic Key: FLINK-3885 URL: https://issues.apache.org/jira/browse/FLINK-3885 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-4042) TwitterStream example does not work

Till Rohrmann created FLINK-4042: Summary: TwitterStream example does not work Key: FLINK-4042 URL: https://issues.apache.org/jira/browse/FLINK-4042 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING

Till Rohrmann created FLINK-4046: Summary: Failing a restarting job can get stuck in JobStatus.FAILING Key: FLINK-4046 URL: https://issues.apache.org/jira/browse/FLINK-4046 Project: Flink Is

[jira] [Created] (FLINK-4055) EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow fails on Travis

Till Rohrmann created FLINK-4055: Summary: EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow fails on Travis Key: FLINK-4055 URL: https://issues.apache.org/jira/browse/FLINK-4055

[jira] [Created] (FLINK-4056) SavepointITCase.testCheckpointHasBeenRemoved failed on Travis

Till Rohrmann created FLINK-4056: Summary: SavepointITCase.testCheckpointHasBeenRemoved failed on Travis Key: FLINK-4056 URL: https://issues.apache.org/jira/browse/FLINK-4056 Project: Flink

[jira] [Created] (FLINK-4060) WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed on Travis

Till Rohrmann created FLINK-4060: Summary: WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed on Travis Key: FLINK-4060 URL: https://issues.apache.org/jira/browse/FLINK-4060 Project: Flink

[jira] [Created] (FLINK-4071) JobManagerHAJobGraphRecoveryITCase.testJobManagerCleanUp failed on Travis

Till Rohrmann created FLINK-4071: Summary: JobManagerHAJobGraphRecoveryITCase.testJobManagerCleanUp failed on Travis Key: FLINK-4071 URL: https://issues.apache.org/jira/browse/FLINK-4071 Project: Flin

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

Till Rohrmann created FLINK-4072: Summary: EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis Key: FLINK-4072 URL: https://issues.apache.org/jira/browse/FLINK-4072 Project: Flink

[jira] [Created] (FLINK-4073) YARNSessionCapacitySchedulerITCase.testTaskManagerFailure failed on Travis

Till Rohrmann created FLINK-4073: Summary: YARNSessionCapacitySchedulerITCase.testTaskManagerFailure failed on Travis Key: FLINK-4073 URL: https://issues.apache.org/jira/browse/FLINK-4073 Project: Fli

[jira] [Created] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis

Till Rohrmann created FLINK-4075: Summary: ContinuousFileProcessingCheckpointITCase failed on Travis Key: FLINK-4075 URL: https://issues.apache.org/jira/browse/FLINK-4075 Project: Flink Issue

[jira] [Created] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

Till Rohrmann created FLINK-4084: Summary: Add configDir parameter to CliFrontend and flink shell script Key: FLINK-4084 URL: https://issues.apache.org/jira/browse/FLINK-4084 Project: Flink

[jira] [Created] (FLINK-4094) Off heap memory deallocation might not work properly

Till Rohrmann created FLINK-4094: Summary: Off heap memory deallocation might not work properly Key: FLINK-4094 URL: https://issues.apache.org/jira/browse/FLINK-4094 Project: Flink Issue Type

[jira] [Created] (FLINK-4112) Replace SuppressRestartException with disabling RestartStrategy

Till Rohrmann created FLINK-4112: Summary: Replace SuppressRestartException with disabling RestartStrategy Key: FLINK-4112 URL: https://issues.apache.org/jira/browse/FLINK-4112 Project: Flink

[jira] [Created] (FLINK-4154) Correction of murmur hash breaks backwards compatibility

Till Rohrmann created FLINK-4154: Summary: Correction of murmur hash breaks backwards compatibility Key: FLINK-4154 URL: https://issues.apache.org/jira/browse/FLINK-4154 Project: Flink Issue

[jira] [Created] (FLINK-4167) TaskMetricGroup does not close IOMetricGroup

Till Rohrmann created FLINK-4167: Summary: TaskMetricGroup does not close IOMetricGroup Key: FLINK-4167 URL: https://issues.apache.org/jira/browse/FLINK-4167 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4171) StatsD does not accept metrics whose name contains ":"

Till Rohrmann created FLINK-4171: Summary: StatsD does not accept metrics whose name contains ":" Key: FLINK-4171 URL: https://issues.apache.org/jira/browse/FLINK-4171 Project: Flink Issue Ty

[jira] [Created] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics

Till Rohrmann created FLINK-4173: Summary: Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics Key: FLINK-4173 URL: https://issues.apache.org/jira/browse/FLINK-4173 Project: Flink

[jira] [Created] (FLINK-4184) Ganglia and GraphiteReporter report metric names with invalid characters

Till Rohrmann created FLINK-4184: Summary: Ganglia and GraphiteReporter report metric names with invalid characters Key: FLINK-4184 URL: https://issues.apache.org/jira/browse/FLINK-4184 Project: Flink

[jira] [Created] (FLINK-4198) Replace org.apache.flink.streaming.api.windowing.time.Time with org.apache.flink.api.common.time.Time

Till Rohrmann created FLINK-4198: Summary: Replace org.apache.flink.streaming.api.windowing.time.Time with org.apache.flink.api.common.time.Time Key: FLINK-4198 URL: https://issues.apache.org/jira/browse/FLINK-41

[jira] [Created] (FLINK-4202) Add JM metric which shows the restart duration

Till Rohrmann created FLINK-4202: Summary: Add JM metric which shows the restart duration Key: FLINK-4202 URL: https://issues.apache.org/jira/browse/FLINK-4202 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-4234) CassandraConnectorTest causes travis build to time out

Till Rohrmann created FLINK-4234: Summary: CassandraConnectorTest causes travis build to time out Key: FLINK-4234 URL: https://issues.apache.org/jira/browse/FLINK-4234 Project: Flink Issue Ty

[jira] [Created] (FLINK-4235) ClassLoaderITCase.testDisposeSavepointWithCustomKvState timed out on Travis

Till Rohrmann created FLINK-4235: Summary: ClassLoaderITCase.testDisposeSavepointWithCustomKvState timed out on Travis Key: FLINK-4235 URL: https://issues.apache.org/jira/browse/FLINK-4235 Project: Fl

[jira] [Created] (FLINK-4240) Cannot use expressions in Scala Table API's groupBy method

Till Rohrmann created FLINK-4240: Summary: Cannot use expressions in Scala Table API's groupBy method Key: FLINK-4240 URL: https://issues.apache.org/jira/browse/FLINK-4240 Project: Flink Issu

[jira] [Created] (FLINK-4241) Cryptic expression parser exceptions

Till Rohrmann created FLINK-4241: Summary: Cryptic expression parser exceptions Key: FLINK-4241 URL: https://issues.apache.org/jira/browse/FLINK-4241 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4242) Improve validation exception messages

Till Rohrmann created FLINK-4242: Summary: Improve validation exception messages Key: FLINK-4242 URL: https://issues.apache.org/jira/browse/FLINK-4242 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4244) Field names for union operator do not have to be equal

Till Rohrmann created FLINK-4244: Summary: Field names for union operator do not have to be equal Key: FLINK-4244 URL: https://issues.apache.org/jira/browse/FLINK-4244 Project: Flink Issue Ty

[jira] [Created] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment

Till Rohrmann created FLINK-4247: Summary: CsvTableSource.getDataSet() expects Java ExecutionEnvironment Key: FLINK-4247 URL: https://issues.apache.org/jira/browse/FLINK-4247 Project: Flink

[jira] [Created] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

Till Rohrmann created FLINK-4248: Summary: CsvTableSource does not support reading SqlTimeTypeInfo types Key: FLINK-4248 URL: https://issues.apache.org/jira/browse/FLINK-4248 Project: Flink

[jira] [Created] (FLINK-4249) CsvTableSource does not support reading SqlTimeTypeInfo types

Till Rohrmann created FLINK-4249: Summary: CsvTableSource does not support reading SqlTimeTypeInfo types Key: FLINK-4249 URL: https://issues.apache.org/jira/browse/FLINK-4249 Project: Flink

[jira] [Created] (FLINK-4250) Cannot select column from CsvTableSource

Till Rohrmann created FLINK-4250: Summary: Cannot select column from CsvTableSource Key: FLINK-4250 URL: https://issues.apache.org/jira/browse/FLINK-4250 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4267) Adding async I/O flat map

Till Rohrmann created FLINK-4267: Summary: Adding async I/O flat map Key: FLINK-4267 URL: https://issues.apache.org/jira/browse/FLINK-4267 Project: Flink Issue Type: New Feature Com

[jira] [Created] (FLINK-4382) Buffer rpc calls until RpcEndpoint is properly started

Till Rohrmann created FLINK-4382: Summary: Buffer rpc calls until RpcEndpoint is properly started Key: FLINK-4382 URL: https://issues.apache.org/jira/browse/FLINK-4382 Project: Flink Issue Ty

[jira] [Created] (FLINK-4383) Check parameters for serializability before sending a remote RpcInvocation message

Till Rohrmann created FLINK-4383: Summary: Check parameters for serializability before sending a remote RpcInvocation message Key: FLINK-4383 URL: https://issues.apache.org/jira/browse/FLINK-4383 Proj

[jira] [Created] (FLINK-4390) Add throws clause verification to RpcCompletenessTest

Till Rohrmann created FLINK-4390: Summary: Add throws clause verification to RpcCompletenessTest Key: FLINK-4390 URL: https://issues.apache.org/jira/browse/FLINK-4390 Project: Flink Issue Typ

[jira] [Created] (FLINK-4395) Eager processing of late arrivals in CEP operator

Till Rohrmann created FLINK-4395: Summary: Eager processing of late arrivals in CEP operator Key: FLINK-4395 URL: https://issues.apache.org/jira/browse/FLINK-4395 Project: Flink Issue Type: I

[jira] [Created] (FLINK-4424) Make network environment start-up/shutdown independent of JobManager association

Till Rohrmann created FLINK-4424: Summary: Make network environment start-up/shutdown independent of JobManager association Key: FLINK-4424 URL: https://issues.apache.org/jira/browse/FLINK-4424 Projec

[jira] [Created] (FLINK-4451) Throw exception when remote connection cannot be resolved

Till Rohrmann created FLINK-4451: Summary: Throw exception when remote connection cannot be resolved Key: FLINK-4451 URL: https://issues.apache.org/jira/browse/FLINK-4451 Project: Flink Issue

[jira] [Created] (FLINK-4455) Replace ActorGateways in NetworkEnvironment by interfaces

Till Rohrmann created FLINK-4455: Summary: Replace ActorGateways in NetworkEnvironment by interfaces Key: FLINK-4455 URL: https://issues.apache.org/jira/browse/FLINK-4455 Project: Flink Issue

[jira] [Created] (FLINK-4456) Replace ActorGateway in RuntimeEnvironment by interface

Till Rohrmann created FLINK-4456: Summary: Replace ActorGateway in RuntimeEnvironment by interface Key: FLINK-4456 URL: https://issues.apache.org/jira/browse/FLINK-4456 Project: Flink Issue T

[jira] [Created] (FLINK-4457) Make the ExecutionGraph independent of Akka

Till Rohrmann created FLINK-4457: Summary: Make the ExecutionGraph independent of Akka Key: FLINK-4457 URL: https://issues.apache.org/jira/browse/FLINK-4457 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-4458) Remove ForkableFlinkMiniCluster

Till Rohrmann created FLINK-4458: Summary: Remove ForkableFlinkMiniCluster Key: FLINK-4458 URL: https://issues.apache.org/jira/browse/FLINK-4458 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4459) Introduce SlotProvider to Scheduler

Till Rohrmann created FLINK-4459: Summary: Introduce SlotProvider to Scheduler Key: FLINK-4459 URL: https://issues.apache.org/jira/browse/FLINK-4459 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4478) Implement heartbeat logic

Till Rohrmann created FLINK-4478: Summary: Implement heartbeat logic Key: FLINK-4478 URL: https://issues.apache.org/jira/browse/FLINK-4478 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-4489) Implement TaskManager's SlotManager

Till Rohrmann created FLINK-4489: Summary: Implement TaskManager's SlotManager Key: FLINK-4489 URL: https://issues.apache.org/jira/browse/FLINK-4489 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4528) Mark runAsync and scheduleAsync methods protected

Till Rohrmann created FLINK-4528: Summary: Mark runAsync and scheduleAsync methods protected Key: FLINK-4528 URL: https://issues.apache.org/jira/browse/FLINK-4528 Project: Flink Issue Type: S

<    1   2   3   4   5   6   7   8   9   10   >