[jira] [Created] (FLINK-6362) Unprotected access to registeredStates in SharedStateRegistry#getReferenceCount

Ted Yu created FLINK-6362: - Summary: Unprotected access to registeredStates in SharedStateRegistry#getReferenceCount Key: FLINK-6362 URL: https://issues.apache.org/jira/browse/FLINK-6362 Project: Flink

[jira] [Created] (FLINK-6359) Utilize Hierarchical Timing Wheels for performant timer

Ted Yu created FLINK-6359: - Summary: Utilize Hierarchical Timing Wheels for performant timer Key: FLINK-6359 URL: https://issues.apache.org/jira/browse/FLINK-6359 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-6333) Utilize Bloomfilters in RocksDb

Ted Yu created FLINK-6333: - Summary: Utilize Bloomfilters in RocksDb Key: FLINK-6333 URL: https://issues.apache.org/jira/browse/FLINK-6333 Project: Flink Issue Type: Improvement Reporter:

[jira] [Created] (FLINK-6332) Upgrade Scala version to 2.11.11

Ted Yu created FLINK-6332: - Summary: Upgrade Scala version to 2.11.11 Key: FLINK-6332 URL: https://issues.apache.org/jira/browse/FLINK-6332 Project: Flink Issue Type: Improvement Reporter

[jira] [Created] (FLINK-6310) LocalExecutor#endSession() uses wrong lock for synchronization

Ted Yu created FLINK-6310: - Summary: LocalExecutor#endSession() uses wrong lock for synchronization Key: FLINK-6310 URL: https://issues.apache.org/jira/browse/FLINK-6310 Project: Flink Issue Type: B

[jira] [Created] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

Ted Yu created FLINK-6275: - Summary: Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster Key: FLINK-6275 URL: https://issues.apache.org/jira/browse/FLINK-6275 Projec

[jira] [Created] (FLINK-6210) RocksDB instance should be closed in ListViaMergeSpeedMiniBenchmark

Ted Yu created FLINK-6210: - Summary: RocksDB instance should be closed in ListViaMergeSpeedMiniBenchmark Key: FLINK-6210 URL: https://issues.apache.org/jira/browse/FLINK-6210 Project: Flink Issue Ty

[jira] [Created] (FLINK-6172) Potentially unclosed RandomAccessFile in HistoryServerStaticFileServerHandler

Ted Yu created FLINK-6172: - Summary: Potentially unclosed RandomAccessFile in HistoryServerStaticFileServerHandler Key: FLINK-6172 URL: https://issues.apache.org/jira/browse/FLINK-6172 Project: Flink

[jira] [Created] (FLINK-6169) yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error

Ted Yu created FLINK-6169: - Summary: yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error Key: FLINK-6169 URL: https://issues.apache.org/jira/browse/FLINK-6169 Project: Flink

[jira] [Created] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

Ted Yu created FLINK-6143: - Summary: Unprotected access to this.flink in LocalExecutor#endSession() Key: FLINK-6143 URL: https://issues.apache.org/jira/browse/FLINK-6143 Project: Flink Issue Type: B

[jira] [Created] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

Ted Yu created FLINK-6130: - Summary: Consider calling resourceManager#getTerminationFuture() with lock held Key: FLINK-6130 URL: https://issues.apache.org/jira/browse/FLINK-6130 Project: Flink Issue

[jira] [Created] (FLINK-6105) Properly handle InterruptedException

Ted Yu created FLINK-6105: - Summary: Properly handle InterruptedException Key: FLINK-6105 URL: https://issues.apache.org/jira/browse/FLINK-6105 Project: Flink Issue Type: Bug Reporter: Te

[jira] [Created] (FLINK-6104) Unclosed WriteOptions in ListViaRangeSpeedMiniBenchmark#main()

Ted Yu created FLINK-6104: - Summary: Unclosed WriteOptions in ListViaRangeSpeedMiniBenchmark#main() Key: FLINK-6104 URL: https://issues.apache.org/jira/browse/FLINK-6104 Project: Flink Issue Type: B

[jira] [Created] (FLINK-6080) Unclosed ObjectOutputStream in NFA#serialize()

Ted Yu created FLINK-6080: - Summary: Unclosed ObjectOutputStream in NFA#serialize() Key: FLINK-6080 URL: https://issues.apache.org/jira/browse/FLINK-6080 Project: Flink Issue Type: Bug Re

