[jira] [Assigned] (FLINK-11608) Translate the "Local Setup Tutorial" page into Chinese

2019-02-13 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 reassigned FLINK-11608: Assignee: shengjk1 > Translate the "Local Setup Tutorial" page into Chinese > ---

[GitHub] carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code

2019-02-13 Thread GitBox
carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code URL: https://github.com/apache/flink/pull/7674#discussion_r256719361 ## File path: flink-runtime/src/main/java/org/a

[jira] [Commented] (FLINK-11159) Allow configuration whether to fall back to savepoints for restore

2019-02-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767938#comment-16767938 ] vinoyang commented on FLINK-11159: -- Just finished my vacation and saw an improved desig

[GitHub] carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code

2019-02-13 Thread GitBox
carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code URL: https://github.com/apache/flink/pull/7674#discussion_r256718752 ## File path: flink-state-backends/flink-stateb

[jira] [Assigned] (FLINK-11607) Translate the "DataStream API Tutorial" page into Chinese

2019-02-13 Thread Benchao Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li reassigned FLINK-11607: -- Assignee: Benchao Li > Translate the "DataStream API Tutorial" page into Chinese > --

[jira] [Created] (FLINK-11614) Translate the "Configuring Dependencies" page into Chinese

2019-02-13 Thread Jark Wu (JIRA)
Jark Wu created FLINK-11614: --- Summary: Translate the "Configuring Dependencies" page into Chinese Key: FLINK-11614 URL: https://issues.apache.org/jira/browse/FLINK-11614 Project: Flink Issue Type:

[jira] [Created] (FLINK-11605) Translate the "Dataflow Programming Model" page into Chinese

2019-02-13 Thread Jark Wu (JIRA)
Jark Wu created FLINK-11605: --- Summary: Translate the "Dataflow Programming Model" page into Chinese Key: FLINK-11605 URL: https://issues.apache.org/jira/browse/FLINK-11605 Project: Flink Issue Typ

[jira] [Assigned] (FLINK-11610) Translate the "Examples" page into Chinese

2019-02-13 Thread shenlei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shenlei reassigned FLINK-11610: --- Assignee: shenlei > Translate the "Examples" page into Chinese > --

[jira] [Assigned] (FLINK-11605) Translate the "Dataflow Programming Model" page into Chinese

2019-02-13 Thread xueyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-11605: - Assignee: xueyu > Translate the "Dataflow Programming Model" page into Chinese > --

[jira] [Created] (FLINK-11613) Translate the "Project Template for Scala" page into Chinese

2019-02-13 Thread Jark Wu (JIRA)
Jark Wu created FLINK-11613: --- Summary: Translate the "Project Template for Scala" page into Chinese Key: FLINK-11613 URL: https://issues.apache.org/jira/browse/FLINK-11613 Project: Flink Issue Typ

[jira] [Created] (FLINK-11608) Translate the "Local Setup Tutorial" page into Chinese

2019-02-13 Thread Jark Wu (JIRA)
Jark Wu created FLINK-11608: --- Summary: Translate the "Local Setup Tutorial" page into Chinese Key: FLINK-11608 URL: https://issues.apache.org/jira/browse/FLINK-11608 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-11612) Translate the "Project Template for Java" page into Chinese

2019-02-13 Thread Jark Wu (JIRA)
Jark Wu created FLINK-11612: --- Summary: Translate the "Project Template for Java" page into Chinese Key: FLINK-11612 URL: https://issues.apache.org/jira/browse/FLINK-11612 Project: Flink Issue Type

[jira] [Created] (FLINK-11611) Translate the "Batch Examples" page into Chinese

2019-02-13 Thread Jark Wu (JIRA)
Jark Wu created FLINK-11611: --- Summary: Translate the "Batch Examples" page into Chinese Key: FLINK-11611 URL: https://issues.apache.org/jira/browse/FLINK-11611 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11607) Translate the "DataStream API Tutorial" page into Chinese

2019-02-13 Thread Jark Wu (JIRA)
Jark Wu created FLINK-11607: --- Summary: Translate the "DataStream API Tutorial" page into Chinese Key: FLINK-11607 URL: https://issues.apache.org/jira/browse/FLINK-11607 Project: Flink Issue Type: S

