[GitHub] [flink] flinkbot edited a comment on issue #9711: [FLINK-14033] upload user artifacts for yarn job cluster

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9711: [FLINK-14033] upload user artifacts for yarn job cluster URL: https://github.com/apache/flink/pull/9711#issuecomment-532971678 ## CI report: * 2011905b5abe4cb332a60bc3f70378c777482924 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/…

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/… URL: https://github.com/apache/flink/pull/9683#issuecomment-531697778 ## CI report: * ba87beba470b132b99ed606411ffc43847a72d8f : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9714: [FLINK-14123]Change taskmanager.memory.fraction default value to 0.6

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9714: [FLINK-14123]Change taskmanager.memory.fraction default value to 0.6 URL: https://github.com/apache/flink/pull/9714#issuecomment-532994026 ## CI report: * 9c2f79d83a667cefc8364c4244f183e3798d9602 : FAILURE

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

2019-09-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933142#comment-16933142 ] Till Rohrmann commented on FLINK-14112: --- I would consider it rather as an additional signal which

[jira] [Commented] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

2019-09-19 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933140#comment-16933140 ] TisonKun commented on FLINK-14010: -- Will send a pull request in hours :-) > Dispatcher & JobManagers

[jira] [Assigned] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

2019-09-19 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-14010: Assignee: TisonKun > Dispatcher & JobManagers don't give up leadership when AM is shut down >

[GitHub] [flink] kl0u commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

2019-09-19 Thread GitBox
kl0u commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-533018187 Thanks a lot @yxu-valleytider . I will have a look.

[jira] [Updated] (FLINK-14094) Fix OperatorIOMetricGroup repeat register problem

2019-09-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14094: -- Affects Version/s: 1.10.0 1.9.0 > Fix OperatorIOMetricGroup repeat

[jira] [Updated] (FLINK-14094) Fix OperatorIOMetricGroup repeat register problem

2019-09-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14094: -- Component/s: Runtime / Metrics > Fix OperatorIOMetricGroup repeat register problem >

[jira] [Updated] (FLINK-14094) Fix OperatorIOMetricGroup repeat register problem

2019-09-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14094: -- Fix Version/s: 1.10.0 > Fix OperatorIOMetricGroup repeat register problem >

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

2019-09-19 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933184#comment-16933184 ] TisonKun commented on FLINK-14112: -- Thanks for your insights [~trohrmann]. Sounds reasonable to me.

[GitHub] [flink] StephanEwen commented on a change in pull request #9694: [hotfix] [docs] Fixes in glossar

2019-09-19 Thread GitBox
StephanEwen commented on a change in pull request #9694: [hotfix] [docs] Fixes in glossar URL: https://github.com/apache/flink/pull/9694#discussion_r326070114 ## File path: docs/concepts/glossary.md ## @@ -79,7 +79,7 @@ whole [Flink Master](#flink-master) was called

[GitHub] [flink] StephanEwen commented on a change in pull request #9694: [hotfix] [docs] Fixes in glossar

2019-09-19 Thread GitBox
StephanEwen commented on a change in pull request #9694: [hotfix] [docs] Fixes in glossar URL: https://github.com/apache/flink/pull/9694#discussion_r326070760 ## File path: docs/concepts/glossary.md ## @@ -161,6 +161,6 @@ subsequent Tasks. A Transformation is applied on

[GitHub] [flink] flinkbot edited a comment on issue #9715: [Flink-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9715: [Flink-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode URL: https://github.com/apache/flink/pull/9715#issuecomment-533036474 ## CI report: * efa22104931934947ad229ead46e2e4747eb0830 : PENDING

[jira] [Created] (FLINK-14126) Elasticsearch Xpack Machine Learning doesn't support ARM

2019-09-19 Thread wangxiyuan (Jira)
wangxiyuan created FLINK-14126: -- Summary: Elasticsearch Xpack Machine Learning doesn't support ARM Key: FLINK-14126 URL: https://issues.apache.org/jira/browse/FLINK-14126 Project: Flink Issue

