[jira] [Updated] (BAHIR-107) Build and test Bahir against Scala 2.12

2017-09-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-107: - Description: Spark has started effort for accommodating Scala 2.12 See SPARK-14220 This JIRA is to track requirem

[jira] [Created] (BAHIR-136) HBase Spark connector

2017-09-12 Thread Ted Yu (JIRA)
Ted Yu created BAHIR-136: Summary: HBase Spark connector Key: BAHIR-136 URL: https://issues.apache.org/jira/browse/BAHIR-136 Project: Bahir Issue Type: Improvement Reporter: Ted Yu

[jira] [Resolved] (BAHIR-136) HBase Spark connector

2017-09-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved BAHIR-136. -- Resolution: Won't Fix Fix Version/s: Not Applicable > HBase Spark connector > - > >

[jira] [Commented] (BAHIR-136) HBase Spark connector

2017-09-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166884#comment-16166884 ] Ted Yu commented on BAHIR-136: -- This was created before recent exchanges on the mailing list.

[jira] [Updated] (BAHIR-107) Build and test Bahir against Scala 2.12

2017-09-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-107: - Description: Spark has started effort for accommodating Scala 2.12 See SPARK-14220 This JIRA is to track requireme

[jira] [Updated] (BAHIR-107) Build and test Bahir against Scala 2.12

2017-11-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-107: - Description: Spark has started effort for accommodating Scala 2.12 See SPARK-14220 This JIRA is to track requirem

[jira] [Created] (BAHIR-172) Avoid FileInputStream/FileOutputStream

2018-07-04 Thread Ted Yu (JIRA)
Ted Yu created BAHIR-172: Summary: Avoid FileInputStream/FileOutputStream Key: BAHIR-172 URL: https://issues.apache.org/jira/browse/BAHIR-172 Project: Bahir Issue Type: Bug Reporter: Ted

[jira] [Created] (BAHIR-173) Upgrade bahir-flink to support Flink 1.5.1

2018-07-13 Thread Ted Yu (JIRA)
Ted Yu created BAHIR-173: Summary: Upgrade bahir-flink to support Flink 1.5.1 Key: BAHIR-173 URL: https://issues.apache.org/jira/browse/BAHIR-173 Project: Bahir Issue Type: Improvement Re

[jira] [Commented] (BAHIR-173) Upgrade bahir-flink to support Flink 1.5.1

2018-07-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16543417#comment-16543417 ] Ted Yu commented on BAHIR-173: -- Currently I saw: {code} [ERROR] warning: [options] bootstrap

[jira] [Commented] (BAHIR-173) Upgrade bahir-flink to support Flink 1.5.1

2018-07-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16547766#comment-16547766 ] Ted Yu commented on BAHIR-173: -- Please go ahead. Thanks > Upgrade bahir-flink to support F

[jira] [Updated] (BAHIR-172) Avoid FileInputStream/FileOutputStream

