[jira] [Updated] (FLINK-13038) CEP WITHIN don’t support interval expression

2019-12-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13038: - Issue Type: New Feature (was: Bug) > CEP WITHIN don’t support interval expression >

[jira] [Updated] (FLINK-14951) State TTL backend end-to-end test fail when taskManager has multiple slot

2019-12-09 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-14951: Priority: Major (was: Minor) > State TTL backend end-to-end test fail when taskManager

[jira] [Commented] (FLINK-14951) State TTL backend end-to-end test fail when taskManager has multiple slot

2019-12-09 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991567#comment-16991567 ] Andrey Zagrebin commented on FLINK-14951: - [~karmagyz] Hi yangze, I do not actually see this

[GitHub] [flink] aljoscha commented on issue #10497: [FLINK-14992][client] Add job listener to execution environments

2019-12-09 Thread GitBox
aljoscha commented on issue #10497: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10497#issuecomment-563230009 @TisonKun & @zjffdu The question is now what version of the listener we want to merge. This here is my proposal.

[GitHub] [flink] flinkbot edited a comment on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#issuecomment-563198013 ## CI report: * 793df2e323b4f84433f99f21515b30a21524658c Travis:

[GitHub] [flink] flinkbot commented on issue #10497: [FLINK-14992][client] Add job listener to execution environments

2019-12-09 Thread GitBox
flinkbot commented on issue #10497: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10497#issuecomment-563230075 ## CI report: * c2bbd3752050a609680b68f2bf4f92457ba360b1 UNKNOWN Bot commands The @flinkbot

[jira] [Commented] (FLINK-15157) Make ScalaShell ensureYarnConfig() and fetchConnectionInfo() public

2019-12-09 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991565#comment-16991565 ] Jeff Zhang commented on FLINK-15157: [~aljoscha] They needs to be public > Make ScalaShell

[GitHub] [flink] aljoscha commented on issue #10497: [FLINK-14992][client] Add job listener to execution environments

2019-12-09 Thread GitBox
aljoscha commented on issue #10497: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10497#issuecomment-563229346 @zjffdu I created https://issues.apache.org/jira/browse/FLINK-15157 and extracted your changes as a commit where you

[jira] [Commented] (FLINK-15157) Make ScalaShell ensureYarnConfig() and fetchConnectionInfo() public

2019-12-09 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991564#comment-16991564 ] Aljoscha Krettek commented on FLINK-15157: -- [~zjffdu] Could you comment on if the methods need

[GitHub] [flink] zjffdu commented on issue #10497: [FLINK-14992][client] Add job listener to execution environments

2019-12-09 Thread GitBox
zjffdu commented on issue #10497: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10497#issuecomment-563229035 @aljoscha No problem, I will update this PR accordingly. Do you mean you are going to make these changes ? I don't see

[jira] [Created] (FLINK-15157) Make ScalaShell ensureYarnConfig() and fetchConnectionInfo() public

2019-12-09 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15157: Summary: Make ScalaShell ensureYarnConfig() and fetchConnectionInfo() public Key: FLINK-15157 URL: https://issues.apache.org/jira/browse/FLINK-15157 Project:

[GitHub] [flink] kl0u commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
kl0u commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563228741 Now I noticed that you added a second execution of the same `statement2`. In this case, it would make sense to

[GitHub] [flink] wangyang0918 commented on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
wangyang0918 commented on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#issuecomment-563227595 @zhijiangW Could you please take a look? It is a small change.

[GitHub] [flink] kl0u commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
kl0u commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#discussion_r355432063 ## File path:

[GitHub] [flink] kl0u commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
kl0u commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563226429 > > For bookkeeping reasons it is good to have separate JIRAs for separate issues. But feel free to create a JIRA

[GitHub] [flink] wangyang0918 removed a comment on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
wangyang0918 removed a comment on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#issuecomment-563196415 @TisonKun Could you please take a look?