[jira] [Created] (FLINK-6079) Ineffective null check in FlinkKafkaConsumerBase#open()

Ted Yu created FLINK-6079: - Summary: Ineffective null check in FlinkKafkaConsumerBase#open() Key: FLINK-6079 URL: https://issues.apache.org/jira/browse/FLINK-6079 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6052) Potential null access in ZooKeeperCompletedCheckpointStore#getLatestCheckpoint()

Ted Yu created FLINK-6052: - Summary: Potential null access in ZooKeeperCompletedCheckpointStore#getLatestCheckpoint() Key: FLINK-6052 URL: https://issues.apache.org/jira/browse/FLINK-6052 Project: Flink

[jira] [Created] (FLINK-5987) Upgrade zookeeper dependency to 3.4.8

Ted Yu created FLINK-5987: - Summary: Upgrade zookeeper dependency to 3.4.8 Key: FLINK-5987 URL: https://issues.apache.org/jira/browse/FLINK-5987 Project: Flink Issue Type: Improvement Rep

[jira] [Created] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()

Ted Yu created FLINK-5943: - Summary: Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown() Key: FLINK-5943 URL: https://issues.apache.org/jira/browse/FLINK-5943 Project: Flink

[jira] [Created] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

Ted Yu created FLINK-5855: - Summary: Unprotected access to pendingFilesPerCheckpoint in BucketingSink Key: FLINK-5855 URL: https://issues.apache.org/jira/browse/FLINK-5855 Project: Flink Issue Type:

[jira] [Created] (FLINK-5696) Access to REAPER_THREAD lacks proper synchronization in SafetyNetCloseableRegistry#doRegister

Ted Yu created FLINK-5696: - Summary: Access to REAPER_THREAD lacks proper synchronization in SafetyNetCloseableRegistry#doRegister Key: FLINK-5696 URL: https://issues.apache.org/jira/browse/FLINK-5696 Project

[jira] [Created] (FLINK-5541) Missing null check for localJar in FlinkSubmitter#submitTopology()

Ted Yu created FLINK-5541: - Summary: Missing null check for localJar in FlinkSubmitter#submitTopology() Key: FLINK-5541 URL: https://issues.apache.org/jira/browse/FLINK-5541 Project: Flink Issue Typ

[jira] [Created] (FLINK-5517) Upgrade hbase version to 1.3.0

Ted Yu created FLINK-5517: - Summary: Upgrade hbase version to 1.3.0 Key: FLINK-5517 URL: https://issues.apache.org/jira/browse/FLINK-5517 Project: Flink Issue Type: Improvement Reporter:

[jira] [Created] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions

Ted Yu created FLINK-5488: - Summary: yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions Key: FLINK-5488 URL: https://issues.apache.org/jira/browse/FLINK-5488 Project: Flink

[jira] [Created] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

Ted Yu created FLINK-5486: - Summary: Lack of synchronization in BucketingSink#handleRestoredBucketState() Key: FLINK-5486 URL: https://issues.apache.org/jira/browse/FLINK-5486 Project: Flink Issue T

[jira] [Created] (FLINK-5391) Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown()

Ted Yu created FLINK-5391: - Summary: Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown() Key: FLINK-5391 URL: https://issues.apache.org/jira/browse/FLINK-5391 Project: Flink I

[jira] [Created] (FLINK-5390) input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph()

Ted Yu created FLINK-5390: - Summary: input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph() Key: FLINK-5390 URL: https://issues.apache.org/jira/browse/FLINK-5390 Project: F

[jira] [Created] (FLINK-5376) Misleading log statements in UnorderedStreamElementQueue

Ted Yu created FLINK-5376: - Summary: Misleading log statements in UnorderedStreamElementQueue Key: FLINK-5376 URL: https://issues.apache.org/jira/browse/FLINK-5376 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5347) Unclosed stream in OperatorBackendSerializationProxy#write()

Ted Yu created FLINK-5347: - Summary: Unclosed stream in OperatorBackendSerializationProxy#write() Key: FLINK-5347 URL: https://issues.apache.org/jira/browse/FLINK-5347 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState()

Ted Yu created FLINK-5282: - Summary: CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() Key: FLINK-5282 URL: https://issues.apache.org/jira/browse/FLINK-5282

[jira] [Created] (FLINK-5283) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState()