2018-07-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-172: - Description: They rely on finalizers (before Java 11), which create unnecessary GC load. The alternatives, {{File

[jira] [Updated] (BAHIR-172) Avoid FileInputStream/FileOutputStream

2018-08-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-172: - Description: They rely on finalizers (before Java 11), which create unnecessary GC load. The alternatives, {{Fil

[jira] [Updated] (BAHIR-172) Avoid FileInputStream/FileOutputStream

2018-09-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-172: - Description: They rely on finalizers (before Java 11), which create unnecessary GC load. The alternatives, {{File

[jira] [Updated] (BAHIR-107) Build and test Bahir against Scala 2.12

2018-09-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-107: - Description: Spark has started effort for accommodating Scala 2.12 See SPARK-14220 . This JIRA is to track requi

[jira] [Updated] (BAHIR-172) Avoid FileInputStream/FileOutputStream

2018-09-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-172: - Description: They rely on finalizers (before Java 11), which create unnecessary GC load. The alternatives, {{Fil

[jira] [Updated] (BAHIR-107) Build and test Bahir against Scala 2.12

2018-09-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BAHIR-107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-107: - Description: Spark has started effort for accommodating Scala 2.12 See SPARK-14220 . This JIRA is to track requi

[jira] [Created] (FLINK-9580) Potentially unclosed ByteBufInputStream in RestClient#readRawResponse

2018-06-13 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9580: - Summary: Potentially unclosed ByteBufInputStream in RestClient#readRawResponse Key: FLINK-9580 URL: https://issues.apache.org/jira/browse/FLINK-9580 Project: Flink Issue

[jira] [Created] (FLINK-9675) Avoid FileInputStream/FileOutputStream

2018-06-27 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9675: - Summary: Avoid FileInputStream/FileOutputStream Key: FLINK-9675 URL: https://issues.apache.org/jira/browse/FLINK-9675 Project: Flink Issue Type: Improvement Re

[jira] [Created] (FLINK-9697) Provide connector for Kafka 2.0.0

2018-06-30 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9697: - Summary: Provide connector for Kafka 2.0.0 Key: FLINK-9697 URL: https://issues.apache.org/jira/browse/FLINK-9697 Project: Flink Issue Type: Improvement Reporte

[jira] [Created] (FLINK-9735) Potential resource leak in RocksDBStateBackend#getDbOptions

2018-07-03 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9735: - Summary: Potential resource leak in RocksDBStateBackend#getDbOptions Key: FLINK-9735 URL: https://issues.apache.org/jira/browse/FLINK-9735 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9736) Potential null reference in KeyGroupPartitionedPriorityQueue#poll()

2018-07-03 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9736: - Summary: Potential null reference in KeyGroupPartitionedPriorityQueue#poll() Key: FLINK-9736 URL: https://issues.apache.org/jira/browse/FLINK-9736 Project: Flink Issue Ty

[jira] [Created] (FLINK-9824) Support IPv6 literal

2018-07-11 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9824: - Summary: Support IPv6 literal Key: FLINK-9824 URL: https://issues.apache.org/jira/browse/FLINK-9824 Project: Flink Issue Type: Bug Reporter: Ted Yu Currently

[jira] [Created] (FLINK-9825) Upgrade checkstyle version to 8.6

2018-07-11 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9825: - Summary: Upgrade checkstyle version to 8.6 Key: FLINK-9825 URL: https://issues.apache.org/jira/browse/FLINK-9825 Project: Flink Issue Type: Improvement Reporte

[jira] [Created] (FLINK-9849) Upgrade hbase version to 2.0.1 for hbase connector

2018-07-13 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9849: - Summary: Upgrade hbase version to 2.0.1 for hbase connector Key: FLINK-9849 URL: https://issues.apache.org/jira/browse/FLINK-9849 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9880) Incorrect argument order calling BucketerContext#update

2018-07-17 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9880: - Summary: Incorrect argument order calling BucketerContext#update Key: FLINK-9880 URL: https://issues.apache.org/jira/browse/FLINK-9880 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9924) Upgrade zookeeper to 3.4.13

2018-07-23 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9924: - Summary: Upgrade zookeeper to 3.4.13 Key: FLINK-9924 URL: https://issues.apache.org/jira/browse/FLINK-9924 Project: Flink Issue Type: Task Reporter: Ted Yu z

[jira] [Created] (FLINK-10125) Unclosed ByteArrayDataOutputView in RocksDBMapState

2018-08-10 Thread Ted Yu (JIRA)
Ted Yu created FLINK-10125: -- Summary: Unclosed ByteArrayDataOutputView in RocksDBMapState Key: FLINK-10125 URL: https://issues.apache.org/jira/browse/FLINK-10125 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10228) Add metrics for netty direct memory consumption

2018-08-27 Thread Ted Yu (JIRA)
Ted Yu created FLINK-10228: -- Summary: Add metrics for netty direct memory consumption Key: FLINK-10228 URL: https://issues.apache.org/jira/browse/FLINK-10228 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10388) RestClientTest sometimes fails with AssertionError

2018-09-21 Thread Ted Yu (JIRA)
Ted Yu created FLINK-10388: -- Summary: RestClientTest sometimes fails with AssertionError Key: FLINK-10388 URL: https://issues.apache.org/jira/browse/FLINK-10388 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-10389) TaskManagerServicesConfiguration ctor contains self assignment

2018-09-21 Thread Ted Yu (JIRA)
Ted Yu created FLINK-10389: -- Summary: TaskManagerServicesConfiguration ctor contains self assignment Key: FLINK-10389 URL: https://issues.apache.org/jira/browse/FLINK-10389 Project: Flink Issue Typ

[jira] [Created] (FLINK-10391) MillisOfDay is used in place of instant for LocalTime ctor in AvroKryoSerializerUtils

2018-09-21 Thread Ted Yu (JIRA)
Ted Yu created FLINK-10391: -- Summary: MillisOfDay is used in place of instant for LocalTime ctor in AvroKryoSerializerUtils Key: FLINK-10391 URL: https://issues.apache.org/jira/browse/FLINK-10391 Project: Fl

[jira] [Created] (FLINK-10446) Use the "guava beta checker" plugin to keep off of @Beta API

2018-09-26 Thread Ted Yu (JIRA)
Ted Yu created FLINK-10446: -- Summary: Use the "guava beta checker" plugin to keep off of @Beta API Key: FLINK-10446 URL: https://issues.apache.org/jira/browse/FLINK-10446 Project: Flink Issue Type:

[jira] [Created] (FLINK-10467) Upgrade commons-compress to 1.18

2018-09-29 Thread Ted Yu (JIRA)
Ted Yu created FLINK-10467: -- Summary: Upgrade commons-compress to 1.18 Key: FLINK-10467 URL: https://issues.apache.org/jira/browse/FLINK-10467 Project: Flink Issue Type: Task Reporter: T

[jira] [Created] (FLINK-10468) Potential missing break for PARTITION_CUSTOM in OutputEmitter ctor

2018-09-30 Thread Ted Yu (JIRA)
Ted Yu created FLINK-10468: -- Summary: Potential missing break for PARTITION_CUSTOM in OutputEmitter ctor Key: FLINK-10468 URL: https://issues.apache.org/jira/browse/FLINK-10468 Project: Flink Issue

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

2016-07-22 Thread Ted Yu (JIRA)
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-4259) Unclosed FSDataOutputStream in FileCache#copy()

2016-07-22 Thread Ted Yu (JIRA)
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-4309) Potential null pointer dereference in DelegatingConfiguration#keySet()

2016-08-02 Thread Ted Yu (JIRA)
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-4436) Unclosed DataOutputBuffer in Utils#setTokensFor()

2016-08-19 Thread Ted Yu (JIRA)
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-4437) Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields

2016-08-19 Thread Ted Yu (JIRA)
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-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock

2016-08-24 Thread Ted Yu (JIRA)
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-4499) Introduce findbugs maven plugin

2016-08-25 Thread Ted Yu (JIRA)
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-4531) Thread.stop() is deprecated

2016-08-29 Thread Ted Yu (JIRA)
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-4533) Unprotected access to meters in StatsDReporter#report()

2016-08-30 Thread Ted Yu (JIRA)
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-4534) Lack of synchronization in BucketingSink#restoreState() w.r.t. state.bucketStates