[GitHub] [flink] flinkbot edited a comment on issue #10495: [FLINK-15151][table-planner-blink] Use new type system in TableSource…

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10495: [FLINK-15151][table-planner-blink] Use new type system in TableSource… URL: https://github.com/apache/flink/pull/10495#issuecomment-563194106 ## CI report: * fbbc9e5281372342a8fe58bc7640b94af947c824 Travis:

[jira] [Updated] (FLINK-15156) Warn user if System.exit() is called in user code

2019-12-09 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15156: --- Description: It would make debugging Flink errors easier if we would intercept and log

[GitHub] [flink] flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563083959 ## CI report: * 2e942aa60f0807a6a41fd0483237d8b571fdca1f Travis:

[GitHub] [flink] kl0u commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
kl0u commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#discussion_r355432063 ## File path:

[jira] [Created] (FLINK-15156) Warn user if System.exit() is called in user code

2019-12-09 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-15156: -- Summary: Warn user if System.exit() is called in user code Key: FLINK-15156 URL: https://issues.apache.org/jira/browse/FLINK-15156 Project: Flink Issue

[jira] [Updated] (FLINK-15156) Warn user if System.exit() is called in user code

2019-12-09 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15156: --- Priority: Minor (was: Major) > Warn user if System.exit() is called in user code >

[GitHub] [flink] aljoscha commented on issue #10497: [FLINK-14992][client] Add job listener to execution environments

2019-12-09 Thread GitBox
aljoscha commented on issue #10497: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10497#issuecomment-563224522 @zjffdu @TisonKun I know this is the third try at this, so sorry for that.  @zjffdu I changed the

[GitHub] [flink] flinkbot commented on issue #10497: [FLINK-14992][client] Add job listener to execution environments

2019-12-09 Thread GitBox
flinkbot commented on issue #10497: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10497#issuecomment-563224440 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] aljoscha opened a new pull request #10497: [FLINK-14992][client] Add job listener to execution environments

2019-12-09 Thread GitBox
aljoscha opened a new pull request #10497: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10497 ## What is the purpose of the change This adds the `JobListener` for frameworks to hook into the job submission process.

[GitHub] [flink] danny0405 commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
danny0405 commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563223532 > For bookkeeping reasons it is good to have separate JIRAs for separate issues. But feel free to create a

[GitHub] [flink] kl0u commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
kl0u commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563221824 For bookkeeping reasons it is good to have separate JIRAs for separate issues. But feel free to create a JIRA and

[GitHub] [flink] danny0405 commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
danny0405 commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563221160 > @danny0405 The changes in

[GitHub] [flink] kl0u commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
kl0u commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563219161 @danny0405 The changes in f9657812903c088739c262b4e418d69683c52989 are unrelated to this change, right? Or am I

[GitHub] [flink] danny0405 commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
danny0405 commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563218572 > StreamPlanEnvironment Thanks for the reminder @kl0u, indeed these `transformation.clear()` can be

[jira] [Updated] (FLINK-14649) Flatten all the connector properties keys to make it easy to configure in DDL

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14649: --- Release Note: {{PlaceHolder}} > Flatten all the connector properties keys to make it easy to

[jira] [Created] (FLINK-15155) Join with a LookupableTableSource: the defined order lookup keys are inconsistent

2019-12-09 Thread Rockey Cui (Jira)
Rockey Cui created FLINK-15155: -- Summary: Join with a LookupableTableSource: the defined order lookup keys are inconsistent Key: FLINK-15155 URL: https://issues.apache.org/jira/browse/FLINK-15155

[jira] [Closed] (FLINK-13438) Support date type in Hive

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13438. -- Resolution: Fixed master: 2994f0e44b53c85535f2f29fb43d320ace91f6f8 > Support date type in Hive >

[GitHub] [flink] KurtYoung closed pull request #10494: [FLINK-13438][hive] Support date type in Hive