Ted Yu created FLINK-5283: - Summary: CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() Key: FLINK-5283 URL: https://issues.apache.org/jira/browse/FLINK-5283

[jira] [Created] (FLINK-5050) JSON.org license is CatX

Ted Yu created FLINK-5050: - Summary: JSON.org license is CatX Key: FLINK-5050 URL: https://issues.apache.org/jira/browse/FLINK-5050 Project: Flink Issue Type: Bug Reporter: Ted Yu We sh

[jira] [Created] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers

Ted Yu created FLINK-5002: - Summary: Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers Key: FLINK-5002 URL: https://issues.apache.org/jira/browse/FLINK-5002 Project: Flink Issue Type

[jira] [Created] (FLINK-4999) Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers

Ted Yu created FLINK-4999: - Summary: Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers Key: FLINK-4999 URL: https://issues.apache.org/jira/browse/FLINK-4999 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4938) Unnecessary update() call for Views to be removed in ViewUpdater#run()

Ted Yu created FLINK-4938: - Summary: Unnecessary update() call for Views to be removed in ViewUpdater#run() Key: FLINK-4938 URL: https://issues.apache.org/jira/browse/FLINK-4938 Project: Flink Issue

[jira] [Created] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

Ted Yu created FLINK-4848: - Summary: keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext Key: FLINK-4848 URL: https://issues.apache.org/jira/browse/FLINK-4848 Project: Flink

[jira] [Created] (FLINK-4849) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

Ted Yu created FLINK-4849: - Summary: keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext Key: FLINK-4849 URL: https://issues.apache.org/jira/browse/FLINK-4849 Project: Flink

[jira] [Created] (FLINK-4759) Unclosed DataOutputViewStream in JavaSerializer

Ted Yu created FLINK-4759: - Summary: Unclosed DataOutputViewStream in JavaSerializer Key: FLINK-4759 URL: https://issues.apache.org/jira/browse/FLINK-4759 Project: Flink Issue Type: Bug R

[jira] [Created] (FLINK-4701) Unprotected access to cancelables in StreamTask

Ted Yu created FLINK-4701: - Summary: Unprotected access to cancelables in StreamTask Key: FLINK-4701 URL: https://issues.apache.org/jira/browse/FLINK-4701 Project: Flink Issue Type: Bug R

[jira] [Created] (FLINK-4659) Potential resource leak due to unclosed InputStream in SecurityContext#populateSystemSecurityProperties()

Ted Yu created FLINK-4659: - Summary: Potential resource leak due to unclosed InputStream in SecurityContext#populateSystemSecurityProperties() Key: FLINK-4659 URL: https://issues.apache.org/jira/browse/FLINK-4659

[jira] [Created] (FLINK-4626) Missing break in MetricStore#add()

Ted Yu created FLINK-4626: - Summary: Missing break in MetricStore#add() Key: FLINK-4626 URL: https://issues.apache.org/jira/browse/FLINK-4626 Project: Flink Issue Type: Bug Reporter: Ted

[jira] [Created] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler#

Ted Yu created FLINK-4573: - Summary: Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler# Key: FLINK-4573 URL: https://issues.apache.org/jira/browse/FLINK-4573 Project: Flink

[jira] [Created] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() w.r.t. state.bucketStates

Ted Yu created FLINK-4534: - Summary: Lack of synchronization in BucketingSink#restoreState() w.r.t. state.bucketStates Key: FLINK-4534 URL: https://issues.apache.org/jira/browse/FLINK-4534 Project: Flink

[jira] [Created] (FLINK-4533) Unprotected access to meters in StatsDReporter#report()

Ted Yu created FLINK-4533: - Summary: Unprotected access to meters in StatsDReporter#report() Key: FLINK-4533 URL: https://issues.apache.org/jira/browse/FLINK-4533 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4531) Thread.stop() is deprecated

Ted Yu created FLINK-4531: - Summary: Thread.stop() is deprecated Key: FLINK-4531 URL: https://issues.apache.org/jira/browse/FLINK-4531 Project: Flink Issue Type: Bug Reporter: Ted Yu

[jira] [Created] (FLINK-4499) Introduce findbugs maven plugin

Ted Yu created FLINK-4499: - Summary: Introduce findbugs maven plugin Key: FLINK-4499 URL: https://issues.apache.org/jira/browse/FLINK-4499 Project: Flink Issue Type: Improvement Reporter:

[jira] [Created] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock

Ted Yu created FLINK-4482: - Summary: numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock Key: FLINK-4482 URL: https://issues.apache.org/jira/browse/FLINK-4482 Project: Flink I

[jira] [Created] (FLINK-4437) Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields

Ted Yu created FLINK-4437: - Summary: Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields Key: FLINK-4437 URL: https://issues.apache.org/jira/browse/FLINK-4437 Project: Flink

[jira] [Created] (FLINK-4436) Unclosed DataOutputBuffer in Utils#setTokensFor()

Ted Yu created FLINK-4436: - Summary: Unclosed DataOutputBuffer in Utils#setTokensFor() Key: FLINK-4436 URL: https://issues.apache.org/jira/browse/FLINK-4436 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4309) Potential null pointer dereference in DelegatingConfiguration#keySet()

Ted Yu created FLINK-4309: - Summary: Potential null pointer dereference in DelegatingConfiguration#keySet() Key: FLINK-4309 URL: https://issues.apache.org/jira/browse/FLINK-4309 Project: Flink Issue

[jira] [Created] (FLINK-4259) Unclosed FSDataOutputStream in FileCache#copy()

Ted Yu created FLINK-4259: - Summary: Unclosed FSDataOutputStream in FileCache#copy() Key: FLINK-4259 URL: https://issues.apache.org/jira/browse/FLINK-4259 Project: Flink Issue Type: Bug R

[jira] [Created] (FLINK-4258) Potential null pointer dereference in SavepointCoordinator#onFullyAcknowledgedCheckpoint

Ted Yu created FLINK-4258: - Summary: Potential null pointer dereference in SavepointCoordinator#onFullyAcknowledgedCheckpoint Key: FLINK-4258 URL: https://issues.apache.org/jira/browse/FLINK-4258 Project: Fli

[jira] [Created] (FLINK-4096) Nested FileOutputStream is not closed in JarFileCreator

Ted Yu created FLINK-4096: - Summary: Nested FileOutputStream is not closed in JarFileCreator Key: FLINK-4096 URL: https://issues.apache.org/jira/browse/FLINK-4096 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4090) Close of OutputStream should be in finally clause in FlinkYarnSessionCli#writeYarnProperties()

Ted Yu created FLINK-4090: - Summary: Close of OutputStream should be in finally clause in FlinkYarnSessionCli#writeYarnProperties() Key: FLINK-4090 URL: https://issues.apache.org/jira/browse/FLINK-4090 Projec

[jira] [Created] (FLINK-4089) Ineffective null check in YarnClusterClient#getApplicationStatus()

Ted Yu created FLINK-4089: - Summary: Ineffective null check in YarnClusterClient#getApplicationStatus() Key: FLINK-4089 URL: https://issues.apache.org/jira/browse/FLINK-4089 Project: Flink Issue Typ

[jira] [Created] (FLINK-4076) BoltWrapper#dispose() should call AbstractStreamOperator#dispose()

Ted Yu created FLINK-4076: - Summary: BoltWrapper#dispose() should call AbstractStreamOperator#dispose() Key: FLINK-4076 URL: https://issues.apache.org/jira/browse/FLINK-4076 Project: Flink Issue Typ

[jira] [Created] (FLINK-4053) Return value from Connection should be checked against null

Ted Yu created FLINK-4053: - Summary: Return value from Connection should be checked against null Key: FLINK-4053 URL: https://issues.apache.org/jira/browse/FLINK-4053 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3998) Access to gauges and counters in StatsDReporter#report() is not properly synchronized

Ted Yu created FLINK-3998: - Summary: Access to gauges and counters in StatsDReporter#report() is not properly synchronized Key: FLINK-3998 URL: https://issues.apache.org/jira/browse/FLINK-3998 Project: Flink

[jira] [Created] (FLINK-3958) Access to MetricRegistry doesn't have proper synchronization in some classes

Ted Yu created FLINK-3958: - Summary: Access to MetricRegistry doesn't have proper synchronization in some classes Key: FLINK-3958 URL: https://issues.apache.org/jira/browse/FLINK-3958 Project: Flink

[jira] [Created] (FLINK-3928) Potential overflow due to 32-bit int arithmetic

Ted Yu created FLINK-3928: - Summary: Potential overflow due to 32-bit int arithmetic Key: FLINK-3928 URL: https://issues.apache.org/jira/browse/FLINK-3928 Project: Flink Issue Type: Bug R