[GitHub] [flink] flinkbot commented on issue #9716: [FLINK-14116][docs] Translate changes on Getting Started Overview to …

2019-09-19 Thread GitBox
flinkbot commented on issue #9716: [FLINK-14116][docs] Translate changes on Getting Started Overview to … URL: https://github.com/apache/flink/pull/9716#issuecomment-533056428 ## CI report: * 0a2f103d2a997afc60424688b87f8aa3fa0d30b1 : UNKNOWN

[jira] [Comment Edited] (FLINK-13682) Translate "Code Style - Scala Guide" page into Chinese

2019-09-19 Thread Jeff Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933091#comment-16933091 ] Jeff Yang edited comment on FLINK-13682 at 9/19/19 6:23 AM: Hi, [~jark]  I

[GitHub] [flink] docete commented on issue #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

2019-09-19 Thread GitBox
docete commented on issue #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#issuecomment-533023154 > Actually, this PR requires a FLIP because it introduces new user-facing features. Shall I complement a

[jira] [Assigned] (FLINK-14094) Fix OperatorIOMetricGroup repeat register problem

2019-09-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14094: - Assignee: xymaqingxiang > Fix OperatorIOMetricGroup repeat register problem >

[jira] [Commented] (FLINK-14019) Python environment and dependency management

2019-09-19 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933161#comment-16933161 ] sunjincheng commented on FLINK-14019: - Hi [~zhongwei] Thank you very much for taking this ticket. I

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE

[GitHub] [flink] StephanEwen commented on issue #9273: [FLINK-13449][core] Add ARM architecture to MemoryArchitecture

2019-09-19 Thread GitBox
StephanEwen commented on issue #9273: [FLINK-13449][core] Add ARM architecture to MemoryArchitecture URL: https://github.com/apache/flink/pull/9273#issuecomment-533057209 Looks good, merging this. This is an automated

[jira] [Commented] (FLINK-13652) Setup instructions for creating an ARM environment

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933225#comment-16933225 ] Stephan Ewen commented on FLINK-13652: -- What do you think about adding some guides about how to do

[GitHub] [flink] flinkbot commented on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

2019-09-19 Thread GitBox
flinkbot commented on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : UNKNOWN

[jira] [Created] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-09-19 Thread liupengcheng (Jira)
liupengcheng created FLINK-14123: Summary: Change taskmanager.memory.fraction default value to 0.6 Key: FLINK-14123 URL: https://issues.apache.org/jira/browse/FLINK-14123 Project: Flink

[jira] [Updated] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-09-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14123: --- Labels: pull-request-available (was: ) > Change taskmanager.memory.fraction default value

[GitHub] [flink] liupc opened a new pull request #9714: [FLINK-14123]Change taskmanager.memory.fraction default value to 0.6

2019-09-19 Thread GitBox
liupc opened a new pull request #9714: [FLINK-14123]Change taskmanager.memory.fraction default value to 0.6 URL: https://github.com/apache/flink/pull/9714 ## What is the purpose of the change The default JVM Option value `NewRatio` is 2, that means the old generation ocuppies

[jira] [Commented] (FLINK-14074) MesosResourceManager can't create new taskmanagers in Session Cluster Mode.

2019-09-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933121#comment-16933121 ] Till Rohrmann commented on FLINK-14074: --- So maybe it is the same problem as with FLINK-13241. >

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

2019-09-19 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933131#comment-16933131 ] TisonKun commented on FLINK-14112: -- [~trohrmann] is its function duplicated by heartbeat mechanism? If

[jira] [Assigned] (FLINK-14120) SystemProcessingTimeServiceTest.testImmediateShutdown failed on Travis

2019-09-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14120: - Assignee: Anatolii Siuniaev > SystemProcessingTimeServiceTest.testImmediateShutdown

[jira] [Commented] (FLINK-14120) SystemProcessingTimeServiceTest.testImmediateShutdown failed on Travis