2019-12-09 Thread GitBox
KurtYoung closed pull request #10494: [FLINK-13438][hive] Support date type in Hive URL: https://github.com/apache/flink/pull/10494 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] danny0405 commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
danny0405 commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#discussion_r355420532 ## File path:

[jira] [Commented] (FLINK-15139) misc end to end test failed on 'SQL Client end-to-end test (Old planner)'

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991540#comment-16991540 ] Jark Wu commented on FLINK-15139: - [~Leonard Xu], I assigned this issue to you. Feel free to open pull

[jira] [Assigned] (FLINK-15139) misc end to end test failed on 'SQL Client end-to-end test (Old planner)'

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15139: --- Assignee: Leonard Xu > misc end to end test failed on 'SQL Client end-to-end test (Old planner)' >

[jira] [Commented] (FLINK-15139) misc end to end test failed on 'SQL Client end-to-end test (Old planner)'

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991539#comment-16991539 ] Jark Wu commented on FLINK-15139: - I think so. The root cause should be that we miss to pass

[jira] [Resolved] (FLINK-14649) Flatten all the connector properties keys to make it easy to configure in DDL

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14649. - Resolution: Fixed 1.10.0: c93205b4abe643d6dd798c3180d68ab8d02eded5 > Flatten all the connector

[GitHub] [flink] wuchong merged pull request #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL

2019-12-09 Thread GitBox
wuchong merged pull request #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL URL: https://github.com/apache/flink/pull/10468 This is an automated message

[GitHub] [flink] flinkbot edited a comment on issue #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement URL: https://github.com/apache/flink/pull/9398#issuecomment-519727123 ## CI report: * 08e406e0565f2f945437c4baeebbf0a6c4489ff3 Travis:

[jira] [Commented] (FLINK-15143) Create document for FLIP-49 TM memory model and configuration guide

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991535#comment-16991535 ] Yu Li commented on FLINK-15143: --- Thanks folks, +1 to add release note in FLINK-13980. > Create document

[jira] [Created] (FLINK-15154) Change Flink binding addresses in local mode

2019-12-09 Thread Andrea Cardaci (Jira)
Andrea Cardaci created FLINK-15154: -- Summary: Change Flink binding addresses in local mode Key: FLINK-15154 URL: https://issues.apache.org/jira/browse/FLINK-15154 Project: Flink Issue Type:

[jira] [Commented] (FLINK-15139) misc end to end test failed on 'SQL Client end-to-end test (Old planner)'

2019-12-09 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991532#comment-16991532 ] Leonard Xu commented on FLINK-15139: This should be a bug imported by FLINK-14840 after checked

[GitHub] [flink] kl0u commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
kl0u commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563210011 You can also remove all the `transformation.clear();` calls from the subclasses of the

[GitHub] [flink] zjuwangg commented on a change in pull request #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog

2019-12-09 Thread GitBox
zjuwangg commented on a change in pull request #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog URL: https://github.com/apache/flink/pull/10493#discussion_r355414468 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#issuecomment-563198013 ## CI report: * 793df2e323b4f84433f99f21515b30a21524658c Travis:

[GitHub] [flink] klion26 commented on issue #10490: [FLINK-15136][docs] Update the Chinese version of Working with State

2019-12-09 Thread GitBox
klion26 commented on issue #10490: [FLINK-15136][docs] Update the Chinese version of Working with State URL: https://github.com/apache/flink/pull/10490#issuecomment-563208283 @carp84 @azagrebin thanks for the review and merging.

[jira] [Closed] (FLINK-15136) Update the Chinese version of "Working with state"

2019-12-09 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-15136. --- Fix Version/s: 1.10.0 Resolution: Done merged into master by

[GitHub] [flink] azagrebin commented on issue #10490: [FLINK-15136][docs] Update the Chinese version of Working with State