[jira] [Created] (FLINK-11610) Translate the "Examples" page into Chinese

2019-02-13 Thread Jark Wu (JIRA)
Jark Wu created FLINK-11610: --- Summary: Translate the "Examples" page into Chinese Key: FLINK-11610 URL: https://issues.apache.org/jira/browse/FLINK-11610 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-11608) Translate the "Local Setup Tutorial" page into Chinese

2019-02-13 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-11608: Description: The page url is https://ci.apache.org/projects/flink/flink-docs-master/tutorials/local_setup

[jira] [Created] (FLINK-11609) Translate the "Running Flink on Windows" page into Chinese

2019-02-13 Thread Jark Wu (JIRA)
Jark Wu created FLINK-11609: --- Summary: Translate the "Running Flink on Windows" page into Chinese Key: FLINK-11609 URL: https://issues.apache.org/jira/browse/FLINK-11609 Project: Flink Issue Type:

[jira] [Commented] (FLINK-11055) Allow Queryable State to be transformed on the TaskManager before being returned to the client

2019-02-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767922#comment-16767922 ] vinoyang commented on FLINK-11055: -- Hi [~galenwarren] I think your proposal is valuable

[jira] [Assigned] (FLINK-11606) Translate the "Distributed Runtime Environment" page into Chinese

2019-02-13 Thread Huadong Sun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huadong Sun reassigned FLINK-11606: --- Assignee: Huadong Sun > Translate the "Distributed Runtime Environment" page into Chinese >

[jira] [Created] (FLINK-11606) Translate the "Distributed Runtime Environment" page into Chinese

2019-02-13 Thread Jark Wu (JIRA)
Jark Wu created FLINK-11606: --- Summary: Translate the "Distributed Runtime Environment" page into Chinese Key: FLINK-11606 URL: https://issues.apache.org/jira/browse/FLINK-11606 Project: Flink Issu

[jira] [Closed] (FLINK-10418) Add COTH math function supported in Table API and SQL

2019-02-13 Thread Aleksei Izmalkin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksei Izmalkin closed FLINK-10418. Resolution: Won't Fix > Add COTH math function supported in Table API and SQL > --

[jira] [Commented] (FLINK-10472) Add CBRT math function supported in Table API and SQL

2019-02-13 Thread Aleksei Izmalkin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767910#comment-16767910 ] Aleksei Izmalkin commented on FLINK-10472: -- The PR is closed. So I close the JI

[jira] [Commented] (FLINK-10418) Add COTH math function supported in Table API and SQL

2019-02-13 Thread Aleksei Izmalkin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767911#comment-16767911 ] Aleksei Izmalkin commented on FLINK-10418: -- The PR is closed. So I close the JI

[jira] [Reopened] (FLINK-10472) Add CBRT math function supported in Table API and SQL

2019-02-13 Thread Aleksei Izmalkin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksei Izmalkin reopened FLINK-10472: -- > Add CBRT math function supported in Table API and SQL >

[jira] [Reopened] (FLINK-10418) Add COTH math function supported in Table API and SQL

2019-02-13 Thread Aleksei Izmalkin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksei Izmalkin reopened FLINK-10418: -- > Add COTH math function supported in Table API and SQL >

[jira] [Closed] (FLINK-10472) Add CBRT math function supported in Table API and SQL

2019-02-13 Thread Aleksei Izmalkin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksei Izmalkin closed FLINK-10472. Resolution: Won't Fix > Add CBRT math function supported in Table API and SQL > --

[jira] [Closed] (FLINK-10418) Add COTH math function supported in Table API and SQL

2019-02-13 Thread Aleksei Izmalkin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksei Izmalkin closed FLINK-10418. Resolution: Fixed > Add COTH math function supported in Table API and SQL > --

[jira] [Closed] (FLINK-10472) Add CBRT math function supported in Table API and SQL

2019-02-13 Thread Aleksei Izmalkin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksei Izmalkin closed FLINK-10472. Resolution: Fixed > Add CBRT math function supported in Table API and SQL > --

[GitHub] igalshilman edited a comment on issue #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations

2019-02-13 Thread GitBox
igalshilman edited a comment on issue #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations URL: https://github.com/apache/flink/pull/7695#issuecomment-463507844 Thanks for the review @tzulitai . Th

[GitHub] igalshilman commented on issue #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations

2019-02-13 Thread GitBox
igalshilman commented on issue #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations URL: https://github.com/apache/flink/pull/7695#issuecomment-463507844 Thanks for the review @tzulita. This is an

[GitHub] zhijiangW commented on issue #7593: [FLINK-11441][network] Remove the schedule mode property from RPDD to TDD

2019-02-13 Thread GitBox
zhijiangW commented on issue #7593: [FLINK-11441][network] Remove the schedule mode property from RPDD to TDD URL: https://github.com/apache/flink/pull/7593#issuecomment-463504624 Considering future extending schedule module which might result in different `sendScheduleOrUpdateConsumers` f

[GitHub] zhijiangW closed pull request #7593: [FLINK-11441][network] Remove the schedule mode property from RPDD to TDD

2019-02-13 Thread GitBox
zhijiangW closed pull request #7593: [FLINK-11441][network] Remove the schedule mode property from RPDD to TDD URL: https://github.com/apache/flink/pull/7593 This is an automated message from the Apache Git Service. To respo

[jira] [Updated] (FLINK-11604) Extend the necessary methods in ResultPartitionWriter interface

2019-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11604: --- Labels: pull-request-available (was: ) > Extend the necessary methods in ResultPartitionWri

[jira] [Commented] (FLINK-11567) Translate "How to Review a Pull Request" page into Chinese

2019-02-13 Thread xulinjie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767892#comment-16767892 ] xulinjie commented on FLINK-11567: -- Hello, would you mind rerecognising the issue? > T

[GitHub] flinkbot commented on issue #7704: [FLINK-11604][network] Extend the necessary methods in ResultPartitionWriter interface

2019-02-13 Thread GitBox
flinkbot commented on issue #7704: [FLINK-11604][network] Extend the necessary methods in ResultPartitionWriter interface URL: https://github.com/apache/flink/pull/7704#issuecomment-463504080 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the comm

[GitHub] zhijiangW opened a new pull request #7704: [FLINK-11604][network] Extend the necessary methods in ResultPartitionWriter interface

2019-02-13 Thread GitBox
zhijiangW opened a new pull request #7704: [FLINK-11604][network] Extend the necessary methods in ResultPartitionWriter interface URL: https://github.com/apache/flink/pull/7704 ## What is the purpose of the change *This is a preparation work for future creating `ResultPartitionWriter

[GitHub] flinkbot commented on issue #7703: [FLINK-11589][Security] Service provider for security module and context discovery

2019-02-13 Thread GitBox
flinkbot commented on issue #7703: [FLINK-11589][Security] Service provider for security module and context discovery URL: https://github.com/apache/flink/pull/7703#issuecomment-463486243 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communit

[jira] [Updated] (FLINK-11589) Introduce service provider pattern for user to dynamically load SecurityFactory classes

2019-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11589: --- Labels: pull-request-available (was: ) > Introduce service provider pattern for user to dyn

[GitHub] walterddr opened a new pull request #7703: [FLINK-11589][Security] Service provider for security module and context discovery

2019-02-13 Thread GitBox
walterddr opened a new pull request #7703: [FLINK-11589][Security] Service provider for security module and context discovery URL: https://github.com/apache/flink/pull/7703 ## What is the purpose of the change This PR refactors `SecurityUtils.class` in `flink-runtime` and replace wit

[GitHub] flinkbot edited a comment on issue #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations

2019-02-13 Thread GitBox
flinkbot edited a comment on issue #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations URL: https://github.com/apache/flink/pull/7695#issuecomment-463298582 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] tzulitai commented on a change in pull request #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations

2019-02-13 Thread GitBox
tzulitai commented on a change in pull request #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations URL: https://github.com/apache/flink/pull/7695#discussion_r256686727 ## File path: flink-core/src/main/java/org/apache/flink/api/common/typeutils/LegacySe

[GitHub] tzulitai commented on a change in pull request #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations

2019-02-13 Thread GitBox
tzulitai commented on a change in pull request #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations URL: https://github.com/apache/flink/pull/7695#discussion_r256686830 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/shared

[GitHub] tzulitai commented on issue #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations

2019-02-13 Thread GitBox
tzulitai commented on issue #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations URL: https://github.com/apache/flink/pull/7695#issuecomment-463484676 @flinkbot approve quality @flinkbot approve architecture ---

[GitHub] tzulitai commented on a change in pull request #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations

2019-02-13 Thread GitBox
tzulitai commented on a change in pull request #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations URL: https://github.com/apache/flink/pull/7695#discussion_r256686616 ## File path: flink-core/src/main/java/org/apache/flink/api/common/typeutils/Composit

[GitHub] becketqin commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-13 Thread GitBox
becketqin commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r256687206 ## File path: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/stre

[GitHub] flinkbot commented on issue #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files

2019-02-13 Thread GitBox
flinkbot commented on issue #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files URL: https://github.com/apache/flink/pull/7702#issuecomment-463484443 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] becketqin commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-13 Thread GitBox
becketqin commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r256686663 ## File path: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/stre

[GitHub] walterddr opened a new pull request #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files

2019-02-13 Thread GitBox
walterddr opened a new pull request #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files URL: https://github.com/apache/flink/pull/7702 ## What is the purpose of the change * This PR introduces two new configuration keys in the YARN configuration to

[jira] [Updated] (FLINK-11088) Allow pre-install Kerberos authentication keytab discovery on YARN

2019-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11088: --- Labels: pull-request-available (was: ) > Allow pre-install Kerberos authentication keytab d

[jira] [Updated] (FLINK-11589) Introduce service provider pattern for user to dynamically load SecurityFactory classes

2019-02-13 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11589: -- Description: Currently there are only 3 security modules in Flink - Hadoop, Zookeeper and JaaS, all o

[GitHub] flinkbot edited a comment on issue #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations

2019-02-13 Thread GitBox
flinkbot edited a comment on issue #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations URL: https://github.com/apache/flink/pull/7695#issuecomment-463298582 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] tzulitai commented on issue #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations

2019-02-13 Thread GitBox
tzulitai commented on issue #7695: [FLINK-11591][core] Support legacy TypeSerializerSnapshot transformations URL: https://github.com/apache/flink/pull/7695#issuecomment-463479601 @flinkbot approve description @flinkbot approve consensus --

[GitHub] carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code

2019-02-13 Thread GitBox
carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code URL: https://github.com/apache/flink/pull/7674#discussion_r256683639 ## File path: flink-state-backends/flink-stateb

[jira] [Created] (FLINK-11604) Extend the necessary methods in ResultPartitionWriter interface

2019-02-13 Thread zhijiang (JIRA)
zhijiang created FLINK-11604: Summary: Extend the necessary methods in ResultPartitionWriter interface Key: FLINK-11604 URL: https://issues.apache.org/jira/browse/FLINK-11604 Project: Flink Issu

[GitHub] carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code

2019-02-13 Thread GitBox
carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code URL: https://github.com/apache/flink/pull/7674#discussion_r256681305 ## File path: flink-state-backends/flink-stateb

[GitHub] carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code

2019-02-13 Thread GitBox
carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code URL: https://github.com/apache/flink/pull/7674#discussion_r256681092 ## File path: flink-streaming-java/src/main/jav

[GitHub] carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code

2019-02-13 Thread GitBox
carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code URL: https://github.com/apache/flink/pull/7674#discussion_r256681007 ## File path: flink-state-backends/flink-stateb

[GitHub] carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code

2019-02-13 Thread GitBox
carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code URL: https://github.com/apache/flink/pull/7674#discussion_r256675562 ## File path: flink-streaming-java/src/main/jav

[GitHub] carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code

2019-02-13 Thread GitBox
carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code URL: https://github.com/apache/flink/pull/7674#discussion_r256675319 ## File path: flink-runtime/src/main/java/org/a

[GitHub] wujinhu commented on issue #7599: [FLINK-11442] upgrade oss sdk version