2019-09-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933134#comment-16933134 ] Till Rohrmann commented on FLINK-14120: --- Yes, I've assigned the issue to you [~anatolii_siuniaev].

[GitHub] [flink] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

2019-09-19 Thread GitBox
docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#discussion_r326045268 ## File path:

[GitHub] [flink] StephanEwen commented on issue #9714: [FLINK-14123]Change taskmanager.memory.fraction default value to 0.6

2019-09-19 Thread GitBox
StephanEwen commented on issue #9714: [FLINK-14123]Change taskmanager.memory.fraction default value to 0.6 URL: https://github.com/apache/flink/pull/9714#issuecomment-533035163 Let's conclude the discussion in JIRA before merging this.

[jira] [Updated] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-09-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13993: -- Labels: pull-request-available (was: ) > Using FlinkUserCodeClassLoaders to load the user class in

[GitHub] [flink] StephanEwen commented on issue #9705: [hotfix][comment]remove useless comment

2019-09-19 Thread GitBox
StephanEwen commented on issue #9705: [hotfix][comment]remove useless comment URL: https://github.com/apache/flink/pull/9705#issuecomment-533044955 Is the comment actually wrong/misleading? If not, I would avoid such refactoring. It is very subjective whether a comment is useful or

[GitHub] [flink] kl0u commented on issue #9695: [FLINK-13748][S3][build] Fix jaxb relocation for S3.

2019-09-19 Thread GitBox
kl0u commented on issue #9695: [FLINK-13748][S3][build] Fix jaxb relocation for S3. URL: https://github.com/apache/flink/pull/9695#issuecomment-533053745 The status can be seen here https://travis-ci.org/kl0u/flink/builds/586896522 and the branch with the changes where we only use `jaxb

[jira] [Updated] (FLINK-13682) Translate "Code Style - Scala Guide" page into Chinese

2019-09-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13682: --- Labels: pull-request-available (was: ) > Translate "Code Style - Scala Guide" page into

[GitHub] [flink] link3280 opened a new pull request #9713: [hotfix][API/DataStream] Add missing assert for checkpoint lock checks

2019-09-19 Thread GitBox
link3280 opened a new pull request #9713: [hotfix][API/DataStream] Add missing assert for checkpoint lock checks URL: https://github.com/apache/flink/pull/9713 ## What is the purpose of the change The return value of `Thread.holdsLock(checkpointLock)` is unused, which are supposed

[GitHub] [flink] yxu-valleytider commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

2019-09-19 Thread GitBox
yxu-valleytider commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-532995742 PTAL @kl0u

[GitHub] [flink] kl0u edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

2019-09-19 Thread GitBox
kl0u edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-533018187 Thanks a lot @yxu-valleytider . I will have a look but

[GitHub] [flink] StephanEwen commented on issue #9681: [FLINK-13450][test] Adjust tests to tolerate arithmetic differences between x86 and ARM

2019-09-19 Thread GitBox
StephanEwen commented on issue #9681: [FLINK-13450][test] Adjust tests to tolerate arithmetic differences between x86 and ARM URL: https://github.com/apache/flink/pull/9681#issuecomment-533038922 Could we reduce the changes to the scope where we really need strict results? It looks like

[GitHub] [flink] tillrohrmann commented on issue #9695: [FLINK-13748][S3][build] Fix jaxb relocation for S3.

2019-09-19 Thread GitBox
tillrohrmann commented on issue #9695: [FLINK-13748][S3][build] Fix jaxb relocation for S3. URL: https://github.com/apache/flink/pull/9695#issuecomment-533051836 If adding the `jaxb` dependency works, then I'd be in favour of doing it because it solves an immediate problem which are

[GitHub] [flink] tillrohrmann commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

2019-09-19 Thread GitBox
tillrohrmann commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326092229 ## File path:

[jira] [Created] (FLINK-14127) Better BackPressure Detection in WebUI