2019-12-09 Thread GitBox
azagrebin commented on issue #10490: [FLINK-15136][docs] Update the Chinese version of Working with State URL: https://github.com/apache/flink/pull/10490#issuecomment-563206761 Thanks @klion26 @carp84 merged into master by f90fd6b9dea154a39d26fa3a5a529565d4efb3e1

[GitHub] [flink] flinkbot edited a comment on issue #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement URL: https://github.com/apache/flink/pull/9398#issuecomment-519727123 ## CI report: * 08e406e0565f2f945437c4baeebbf0a6c4489ff3 Travis:

[GitHub] [flink] azagrebin closed pull request #10490: [FLINK-15136][docs] Update the Chinese version of Working with State

2019-12-09 Thread GitBox
azagrebin closed pull request #10490: [FLINK-15136][docs] Update the Chinese version of Working with State URL: https://github.com/apache/flink/pull/10490 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on issue #10495: [FLINK-15151][table-planner-blink] Use new type system in TableSource…

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10495: [FLINK-15151][table-planner-blink] Use new type system in TableSource… URL: https://github.com/apache/flink/pull/10495#issuecomment-563194106 ## CI report: * fbbc9e5281372342a8fe58bc7640b94af947c824 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10482: WIP [Flink-11956] Unshade s3 filesystems

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10482: WIP [Flink-11956] Unshade s3 filesystems URL: https://github.com/apache/flink/pull/10482#issuecomment-562885821 ## CI report: * 3ad923385d40723d4ff6aba32cde9fb31d124c1f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment URL: https://github.com/apache/flink/pull/10431#issuecomment-562033619 ## CI report: * e0b1afaebe5bd4fc07e61785a38ef82f55e16f69

[jira] [Commented] (FLINK-14898) Enable background cleanup of state with TTL by default

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991517#comment-16991517 ] Yu Li commented on FLINK-14898: --- Thanks for the quick action [~azagrebin]! > Enable background cleanup of

[jira] [Commented] (FLINK-15031) Calculate required shuffle memory before allocating slots if resources are specified

2019-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991514#comment-16991514 ] Zhu Zhu commented on FLINK-15031: - Postpone to 1.11 since several re-requisites to use this feature is

[jira] [Updated] (FLINK-15031) Calculate required shuffle memory before allocating slots if resources are specified

2019-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15031: Fix Version/s: (was: 1.10.0) 1.11.0 > Calculate required shuffle memory before

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-09 Thread GitBox
zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r355402750 ## File path:

[GitHub] [flink] flinkbot commented on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
flinkbot commented on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#issuecomment-563198013 ## CI report: * 793df2e323b4f84433f99f21515b30a21524658c UNKNOWN Bot commands The

[GitHub] [flink] wangyang0918 commented on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
wangyang0918 commented on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#issuecomment-563196415 @TisonKun Could you please take a look?

[GitHub] [flink] igalshilman commented on issue #10324: [FLINK-11767] Introduce new TypeSerializerUpgradeTestBase

2019-12-09 Thread GitBox
igalshilman commented on issue #10324: [FLINK-11767] Introduce new TypeSerializerUpgradeTestBase URL: https://github.com/apache/flink/pull/10324#issuecomment-563196499 Hi @tzulitai, Thanks for working on this, indeed this seems like an important improvement. I've checked the PR

[GitHub] [flink] flinkbot commented on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
flinkbot commented on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#issuecomment-563196256 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-15153) Service selector needs to contain jobmanager component label

2019-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15153: --- Labels: pull-request-available (was: ) > Service selector needs to contain jobmanager

[GitHub] [flink] wangyang0918 opened a new pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
wangyang0918 opened a new pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496 ## What is the purpose of the change The jobmanager label needs to be added to service selector.

[GitHub] [flink] flinkbot commented on issue #10495: [FLINK-15151][table-planner-blink] Use new type system in TableSource…

