[jira] [Updated] (FLINK-15530) Replace process memory with flink memory for TMs in default flink-conf.yaml

2020-01-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15530: --- Labels: pull-request-available (was: ) > Replace process memory with flink memory for TMs

[GitHub] [flink] xintongsong opened a new pull request #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml

2020-01-11 Thread GitBox
xintongsong opened a new pull request #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml URL: https://github.com/apache/flink/pull/10834 ## What is the purpose of the change This PR replaces `taskmanager.memory.process.size` with

[GitHub] [flink] flinkbot commented on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml

2020-01-11 Thread GitBox
flinkbot commented on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml URL: https://github.com/apache/flink/pull/10834#issuecomment-573298663 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] xintongsong commented on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml

2020-01-11 Thread GitBox
xintongsong commented on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml URL: https://github.com/apache/flink/pull/10834#issuecomment-573298450 cc @azagrebin

[GitHub] [flink] flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml

2020-01-11 Thread GitBox
flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml URL: https://github.com/apache/flink/pull/10834#issuecomment-573300994 ## CI report: * 78ce3aaf9f756bb27b20e1f51ff57d0ff4143b75 Travis:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly

2020-01-11 Thread GitBox
KarmaGYZ commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#discussion_r365509114 ## File path: flink-dist/src/test/java/org/apache/flink/dist/BashJavaUtilsITCase.java ## @@

[GitHub] [flink] flinkbot commented on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml

2020-01-11 Thread GitBox
flinkbot commented on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml URL: https://github.com/apache/flink/pull/10834#issuecomment-573300994 ## CI report: * 78ce3aaf9f756bb27b20e1f51ff57d0ff4143b75 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml

2020-01-11 Thread GitBox
flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml URL: https://github.com/apache/flink/pull/10834#issuecomment-573300994 ## CI report: * 78ce3aaf9f756bb27b20e1f51ff57d0ff4143b75 Travis:

[jira] [Commented] (FLINK-15555) Delete TABLE_OPTIMIZER_REUSE_SOURCE_ENABLED option for subplaner reuse

2020-01-11 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013449#comment-17013449 ] godfrey he commented on FLINK-1: hi [~hailong wang], If the build side and probe side of a

[GitHub] [flink] flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml

2020-01-11 Thread GitBox
flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml URL: https://github.com/apache/flink/pull/10834#issuecomment-573300994 ## CI report: * 78ce3aaf9f756bb27b20e1f51ff57d0ff4143b75 Travis:

[jira] [Updated] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

2020-01-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-15504: --- Fix Version/s: (was: 1.11.0) > Flink suppresses stdout/stderr during JobGraph

[jira] [Updated] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

2020-01-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-15504: --- Fix Version/s: 1.10.0 > Flink suppresses stdout/stderr during JobGraph generation

[jira] [Commented] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

2020-01-11 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013414#comment-17013414 ] Yangze Guo commented on FLINK-15549: Hi, [~caojian0613]. Thanks for your effort:). I'll try to find

[jira] [Commented] (FLINK-15556) Add a switch for PushProjectIntoTableSourceScanRule

2020-01-11 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013453#comment-17013453 ] godfrey he commented on FLINK-15556: hi [~hailong wang], if there are many different kinds of table

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2020-01-11 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013533#comment-17013533 ] YufeiLiu commented on FLINK-12122: -- [~trohrmann] Thanks for reply. I‘ve found load balance issue

[jira] [Commented] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

2020-01-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013491#comment-17013491 ] Maximilian Michels commented on FLINK-15504: master:

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

2020-01-11 Thread GitBox
flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729 ## CI report: * 5eb1599945f1bee35c342f762cc25684013d2d83 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

2020-01-11 Thread GitBox
flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729 ## CI report: * 5eb1599945f1bee35c342f762cc25684013d2d83 Travis:

[GitHub] [flink] openinx commented on a change in pull request #10637: [FLINK-15319][e2e] flink-end-to-end-tests-common-kafka fails due to t…

2020-01-11 Thread GitBox
openinx commented on a change in pull request #10637: [FLINK-15319][e2e] flink-end-to-end-tests-common-kafka fails due to t… URL: https://github.com/apache/flink/pull/10637#discussion_r365559972 ## File path:

[jira] [Commented] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

2020-01-11 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013650#comment-17013650 ] Benchao Li commented on FLINK-15431: [~dwysakowicz] Since we are already in an agreement that

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

2020-01-11 Thread GitBox
flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729 ## CI report: * 5eb1599945f1bee35c342f762cc25684013d2d83 Travis:

[jira] [Commented] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

2020-01-11 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013666#comment-17013666 ] Zhenqiu Huang commented on FLINK-11899: --- [~lzljs3620320] it looks all of the vector related

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

2020-01-11 Thread GitBox
flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729 ## CI report: * 5eb1599945f1bee35c342f762cc25684013d2d83 Travis:

[jira] [Created] (FLINK-15559) Missing {{site.baseurl}} in some docs

2020-01-11 Thread Benchao Li (Jira)
Benchao Li created FLINK-15559: -- Summary: Missing {{site.baseurl}} in some docs Key: FLINK-15559 URL: https://issues.apache.org/jira/browse/FLINK-15559 Project: Flink Issue Type: Improvement

[GitHub] [flink] veysiertekin removed a comment on issue #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem

2020-01-11 Thread GitBox
veysiertekin removed a comment on issue #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem URL: https://github.com/apache/flink/pull/7991#issuecomment-573359364 There is a problem with closing operation: ```java

[GitHub] [flink] flinkbot commented on issue #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem

2020-01-11 Thread GitBox
flinkbot commented on issue #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem URL: https://github.com/apache/flink/pull/7991#issuecomment-573362913 ## CI report: * 43899cf816fbf81cc6248b1aa2524b348bbef47f UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem

2020-01-11 Thread GitBox
flinkbot edited a comment on issue #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem URL: https://github.com/apache/flink/pull/7991#issuecomment-573362913 ## CI report: * 43899cf816fbf81cc6248b1aa2524b348bbef47f

[GitHub] [flink] veysiertekin commented on a change in pull request #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem

2020-01-11 Thread GitBox
veysiertekin commented on a change in pull request #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem URL: https://github.com/apache/flink/pull/7991#discussion_r365549543 ## File path:

[GitHub] [flink] veysiertekin commented on a change in pull request #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem

2020-01-11 Thread GitBox
veysiertekin commented on a change in pull request #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem URL: https://github.com/apache/flink/pull/7991#discussion_r365549543 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

2020-01-11 Thread GitBox
zentol commented on a change in pull request #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#discussion_r365536939 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

2020-01-11 Thread GitBox
zentol commented on a change in pull request #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#discussion_r365536998 ## File path:

[GitHub] [flink] zentol commented on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

2020-01-11 Thread GitBox
zentol commented on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#issuecomment-573345391 @tillrohrmann An annotation-based approach was my first instinct as well but that doesn't work with the

[GitHub] [flink] veysiertekin edited a comment on issue #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem

2020-01-11 Thread GitBox
veysiertekin edited a comment on issue #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem URL: https://github.com/apache/flink/pull/7991#issuecomment-573359364 There is a problem with closing operation: ```java

[GitHub] [flink] veysiertekin commented on issue #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem

2020-01-11 Thread GitBox
veysiertekin commented on issue #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem URL: https://github.com/apache/flink/pull/7991#issuecomment-573359364 There is a problem with closing operation: ```java 2020-01-11