2019-09-19 Thread Yadong Xie (Jira)
Yadong Xie created FLINK-14127: -- Summary: Better BackPressure Detection in WebUI Key: FLINK-14127 URL: https://issues.apache.org/jira/browse/FLINK-14127 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on issue #9713: [hotfix][API/DataStream] Add missing assert for checkpoint lock checks

2019-09-19 Thread GitBox
flinkbot commented on issue #9713: [hotfix][API/DataStream] Add missing assert for checkpoint lock checks URL: https://github.com/apache/flink/pull/9713#issuecomment-532988933 ## CI report: * f0fb6004eb0d0cf294f530aa0348ce23c5e701d8 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE

[GitHub] [flink] flinkbot commented on issue #9714: [FLINK-14123]Change taskmanager.memory.fraction default value to 0.6

2019-09-19 Thread GitBox
flinkbot commented on issue #9714: [FLINK-14123]Change taskmanager.memory.fraction default value to 0.6 URL: https://github.com/apache/flink/pull/9714#issuecomment-532994026 ## CI report: * 9c2f79d83a667cefc8364c4244f183e3798d9602 : UNKNOWN

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

2019-09-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933120#comment-16933120 ] Till Rohrmann commented on FLINK-14112: --- {{null}} just means that there is no leader at the

[jira] [Comment Edited] (FLINK-13343) Translate "Contribute Code" page into Chinese

2019-09-19 Thread Jeff Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890664#comment-16890664 ] Jeff Yang edited comment on FLINK-13343 at 9/19/19 7:11 AM: Hi,[~jark], I 

[jira] [Commented] (FLINK-13343) Translate "Contribute Code" page into Chinese

2019-09-19 Thread Jeff Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933119#comment-16933119 ] Jeff Yang commented on FLINK-13343: --- Hi, [~jark] Please take a look,Thank you very much. > Translate

[GitHub] [flink] flinkbot edited a comment on issue #9713: [hotfix][API/DataStream] Add missing assert for checkpoint lock checks

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9713: [hotfix][API/DataStream] Add missing assert for checkpoint lock checks URL: https://github.com/apache/flink/pull/9713#issuecomment-532988933 ## CI report: * f0fb6004eb0d0cf294f530aa0348ce23c5e701d8 : SUCCESS

[jira] [Commented] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

2019-09-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933139#comment-16933139 ] Till Rohrmann commented on FLINK-14010: --- Ok, then let's do it like this. Do you have to time to

[jira] [Commented] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

2019-09-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933138#comment-16933138 ] Till Rohrmann commented on FLINK-14118: --- I think we should also back port it to 1.8 since the

[jira] [Updated] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

2019-09-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14118: -- Fix Version/s: 1.8.3 > Reduce the unnecessary flushing when there is no data available for

[jira] [Created] (FLINK-14124) potential memory leak in netty server

2019-09-19 Thread YufeiLiu (Jira)
YufeiLiu created FLINK-14124: Summary: potential memory leak in netty server Key: FLINK-14124 URL: https://issues.apache.org/jira/browse/FLINK-14124 Project: Flink Issue Type: Improvement

[GitHub] [flink] StephanEwen commented on issue #9692: [FLINK-13896]make scala-maven-plugin compile target jvm version consistent with java version

2019-09-19 Thread GitBox
StephanEwen commented on issue #9692: [FLINK-13896]make scala-maven-plugin compile target jvm version consistent with java version URL: https://github.com/apache/flink/pull/9692#issuecomment-533040912 Looks good to me, merging this...

[GitHub] [flink] StephanEwen commented on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly.

2019-09-19 Thread GitBox
StephanEwen commented on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly. URL: https://github.com/apache/flink/pull/9710#issuecomment-533048493 Small but nice improvement. Change looks good to me.

[jira] [Updated] (FLINK-14044) Reducing synchronization in AsyncWaitOperator

2019-09-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14044: --- Labels: pull-request-available (was: ) > Reducing synchronization in AsyncWaitOperator >

[GitHub] [flink] AHeise opened a new pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