2016-08-30 Thread Ted Yu (JIRA)
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-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler#

2016-09-02 Thread Ted Yu (JIRA)
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-4626) Missing break in MetricStore#add()

2016-09-15 Thread Ted Yu (JIRA)
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-4659) Potential resource leak due to unclosed InputStream in SecurityContext#populateSystemSecurityProperties()

2016-09-21 Thread Ted Yu (JIRA)
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-4701) Unprotected access to cancelables in StreamTask

2016-09-27 Thread Ted Yu (JIRA)
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-4759) Unclosed DataOutputViewStream in JavaSerializer

2016-10-06 Thread Ted Yu (JIRA)
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-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

2016-10-17 Thread Ted Yu (JIRA)
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

2016-10-17 Thread Ted Yu (JIRA)
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-4938) Unnecessary update() call for Views to be removed in ViewUpdater#run()

2016-10-26 Thread Ted Yu (JIRA)
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-4999) Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers

2016-11-02 Thread Ted Yu (JIRA)
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-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers

2016-11-02 Thread Ted Yu (JIRA)
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-5050) JSON.org license is CatX

2016-11-10 Thread Ted Yu (JIRA)
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-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState()

2016-12-07 Thread Ted Yu (JIRA)
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()

2016-12-07 Thread Ted Yu (JIRA)
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-5347) Unclosed stream in OperatorBackendSerializationProxy#write()