2019-02-13 Thread GitBox
wujinhu commented on issue #7599: [FLINK-11442] upgrade oss sdk version URL: https://github.com/apache/flink/pull/7599#issuecomment-463467815 @StefanRRichter Please help to review this PR, thanks :) This is an automated messag

[GitHub] FaxianZhao commented on issue #7675: [FLINK-8297] [flink-rocksdb] A plan store elements of ListState as multiple key-values in rocksdb

2019-02-13 Thread GitBox
FaxianZhao commented on issue #7675: [FLINK-8297] [flink-rocksdb] A plan store elements of ListState as multiple key-values in rocksdb URL: https://github.com/apache/flink/pull/7675#issuecomment-463467316 @klion26 thanks for your help. It looks good to me. -

[jira] [Closed] (FLINK-9700) Document FlinkKafkaProducer behaviour for Kafka versions > 0.11

2019-02-13 Thread leesf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leesf closed FLINK-9700. Resolution: Fixed > Document FlinkKafkaProducer behaviour for Kafka versions > 0.11 > -

[jira] [Commented] (FLINK-11430) Incorrect Akka timeout syntax

2019-02-13 Thread leesf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767800#comment-16767800 ] leesf commented on FLINK-11430: --- [~sinadoom], hi sina, it seems all right with spaces in A

[GitHub] liu-zhaokun commented on issue #7257: [FLINK-11089]Log filecache directory removed messages

2019-02-13 Thread GitBox
liu-zhaokun commented on issue #7257: [FLINK-11089]Log filecache directory removed messages URL: https://github.com/apache/flink/pull/7257#issuecomment-463450318 @rmetzger Thanks for your reply.I have update the patch,could help me to review it? ---

[jira] [Commented] (FLINK-11334) Migrate enum serializers to use new serialization compatibility abstractions

2019-02-13 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767771#comment-16767771 ] Congxian Qiu commented on FLINK-11334: -- Hi,  [~kisimple], What's the status of this

[jira] [Updated] (FLINK-11421) Add compilation options to allow compiling generated code with JDK compiler