2019-12-09 Thread GitBox
flinkbot commented on issue #10495: [FLINK-15151][table-planner-blink] Use new type system in TableSource… URL: https://github.com/apache/flink/pull/10495#issuecomment-563194106 ## CI report: * fbbc9e5281372342a8fe58bc7640b94af947c824 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10494: [FLINK-13438][hive] Support date type in Hive

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10494: [FLINK-13438][hive] Support date type in Hive URL: https://github.com/apache/flink/pull/10494#issuecomment-563152647 ## CI report: * f0985f3ee25c3016e811caefb468633d5e07406b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog URL: https://github.com/apache/flink/pull/10493#issuecomment-563111006 ## CI report: * a79225d75a53240951a4378380ff2aac457c1278

[GitHub] [flink] flinkbot edited a comment on issue #10482: WIP [Flink-11956] Unshade s3 filesystems

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10482: WIP [Flink-11956] Unshade s3 filesystems URL: https://github.com/apache/flink/pull/10482#issuecomment-562885821 ## CI report: * 3ad923385d40723d4ff6aba32cde9fb31d124c1f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment URL: https://github.com/apache/flink/pull/10431#issuecomment-562033619 ## CI report: * e0b1afaebe5bd4fc07e61785a38ef82f55e16f69

[jira] [Updated] (FLINK-15153) Service selector needs to contain jobmanager component label

2019-12-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15153: -- Fix Version/s: 1.10.0 > Service selector needs to contain jobmanager component label >

[jira] [Updated] (FLINK-15153) Service selector needs to contain jobmanager component label

2019-12-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15153: -- Component/s: Deployment / Kubernetes > Service selector needs to contain jobmanager component label >

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

2019-12-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-9953: - Issue Type: New Feature (was: Bug) > Active Kubernetes integration > - > >

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

2019-12-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-9953: - Issue Type: Bug (was: New Feature) > Active Kubernetes integration > - > >

[jira] [Created] (FLINK-15153) Service selector needs to contain jobmanager component label

2019-12-09 Thread Yang Wang (Jira)
Yang Wang created FLINK-15153: - Summary: Service selector needs to contain jobmanager component label Key: FLINK-15153 URL: https://issues.apache.org/jira/browse/FLINK-15153 Project: Flink

[jira] [Updated] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

2019-12-09 Thread Feng Jiajie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-15152: Description: I have a streaming job configured with periodically checkpoint, but after one week

[jira] [Updated] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

2019-12-09 Thread Feng Jiajie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-15152: Description: I have a streaming job configured with periodically checkpoint, but after one week

[jira] [Created] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

2019-12-09 Thread Feng Jiajie (Jira)
Feng Jiajie created FLINK-15152: --- Summary: Job running without periodic checkpoint for stop failed at the beginning Key: FLINK-15152 URL: https://issues.apache.org/jira/browse/FLINK-15152 Project:

[jira] [Commented] (FLINK-15053) Configurations with values contains space may cause TM failures on Yarn

2019-12-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991494#comment-16991494 ] Yang Wang commented on FLINK-15053: --- All the value of dynamic properties will be put into a pair of

[GitHub] [flink] asfgit closed pull request #10423: [FLINK-14378][state] Cleanup rocksDB lib folder if fail to load library

2019-12-09 Thread GitBox
asfgit closed pull request #10423: [FLINK-14378][state] Cleanup rocksDB lib folder if fail to load library URL: https://github.com/apache/flink/pull/10423 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] azagrebin commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-09 Thread GitBox
azagrebin commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r355385739 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#issuecomment-563110907 ## CI report: * bef118a977b3aa635fc748260d07b0d5079b2c0e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10486: [FLINK-15131][connector/source] Add the APIs for Source (FLIP-27).

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10486: [FLINK-15131][connector/source] Add the APIs for Source (FLIP-27). URL: https://github.com/apache/flink/pull/10486#issuecomment-562960855 ## CI report: * 8c84da76b5e6919173d15a369a204c12d8a53da2 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563083959 ## CI report: * 2e942aa60f0807a6a41fd0483237d8b571fdca1f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10479: [FLINK-14992][client] Add job listener to execution environments

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10479: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10479#issuecomment-562851491 ## CI report: * a5903c83403e4628cdb00e85ab5860be9ebaadc4 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo URL: https://github.com/apache/flink/pull/10458#issuecomment-562482569 ## CI report: * 303f921f58ff61aa3e332c36ffdc07d5f9ceb352 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment URL: https://github.com/apache/flink/pull/10431#issuecomment-562033619 ## CI report: * e0b1afaebe5bd4fc07e61785a38ef82f55e16f69