2016-12-15 Thread Ted Yu (JIRA)
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-5376) Misleading log statements in UnorderedStreamElementQueue

2016-12-20 Thread Ted Yu (JIRA)
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-5390) input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph()

2016-12-23 Thread Ted Yu (JIRA)
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-5391) Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown()

2016-12-23 Thread Ted Yu (JIRA)
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-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

2017-01-13 Thread Ted Yu (JIRA)
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-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions

2017-01-13 Thread Ted Yu (JIRA)
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-5517) Upgrade hbase version to 1.3.0

2017-01-16 Thread Ted Yu (JIRA)
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-5541) Missing null check for localJar in FlinkSubmitter#submitTopology()

2017-01-17 Thread Ted Yu (JIRA)
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-5696) Access to REAPER_THREAD lacks proper synchronization in SafetyNetCloseableRegistry#doRegister

2017-02-01 Thread Ted Yu (JIRA)
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-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

2017-02-20 Thread Ted Yu (JIRA)
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-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()

2017-03-01 Thread Ted Yu (JIRA)
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-5987) Upgrade zookeeper dependency to 3.4.8

2017-03-07 Thread Ted Yu (JIRA)
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-6052) Potential null access in ZooKeeperCompletedCheckpointStore#getLatestCheckpoint()

2017-03-14 Thread Ted Yu (JIRA)
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-6079) Ineffective null check in FlinkKafkaConsumerBase#open()

2017-03-16 Thread Ted Yu (JIRA)
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-6080) Unclosed ObjectOutputStream in NFA#serialize()

2017-03-16 Thread Ted Yu (JIRA)
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-6104) Unclosed WriteOptions in ListViaRangeSpeedMiniBenchmark#main()

2017-03-17 Thread Ted Yu (JIRA)
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-6105) Properly handle InterruptedException

2017-03-17 Thread Ted Yu (JIRA)
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-6130) Consider calling resourceManager#getTerminationFuture() with lock held

2017-03-20 Thread Ted Yu (JIRA)
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-6143) Unprotected access to this.flink in LocalExecutor#endSession()

2017-03-21 Thread Ted Yu (JIRA)
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-6169) yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error

2017-03-22 Thread Ted Yu (JIRA)
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-6172) Potentially unclosed RandomAccessFile in HistoryServerStaticFileServerHandler

2017-03-22 Thread Ted Yu (JIRA)
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-6210) RocksDB instance should be closed in ListViaMergeSpeedMiniBenchmark

2017-03-28 Thread Ted Yu (JIRA)
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-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

2017-04-06 Thread Ted Yu (JIRA)
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-2511) Potential resource leak due to unclosed InputStream in FlinkZooKeeperQuorumPeer.java

2015-08-11 Thread Ted Yu (JIRA)
Ted Yu created FLINK-2511: - Summary: Potential resource leak due to unclosed InputStream in FlinkZooKeeperQuorumPeer.java Key: FLINK-2511 URL: https://issues.apache.org/jira/browse/FLINK-2511 Project: Flink

[jira] [Created] (FLINK-2538) Potential resource leak in ClassLoaderUtil#getUserCodeClassLoaderInfo()