[jira] [Created] (FLINK-3810) Missing break in ZooKeeperLeaderElectionService#handleStateChange()

Ted Yu created FLINK-3810: - Summary: Missing break in ZooKeeperLeaderElectionService#handleStateChange() Key: FLINK-3810 URL: https://issues.apache.org/jira/browse/FLINK-3810 Project: Flink Issue Ty

[jira] [Created] (FLINK-3809) Missing break in ZooKeeperLeaderRetrievalService#handleStateChange()

Ted Yu created FLINK-3809: - Summary: Missing break in ZooKeeperLeaderRetrievalService#handleStateChange() Key: FLINK-3809 URL: https://issues.apache.org/jira/browse/FLINK-3809 Project: Flink Issue T

[jira] [Created] (FLINK-3801) Upgrade Joda-Time library to 2.9.3

Ted Yu created FLINK-3801: - Summary: Upgrade Joda-Time library to 2.9.3 Key: FLINK-3801 URL: https://issues.apache.org/jira/browse/FLINK-3801 Project: Flink Issue Type: Improvement Report

[jira] [Created] (FLINK-3781) BlobClient may be left unclosed in BlobCache#deleteGlobal()

Ted Yu created FLINK-3781: - Summary: BlobClient may be left unclosed in BlobCache#deleteGlobal() Key: FLINK-3781 URL: https://issues.apache.org/jira/browse/FLINK-3781 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3773) Scanners are left unclosed in SqlExplainTest

Ted Yu created FLINK-3773: - Summary: Scanners are left unclosed in SqlExplainTest Key: FLINK-3773 URL: https://issues.apache.org/jira/browse/FLINK-3773 Project: Flink Issue Type: Bug Repo

[jira] [Created] (FLINK-3753) KillerWatchDog should not use kill on toKill thread

Ted Yu created FLINK-3753: - Summary: KillerWatchDog should not use kill on toKill thread Key: FLINK-3753 URL: https://issues.apache.org/jira/browse/FLINK-3753 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

Ted Yu created FLINK-3734: - Summary: Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState() Key: FLINK-3734 URL: https://issues.apache.org/jira/browse/FLINK-3734 Project: Flink

[jira] [Created] (FLINK-3733) registeredTypesWithKryoSerializers is not assigned in ExecutionConfig#deserializeUserCode()

Ted Yu created FLINK-3733: - Summary: registeredTypesWithKryoSerializers is not assigned in ExecutionConfig#deserializeUserCode() Key: FLINK-3733 URL: https://issues.apache.org/jira/browse/FLINK-3733 Project:

[jira] [Created] (FLINK-3732) Potential null deference in ExecutionConfig#equals()

Ted Yu created FLINK-3732: - Summary: Potential null deference in ExecutionConfig#equals() Key: FLINK-3732 URL: https://issues.apache.org/jira/browse/FLINK-3732 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3668) Potential null deference in HadoopInputFormatBase#createInputSplits()

Ted Yu created FLINK-3668: - Summary: Potential null deference in HadoopInputFormatBase#createInputSplits() Key: FLINK-3668 URL: https://issues.apache.org/jira/browse/FLINK-3668 Project: Flink Issue

[jira] [Created] (FLINK-3635) Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap

Ted Yu created FLINK-3635: - Summary: Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap Key: FLINK-3635 URL: https://issues.apache.org/jira/browse/FLINK-3635 Project: Flink

[jira] [Created] (FLINK-3576) Upgrade Snappy Java to 1.1.2.1

Ted Yu created FLINK-3576: - Summary: Upgrade Snappy Java to 1.1.2.1 Key: FLINK-3576 URL: https://issues.apache.org/jira/browse/FLINK-3576 Project: Flink Issue Type: Improvement Reporter:

[jira] [Created] (FLINK-3525) Missing call to super#close() in TimestampsAndPeriodicWatermarksOperator#close()

Ted Yu created FLINK-3525: - Summary: Missing call to super#close() in TimestampsAndPeriodicWatermarksOperator#close() Key: FLINK-3525 URL: https://issues.apache.org/jira/browse/FLINK-3525 Project: Flink

[jira] [Created] (FLINK-3434) Return value from flinkYarnClient#deploy() should be checked against null