2019-09-19 Thread GitBox
AHeise opened a new pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717 ## What is the purpose of the change Currently, AsyncWaitOperator receives computed results from a user thread and

[GitHub] [flink] flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445 ## CI report: *

[jira] [Updated] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

2019-09-19 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-14010: - Affects Version/s: (was: 1.8.1) 1.8.2 > Dispatcher & JobManagers don't give

[GitHub] [flink] tillrohrmann closed pull request #9713: [hotfix][API/DataStream] Add missing assert for checkpoint lock checks

2019-09-19 Thread GitBox
tillrohrmann closed pull request #9713: [hotfix][API/DataStream] Add missing assert for checkpoint lock checks URL: https://github.com/apache/flink/pull/9713 This is an automated message from the Apache Git Service. To

[GitHub] [flink] GJL commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-19 Thread GitBox
GJL commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#discussion_r326047014 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-19 Thread GitBox
GJL commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#discussion_r326028280 ## File path: pom.xml ## @@ -148,6 +148,8 @@ under the License.

[jira] [Updated] (FLINK-14124) potential memory leak in netty server

2019-09-19 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YufeiLiu updated FLINK-14124: - Description: I have a job running in flink 1.4.2, end of the task is use Phoenix jdbc driver write

[jira] [Updated] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-09-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13993: -- Remaining Estimate: 144h (was: 168h) Original Estimate: 144h (was: 168h) > Using

[jira] [Updated] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-09-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13993: -- Remaining Estimate: 48h (was: 144h) Original Estimate: 48h (was: 144h) > Using

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE

[jira] [Updated] (FLINK-14116) Translate changes on Getting Started Overview to Chinese

2019-09-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14116: --- Labels: pull-request-available (was: ) > Translate changes on Getting Started Overview to

[GitHub] [flink] rongzhg opened a new pull request #9716: [FLINK-14116][docs] Translate changes on Getting Started Overview to …

2019-09-19 Thread GitBox
rongzhg opened a new pull request #9716: [FLINK-14116][docs] Translate changes on Getting Started Overview to … URL: https://github.com/apache/flink/pull/9716 …Chinese ## What is the purpose of the change *(For example: This pull request makes task deployment go

[jira] [Commented] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

2019-09-19 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933221#comment-16933221 ] Jiayi Liao commented on FLINK-14122: [~sjwiesman] Hi I'm also paying attention to this module.

[GitHub] [flink] yxu-valleytider commented on a change in pull request #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileS

2019-09-19 Thread GitBox
yxu-valleytider commented on a change in pull request #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#discussion_r326002700 ## File path:

[GitHub] [flink] yxu-valleytider commented on a change in pull request #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileS

2019-09-19 Thread GitBox
yxu-valleytider commented on a change in pull request #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#discussion_r326000120 ## File path:

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

2019-09-19 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933087#comment-16933087 ] liupengcheng commented on FLINK-14037: -- [~zhuzh]  Yes, that's weird, Maybe I think your test is

[GitHub] [flink] flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445 ## CI report: *

[jira] [Updated] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-09-19 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liupengcheng updated FLINK-14123: - Description: Currently, we are testing flink batch task, such as terasort, however, it started

[jira] [Commented] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout

2019-09-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933159#comment-16933159 ] Till Rohrmann commented on FLINK-14038: --- I see your point [~liupengcheng] and I think you are

[GitHub] [flink] flinkbot commented on issue #9715: [Flink 13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-09-19 Thread GitBox
flinkbot commented on issue #9715: [Flink 13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode URL: https://github.com/apache/flink/pull/9715#issuecomment-533028339 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933186#comment-16933186 ] Stephan Ewen commented on FLINK-14123: -- I get the reasoning behind this, it probably makes sense.

[GitHub] [flink] flinkbot commented on issue #9715: [Flink 13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-09-19 Thread GitBox
flinkbot commented on issue #9715: [Flink 13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode URL: https://github.com/apache/flink/pull/9715#issuecomment-533036474 ## CI report: * efa22104931934947ad229ead46e2e4747eb0830 : UNKNOWN