2015-08-17 Thread Ted Yu (JIRA)
Ted Yu created FLINK-2538: - Summary: Potential resource leak in ClassLoaderUtil#getUserCodeClassLoaderInfo() Key: FLINK-2538 URL: https://issues.apache.org/jira/browse/FLINK-2538 Project: Flink Issu

[jira] [Created] (FLINK-2595) Unclosed JarFile may leak resource in ClassLoaderUtilsTest

2015-08-28 Thread Ted Yu (JIRA)
Ted Yu created FLINK-2595: - Summary: Unclosed JarFile may leak resource in ClassLoaderUtilsTest Key: FLINK-2595 URL: https://issues.apache.org/jira/browse/FLINK-2595 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-2604) Access to SessionID without holding lock in ZooKeeperLeaderElectionService

2015-09-01 Thread Ted Yu (JIRA)
Ted Yu created FLINK-2604: - Summary: Access to SessionID without holding lock in ZooKeeperLeaderElectionService Key: FLINK-2604 URL: https://issues.apache.org/jira/browse/FLINK-2604 Project: Flink I

[jira] [Created] (FLINK-2605) Unclosed RandomAccessFile may leak resource in StaticFileServerHandler

2015-09-01 Thread Ted Yu (JIRA)
Ted Yu created FLINK-2605: - Summary: Unclosed RandomAccessFile may leak resource in StaticFileServerHandler Key: FLINK-2605 URL: https://issues.apache.org/jira/browse/FLINK-2605 Project: Flink Issue

[jira] [Created] (FLINK-2649) Potential resource leak in JarHelper#unjar()

2015-09-09 Thread Ted Yu (JIRA)
Ted Yu created FLINK-2649: - Summary: Potential resource leak in JarHelper#unjar() Key: FLINK-2649 URL: https://issues.apache.org/jira/browse/FLINK-2649 Project: Flink Issue Type: Bug Repo

[jira] [Created] (FLINK-2708) Potential null pointer dereference in JoinWithSolutionSetFirstDriver#run()

2015-09-18 Thread Ted Yu (JIRA)
Ted Yu created FLINK-2708: - Summary: Potential null pointer dereference in JoinWithSolutionSetFirstDriver#run() Key: FLINK-2708 URL: https://issues.apache.org/jira/browse/FLINK-2708 Project: Flink I

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

2015-09-25 Thread Ted Yu (JIRA)
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

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

2015-10-06 Thread Ted Yu (JIRA)
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-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties()

2015-10-06 Thread Ted Yu (JIRA)
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-2866) Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle

2015-10-18 Thread Ted Yu (JIRA)
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-2867) Access to pendingFilesPerCheckpoint should be synchronized

2015-10-18 Thread Ted Yu (JIRA)
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-2868) Missing null check for operatorChain in StreamTask#invoke()

2015-10-18 Thread Ted Yu (JIRA)
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-2912) Potential resource leak due to unclosed RandomAccessFile in StaticFileServerHandler

2015-10-24 Thread Ted Yu (JIRA)
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-2913) Close of ObjectOutputStream should be enclosed in finally block in FsStateBackend

2015-10-24 Thread Ted Yu (JIRA)
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-2914) Missing break in ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent()

2015-10-24 Thread Ted Yu (JIRA)
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-2963) Dependence on SerializationUtils#deserialize() should be avoided

2015-11-03 Thread Ted Yu (JIRA)
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-3005) Commons-collections object deserialization remote command execution vulnerability

2015-11-11 Thread Ted Yu (JIRA)
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-3014) Return code from InputStream#read() should be checked in PythonStreamer#sendBroadCastVariables

2015-11-15 Thread Ted Yu (JIRA)
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-3103) Accessing closed in FsStateBackend#FsCheckpointStateOutputStream#flush() should be synchronized

2015-12-02 Thread Ted Yu (JIRA)
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

<    5   6   7   8   9   10   11   >