[jira] [Closed] (FLINK-14898) Enable background cleanup of state with TTL by default

2019-12-09 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-14898. --- Release Note: The background cleanup of the expired state with TTL is now activated by

[GitHub] [flink] wangxiyuan edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum

2019-12-09 Thread GitBox
wangxiyuan edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum URL: https://github.com/apache/flink/pull/9768#issuecomment-563177370 @StephanEwen Done. Merged the arch recheck into `MemoryArchitecture` and renamed it. The test is passed on both

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-09 Thread GitBox
zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r355379611 ## File path:

[GitHub] [flink] wangxiyuan commented on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum

2019-12-09 Thread GitBox
wangxiyuan commented on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum URL: https://github.com/apache/flink/pull/9768#issuecomment-563177370 @StephanEwen Done. Merged the arch recheck into `MemoryArchitecture` and renamed it.

[GitHub] [flink] flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum URL: https://github.com/apache/flink/pull/9768#issuecomment-534899022 ## CI report: * 51ae12da735fd7fd1bdadd282839c9bfe7b80146 Travis:

[GitHub] [flink] flinkbot commented on issue #10495: [FLINK-15151][table-planner-blink] Use new type system in TableSource…

2019-12-09 Thread GitBox
flinkbot commented on issue #10495: [FLINK-15151][table-planner-blink] Use new type system in TableSource… URL: https://github.com/apache/flink/pull/10495#issuecomment-563174990 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] azagrebin commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-09 Thread GitBox
azagrebin commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r355376622 ## File path:

[jira] [Updated] (FLINK-15151) Use new type system in TableSourceUtil.computeIndexMapping of blink planner

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

[GitHub] [flink] docete opened a new pull request #10495: [FLINK-15151][table-planner-blink] Use new type system in TableSource…

2019-12-09 Thread GitBox
docete opened a new pull request #10495: [FLINK-15151][table-planner-blink] Use new type system in TableSource… URL: https://github.com/apache/flink/pull/10495 …Util.computeIndexMapping of blink planner ## What is the purpose of the change

[GitHub] [flink] klion26 commented on issue #10490: [FLINK-15136][docs] Update the Chinese version of Working with State

2019-12-09 Thread GitBox
klion26 commented on issue #10490: [FLINK-15136][docs] Update the Chinese version of Working with State URL: https://github.com/apache/flink/pull/10490#issuecomment-563170155 test failed because of irrelevant case, create an [issue](https://issues.apache.org/jira/browse/FLINK-15150) to

[GitHub] [flink] aljoscha commented on issue #10479: [FLINK-14992][client] Add job listener to execution environments

2019-12-09 Thread GitBox
aljoscha commented on issue #10479: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10479#issuecomment-563170033 This leaves `JobListener.onJobExecuted()` in, but it's not called anymore from the environments.

[jira] [Created] (FLINK-15151) Use new type system in TableSourceUtil.computeIndexMapping of blink planner

2019-12-09 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-15151: Summary: Use new type system in TableSourceUtil.computeIndexMapping of blink planner Key: FLINK-15151 URL: https://issues.apache.org/jira/browse/FLINK-15151 Project:

[jira] [Commented] (FLINK-14898) Enable background cleanup of state with TTL by default

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991474#comment-16991474 ] Yu Li commented on FLINK-14898: --- [~azagrebin] Could you also add a release note here to reflect the

<    1   2   3   4   5   6   7   8   >