Ted Yu created FLINK-3434: - Summary: Return value from flinkYarnClient#deploy() should be checked against null Key: FLINK-3434 URL: https://issues.apache.org/jira/browse/FLINK-3434 Project: Flink Is

[jira] [Created] (FLINK-3433) Return value from ObjectInputStream#read() should be checked in AvroOutputFormat#readObject

Ted Yu created FLINK-3433: - Summary: Return value from ObjectInputStream#read() should be checked in AvroOutputFormat#readObject Key: FLINK-3433 URL: https://issues.apache.org/jira/browse/FLINK-3433 Project:

[jira] [Created] (FLINK-3392) Unprotected access to elements in ClosableBlockingQueue#size()

Ted Yu created FLINK-3392: - Summary: Unprotected access to elements in ClosableBlockingQueue#size() Key: FLINK-3392 URL: https://issues.apache.org/jira/browse/FLINK-3392 Project: Flink Issue Type: B

[jira] [Created] (FLINK-3362) Potential overflow in NettyBufferPool#getNumberOfAllocatedBytes

Ted Yu created FLINK-3362: - Summary: Potential overflow in NettyBufferPool#getNumberOfAllocatedBytes Key: FLINK-3362 URL: https://issues.apache.org/jira/browse/FLINK-3362 Project: Flink Issue Type:

[jira] [Created] (FLINK-3329) Unclosed BackupEngine in AbstractRocksDBState#snapshot()

Ted Yu created FLINK-3329: - Summary: Unclosed BackupEngine in AbstractRocksDBState#snapshot() Key: FLINK-3329 URL: https://issues.apache.org/jira/browse/FLINK-3329 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3325) Unclosed InputStream in CEPPatternOperator#restoreState()

Ted Yu created FLINK-3325: - Summary: Unclosed InputStream in CEPPatternOperator#restoreState() Key: FLINK-3325 URL: https://issues.apache.org/jira/browse/FLINK-3325 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3301) Ineffective synchronization in MessageAcknowledgingSourceBase#restoreState

Ted Yu created FLINK-3301: - Summary: Ineffective synchronization in MessageAcknowledgingSourceBase#restoreState Key: FLINK-3301 URL: https://issues.apache.org/jira/browse/FLINK-3301 Project: Flink I

[jira] [Created] (FLINK-3280) Wrong usage of Boolean.getBoolean()

Ted Yu created FLINK-3280: - Summary: Wrong usage of Boolean.getBoolean() Key: FLINK-3280 URL: https://issues.apache.org/jira/browse/FLINK-3280 Project: Flink Issue Type: Bug Reporter: Ted

[jira] [Created] (FLINK-3269) Return value from DataInputStream#read() should be checked in PythonPlanReceiver

Ted Yu created FLINK-3269: - Summary: Return value from DataInputStream#read() should be checked in PythonPlanReceiver Key: FLINK-3269 URL: https://issues.apache.org/jira/browse/FLINK-3269 Project: Flink

[jira] [Created] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode()

Ted Yu created FLINK-3222: - Summary: Incorrect shift amount in OperatorCheckpointStats#hashCode() Key: FLINK-3222 URL: https://issues.apache.org/jira/browse/FLINK-3222 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3210) Unnecessary call to deserializer#deserialize() in LegacyFetcher#SimpleConsumerThread#run()

Ted Yu created FLINK-3210: - Summary: Unnecessary call to deserializer#deserialize() in LegacyFetcher#SimpleConsumerThread#run() Key: FLINK-3210 URL: https://issues.apache.org/jira/browse/FLINK-3210 Project: F

[jira] [Created] (FLINK-3197) InputStream not closed in BinaryInputFormat#createStatistics

Ted Yu created FLINK-3197: - Summary: InputStream not closed in BinaryInputFormat#createStatistics Key: FLINK-3197 URL: https://issues.apache.org/jira/browse/FLINK-3197 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3196) InputStream should be closed in EnvironmentInformation#getRevisionInformation()

Ted Yu created FLINK-3196: - Summary: InputStream should be closed in EnvironmentInformation#getRevisionInformation() Key: FLINK-3196 URL: https://issues.apache.org/jira/browse/FLINK-3196 Project: Flink

[jira] [Created] (FLINK-3137) Missing break in OutputEmitter ctor

Ted Yu created FLINK-3137: - Summary: Missing break in OutputEmitter ctor Key: FLINK-3137 URL: https://issues.apache.org/jira/browse/FLINK-3137 Project: Flink Issue Type: Bug Reporter: Ted