[jira] [Updated] (FLINK-14124) potential memory leak in netty server

2019-09-19 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YufeiLiu updated FLINK-14124: - Description: I have a job running in flink 1.4.2, end of the task is use Phoenix jdbc driver write

[jira] [Updated] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-09-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13993: -- Remaining Estimate: 30h (was: 48h) Original Estimate: 30h (was: 48h) > Using

[jira] [Commented] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933200#comment-16933200 ] Stephan Ewen commented on FLINK-14118: -- Great diagnosis and great fix! Do we have any data as to

[jira] [Comment Edited] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-09-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933201#comment-16933201 ] Guowei Ma edited comment on FLINK-13993 at 9/19/19 9:25 AM: Sorry

[jira] [Commented] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-09-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933201#comment-16933201 ] Guowei Ma commented on FLINK-13993: --- Sorry, I change the time. Actually, what I mean is one man week.

[GitHub] [flink] tillrohrmann commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

2019-09-19 Thread GitBox
tillrohrmann commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326086377 ## File path:

[GitHub] [flink] StephanEwen commented on issue #9681: [FLINK-13450][test] Adjust tests to tolerate arithmetic differences between x86 and ARM

2019-09-19 Thread GitBox
StephanEwen commented on issue #9681: [FLINK-13450][test] Adjust tests to tolerate arithmetic differences between x86 and ARM URL: https://github.com/apache/flink/pull/9681#issuecomment-533056128 To clarify how this relates to my previous comment ("have just StrictMath"): Within a

[GitHub] [flink] tillrohrmann commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

2019-09-19 Thread GitBox
tillrohrmann commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326090882 ## File path:

[GitHub] [flink] flinkbot commented on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

2019-09-19 Thread GitBox
flinkbot commented on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#issuecomment-533060454 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #9715: [Flink-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9715: [Flink-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode URL: https://github.com/apache/flink/pull/9715#issuecomment-533036474 ## CI report: * efa22104931934947ad229ead46e2e4747eb0830 : FAILURE

[jira] [Commented] (FLINK-13598) frocksdb doesn't have arm release

2019-09-19 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933238#comment-16933238 ] Andrey Zagrebin commented on FLINK-13598: - I agree with [~carp84], we need to do thorough

[GitHub] [flink] yxu-valleytider commented on a change in pull request #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileS

2019-09-19 Thread GitBox
yxu-valleytider commented on a change in pull request #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#discussion_r325999744 ## File path:

[GitHub] [flink] yxu-valleytider commented on a change in pull request #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileS

2019-09-19 Thread GitBox
yxu-valleytider commented on a change in pull request #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#discussion_r326002736 ## File path:

[GitHub] [flink] yxu-valleytider commented on a change in pull request #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileS

2019-09-19 Thread GitBox
yxu-valleytider commented on a change in pull request #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#discussion_r326002753 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

2019-09-19 Thread GitBox
xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r326013357 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

2019-09-19 Thread GitBox
xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r326013260 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9713: [hotfix][API/DataStream] Add missing assert for checkpoint lock checks

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9713: [hotfix][API/DataStream] Add missing assert for checkpoint lock checks URL: https://github.com/apache/flink/pull/9713#issuecomment-532988933 ## CI report: * f0fb6004eb0d0cf294f530aa0348ce23c5e701d8 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9711: [FLINK-14033] upload user artifacts for yarn job cluster

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9711: [FLINK-14033] upload user artifacts for yarn job cluster URL: https://github.com/apache/flink/pull/9711#issuecomment-532971678 ## CI report: * 2011905b5abe4cb332a60bc3f70378c777482924 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/…

2019-09-19 Thread GitBox
flinkbot edited a comment on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/… URL: https://github.com/apache/flink/pull/9683#issuecomment-531697778 ## CI report: * ba87beba470b132b99ed606411ffc43847a72d8f : SUCCESS

  1   2   3   4   5   >