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

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

[jira] [Created] (FLINK-2511) Potential resource leak due to unclosed InputStream in FlinkZooKeeperQuorumPeer.java

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-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-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

[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] [Resolved] (FLINK-2867) Access to pendingFilesPerCheckpoint should be synchronized

[ https://issues.apache.org/jira/browse/FLINK-2867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-2867. --- Resolution: Not A Problem > Access to pendingFilesPerCheckpoint should be synchronized >

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

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

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

[ https://issues.apache.org/jira/browse/FLINK-2868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-2868. --- Resolution: Not A Problem > Missing null check for operatorChain in StreamTask#invoke() >

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

[ https://issues.apache.org/jira/browse/FLINK-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14978749#comment-14978749 ] Ted Yu commented on FLINK-2826: --- Can you clarify on point #1 please. We already have: {code} private

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

[ https://issues.apache.org/jira/browse/FLINK-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu reassigned FLINK-2826: - Assignee: Ted Yu > transformed is modified in >

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

[ https://issues.apache.org/jira/browse/FLINK-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14998719#comment-14998719 ] Ted Yu commented on FLINK-2963: --- Not completely: {code} return

[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] [Updated] (FLINK-2914) Missing break in ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent()

[ https://issues.apache.org/jira/browse/FLINK-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2914: -- Description: {code} case CONNECTION_SUSPENDED: LOG.warn("ZooKeeper connection SUSPENDED.

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

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

[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

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

[ https://issues.apache.org/jira/browse/FLINK-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2914: -- Description: {code} case CONNECTION_SUSPENDED: LOG.warn("ZooKeeper connection SUSPENDED.

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

[ https://issues.apache.org/jira/browse/FLINK-2913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2913: -- Description: {code} ObjectOutputStream os = new ObjectOutputStream(outStream);

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

[ https://issues.apache.org/jira/browse/FLINK-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2914: -- Description: {code} case CONNECTION_SUSPENDED: LOG.warn("ZooKeeper connection SUSPENDED.

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

[ https://issues.apache.org/jira/browse/FLINK-2913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2913: -- Description: {code} ObjectOutputStream os = new ObjectOutputStream(outStream);

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

[ https://issues.apache.org/jira/browse/FLINK-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2914: -- Description: {code} case CONNECTION_SUSPENDED: LOG.warn("ZooKeeper connection SUSPENDED.

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

[ https://issues.apache.org/jira/browse/FLINK-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2826: -- Description: Here is related code: {code} if (references.isEmpty()) {

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

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

[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

[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:

[jira] [Updated] (FLINK-2789) Vulnerability to XSS attack due to printing HTML output

[ https://issues.apache.org/jira/browse/FLINK-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2789: -- Priority: Minor (was: Major) > Vulnerability to XSS attack due to printing HTML output >

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

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

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

[ https://issues.apache.org/jira/browse/FLINK-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2826: -- Description: Here is related code: {code} if (references.isEmpty()) {

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

[ https://issues.apache.org/jira/browse/FLINK-2827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2827: -- Description: Here is related code: {code} Properties properties = new Properties();

[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-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

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

[ https://issues.apache.org/jira/browse/FLINK-3005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15011251#comment-15011251 ] Ted Yu commented on FLINK-3005: --- Would update to Commons Collections 3.2.2 alleviate the remote code

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-2605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2605: -- Attachment: flink-2605-v1.txt Can I use try-with-resources ? > Unclosed RandomAccessFile may leak resource in

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

[ https://issues.apache.org/jira/browse/FLINK-2595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2595: -- Description: Here is related code: {code} try { new

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

[ https://issues.apache.org/jira/browse/FLINK-2595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2595: -- Description: Here is related code: {code} try { new

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

[ https://issues.apache.org/jira/browse/FLINK-2649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2649: -- Description: {code} dest = new BufferedOutputStream(fos, BUFFER_SIZE); while ((count = jis.read(data,

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

[ https://issues.apache.org/jira/browse/FLINK-2595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2595: -- Description: Here is related code: {code} try { new

[jira] [Moved] (FLINK-2789) Vulnerability to XSS attack due to printing HTML output

[ https://issues.apache.org/jira/browse/FLINK-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu moved HBASE-14514 to FLINK-2789: --- Workflow: jira (was: no-reopen-closed, patch-avail) Key: FLINK-2789 (was:

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

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

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

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

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

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

[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

[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

[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] [Resolved] (FLINK-3104) Potential null dereference of outStream in FsStateBackend#CheckpointStateOutputStream#closeAndGetHandle()

[ https://issues.apache.org/jira/browse/FLINK-3104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-3104. --- Resolution: Not A Problem > Potential null dereference of outStream in >

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

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

[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:

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

[ https://issues.apache.org/jira/browse/FLINK-3137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045751#comment-15045751 ] Ted Yu commented on FLINK-3137: --- I see. A comment would help people who later look at this code. > Missing

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

[ https://issues.apache.org/jira/browse/FLINK-3137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15046159#comment-15046159 ] Ted Yu commented on FLINK-3137: --- I want to point out that current code is prone to bug which might be

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

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

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

[ https://issues.apache.org/jira/browse/FLINK-3103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3103: -- Description: Here is related code: {code} public void flush() throws IOException { if (!closed) {

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

[ https://issues.apache.org/jira/browse/FLINK-3014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081609#comment-15081609 ] Ted Yu commented on FLINK-3014: --- Can someone review the PR ? Thanks > Return code from InputStream#read()

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

[ https://issues.apache.org/jira/browse/FLINK-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3197: -- Description: Here is related code: {code} FSDataInputStream fdis =

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

[ https://issues.apache.org/jira/browse/FLINK-3196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3196: -- Description: Here is related code: {code} InputStream propFile =

[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:

[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] [Updated] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.1 release

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

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

[ https://issues.apache.org/jira/browse/FLINK-3014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3014: -- Description: Here is related code (there're 3 occurrences in the method): {code} in.read(buffer, 0, 4);

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

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

[jira] [Updated] (FLINK-3103) Remove synchronization in FsStateBackend#FsCheckpointStateOutputStream#close()

[ https://issues.apache.org/jira/browse/FLINK-3103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3103: -- Summary: Remove synchronization in FsStateBackend#FsCheckpointStateOutputStream#close() (was: Accessing closed

[jira] [Assigned] (FLINK-3103) Remove synchronization in FsStateBackend#FsCheckpointStateOutputStream#close()

[ https://issues.apache.org/jira/browse/FLINK-3103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu reassigned FLINK-3103: - Assignee: Ted Yu > Remove synchronization in FsStateBackend#FsCheckpointStateOutputStream#close() >

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

[ https://issues.apache.org/jira/browse/FLINK-3014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15066754#comment-15066754 ] Ted Yu commented on FLINK-3014: --- Thanks for the PR, Chesnay. > Return code from InputStream#read() should

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

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

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

[ https://issues.apache.org/jira/browse/FLINK-3014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3014: -- Description: Here is related code (there're 3 occurrences in the method): {code} in.read(buffer, 0, 4);

[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:

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

[ https://issues.apache.org/jira/browse/FLINK-3014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15094297#comment-15094297 ] Ted Yu commented on FLINK-3014: --- Ping ... > Return code from InputStream#read() should be checked in >

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

[ https://issues.apache.org/jira/browse/FLINK-3958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-3958. --- Resolution: Not A Problem > Access to MetricRegistry doesn't have proper synchronization in some classes >

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

[ https://issues.apache.org/jira/browse/FLINK-3958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3958: -- Description: In GraphiteReporter#getReporter(): {code} com.codahale.metrics.graphite.GraphiteReporter.Builder

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

[ https://issues.apache.org/jira/browse/FLINK-3998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3998: -- Description: {code} for (Map.Entry entry : gauges.entrySet()) {

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

[ https://issues.apache.org/jira/browse/FLINK-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3753: -- Description: {code} // this is harsh, but this watchdog is a last resort if (toKill.isAlive()) {

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

[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3734: -- Description: {code} DataInputView in = inputState.getState(getUserCodeClassloader()); final long

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

[ https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3801: -- Description: Currently yoda-time 2.5 is used which was very old. We should upgrade to 2.9.3 was: Currently

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

[ https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3801: -- Description: Currently yoda-time 2.5 is used which was very old. We should upgrade to 2.9.3 was: Currently

[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] [Commented] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15302121#comment-15302121 ] Ted Yu commented on FLINK-2765: --- API compatibility is maintained. However, HBASE-15198 caused regression

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

[ https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3801: -- Description: Currently yoda-time 2.5 is used which was very old. We should upgrade to 2.9.3 was: Currently

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

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

[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] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3734: -- Description: {code} DataInputView in = inputState.getState(getUserCodeClassloader()); final long

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

[ https://issues.apache.org/jira/browse/FLINK-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3753: -- Description: {code} // this is harsh, but this watchdog is a last resort if (toKill.isAlive()) {

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

[ https://issues.apache.org/jira/browse/FLINK-3958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3958: -- Description: In GraphiteReporter#getReporter(): {code} com.codahale.metrics.graphite.GraphiteReporter.Builder

[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

[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

[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

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

[ https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3222: -- Description: Here is related code: {code} result = 31 * result + (int) (subTaskStats.length ^

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

[ https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3801: -- Description: Currently yoda-time 2.5 is used which was very old. We should upgrade to 2.9.3 was: Currently

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

[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3734: -- Description: {code} DataInputView in = inputState.getState(getUserCodeClassloader()); final long

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

[ https://issues.apache.org/jira/browse/FLINK-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3753: -- Description: {code} // this is harsh, but this watchdog is a last resort if (toKill.isAlive()) {

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

[ https://issues.apache.org/jira/browse/FLINK-4053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4053: -- Description: In RMQSource.java and RMQSink.java, there is code in the following pattern: {code}

[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:

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

[ https://issues.apache.org/jira/browse/FLINK-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15089572#comment-15089572 ] Ted Yu commented on FLINK-3210: --- bq. The key can still contain something I agree. But why deserializing the

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

[ https://issues.apache.org/jira/browse/FLINK-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3210: -- Description: Here is related code: {code} byte[] valueBytes; if (payload ==

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

[ https://issues.apache.org/jira/browse/FLINK-3196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3196: -- Description: Here is related code: {code} InputStream propFile =

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

[ https://issues.apache.org/jira/browse/FLINK-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3197: -- Description: Here is related code: {code} FSDataInputStream fdis =

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

[ https://issues.apache.org/jira/browse/FLINK-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105804#comment-15105804 ] Ted Yu commented on FLINK-3210: --- My point is that assigning null to valueBytes can be avoided by refactoring

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

[ https://issues.apache.org/jira/browse/FLINK-4096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4096: -- Description: {code} final JarOutputStream jos = new JarOutputStream(new FileOutputStream(this.outputFile),

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

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

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

[ https://issues.apache.org/jira/browse/FLINK-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-3210. --- Resolution: Later > Unnecessary call to deserializer#deserialize() in >

  1   2   3   4   5   6   7   8   9   10   >