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

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933112#comment-16933112 ] Till Rohrmann commented on FLINK-13993: --- Thanks for updating the work estimate [~m

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

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 [Build](https://

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

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 [Build](https://travis-ci.com/f

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

[ https://issues.apache.org/jira/browse/FLINK-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16890664#comment-16890664 ] Jeff Yang edited comment on FLINK-13343 at 9/19/19 7:11 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933119#comment-16933119 ] Jeff Yang commented on FLINK-13343: --- Hi, [~jark] Please take a look,Thank you very muc

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

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933120#comment-16933120 ] Till Rohrmann commented on FLINK-14112: --- {{null}} just means that there is no lead

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

[ https://issues.apache.org/jira/browse/FLINK-14074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933121#comment-16933121 ] Till Rohrmann commented on FLINK-14074: --- So maybe it is the same problem as with F

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

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: * dc9cdc1364b9050c3d2f3cba

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

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933131#comment-16933131 ] TisonKun commented on FLINK-14112: -- [~trohrmann] is its function duplicated by heartbea

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

[ https://issues.apache.org/jira/browse/FLINK-14120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933134#comment-16933134 ] Till Rohrmann commented on FLINK-14120: --- Yes, I've assigned the issue to you [~ana

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

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

[jira] [Assigned] (FLINK-14093) Java8 lambdas and exceptions lead to compile error

[ https://issues.apache.org/jira/browse/FLINK-14093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-14093: Assignee: zzsmdfj > Java8 lambdas and exceptions lead to compile error >

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

[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933138#comment-16933138 ] Till Rohrmann commented on FLINK-14118: --- I think we should also back port it to 1.

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

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

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

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 [Build](https://travis-ci.com

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

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933139#comment-16933139 ] Till Rohrmann commented on FLINK-14010: --- Ok, then let's do it like this. Do you ha

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933142#comment-16933142 ] Till Rohrmann commented on FLINK-14112: --- I would consider it rather as an addition

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

[ 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] [Updated] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

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

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

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] [Created] (FLINK-14124) potential memory leak in netty server

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] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

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_r326043179 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gat

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

[ https://issues.apache.org/jira/browse/FLINK-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933159#comment-16933159 ] Till Rohrmann commented on FLINK-14038: --- I see your point [~liupengcheng] and I th

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

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: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gat

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

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 FLIP

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

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: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaste

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

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.

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

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 respo

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

[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933161#comment-16933161 ] sunjincheng commented on FLINK-14019: - Hi [~zhongwei] Thank you very much for taking

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

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

[GitHub] [flink] guoweiM opened a new pull request #9715: [Flink 13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

guoweiM opened a new pull request #9715: [Flink 13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode URL: https://github.com/apache/flink/pull/9715 ## What is the purpose of the change Currently, Flink has the FlinkUserCodeClassLoader, whi

[GitHub] [flink] tillrohrmann commented on a change in pull request #9697: [FLINK-14094] [runtime] [metric] Fix OperatorIOMetricGroup repeat register problem

tillrohrmann commented on a change in pull request #9697: [FLINK-14094] [runtime] [metric] Fix OperatorIOMetricGroup repeat register problem URL: https://github.com/apache/flink/pull/9697#discussion_r326051179 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metri

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

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

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

[ 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

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

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

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 hel

[GitHub] [flink] vthinkxie commented on issue #9504: [FLINK-13799][web]: fix error message web submit is disables in the c…

vthinkxie commented on issue #9504: [FLINK-13799][web]: fix error message web submit is disables in the c… URL: https://github.com/apache/flink/pull/9504#issuecomment-533031029 Hi @zentol I found that the web can get web.submit.enable from the jobmanager configuration, is that correct

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

[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933177#comment-16933177 ] Wei Zhong commented on FLINK-14019: --- Hi [~sunjincheng121]. That makes sense. There's a

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

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] aljoscha commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/…

aljoscha commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/… URL: https://github.com/apache/flink/pull/9683#issuecomment-533033727 I think now we're in a similar situation. We have parameters for `PackagedProgram` where we often pas

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

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933184#comment-16933184 ] TisonKun commented on FLINK-14112: -- Thanks for your insights [~trohrmann]. Sounds reaso

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

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

[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

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

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

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933186#comment-16933186 ] Stephan Ewen commented on FLINK-14123: -- I get the reasoning behind this, it probabl

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

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

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

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

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

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

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

[jira] [Created] (FLINK-14125) Display memory and CPU usage in the overview page

Yadong Xie created FLINK-14125: -- Summary: Display memory and CPU usage in the overview page Key: FLINK-14125 URL: https://issues.apache.org/jira/browse/FLINK-14125 Project: Flink Issue Type: Imp

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

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

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

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

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

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

[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

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

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

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

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

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 JobMan

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

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 o

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

StephanEwen commented on issue #9695: [FLINK-13748][S3][build] Fix jaxb relocation for S3. URL: https://github.com/apache/flink/pull/9695#issuecomment-533044199 We were planning to completely remove shading of the file systems for Flink 1.10 and put them into the plugins directory.

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

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 u

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

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

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

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

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

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 throug

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933200#comment-16933200 ] Stephan Ewen commented on FLINK-14118: -- Great diagnosis and great fix! Do we have

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

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933201#comment-16933201 ] Guowei Ma commented on FLINK-13993: --- Sorry, I change the time. Actually, what I mean

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

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933201#comment-16933201 ] Guowei Ma edited comment on FLINK-13993 at 9/19/19 9:25 AM:

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

flinkbot commented on issue #9716: [FLINK-14116][docs] Translate changes on Getting Started Overview to … URL: https://github.com/apache/flink/pull/9716#issuecomment-533047146 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

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

kl0u commented on issue #9695: [FLINK-13748][S3][build] Fix jaxb relocation for S3. URL: https://github.com/apache/flink/pull/9695#issuecomment-533047412 @StephanEwen I agree that if this is the goal, then this effort is "instant legacy". That said, I do not feel comfortable doing t

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

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] [Commented] (FLINK-14019) Python environment and dependency management

[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933205#comment-16933205 ] sunjincheng commented on FLINK-14019: - Sounds pretty good，great thanks [~zhongwei]

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

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 failin

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

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 Ty

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

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 2

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

[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933221#comment-16933221 ] Jiayi Liao commented on FLINK-14122: [~sjwiesman] Hi I'm also paying attention to th

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

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_r326085068 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.j

[jira] [Assigned] (FLINK-13450) Adjust tests to tolerate arithmetic differences between x86 and ARM

[ https://issues.apache.org/jira/browse/FLINK-13450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-13450: Assignee: wangxiyuan > Adjust tests to tolerate arithmetic differences between x86 and AR

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

[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933222#comment-16933222 ] Stephan Ewen commented on FLINK-13598: -- I think we are trying to move back to more

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

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: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultSchedulerFa

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

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 module

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

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

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

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 message

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

[ https://issues.apache.org/jira/browse/FLINK-13652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933225#comment-16933225 ] Stephan Ewen commented on FLINK-13652: -- What do you think about adding some guides

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

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933226#comment-16933226 ] Zhu Zhu commented on FLINK-14037: - [~liupengcheng] a.b.c.B is tested and the base class

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

[ https://issues.apache.org/jira/browse/FLINK-14124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933227#comment-16933227 ] Jiayi Liao commented on FLINK-14124: Can you provide the topology(including the para

[jira] [Assigned] (FLINK-13449) Add ARM architecture to MemoryArchitecture

[ https://issues.apache.org/jira/browse/FLINK-13449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-13449: Assignee: wangxiyuan > Add ARM architecture to MemoryArchitecture > -

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

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

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

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

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

[ 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

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 put

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

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: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGrap

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

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 revie

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

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: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGrap

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

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

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

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

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

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

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

flinkbot edited a comment 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 : PENDING [Build](https://travis-ci.com

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

[ https://issues.apache.org/jira/browse/FLINK-14044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-14044: -- Assignee: Arvid Heise > Reducing synchronization in AsyncWaitOperator > -

[GitHub] [flink] StephanEwen commented on issue #9448: [FLINK-13710] Fix JarListHandler always extract the jar package

StephanEwen commented on issue #9448: [FLINK-13710] Fix JarListHandler always extract the jar package URL: https://github.com/apache/flink/pull/9448#issuecomment-533065152 I think the problem and solution are valid, but the PR fails with basic checkstyle errors. Closing this for now, pl

[GitHub] [flink] StephanEwen closed pull request #9448: [FLINK-13710] Fix JarListHandler always extract the jar package

StephanEwen closed pull request #9448: [FLINK-13710] Fix JarListHandler always extract the jar package URL: https://github.com/apache/flink/pull/9448 This is an automated message from the Apache Git Service. To respond to th

  1   2   3   4   >