2019-02-13 Thread Chunhui Shi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chunhui Shi updated FLINK-11421: Summary: Add compilation options to allow compiling generated code with JDK compiler (was: Provi

[jira] [Updated] (FLINK-11601) Remove legacy JobManagerGateway

2019-02-13 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-11601: - Summary: Remove legacy JobManagerGateway (was: Remove legacy AkkaJobManagerGateway) > Remove legacy Jo

[jira] [Created] (FLINK-11603) Ported the MetricQueryService to the new RpcEndpoint

2019-02-13 Thread TisonKun (JIRA)
TisonKun created FLINK-11603: Summary: Ported the MetricQueryService to the new RpcEndpoint Key: FLINK-11603 URL: https://issues.apache.org/jira/browse/FLINK-11603 Project: Flink Issue Type: Impr

[jira] [Updated] (FLINK-11603) Port the MetricQueryService to the new RpcEndpoint

2019-02-13 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-11603: - Summary: Port the MetricQueryService to the new RpcEndpoint (was: Ported the MetricQueryService to the

[jira] [Updated] (FLINK-11602) Remove legacy AkkaJobManagerRetriever

2019-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11602: --- Labels: pull-request-available (was: ) > Remove legacy AkkaJobManagerRetriever > --

[GitHub] flinkbot commented on issue #7701: [FLINK-11602] Remove legacy AkkaJobManagerRetriever

2019-02-13 Thread GitBox
flinkbot commented on issue #7701: [FLINK-11602] Remove legacy AkkaJobManagerRetriever URL: https://github.com/apache/flink/pull/7701#issuecomment-463426863 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull reques

[jira] [Closed] (FLINK-10495) Add HYPOT math function supported in Table API and SQL

2019-02-13 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-10495. --- Resolution: Won't Fix The master code is changed, and the PR is closed. So I close the JIRA. > Add

[GitHub] TisonKun opened a new pull request #7701: [FLINK-11602] Remove legacy AkkaJobManagerRetriever

2019-02-13 Thread GitBox
TisonKun opened a new pull request #7701: [FLINK-11602] Remove legacy AkkaJobManagerRetriever URL: https://github.com/apache/flink/pull/7701 ## What is the purpose of the change Remove legacy `AkkaJobManagerRetriever` ## Verifying this change This change is a trivial re

[jira] [Created] (FLINK-11602) Remove legacy AkkaJobManagerRetriever

2019-02-13 Thread TisonKun (JIRA)
TisonKun created FLINK-11602: Summary: Remove legacy AkkaJobManagerRetriever Key: FLINK-11602 URL: https://issues.apache.org/jira/browse/FLINK-11602 Project: Flink Issue Type: Sub-task Affect

[GitHub] sunjincheng121 commented on issue #6797: [FLINK-10495] [table] Add HYPOT math function supported in Table API and SQL

2019-02-13 Thread GitBox
sunjincheng121 commented on issue #6797: [FLINK-10495] [table] Add HYPOT math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6797#issuecomment-463426141 Thanks for check the code and close the PR. @aai95 --

[jira] [Created] (FLINK-11601) Remove legacy AkkaJobManagerGateway

2019-02-13 Thread TisonKun (JIRA)
TisonKun created FLINK-11601: Summary: Remove legacy AkkaJobManagerGateway Key: FLINK-11601 URL: https://issues.apache.org/jira/browse/FLINK-11601 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-11600) Remove legacy JobListeningContext

2019-02-13 Thread TisonKun (JIRA)
TisonKun created FLINK-11600: Summary: Remove legacy JobListeningContext Key: FLINK-11600 URL: https://issues.apache.org/jira/browse/FLINK-11600 Project: Flink Issue Type: Sub-task Comp

[jira] [Created] (FLINK-11599) Remove legacy JobClientActor

2019-02-13 Thread TisonKun (JIRA)
TisonKun created FLINK-11599: Summary: Remove legacy JobClientActor Key: FLINK-11599 URL: https://issues.apache.org/jira/browse/FLINK-11599 Project: Flink Issue Type: Sub-task Component

[jira] [Created] (FLINK-11598) Remove legacy JobSubmissionClientActor

2019-02-13 Thread TisonKun (JIRA)
TisonKun created FLINK-11598: Summary: Remove legacy JobSubmissionClientActor Key: FLINK-11598 URL: https://issues.apache.org/jira/browse/FLINK-11598 Project: Flink Issue Type: Sub-task

[GitHub] TisonKun opened a new pull request #7700: [FILNK-11597][test] Remove legacy JobManagerActorTestUtils

2019-02-13 Thread GitBox
TisonKun opened a new pull request #7700: [FILNK-11597][test] Remove legacy JobManagerActorTestUtils URL: https://github.com/apache/flink/pull/7700 ## What is the purpose of the change Remove legacy `JobManagerActorTestUtils` ## Verifying this change This change is a tr

[GitHub] flinkbot commented on issue #7700: [FILNK-11597][test] Remove legacy JobManagerActorTestUtils

2019-02-13 Thread GitBox
flinkbot commented on issue #7700: [FILNK-11597][test] Remove legacy JobManagerActorTestUtils URL: https://github.com/apache/flink/pull/7700#issuecomment-463419212 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Created] (FLINK-11597) Remove legacy JobManagerActorTestUtils

2019-02-13 Thread TisonKun (JIRA)
TisonKun created FLINK-11597: Summary: Remove legacy JobManagerActorTestUtils Key: FLINK-11597 URL: https://issues.apache.org/jira/browse/FLINK-11597 Project: Flink Issue Type: Sub-task

[GitHub] flinkbot commented on issue #7699: [hotfix] Remove legacy ResourceManagerRunner

2019-02-13 Thread GitBox
flinkbot commented on issue #7699: [hotfix] Remove legacy ResourceManagerRunner URL: https://github.com/apache/flink/pull/7699#issuecomment-463418201 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

[GitHub] TisonKun opened a new pull request #7699: [hotfix] Remove legacy ResourceManagerRunner

2019-02-13 Thread GitBox
TisonKun opened a new pull request #7699: [hotfix] Remove legacy ResourceManagerRunner URL: https://github.com/apache/flink/pull/7699 ## What is the purpose of the change Now a ResourceManager use FatalErrorHandler implementation in ClusterEntrypoint. No use point of `ResourceMa

[jira] [Updated] (FLINK-11596) Check & port ResourceManagerTest to new code base

2019-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11596: --- Labels: pull-request-available (was: ) > Check & port ResourceManagerTest to new code base

[GitHub] flinkbot commented on issue #7698: [FLINK-11596][test] Remove legacy ResourceManagerTest

2019-02-13 Thread GitBox
flinkbot commented on issue #7698: [FLINK-11596][test] Remove legacy ResourceManagerTest URL: https://github.com/apache/flink/pull/7698#issuecomment-463410663 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull requ

[GitHub] TisonKun opened a new pull request #7698: [FLINK-11596][test] Remove legacy ResourceManagerTest

2019-02-13 Thread GitBox
TisonKun opened a new pull request #7698: [FLINK-11596][test] Remove legacy ResourceManagerTest URL: https://github.com/apache/flink/pull/7698 ## What is the purpose of the change Remove legacy `ResourceManagerTest` `testJobManagerRegistrationAndReconciliation` → Invalid, now

[jira] [Assigned] (FLINK-11596) Check & port ResourceManagerTest to new code base

2019-02-13 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-11596: Assignee: TisonKun > Check & port ResourceManagerTest to new code base >

[jira] [Created] (FLINK-11596) Check & port ResourceManagerTest to new code base

2019-02-13 Thread TisonKun (JIRA)
TisonKun created FLINK-11596: Summary: Check & port ResourceManagerTest to new code base Key: FLINK-11596 URL: https://issues.apache.org/jira/browse/FLINK-11596 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-11595) Gelly addEdge in certain circumstances still include duplicate vertices.

2019-02-13 Thread Calvin Han (JIRA)
Calvin Han created FLINK-11595: -- Summary: Gelly addEdge in certain circumstances still include duplicate vertices. Key: FLINK-11595 URL: https://issues.apache.org/jira/browse/FLINK-11595 Project: Flink

[jira] [Updated] (FLINK-11595) Gelly's addEdge() in certain circumstances still includes duplicate vertices.

2019-02-13 Thread Calvin Han (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Calvin Han updated FLINK-11595: --- Summary: Gelly's addEdge() in certain circumstances still includes duplicate vertices. (was: Gelly

[jira] [Commented] (FLINK-6966) Add maxParallelism and UIDs to all operators generated by the Table API / SQL

2019-02-13 Thread Hao Dang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767618#comment-16767618 ] Hao Dang commented on FLINK-6966: - Hi [~hequn8128], Understand this work didn't start as

[GitHub] azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

2019-02-13 Thread GitBox
azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r256595763 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

2019-02-13 Thread GitBox
azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r256598926 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

2019-02-13 Thread GitBox
azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r256595763 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

2019-02-13 Thread GitBox
azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r256595763 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] flinkbot commented on issue #7697: [FLINK-11578][tests] Port BackPressureStatsTrackerImplITCase to new code base

2019-02-13 Thread GitBox
flinkbot commented on issue #7697: [FLINK-11578][tests] Port BackPressureStatsTrackerImplITCase to new code base URL: https://github.com/apache/flink/pull/7697#issuecomment-463356048 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] GJL opened a new pull request #7697: [FLINK-11578][tests] Port BackPressureStatsTrackerImplITCase to new code base

2019-02-13 Thread GitBox
GJL opened a new pull request #7697: [FLINK-11578][tests] Port BackPressureStatsTrackerImplITCase to new code base URL: https://github.com/apache/flink/pull/7697 ## What is the purpose of the change *Port BackPressureStatsTrackerImplITCase to new code base* ## Brief change log

[GitHub] flinkbot commented on issue #7696: [FLINK-11588][core] Migrating the CopyableValueSerializer

2019-02-13 Thread GitBox
flinkbot commented on issue #7696: [FLINK-11588][core] Migrating the CopyableValueSerializer URL: https://github.com/apache/flink/pull/7696#issuecomment-463303562 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-11588) Migrate CopyableValueSerializer to use new serialization compatibility abstractions

2019-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11588: --- Labels: pull-request-available (was: ) > Migrate CopyableValueSerializer to use new seriali

  1   2   3   >