Ufuk Celebi created FLINK-3461:
--
Summary: Remove duplicate condition check in
ZooKeeperLeaderElectionService
Key: FLINK-3461
URL: https://issues.apache.org/jira/browse/FLINK-3461
Project: Flink
Ufuk Celebi created FLINK-3462:
--
Summary: Add position and magic number checks to record
(de)serializers
Key: FLINK-3462
URL: https://issues.apache.org/jira/browse/FLINK-3462
Project: Flink
Ufuk Celebi created FLINK-3493:
--
Summary: Update plan visualizer to web frontend version
Key: FLINK-3493
URL: https://issues.apache.org/jira/browse/FLINK-3493
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3494:
--
Summary: Integrate plan visualizer with web page
Key: FLINK-3494
URL: https://issues.apache.org/jira/browse/FLINK-3494
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-3499:
--
Summary: Possible ghost references in ZooKeeper completed
checkpoint store
Key: FLINK-3499
URL: https://issues.apache.org/jira/browse/FLINK-3499
Project: Flink
Ufuk Celebi created FLINK-3500:
--
Summary: ExecutionGraphRestartTest
testFailingExecutionAfterRestart fails
Key: FLINK-3500
URL: https://issues.apache.org/jira/browse/FLINK-3500
Project: Flink
Ufuk Celebi created FLINK-3510:
--
Summary: Pattern class class-level comment misses type argument
Key: FLINK-3510
URL: https://issues.apache.org/jira/browse/FLINK-3510
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3516:
--
Summary: JobManagerHACheckpointRecoveryITCase
testCheckpointedStreamingSumProgram still fails :(
Key: FLINK-3516
URL: https://issues.apache.org/jira/browse/FLINK-3516
Ufuk Celebi created FLINK-3517:
--
Summary: Number of job and task managers not checked in scripts
Key: FLINK-3517
URL: https://issues.apache.org/jira/browse/FLINK-3517
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3535:
--
Summary: Decrease logging verbosity of StackTraceSampleCoordinator
Key: FLINK-3535
URL: https://issues.apache.org/jira/browse/FLINK-3535
Project: Flink
Issue
Ufuk Celebi created FLINK-3539:
--
Summary: Sync running Execution and Task instances via heartbeats
Key: FLINK-3539
URL: https://issues.apache.org/jira/browse/FLINK-3539
Project: Flink
Issue
Ufuk Celebi created FLINK-3556:
--
Summary: Unneeded check in HA blob store configuration
Key: FLINK-3556
URL: https://issues.apache.org/jira/browse/FLINK-3556
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-3558:
--
Summary: Many declined checkpoints on startup
Key: FLINK-3558
URL: https://issues.apache.org/jira/browse/FLINK-3558
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-3559:
--
Summary: Don't print pid file check if no active PID
Key: FLINK-3559
URL: https://issues.apache.org/jira/browse/FLINK-3559
Project: Flink
Issue
Ufuk Celebi created FLINK-3592:
--
Summary: Update setup quickstart
Key: FLINK-3592
URL: https://issues.apache.org/jira/browse/FLINK-3592
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-3600:
--
Summary: Provide clear description network ports usage
Key: FLINK-3600
URL: https://issues.apache.org/jira/browse/FLINK-3600
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3705:
--
Summary: Provide explanation for Hadoop dependencies and how to
configure it
Key: FLINK-3705
URL: https://issues.apache.org/jira/browse/FLINK-3705
Project: Flink
Ufuk Celebi created FLINK-3779:
--
Summary: Add support for queryable state
Key: FLINK-3779
URL: https://issues.apache.org/jira/browse/FLINK-3779
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-3812:
--
Summary: Kafka09ITCase testAllDeletes fails on Travis
Key: FLINK-3812
URL: https://issues.apache.org/jira/browse/FLINK-3812
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-3884:
--
Summary: Snapshot quickstart projects don't include snapshot
repository
Key: FLINK-3884
URL: https://issues.apache.org/jira/browse/FLINK-3884
Project:
Ufuk Celebi created FLINK-3902:
--
Summary: Discarded FileSystem checkpoints are lingering around
Key: FLINK-3902
URL: https://issues.apache.org/jira/browse/FLINK-3902
Project: Flink
Issue Type
Ufuk Celebi created FLINK-4005:
--
Summary: LocalExecutorITCase.testLocalExecutorWithWordCount fails
Key: FLINK-4005
URL: https://issues.apache.org/jira/browse/FLINK-4005
Project: Flink
Issue
Ufuk Celebi created FLINK-4036:
--
Summary: Potential deadlock in StreamIterationSink
Key: FLINK-4036
URL: https://issues.apache.org/jira/browse/FLINK-4036
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-4067:
--
Summary: Add version header to savepoints
Key: FLINK-4067
URL: https://issues.apache.org/jira/browse/FLINK-4067
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-4078:
--
Summary: Use ClosureCleaner for CoGroup where
Key: FLINK-4078
URL: https://issues.apache.org/jira/browse/FLINK-4078
Project: Flink
Issue Type: Bug
Affects
Ufuk Celebi created FLINK-4079:
--
Summary: YARN properties file used for per-job cluster
Key: FLINK-4079
URL: https://issues.apache.org/jira/browse/FLINK-4079
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-4095:
--
Summary: Add configDir argument to shell scripts
Key: FLINK-4095
URL: https://issues.apache.org/jira/browse/FLINK-4095
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-4099:
--
Summary: CliFrontendYarnAddressConfigurationTest fails
Key: FLINK-4099
URL: https://issues.apache.org/jira/browse/FLINK-4099
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-4131:
--
Summary: Confusing error for out dated RequestPartitionState
Key: FLINK-4131
URL: https://issues.apache.org/jira/browse/FLINK-4131
Project: Flink
Issue Type
Ufuk Celebi created FLINK-4145:
--
Summary: JmxReporterTest fails due to port conflicts
Key: FLINK-4145
URL: https://issues.apache.org/jira/browse/FLINK-4145
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-4146:
--
Summary: CliFrontendYarnAddressConfigurationTest picks wrong IP
address on Travis
Key: FLINK-4146
URL: https://issues.apache.org/jira/browse/FLINK-4146
Project: Flink
Ufuk Celebi created FLINK-4170:
--
Summary: Remove `CONFIG_` prefix from KinesisConfigConstants
variables
Key: FLINK-4170
URL: https://issues.apache.org/jira/browse/FLINK-4170
Project: Flink
Ufuk Celebi created FLINK-4220:
--
Summary: ClientTest fails after port conflict
Key: FLINK-4220
URL: https://issues.apache.org/jira/browse/FLINK-4220
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-4228:
--
Summary: RocksDB semi-async snapshot to S3AFileSystem fails
Key: FLINK-4228
URL: https://issues.apache.org/jira/browse/FLINK-4228
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-4253:
--
Summary: Rename "recovery.mode" config key to "high-availability"
Key: FLINK-4253
URL: https://issues.apache.org/jira/browse/FLINK-4253
Project: F
Ufuk Celebi created FLINK-4254:
--
Summary: Add file system based high-availability mode
Key: FLINK-4254
URL: https://issues.apache.org/jira/browse/FLINK-4254
Project: Flink
Issue Type: New
Ufuk Celebi created FLINK-4269:
--
Summary: Decrease log level in RuntimeMonitorHandler
Key: FLINK-4269
URL: https://issues.apache.org/jira/browse/FLINK-4269
Project: Flink
Issue Type
Ufuk Celebi created FLINK-4289:
--
Summary: Source files have executable flag set
Key: FLINK-4289
URL: https://issues.apache.org/jira/browse/FLINK-4289
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-4299:
--
Summary: Show loss of job manager in Client
Key: FLINK-4299
URL: https://issues.apache.org/jira/browse/FLINK-4299
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-4302:
--
Summary: Add JavaDocs to MetricConfig
Key: FLINK-4302
URL: https://issues.apache.org/jira/browse/FLINK-4302
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-1568:
--
Summary: Add failure-case tests for data exchange
Key: FLINK-1568
URL: https://issues.apache.org/jira/browse/FLINK-1568
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-1570:
--
Summary: Add failure-case tests for pipelined data exchange
Key: FLINK-1570
URL: https://issues.apache.org/jira/browse/FLINK-1570
Project: Flink
Issue Type: Sub
Ufuk Celebi created FLINK-1571:
--
Summary: Add failure-case tests for blocking data exchange
Key: FLINK-1571
URL: https://issues.apache.org/jira/browse/FLINK-1571
Project: Flink
Issue Type: Sub
Ufuk Celebi created FLINK-1577:
--
Summary: Misleading error messages when cancelling tasks
Key: FLINK-1577
URL: https://issues.apache.org/jira/browse/FLINK-1577
Project: Flink
Issue Type
Ufuk Celebi created FLINK-1627:
--
Summary: Netty channel connect deadlock
Key: FLINK-1627
URL: https://issues.apache.org/jira/browse/FLINK-1627
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-1636:
--
Summary: Misleading exception during concurrent partition release
and remote request
Key: FLINK-1636
URL: https://issues.apache.org/jira/browse/FLINK-1636
Project: Flink
Ufuk Celebi created FLINK-1660:
--
Summary: MultiTriggerPolicyTest timeout during test
Key: FLINK-1660
URL: https://issues.apache.org/jira/browse/FLINK-1660
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-1672:
--
Summary: Refactor task registration/unregistration
Key: FLINK-1672
URL: https://issues.apache.org/jira/browse/FLINK-1672
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-1709:
--
Summary: Add support for programs with higher-than-slot parallelism
Key: FLINK-1709
URL: https://issues.apache.org/jira/browse/FLINK-1709
Project: Flink
Issue
Ufuk Celebi created FLINK-1713:
--
Summary: Add support for blocking data exchange in closed loop
iterations
Key: FLINK-1713
URL: https://issues.apache.org/jira/browse/FLINK-1713
Project: Flink
Ufuk Celebi created FLINK-1715:
--
Summary: Remove print statements in MultiEvictionPolicy and
GroupedDataStream
Key: FLINK-1715
URL: https://issues.apache.org/jira/browse/FLINK-1715
Project: Flink
Ufuk Celebi created FLINK-1724:
--
Summary: TestingCluster uses local communication with multiple
task managers
Key: FLINK-1724
URL: https://issues.apache.org/jira/browse/FLINK-1724
Project: Flink
Ufuk Celebi created FLINK-1747:
--
Summary: Remove deadlock detection and pipeline breaker placement
in optimizer
Key: FLINK-1747
URL: https://issues.apache.org/jira/browse/FLINK-1747
Project: Flink
Ufuk Celebi created FLINK-1761:
--
Summary: IndexOutOfBoundsException when receiving empty buffer at
remote channel
Key: FLINK-1761
URL: https://issues.apache.org/jira/browse/FLINK-1761
Project: Flink
Ufuk Celebi created FLINK-1786:
--
Summary: Add support for pipelined programs with slot count
exceeding parallelism
Key: FLINK-1786
URL: https://issues.apache.org/jira/browse/FLINK-1786
Project: Flink
Ufuk Celebi created FLINK-1806:
--
Summary: Improve S3 file system error message when no
access/secret key provided
Key: FLINK-1806
URL: https://issues.apache.org/jira/browse/FLINK-1806
Project: Flink
Ufuk Celebi created FLINK-1810:
--
Summary: UpdateTask message contains unused information
Key: FLINK-1810
URL: https://issues.apache.org/jira/browse/FLINK-1810
Project: Flink
Issue Type
Ufuk Celebi created FLINK-1833:
--
Summary: Refactor partition availability notification in
ExecutionGraph
Key: FLINK-1833
URL: https://issues.apache.org/jira/browse/FLINK-1833
Project: Flink
Ufuk Celebi created FLINK-1850:
--
Summary: Snapshot docs overview page refers to wrong version
Key: FLINK-1850
URL: https://issues.apache.org/jira/browse/FLINK-1850
Project: Flink
Issue Type
Ufuk Celebi created FLINK-1877:
--
Summary: Stalled Flink on Tez build
Key: FLINK-1877
URL: https://issues.apache.org/jira/browse/FLINK-1877
Project: Flink
Issue Type: Bug
Components
Ufuk Celebi created FLINK-1954:
--
Summary: Task Failures and Error Handling
Key: FLINK-1954
URL: https://issues.apache.org/jira/browse/FLINK-1954
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-1955:
--
Summary: Improve error handling of sender task failures
Key: FLINK-1955
URL: https://issues.apache.org/jira/browse/FLINK-1955
Project: Flink
Issue Type
Ufuk Celebi created FLINK-1957:
--
Summary: Improve error handling of transport failures
Key: FLINK-1957
URL: https://issues.apache.org/jira/browse/FLINK-1957
Project: Flink
Issue Type
Ufuk Celebi created FLINK-1958:
--
Summary: Improve error handling of receiver task failures
Key: FLINK-1958
URL: https://issues.apache.org/jira/browse/FLINK-1958
Project: Flink
Issue Type
Ufuk Celebi created FLINK-2089:
--
Summary: "Buffer recycled" IllegalStateException during cancelling
Key: FLINK-2089
URL: https://issues.apache.org/jira/browse/FLINK-2089
Project: Flink
Ufuk Celebi created FLINK-2091:
--
Summary: Lock contention during release of network buffer pools
Key: FLINK-2091
URL: https://issues.apache.org/jira/browse/FLINK-2091
Project: Flink
Issue Type
Ufuk Celebi created FLINK-2109:
--
Summary: CancelTaskException leads to FAILED task state
Key: FLINK-2109
URL: https://issues.apache.org/jira/browse/FLINK-2109
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-2110:
--
Summary: Early slot release after Execution failure
Key: FLINK-2110
URL: https://issues.apache.org/jira/browse/FLINK-2110
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-2119:
--
Summary: Add ExecutionGraph support for leg-wise scheduling
Key: FLINK-2119
URL: https://issues.apache.org/jira/browse/FLINK-2119
Project: Flink
Issue Type
Ufuk Celebi created FLINK-2120:
--
Summary: Rename AbstractJobVertex to JobVertex
Key: FLINK-2120
URL: https://issues.apache.org/jira/browse/FLINK-2120
Project: Flink
Issue Type: Wish
Ufuk Celebi created FLINK-2123:
--
Summary: Fix CLI client logging
Key: FLINK-2123
URL: https://issues.apache.org/jira/browse/FLINK-2123
Project: Flink
Issue Type: Bug
Components: Core
Ufuk Celebi created FLINK-2128:
--
Summary: ScalaShellITSuite failing
Key: FLINK-2128
URL: https://issues.apache.org/jira/browse/FLINK-2128
Project: Flink
Issue Type: Bug
Components
Ufuk Celebi created FLINK-2132:
--
Summary: Java version parsing is not working for OpenJDK
Key: FLINK-2132
URL: https://issues.apache.org/jira/browse/FLINK-2132
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-2134:
--
Summary: Deadlock in SuccessAfterNetworkBuffersFailureITCase
Key: FLINK-2134
URL: https://issues.apache.org/jira/browse/FLINK-2134
Project: Flink
Issue Type
Ufuk Celebi created FLINK-2159:
--
Summary: SimpleRecoveryITCase fails
Key: FLINK-2159
URL: https://issues.apache.org/jira/browse/FLINK-2159
Project: Flink
Issue Type: Bug
Components
Ufuk Celebi created FLINK-2195:
--
Summary: Set Configuration for Configurable Hadoop InputFormats
Key: FLINK-2195
URL: https://issues.apache.org/jira/browse/FLINK-2195
Project: Flink
Issue Type
Ufuk Celebi created FLINK-2212:
--
Summary: Exit code on failed job
Key: FLINK-2212
URL: https://issues.apache.org/jira/browse/FLINK-2212
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-2213:
--
Summary: Configure number of vcores
Key: FLINK-2213
URL: https://issues.apache.org/jira/browse/FLINK-2213
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-2216:
--
Summary: Examples directory contains
`flink-java-examples-0.9.0-javadoc.jar`
Key: FLINK-2216
URL: https://issues.apache.org/jira/browse/FLINK-2216
Project: Flink
Ufuk Celebi created FLINK-2217:
--
Summary: Web client does not remove uploaded JARs
Key: FLINK-2217
URL: https://issues.apache.org/jira/browse/FLINK-2217
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-2218:
--
Summary: Web client cannot specify parallelism
Key: FLINK-2218
URL: https://issues.apache.org/jira/browse/FLINK-2218
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-2219:
--
Summary: JobManagerInfoServlet IllegalArgumentException when
pressing state button
Key: FLINK-2219
URL: https://issues.apache.org/jira/browse/FLINK-2219
Project: Flink
Ufuk Celebi created FLINK-2227:
--
Summary: .yarn-properties file is not cleaned up
Key: FLINK-2227
URL: https://issues.apache.org/jira/browse/FLINK-2227
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-2232:
--
Summary: StormWordCountLocalITCase fails
Key: FLINK-2232
URL: https://issues.apache.org/jira/browse/FLINK-2232
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-2233:
--
Summary: InputFormat nextRecord Javadocs out of sync
Key: FLINK-2233
URL: https://issues.apache.org/jira/browse/FLINK-2233
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-2242:
--
Summary: Deprecate RemoteCollector
Key: FLINK-2242
URL: https://issues.apache.org/jira/browse/FLINK-2242
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-2246:
--
Summary: Combiner not chained
Key: FLINK-2246
URL: https://issues.apache.org/jira/browse/FLINK-2246
Project: Flink
Issue Type: Bug
Components: Core
Ufuk Celebi created FLINK-2287:
--
Summary: Implement JobManager high availability
Key: FLINK-2287
URL: https://issues.apache.org/jira/browse/FLINK-2287
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-2288:
--
Summary: Setup ZooKeeper for distributed coordination
Key: FLINK-2288
URL: https://issues.apache.org/jira/browse/FLINK-2288
Project: Flink
Issue Type: Sub-task
Ufuk Celebi created FLINK-2302:
--
Summary: Allow multiple instances to run on single host
Key: FLINK-2302
URL: https://issues.apache.org/jira/browse/FLINK-2302
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-2354:
--
Summary: Recover running jobs on JobManager failure
Key: FLINK-2354
URL: https://issues.apache.org/jira/browse/FLINK-2354
Project: Flink
Issue Type: Sub-task
Ufuk Celebi created FLINK-2356:
--
Summary: Resource leak in checkpoint coordinator
Key: FLINK-2356
URL: https://issues.apache.org/jira/browse/FLINK-2356
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-2380:
--
Summary: Allow to configure default FS for file inputs
Key: FLINK-2380
URL: https://issues.apache.org/jira/browse/FLINK-2380
Project: Flink
Issue Type
Ufuk Celebi created FLINK-2381:
--
Summary: Possible class not found Exception on failed partition
producer
Key: FLINK-2381
URL: https://issues.apache.org/jira/browse/FLINK-2381
Project: Flink
Ufuk Celebi created FLINK-2399:
--
Summary: Fail when actor versions don't match
Key: FLINK-2399
URL: https://issues.apache.org/jira/browse/FLINK-2399
Project: Flink
Issue Type: Improv
Ufuk Celebi created FLINK-2400:
--
Summary: TaskTest.testExecutionFailesAfterCanceling fails
Key: FLINK-2400
URL: https://issues.apache.org/jira/browse/FLINK-2400
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-2424:
--
Summary: InstantiationUtil.serializeObject(Object) does not close
output stream
Key: FLINK-2424
URL: https://issues.apache.org/jira/browse/FLINK-2424
Project: Flink
Ufuk Celebi created FLINK-2450:
--
Summary: IndexOutOfBoundsException in KryoSerializer
Key: FLINK-2450
URL: https://issues.apache.org/jira/browse/FLINK-2450
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-2455:
--
Summary: Misleading I/O manager error log messages
Key: FLINK-2455
URL: https://issues.apache.org/jira/browse/FLINK-2455
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-2513:
--
Summary: Extend state handle provider interface to list all state
handles
Key: FLINK-2513
URL: https://issues.apache.org/jira/browse/FLINK-2513
Project: Flink
701 - 800 of 991 matches
Mail list logo
