[GitHub] [flink] yanghua closed pull request #8152: [FLINK-11761] Update FlinkKafkaConsumerBaseMigrationTest for 1.8

2019-04-13 Thread GitBox
yanghua closed pull request #8152: [FLINK-11761] Update FlinkKafkaConsumerBaseMigrationTest for 1.8 URL: https://github.com/apache/flink/pull/8152 This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [flink] yanghua commented on issue #8152: [FLINK-11761] Update FlinkKafkaConsumerBaseMigrationTest for 1.8

2019-04-13 Thread GitBox
yanghua commented on issue #8152: [FLINK-11761] Update FlinkKafkaConsumerBaseMigrationTest for 1.8 URL: https://github.com/apache/flink/pull/8152#issuecomment-482924977 @zentol Thanks for your suggestion. I have reopened a new PR #8168 for the migration test umbrella issue, this PR's commi

[GitHub] [flink] flinkbot commented on issue #8168: [Flink-11756] Update migration tests for Flink 1.8

2019-04-13 Thread GitBox
flinkbot commented on issue #8168: [Flink-11756] Update migration tests for Flink 1.8 URL: https://github.com/apache/flink/pull/8168#issuecomment-482924888 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request

[GitHub] [flink] yanghua opened a new pull request #8168: [Flink-11756] Update migration tests for Flink 1.8

2019-04-13 Thread GitBox
yanghua opened a new pull request #8168: [Flink-11756] Update migration tests for Flink 1.8 URL: https://github.com/apache/flink/pull/8168 ## What is the purpose of the change *This pull request updates migration tests for Flink 1.8, it is opened for the umbrella issue, and one comm

[jira] [Updated] (FLINK-12187) wrap FileWriter with BufferedWriter for better performance