[jira] [Created] (FLINK-3104) Potential null dereference of outStream in FsStateBackend#CheckpointStateOutputStream#closeAndGetHandle()

Ted Yu created FLINK-3104: - Summary: Potential null dereference of outStream in FsStateBackend#CheckpointStateOutputStream#closeAndGetHandle() Key: FLINK-3104 URL: https://issues.apache.org/jira/browse/FLINK-3104

[jira] [Created] (FLINK-3103) Accessing closed in FsStateBackend#FsCheckpointStateOutputStream#flush() should be synchronized

Ted Yu created FLINK-3103: - Summary: Accessing closed in FsStateBackend#FsCheckpointStateOutputStream#flush() should be synchronized Key: FLINK-3103 URL: https://issues.apache.org/jira/browse/FLINK-3103 Proje

[jira] [Created] (FLINK-3014) Return code from InputStream#read() should be checked in PythonStreamer#sendBroadCastVariables

Ted Yu created FLINK-3014: - Summary: Return code from InputStream#read() should be checked in PythonStreamer#sendBroadCastVariables Key: FLINK-3014 URL: https://issues.apache.org/jira/browse/FLINK-3014 Projec

[jira] [Created] (FLINK-3005) Commons-collections object deserialization remote command execution vulnerability

Ted Yu created FLINK-3005: - Summary: Commons-collections object deserialization remote command execution vulnerability Key: FLINK-3005 URL: https://issues.apache.org/jira/browse/FLINK-3005 Project: Flink

[jira] [Created] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided

Ted Yu created FLINK-2963: - Summary: Dependence on SerializationUtils#deserialize() should be avoided Key: FLINK-2963 URL: https://issues.apache.org/jira/browse/FLINK-2963 Project: Flink Issue Type:

[jira] [Created] (FLINK-2914) Missing break in ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent()

Ted Yu created FLINK-2914: - Summary: Missing break in ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent() Key: FLINK-2914 URL: https://issues.apache.org/jira/browse/FLINK-2914 Pro

[jira] [Created] (FLINK-2913) Close of ObjectOutputStream should be enclosed in finally block in FsStateBackend

Ted Yu created FLINK-2913: - Summary: Close of ObjectOutputStream should be enclosed in finally block in FsStateBackend Key: FLINK-2913 URL: https://issues.apache.org/jira/browse/FLINK-2913 Project: Flink

[jira] [Created] (FLINK-2912) Potential resource leak due to unclosed RandomAccessFile in StaticFileServerHandler

Ted Yu created FLINK-2912: - Summary: Potential resource leak due to unclosed RandomAccessFile in StaticFileServerHandler Key: FLINK-2912 URL: https://issues.apache.org/jira/browse/FLINK-2912 Project: Flink

[jira] [Created] (FLINK-2868) Missing null check for operatorChain in StreamTask#invoke()

Ted Yu created FLINK-2868: - Summary: Missing null check for operatorChain in StreamTask#invoke() Key: FLINK-2868 URL: https://issues.apache.org/jira/browse/FLINK-2868 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2867) Access to pendingFilesPerCheckpoint should be synchronized

Ted Yu created FLINK-2867: - Summary: Access to pendingFilesPerCheckpoint should be synchronized Key: FLINK-2867 URL: https://issues.apache.org/jira/browse/FLINK-2867 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2866) Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle

Ted Yu created FLINK-2866: - Summary: Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle Key: FLINK-2866 URL: https://issues.apache.org/jira/browse/FLINK-2866 Project: Fli

[jira] [Created] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties()

Ted Yu created FLINK-2827: - Summary: Potential resource leak in TwitterSource#loadAuthenticationProperties() Key: FLINK-2827 URL: https://issues.apache.org/jira/browse/FLINK-2827 Project: Flink Issu

[jira] [Created] (FLINK-2826) transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking

Ted Yu created FLINK-2826: - Summary: transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking Key: FLINK-2826 URL: https://issues.apache.org/jira/browse/FLINK-2826

[jira] [Created] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.1 release

Ted Yu created FLINK-2765: - Summary: Upgrade hbase version for hadoop-2 to 1.1 release Key: FLINK-2765 URL: https://issues.apache.org/jira/browse/FLINK-2765 Project: Flink Issue Type: Improvement

<    1   2   3   >