[jira] [Created] (FLINK-1739) Fix the bug of JobManager and TaskManager Port Check.
Sibao Hong created FLINK-1739: - Summary: Fix the bug of JobManager and TaskManager Port Check. Key: FLINK-1739 URL: https://issues.apache.org/jira/browse/FLINK-1739 Project: Flink Issue Type: Bug Components: JobManager, Local Runtime, TaskManager Reporter: Sibao Hong Fix For: master The IPC port of JobManager and IPC port of TaskManager must be great than 0 and less than 65535. It must have check the port whether is in right range area before run the JobManager and TaskManager. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1768) Fix the bug of BlobServerConnection's LOG.
Sibao Hong created FLINK-1768: - Summary: Fix the bug of BlobServerConnection's LOG. Key: FLINK-1768 URL: https://issues.apache.org/jira/browse/FLINK-1768 Project: Flink Issue Type: Bug Reporter: Sibao Hong The LOG in class of BlobServerConnection should be created by classloader of BlobServerConnection.class -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1714) Fix the bug of logger class loader
Sibao Hong created FLINK-1714: - Summary: Fix the bug of logger class loader Key: FLINK-1714 URL: https://issues.apache.org/jira/browse/FLINK-1714 Project: Flink Issue Type: Improvement Components: JobManager Affects Versions: master Reporter: Sibao Hong Priority: Minor For log in class SecurityUtils, the LoggerFactory.getLogger() function should be for SecurityUtils not MapPartitionDriver. It is a bug I think -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1766) Fix the bug of equals function of FSKey
Sibao Hong created FLINK-1766: - Summary: Fix the bug of equals function of FSKey Key: FLINK-1766 URL: https://issues.apache.org/jira/browse/FLINK-1766 Project: Flink Issue Type: Bug Reporter: Sibao Hong Priority: Minor The equals function in org.apache.flink.core.fs.FileSystem.FSKey should first have a confirm whether obj == this, if obj is the same object.It should return True. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Assigned] (FLINK-1714) Fix the bug of logger class loader
[ https://issues.apache.org/jira/browse/FLINK-1714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong reassigned FLINK-1714: - Assignee: Sibao Hong Fix the bug of logger class loader -- Key: FLINK-1714 URL: https://issues.apache.org/jira/browse/FLINK-1714 Project: Flink Issue Type: Improvement Components: JobManager Affects Versions: master Reporter: Sibao Hong Assignee: Sibao Hong Priority: Minor Fix For: 0.9 For log in class SecurityUtils, the LoggerFactory.getLogger() function should be for SecurityUtils not MapPartitionDriver. It is a bug I think -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1779) Rename the function name from getCurrentyActiveConnections to getCurrentActiveConnections in org.apache.flink.runtime.blob
Sibao Hong created FLINK-1779: - Summary: Rename the function name from getCurrentyActiveConnections to getCurrentActiveConnections in org.apache.flink.runtime.blob Key: FLINK-1779 URL: https://issues.apache.org/jira/browse/FLINK-1779 Project: Flink Issue Type: Improvement Reporter: Sibao Hong Assignee: Sibao Hong Priority: Minor Fix For: master I think the function name getCurrentyActiveConnections in ' org.apache.flink.runtime.blob' is a wrong spelling, it should be getCurrentyActiveConnections is more better, and also I add some comments about the function and the Tests. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (FLINK-1779) Rename the function name from getCurrentyActiveConnections to getCurrentActiveConnections in org.apache.flink.runtime.blob
[ https://issues.apache.org/jira/browse/FLINK-1779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong updated FLINK-1779: -- Description: I think the function name getCurrentyActiveConnections in ' org.apache.flink.runtime.blob' is a wrong spelling, it should be getCurrentActiveConnections is more better, and also I add some comments about the function and the Tests. (was: I think the function name getCurrentyActiveConnections in ' org.apache.flink.runtime.blob' is a wrong spelling, it should be getCurrentyActiveConnections is more better, and also I add some comments about the function and the Tests.) Rename the function name from getCurrentyActiveConnections to getCurrentActiveConnections in org.apache.flink.runtime.blob --- Key: FLINK-1779 URL: https://issues.apache.org/jira/browse/FLINK-1779 Project: Flink Issue Type: Improvement Reporter: Sibao Hong Assignee: Sibao Hong Priority: Minor Fix For: master I think the function name getCurrentyActiveConnections in ' org.apache.flink.runtime.blob' is a wrong spelling, it should be getCurrentActiveConnections is more better, and also I add some comments about the function and the Tests. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (FLINK-1766) Fix the bug of equals function of FSKey
[ https://issues.apache.org/jira/browse/FLINK-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong updated FLINK-1766: -- Issue Type: Improvement (was: Bug) Fix the bug of equals function of FSKey --- Key: FLINK-1766 URL: https://issues.apache.org/jira/browse/FLINK-1766 Project: Flink Issue Type: Improvement Reporter: Sibao Hong Assignee: Sibao Hong Priority: Minor The equals function in org.apache.flink.core.fs.FileSystem.FSKey should first have a confirm whether obj == this, if obj is the same object.It should return True. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1805) The class IOManagerAsync(in org.apache.flink.runtime.io.disk.iomanager) should use its own Log
Sibao Hong created FLINK-1805: - Summary: The class IOManagerAsync(in org.apache.flink.runtime.io.disk.iomanager) should use its own Log Key: FLINK-1805 URL: https://issues.apache.org/jira/browse/FLINK-1805 Project: Flink Issue Type: Bug Components: Local Runtime Affects Versions: master Reporter: Sibao Hong Assignee: Sibao Hong Although class 'IOManagerAsync' is extended from 'IOManager' in package 'org.apache.flink.runtime.io.disk.iomanager', but I think it should has its own Log instance. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1770) Rename the variable 'contentAdressable' to 'contentAddressable'
Sibao Hong created FLINK-1770: - Summary: Rename the variable 'contentAdressable' to 'contentAddressable' Key: FLINK-1770 URL: https://issues.apache.org/jira/browse/FLINK-1770 Project: Flink Issue Type: Bug Reporter: Sibao Hong Priority: Minor Rename the variable 'contentAdressable' to 'contentAddressable' in order to better understanding. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (FLINK-1770) Rename the variable 'contentAdressable' to 'contentAddressable'
[ https://issues.apache.org/jira/browse/FLINK-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong updated FLINK-1770: -- Fix Version/s: master Rename the variable 'contentAdressable' to 'contentAddressable' --- Key: FLINK-1770 URL: https://issues.apache.org/jira/browse/FLINK-1770 Project: Flink Issue Type: Bug Reporter: Sibao Hong Priority: Minor Fix For: master Rename the variable 'contentAdressable' to 'contentAddressable' in order to better understanding. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (FLINK-1770) Rename the variable 'contentAdressable' to 'contentAddressable'
[ https://issues.apache.org/jira/browse/FLINK-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong updated FLINK-1770: -- Affects Version/s: master Rename the variable 'contentAdressable' to 'contentAddressable' --- Key: FLINK-1770 URL: https://issues.apache.org/jira/browse/FLINK-1770 Project: Flink Issue Type: Bug Affects Versions: master Reporter: Sibao Hong Priority: Minor Fix For: master Rename the variable 'contentAdressable' to 'contentAddressable' in order to better understanding. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Assigned] (FLINK-1768) Fix the bug of BlobServerConnection's LOG.
[ https://issues.apache.org/jira/browse/FLINK-1768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong reassigned FLINK-1768: - Assignee: Sibao Hong Fix the bug of BlobServerConnection's LOG. -- Key: FLINK-1768 URL: https://issues.apache.org/jira/browse/FLINK-1768 Project: Flink Issue Type: Bug Reporter: Sibao Hong Assignee: Sibao Hong The LOG in class of BlobServerConnection should be created by classloader of BlobServerConnection.class -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Assigned] (FLINK-1766) Fix the bug of equals function of FSKey
[ https://issues.apache.org/jira/browse/FLINK-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong reassigned FLINK-1766: - Assignee: Sibao Hong Fix the bug of equals function of FSKey --- Key: FLINK-1766 URL: https://issues.apache.org/jira/browse/FLINK-1766 Project: Flink Issue Type: Bug Reporter: Sibao Hong Assignee: Sibao Hong Priority: Minor The equals function in org.apache.flink.core.fs.FileSystem.FSKey should first have a confirm whether obj == this, if obj is the same object.It should return True. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Assigned] (FLINK-1770) Rename the variable 'contentAdressable' to 'contentAddressable'
[ https://issues.apache.org/jira/browse/FLINK-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong reassigned FLINK-1770: - Assignee: Sibao Hong Rename the variable 'contentAdressable' to 'contentAddressable' --- Key: FLINK-1770 URL: https://issues.apache.org/jira/browse/FLINK-1770 Project: Flink Issue Type: Bug Affects Versions: master Reporter: Sibao Hong Assignee: Sibao Hong Priority: Minor Fix For: master Rename the variable 'contentAdressable' to 'contentAddressable' in order to better understanding. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (FLINK-1790) d
[ https://issues.apache.org/jira/browse/FLINK-1790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong updated FLINK-1790: -- Description: Remove the redundant import code (was: Remove the redunant import code) d - Key: FLINK-1790 URL: https://issues.apache.org/jira/browse/FLINK-1790 Project: Flink Issue Type: Improvement Components: TaskManager Affects Versions: master Reporter: Sibao Hong Assignee: Sibao Hong Priority: Minor Remove the redundant import code -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (FLINK-1790) d
[ https://issues.apache.org/jira/browse/FLINK-1790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong updated FLINK-1790: -- Summary: d (was: Remove the redunant import code) d - Key: FLINK-1790 URL: https://issues.apache.org/jira/browse/FLINK-1790 Project: Flink Issue Type: Improvement Components: TaskManager Affects Versions: master Reporter: Sibao Hong Assignee: Sibao Hong Priority: Minor Remove the redunant import code -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1790) Remove the redunant import code
Sibao Hong created FLINK-1790: - Summary: Remove the redunant import code Key: FLINK-1790 URL: https://issues.apache.org/jira/browse/FLINK-1790 Project: Flink Issue Type: Improvement Components: TaskManager Affects Versions: master Reporter: Sibao Hong Assignee: Sibao Hong Priority: Minor Remove the redunant import code -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1774) Remove the redundant code in try{} block
Sibao Hong created FLINK-1774:
-
Summary: Remove the redundant code in try{} block
Key: FLINK-1774
URL: https://issues.apache.org/jira/browse/FLINK-1774
Project: Flink
Issue Type: Improvement
Reporter: Sibao Hong
Priority: Minor
Remove the redundant code of fos.close(); fos = null; in try block because
the fos,close() code will always executes in finally block.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Updated] (FLINK-1774) Remove the redundant code in try{} block
[
https://issues.apache.org/jira/browse/FLINK-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sibao Hong updated FLINK-1774:
--
Affects Version/s: master
Remove the redundant code in try{} block
Key: FLINK-1774
URL: https://issues.apache.org/jira/browse/FLINK-1774
Project: Flink
Issue Type: Improvement
Affects Versions: master
Reporter: Sibao Hong
Priority: Minor
Fix For: master
Remove the redundant code of fos.close(); fos = null; in try block because
the fos,close() code will always executes in finally block.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Updated] (FLINK-1774) Remove the redundant code in try{} block
[
https://issues.apache.org/jira/browse/FLINK-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sibao Hong updated FLINK-1774:
--
Fix Version/s: master
Remove the redundant code in try{} block
Key: FLINK-1774
URL: https://issues.apache.org/jira/browse/FLINK-1774
Project: Flink
Issue Type: Improvement
Affects Versions: master
Reporter: Sibao Hong
Priority: Minor
Fix For: master
Remove the redundant code of fos.close(); fos = null; in try block because
the fos,close() code will always executes in finally block.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Assigned] (FLINK-1739) Fix the bug of JobManager and TaskManager Port Check.
[ https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong reassigned FLINK-1739: - Assignee: Sibao Hong Fix the bug of JobManager and TaskManager Port Check. - Key: FLINK-1739 URL: https://issues.apache.org/jira/browse/FLINK-1739 Project: Flink Issue Type: Bug Components: JobManager, Local Runtime, TaskManager Reporter: Sibao Hong Assignee: Sibao Hong Fix For: master The IPC port of JobManager and IPC port of TaskManager must be great than 0 and less than 65535. It must have check the port whether is in right range area before run the JobManager and TaskManager. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1887) Fix the message in runtime exception
Sibao Hong created FLINK-1887: - Summary: Fix the message in runtime exception Key: FLINK-1887 URL: https://issues.apache.org/jira/browse/FLINK-1887 Project: Flink Issue Type: Improvement Components: Local Runtime Affects Versions: master Reporter: Sibao Hong Assignee: Sibao Hong Priority: Minor Fix the message in runtime exception -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1891) Add isEmpty check when the input dir
Sibao Hong created FLINK-1891: - Summary: Add isEmpty check when the input dir Key: FLINK-1891 URL: https://issues.apache.org/jira/browse/FLINK-1891 Project: Flink Issue Type: Bug Components: Local Runtime Affects Versions: master Reporter: Sibao Hong Assignee: Sibao Hong Add the input storageDirectory empty check, if input of storageDirectory is empty, we should use tmp as the base dir -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1826) Remove the code never be executed in function getNumPages
Sibao Hong created FLINK-1826: - Summary: Remove the code never be executed in function getNumPages Key: FLINK-1826 URL: https://issues.apache.org/jira/browse/FLINK-1826 Project: Flink Issue Type: Improvement Components: Local Runtime Affects Versions: master Reporter: Sibao Hong Assignee: Sibao Hong Priority: Minor Fix For: master Remove the code never be executed in function getNumPages, because the input of numBytes has be validataion by its caller of DefaultMemoryManager(long memorySize, int numberOfSlots, int pageSize). -- This message was sent by Atlassian JIRA (v6.3.4#6332)