2019-04-13 Thread bd2019us (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bd2019us updated FLINK-12187: - Attachment: 1.patch > wrap FileWriter with BufferedWriter for better performance > -

[jira] [Updated] (FLINK-12187) wrap FileWriter with BufferedWriter for better performance

2019-04-13 Thread bd2019us (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bd2019us updated FLINK-12187: - Labels: patch-available pull-requests-available (was: pull-requests-available) > wrap FileWriter with

[jira] [Updated] (FLINK-12187) wrap FileWriter with BufferedWriter for better performance

2019-04-13 Thread bd2019us (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bd2019us updated FLINK-12187: - Labels: pull-requests-available (was: pull-request-available) > wrap FileWriter with BufferedWriter for

[jira] [Updated] (FLINK-12187) wrap FileWriter with BufferedWriter for better performance

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12187: --- Labels: pull-request-available (was: ) > wrap FileWriter with BufferedWriter for better per

[GitHub] [flink] flinkbot commented on issue #8167: [FLINK-12187][Examples] Bug fixes, Use BufferedWriter in a loop instead of FileWriter

2019-04-13 Thread GitBox
flinkbot commented on issue #8167: [FLINK-12187][Examples] Bug fixes, Use BufferedWriter in a loop instead of FileWriter URL: https://github.com/apache/flink/pull/8167#issuecomment-482919503 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commu

[GitHub] [flink] bd2019us opened a new pull request #8167: [FLINK-12187][Examples] Bug fixes, Use BufferedWriter in a loop instead of FileWriter

2019-04-13 Thread GitBox
bd2019us opened a new pull request #8167: [FLINK-12187][Examples] Bug fixes, Use BufferedWriter in a loop instead of FileWriter URL: https://github.com/apache/flink/pull/8167 ## What is the purpose of the change This pull request changes FileWriter to BufferedWriter when the write()

[jira] [Updated] (FLINK-12187) wrap FileWriter with BufferedWriter for better performance

2019-04-13 Thread bd2019us (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bd2019us updated FLINK-12187: - Component/s: Examples > wrap FileWriter with BufferedWriter for better performance > ---

[jira] [Created] (FLINK-12187) wrap FileWriter with BufferedWriter for better performance

2019-04-13 Thread bd2019us (JIRA)
bd2019us created FLINK-12187: Summary: wrap FileWriter with BufferedWriter for better performance Key: FLINK-12187 URL: https://issues.apache.org/jira/browse/FLINK-12187 Project: Flink Issue Type

[jira] [Updated] (FLINK-12183) Job Cluster doesn't stop after cancel a running job in per-job Yarn mode

2019-04-13 Thread Yumeng Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yumeng Zhang updated FLINK-12183: - Description: The per-job Yarn cluster doesn't stop after cancel a running job if the job restar

[jira] [Updated] (FLINK-12183) Job Cluster doesn't stop after cancel a running job in per-job Yarn mode

2019-04-13 Thread Yumeng Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yumeng Zhang updated FLINK-12183: - Summary: Job Cluster doesn't stop after cancel a running job in per-job Yarn mode (was: Job Clu

[jira] [Commented] (FLINK-12130) Apply command line options to configuration before installing security modules

2019-04-13 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817050#comment-16817050 ] Victor Wong commented on FLINK-12130: - Hi [~aljoscha], I have created a PR with your

[GitHub] [flink] flinkbot commented on issue #8166: Flink victor

2019-04-13 Thread GitBox
flinkbot commented on issue #8166: Flink victor URL: https://github.com/apache/flink/pull/8166#issuecomment-482864010 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] jiasheng55 opened a new pull request #8166: Flink victor

2019-04-13 Thread GitBox
jiasheng55 opened a new pull request #8166: Flink victor URL: https://github.com/apache/flink/pull/8166 ## What is the purpose of the change This pull request makes dynamic properties in command line taking effect before installing security modules, so the users can configure Kerbero

[jira] [Commented] (FLINK-9953) Active Kubernetes integration

2019-04-13 Thread Boris Lublinsky (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817040#comment-16817040 ] Boris Lublinsky commented on FLINK-9953: I have just opened source 2 projects: [

[jira] [Created] (FLINK-12186) Add implementation of FLIP-23 - Model Serving

2019-04-13 Thread Boris Lublinsky (JIRA)
Boris Lublinsky created FLINK-12186: --- Summary: Add implementation of FLIP-23 - Model Serving Key: FLINK-12186 URL: https://issues.apache.org/jira/browse/FLINK-12186 Project: Flink Issue Typ

[GitHub] [flink] klion26 commented on a change in pull request #8164: [FLINK-12184] history server compatible with old version

2019-04-13 Thread GitBox
klion26 commented on a change in pull request #8164: [FLINK-12184] history server compatible with old version URL: https://github.com/apache/flink/pull/8164#discussion_r275116911 ## File path: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServer

[jira] [Closed] (FLINK-12161) Supports partial-final optimization for stream group aggregate

2019-04-13 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12161. -- Resolution: Fixed Fix Version/s: 1.9.0 fixed in f1a45157238d2f76c4879d953ccd3877958da7c8 > Su

[GitHub] [flink] KurtYoung merged pull request #8148: [FLINK-12161] [table-planner-blink] Supports partial-final optimization for stream group aggregate

2019-04-13 Thread GitBox
KurtYoung merged pull request #8148: [FLINK-12161] [table-planner-blink] Supports partial-final optimization for stream group aggregate URL: https://github.com/apache/flink/pull/8148 This is an automated message from the Apa

[GitHub] [flink] flinkbot commented on issue #8165: [FLINK-12185] [table-planner-blink] Add support for generating optimized logical plan for join on stream

2019-04-13 Thread GitBox
flinkbot commented on issue #8165: [FLINK-12185] [table-planner-blink] Add support for generating optimized logical plan for join on stream URL: https://github.com/apache/flink/pull/8165#issuecomment-482799919 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbo

[GitHub] [flink] godfreyhe opened a new pull request #8165: [FLINK-12185] [table-planner-blink] Add support for generating optimized logical plan for join on stream

2019-04-13 Thread GitBox
godfreyhe opened a new pull request #8165: [FLINK-12185] [table-planner-blink] Add support for generating optimized logical plan for join on stream URL: https://github.com/apache/flink/pull/8165 ## What is the purpose of the change *Add support for generating optimized logical pl

[jira] [Updated] (FLINK-12185) Add support for generating optimized logical plan for join on stream

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12185: --- Labels: pull-request-available (was: ) > Add support for generating optimized logical plan

[jira] [Updated] (FLINK-12184) HistoryServerArchiveFetcher isn't compatible with old version

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12184: --- Labels: pull-request-available (was: ) > HistoryServerArchiveFetcher isn't compatible with

[jira] [Created] (FLINK-12185) Add support for generating optimized logical plan for join on stream

2019-04-13 Thread godfrey he (JIRA)
godfrey he created FLINK-12185: -- Summary: Add support for generating optimized logical plan for join on stream Key: FLINK-12185 URL: https://issues.apache.org/jira/browse/FLINK-12185 Project: Flink

[GitHub] [flink] yumengz5 opened a new pull request #8164: [FLINK-12184] history server compatible with old version

2019-04-13 Thread GitBox
yumengz5 opened a new pull request #8164: [FLINK-12184] history server compatible with old version URL: https://github.com/apache/flink/pull/8164 ## What is the purpose of the change This PR fixes FLINK-12184. The problem is that the HistoryServerArchiveFetcher can't convert

[GitHub] [flink] flinkbot commented on issue #8164: [FLINK-12184] history server compatible with old version

2019-04-13 Thread GitBox
flinkbot commented on issue #8164: [FLINK-12184] history server compatible with old version URL: https://github.com/apache/flink/pull/8164#issuecomment-482799381 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull r

[jira] [Created] (FLINK-12184) HistoryServerArchiveFetcher isn't compatible with old version

2019-04-13 Thread Yumeng Zhang (JIRA)
Yumeng Zhang created FLINK-12184: Summary: HistoryServerArchiveFetcher isn't compatible with old version Key: FLINK-12184 URL: https://issues.apache.org/jira/browse/FLINK-12184 Project: Flink

[GitHub] [flink] flinkbot commented on issue #8163: [FLINK-12183 ] Get a valid start index when archive execution graph

2019-04-13 Thread GitBox
flinkbot commented on issue #8163: [FLINK-12183 ] Get a valid start index when archive execution graph URL: https://github.com/apache/flink/pull/8163#issuecomment-482797091 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-12183) Job Cluster doesn't release resources after cancel a running job in per-job Yarn mode

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12183: --- Labels: pull-request-available (was: ) > Job Cluster doesn't release resources after cancel

[GitHub] [flink] yumengz5 opened a new pull request #8163: [FLINK-12183 ] Get a valid start index when archive execution graph

2019-04-13 Thread GitBox
yumengz5 opened a new pull request #8163: [FLINK-12183 ] Get a valid start index when archive execution graph URL: https://github.com/apache/flink/pull/8163 ## What is the purpose of the change This PR fixes FLINK-12183. The problem was that the per-job Yarn cluster doesn't

[jira] [Created] (FLINK-12183) Job Cluster doesn't release resources after cancel a running job in per-job Yarn mode

2019-04-13 Thread Yumeng Zhang (JIRA)
Yumeng Zhang created FLINK-12183: Summary: Job Cluster doesn't release resources after cancel a running job in per-job Yarn mode Key: FLINK-12183 URL: https://issues.apache.org/jira/browse/FLINK-12183

[jira] [Updated] (FLINK-12182) AggregateProjectMergeRule can not handle LogicalWindowAggregate

2019-04-13 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-12182: Description: Currently, we add the AggregateProjectMergeRule.INSTANCE in logical rule sets and us

[jira] [Updated] (FLINK-12174) Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12174: --- Labels: pull-request-available (was: ) > Introduce FlinkAggregateExtractProjectRule and rem

[GitHub] [flink] hequn8128 opened a new pull request #8162: [FLINK-12174][table] Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences

2019-04-13 Thread GitBox
hequn8128 opened a new pull request #8162: [FLINK-12174][table] Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences URL: https://github.com/apache/flink/pull/8162 ## What is the purpose of the change This pull request adds FlinkAggregateExtractProjectRule for

[GitHub] [flink] flinkbot commented on issue #8162: [FLINK-12174][table] Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences

2019-04-13 Thread GitBox
flinkbot commented on issue #8162: [FLINK-12174][table] Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences URL: https://github.com/apache/flink/pull/8162#issuecomment-482784163 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I he

[jira] [Created] (FLINK-12182) AggregateProjectMergeRule can not handle LogicalWindowAggregate

2019-04-13 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-12182: --- Summary: AggregateProjectMergeRule can not handle LogicalWindowAggregate Key: FLINK-12182 URL: https://issues.apache.org/jira/browse/FLINK-12182 Project: Flink

[GitHub] [flink] flinkbot commented on issue #8161: [hotfix] Fix typo in YarnConfigurationITCase

2019-04-13 Thread GitBox
flinkbot commented on issue #8161: [hotfix] Fix typo in YarnConfigurationITCase URL: https://github.com/apache/flink/pull/8161#issuecomment-482783051 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We wi