[GitHub] [flink] GJL commented on a change in pull request #7883: [FLINK-11781][yarn] Remove "DISABLED" as possible value for yarn.per-job-cluster.include-user-jar

2019-03-04 Thread GitBox
GJL commented on a change in pull request #7883: [FLINK-11781][yarn] Remove "DISABLED" as possible value for yarn.per-job-cluster.include-user-jar URL: https://github.com/apache/flink/pull/7883#discussion_r262099481 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/confi

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262099480 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/s

[jira] [Closed] (FLINK-11801) Port SqlParserException to flink-table-api-java

2019-03-04 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-11801. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9: eb683e5db2f8eafc927f7c77579cf1109375479a > Port

[GitHub] [flink] GJL commented on a change in pull request #7883: [FLINK-11781][yarn] Remove "DISABLED" as possible value for yarn.per-job-cluster.include-user-jar

2019-03-04 Thread GitBox
GJL commented on a change in pull request #7883: [FLINK-11781][yarn] Remove "DISABLED" as possible value for yarn.per-job-cluster.include-user-jar URL: https://github.com/apache/flink/pull/7883#discussion_r262099481 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/confi

[GitHub] [flink] carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262098661 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/hea

[GitHub] [flink] flinkbot commented on issue #7894: [FLINK-11420][core][bp-1.8] Fixed duplicate method of TraversableSerializer

2019-03-04 Thread GitBox
flinkbot commented on issue #7894: [FLINK-11420][core][bp-1.8] Fixed duplicate method of TraversableSerializer URL: https://github.com/apache/flink/pull/7894#issuecomment-469283163 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community t

[GitHub] [flink] dawidwys opened a new pull request #7894: [FLINK-11420][core] Fixed duplicate method of TraversableSerializer

2019-03-04 Thread GitBox
dawidwys opened a new pull request #7894: [FLINK-11420][core] Fixed duplicate method of TraversableSerializer URL: https://github.com/apache/flink/pull/7894 backport of #7872 See the description there. This is an automated m

[GitHub] [flink] asfgit closed pull request #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java

2019-03-04 Thread GitBox
asfgit closed pull request #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java URL: https://github.com/apache/flink/pull/7888 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot commented on issue #7893: [hotfix] Fix checkstyle violations and remove unnecessary symbol in IOManagerAsync

2019-03-04 Thread GitBox
flinkbot commented on issue #7893: [hotfix] Fix checkstyle violations and remove unnecessary symbol in IOManagerAsync URL: https://github.com/apache/flink/pull/7893#issuecomment-469278254 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communit

[GitHub] [flink] leesf opened a new pull request #7893: [hotfix] Fix checkstyle violations and remove unnecessary symbol in IOManagerAsync

2019-03-04 Thread GitBox
leesf opened a new pull request #7893: [hotfix] Fix checkstyle violations and remove unnecessary symbol in IOManagerAsync URL: https://github.com/apache/flink/pull/7893 Fix checkstyle violations and remove unnecessary symbol in IOManagerAsync ---

[jira] [Updated] (FLINK-5080) Cassandra connector ignores saveAsync result onSuccess

2019-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5080: -- Labels: pull-request-available (was: ) > Cassandra connector ignores saveAsync result onSucces

[GitHub] [flink] flinkbot commented on issue #7892: [FLINK-5080] [Connectors / Cassandra] Cassandra connector ignores saveAsync result onSuccess

2019-03-04 Thread GitBox
flinkbot commented on issue #7892: [FLINK-5080] [Connectors / Cassandra] Cassandra connector ignores saveAsync result onSuccess URL: https://github.com/apache/flink/pull/7892#issuecomment-469271492 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help th

[GitHub] [flink] Salatich opened a new pull request #7892: [FLINK-5080] [Connectors / Cassandra] Cassandra connector ignores saveAsync result onSuccess

2019-03-04 Thread GitBox
Salatich opened a new pull request #7892: [FLINK-5080] [Connectors / Cassandra] Cassandra connector ignores saveAsync result onSuccess URL: https://github.com/apache/flink/pull/7892 ## What is the purpose of the change Add possibility of passing a custom callback in CassandraPojo

[GitHub] [flink] dawidwys merged pull request #7747: [FLINK-11653][DataStream] Add configuration to enforce custom UID's o…

2019-03-04 Thread GitBox
dawidwys merged pull request #7747: [FLINK-11653][DataStream] Add configuration to enforce custom UID's o… URL: https://github.com/apache/flink/pull/7747 This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink] flinkbot edited a comment on issue #7747: [FLINK-11653][DataStream] Add configuration to enforce custom UID's o…

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7747: [FLINK-11653][DataStream] Add configuration to enforce custom UID's o… URL: https://github.com/apache/flink/pull/7747#issuecomment-464851132 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262072946 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/s

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262072838 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/s

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262069510 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/s

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262068514 ## File path: flink-streaming-java/src/test/java/org/apache/flink/st

[GitHub] [flink] flinkbot edited a comment on issue #7867: [hotfix][datastream] Fix typos in DataStream

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7867: [hotfix][datastream] Fix typos in DataStream URL: https://github.com/apache/flink/pull/7867#issuecomment-468559265 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull reques

[GitHub] [flink] KurtYoung merged pull request #7867: [hotfix][datastream] Fix typos in DataStream

2019-03-04 Thread GitBox
KurtYoung merged pull request #7867: [hotfix][datastream] Fix typos in DataStream URL: https://github.com/apache/flink/pull/7867 This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] Clarkkkkk commented on issue #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base

2019-03-04 Thread GitBox
Clark commented on issue #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base URL: https://github.com/apache/flink/pull/7780#issuecomment-469260366 The test fails on Kafka09ITTest, which seems like having nothing to do with the changes. ---

[jira] [Closed] (FLINK-11802) Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11802. -- Resolution: Implemented Fix Version/s: 1.9.0 > Create TypeInfo and TypeSerializer for blink dat

[jira] [Commented] (FLINK-11802) Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16783377#comment-16783377 ] Kurt Young commented on FLINK-11802: implemented in 76eb0397041915c867df57b7e2478cac

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262062202 ## File path: flink-streaming-java/src/main/java/org/apache/flink/st

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262062202 ## File path: flink-streaming-java/src/main/java/org/apache/flink/st

[GitHub] [flink] KurtYoung closed pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
KurtYoung closed pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887 This is an automated message from the Apache Git

[GitHub] [flink] KurtYoung commented on issue #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
KurtYoung commented on issue #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#issuecomment-469256014 Looks good, merging this. T

[GitHub] [flink] carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262061037 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/hea

[jira] [Created] (FLINK-11811) Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11811: -- Summary: Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore Key: FLINK-11811 URL: https://issues.apache.org/jira/browse/FLINK-11811 Project: Flin

[jira] [Created] (FLINK-11812) Composite etcd based HighAvailability components

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11812: -- Summary: Composite etcd based HighAvailability components Key: FLINK-11812 URL: https://issues.apache.org/jira/browse/FLINK-11812 Project: Flink Issue Ty

[jira] [Commented] (FLINK-11811) Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore

2019-03-04 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16783373#comment-16783373 ] Flavio Pompermaier commented on FLINK-11811: What about using Apache BookKee

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262017924 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/s

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262016736 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/s

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262042957 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/s

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262016772 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/s

[jira] [Updated] (FLINK-11810) Implement etcd based CheckpointRecoveryFactory

2019-03-04 Thread MalcolmSanders (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] MalcolmSanders updated FLINK-11810: --- Description: Implement CheckpointRecoveryFactory using jetcd. A CheckpointRecoveryFactory im

[jira] [Assigned] (FLINK-11809) Implement etcd based StateHandleStore

2019-03-04 Thread MalcolmSanders (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] MalcolmSanders reassigned FLINK-11809: -- Assignee: MalcolmSanders > Implement etcd based StateHandleStore > --

[GitHub] [flink] Fokko closed pull request #7891: WIP: Gcs filesystem

2019-03-04 Thread GitBox
Fokko closed pull request #7891: WIP: Gcs filesystem URL: https://github.com/apache/flink/pull/7891 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot commented on issue #7891: WIP: Gcs filesystem

2019-03-04 Thread GitBox
flinkbot commented on issue #7891: WIP: Gcs filesystem URL: https://github.com/apache/flink/pull/7891#issuecomment-469250075 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 tr

[GitHub] [flink] Fokko opened a new pull request #7891: WIP: Gcs filesystem

2019-03-04 Thread GitBox
Fokko opened a new pull request #7891: WIP: Gcs filesystem URL: https://github.com/apache/flink/pull/7891 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-tran

[GitHub] [flink] carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262052077 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/Sta

[GitHub] [flink] carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262052014 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/Sta

[jira] [Created] (FLINK-11810) Implement etcd based CheckpointRecoveryFactory

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11810: -- Summary: Implement etcd based CheckpointRecoveryFactory Key: FLINK-11810 URL: https://issues.apache.org/jira/browse/FLINK-11810 Project: Flink Issue Type

[jira] [Updated] (FLINK-11808) Implement etcd based SharedCount or sequencer

2019-03-04 Thread MalcolmSanders (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] MalcolmSanders updated FLINK-11808: --- Description: Implement SharedCount or sequencer API using jetcd. CheckpointIDCounter is use

[jira] [Created] (FLINK-11809) Implement etcd based StateHandleStore

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11809: -- Summary: Implement etcd based StateHandleStore Key: FLINK-11809 URL: https://issues.apache.org/jira/browse/FLINK-11809 Project: Flink Issue Type: Sub-tas

[GitHub] [flink] flinkbot commented on issue #7890: [FLINK-9003][E2E] Add operators with input type that goes through custom, stateful serialization

2019-03-04 Thread GitBox
flinkbot commented on issue #7890: [FLINK-9003][E2E] Add operators with input type that goes through custom, stateful serialization URL: https://github.com/apache/flink/pull/7890#issuecomment-469246128 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I hel

[GitHub] [flink] azagrebin opened a new pull request #7890: [FLINK-9003][E2E] Add operators with input type that goes through custom, stateful serialization

2019-03-04 Thread GitBox
azagrebin opened a new pull request #7890: [FLINK-9003][E2E] Add operators with input type that goes through custom, stateful serialization URL: https://github.com/apache/flink/pull/7890 1.7 backport of #7846 This is an autom

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r262048964 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[jira] [Updated] (FLINK-11808) etcd based SharedCount or sequencer

2019-03-04 Thread MalcolmSanders (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] MalcolmSanders updated FLINK-11808: --- Component/s: Runtime / Coordination > etcd based SharedCount or sequencer >

[jira] [Updated] (FLINK-11808) Implement etcd based SharedCount or sequencer

2019-03-04 Thread MalcolmSanders (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] MalcolmSanders updated FLINK-11808: --- Summary: Implement etcd based SharedCount or sequencer (was: etcd based SharedCount or sequ

[GitHub] [flink] carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262044916 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/

[GitHub] [flink] carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262044190 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/

[jira] [Commented] (FLINK-11782) Enhance TaskManager log visualization by listing all log files for Flink web UI

2019-03-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16783339#comment-16783339 ] vinoyang commented on FLINK-11782: -- [~StephanEwen] [~till.rohrmann] and [~Zentol] If we

[jira] [Created] (FLINK-11808) etcd based SharedCount or sequencer

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11808: -- Summary: etcd based SharedCount or sequencer Key: FLINK-11808 URL: https://issues.apache.org/jira/browse/FLINK-11808 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11807) Implement etcd based LeaderElectionService and LeaderRetrievalService

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11807: -- Summary: Implement etcd based LeaderElectionService and LeaderRetrievalService Key: FLINK-11807 URL: https://issues.apache.org/jira/browse/FLINK-11807 Project: Fl

[GitHub] [flink] carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262039963 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/Sta

[jira] [Updated] (FLINK-11716) Introduce Task Manager configuration option to customize address binding mechanism

2019-03-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11716: - Release Note: `TaskManagers` now bind to the host IP address instead of the hostname by

[jira] [Commented] (FLINK-11439) INSERT INTO flink_sql SELECT * FROM blink_sql

2019-03-04 Thread hery168 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16783323#comment-16783323 ] hery168 commented on FLINK-11439: - 留名 > INSERT INTO flink_sql SELECT * FROM blink_sql >

[jira] [Updated] (FLINK-11806) Import shaded jetcd

2019-03-04 Thread MalcolmSanders (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] MalcolmSanders updated FLINK-11806: --- Issue Type: Sub-task (was: Task) Parent: FLINK-11105 > Import shaded jetcd > --

[jira] [Created] (FLINK-11806) Import shaded jetcd

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11806: -- Summary: Import shaded jetcd Key: FLINK-11806 URL: https://issues.apache.org/jira/browse/FLINK-11806 Project: Flink Issue Type: Task Components

[jira] [Issue Comment Deleted] (FLINK-11439) INSERT INTO flink_sql SELECT * FROM blink_sql

2019-03-04 Thread hery168 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hery168 updated FLINK-11439: Comment: was deleted (was: 留名) > INSERT INTO flink_sql SELECT * FROM blink_sql >

[GitHub] [flink] pnowojski commented on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2019-03-04 Thread GitBox
pnowojski commented on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-469230797 @gaoyunhaii Could you provide benchmark results (https://github.com/dataArtisans/flink-benchmarks/) t

[GitHub] [flink] link3280 closed pull request #7294: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials

2019-03-04 Thread GitBox
link3280 closed pull request #7294: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials URL: https://github.com/apache/flink/pull/7294 This is an automated message from the Apache Git Service. To

[jira] [Assigned] (FLINK-11661) Implement HadoopReduceCombineFunctionITCase for new Hadoop API

2019-03-04 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11661: Assignee: TANG Wen-hui (was: vinoyang) > Implement HadoopReduceCombineFunctionITCase for

[jira] [Assigned] (FLINK-11658) Implement HadoopMapreduceITCase for new Hadoop API

2019-03-04 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11658: Assignee: TANG Wen-hui (was: vinoyang) > Implement HadoopMapreduceITCase for new Hadoop

[jira] [Assigned] (FLINK-11659) Implement HadoopMapFunctionITCase for new Hadoop API

2019-03-04 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11659: Assignee: TANG Wen-hui (was: vinoyang) > Implement HadoopMapFunctionITCase for new Hadoo

[jira] [Assigned] (FLINK-11660) Implement HadoopReduceFunctionITCase for new Hadoop API

2019-03-04 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11660: Assignee: TANG Wen-hui (was: vinoyang) > Implement HadoopReduceFunctionITCase for new Ha

[jira] [Created] (FLINK-11805) A Common External Shuffle Service Framework

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11805: -- Summary: A Common External Shuffle Service Framework Key: FLINK-11805 URL: https://issues.apache.org/jira/browse/FLINK-11805 Project: Flink Issue Type: N

[GitHub] [flink] tillrohrmann commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData

2019-03-04 Thread GitBox
tillrohrmann commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData URL: https://github.com/apache/flink/pull/7880#discussion_r262018551 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavai

[jira] [Updated] (FLINK-11665) Flink fails to remove JobGraph from ZK even though it reports it did

2019-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11665: --- Labels: pull-request-available (was: ) > Flink fails to remove JobGraph from ZK even though

[GitHub] [flink] flinkbot commented on issue #7889: [FLINK-11665] Wait for job termination before recovery in Dispatcher

2019-03-04 Thread GitBox
flinkbot commented on issue #7889: [FLINK-11665] Wait for job termination before recovery in Dispatcher URL: https://github.com/apache/flink/pull/7889#issuecomment-469214275 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] azagrebin opened a new pull request #7889: [FLINK-11665] Wait for job termination before recovery in Dispatcher

2019-03-04 Thread GitBox
azagrebin opened a new pull request #7889: [FLINK-11665] Wait for job termination before recovery in Dispatcher URL: https://github.com/apache/flink/pull/7889 ## What is the purpose of the change This PR addresses a concurrency problem when dispatcher loses leadership and immediatel

[GitHub] [flink] TisonKun commented on issue #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData

2019-03-04 Thread GitBox
TisonKun commented on issue #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData URL: https://github.com/apache/flink/pull/7880#issuecomment-469213864 Thanks for the explanation! This is an a

[GitHub] [flink] tillrohrmann commented on issue #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData

2019-03-04 Thread GitBox
tillrohrmann commented on issue #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData URL: https://github.com/apache/flink/pull/7880#issuecomment-469213347 `#closeAndCleanupAllData` should only be called by the `ClusterEntrypoint` which transitions the exec

[GitHub] [flink] flinkbot edited a comment on issue #7838: [FLINK-11711][table-planner-blink] Add table and column stats

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7838: [FLINK-11711][table-planner-blink] Add table and column stats URL: https://github.com/apache/flink/pull/7838#issuecomment-467405536 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] twalthr commented on issue #7838: [FLINK-11711][table-planner-blink] Add table and column stats

2019-03-04 Thread GitBox
twalthr commented on issue #7838: [FLINK-11711][table-planner-blink] Add table and column stats URL: https://github.com/apache/flink/pull/7838#issuecomment-469208512 #7642 has been merged. One comment about the package location of `TableStats` and `ColumnStats`: Once we expose those classe

[GitHub] [flink] TisonKun commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData

2019-03-04 Thread GitBox
TisonKun commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData URL: https://github.com/apache/flink/pull/7880#discussion_r262008151 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailabi

[GitHub] [flink] TisonKun commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData

2019-03-04 Thread GitBox
TisonKun commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData URL: https://github.com/apache/flink/pull/7880#discussion_r262008151 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailabi

[GitHub] [flink] flinkbot edited a comment on issue #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#issuecomment-468420125 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262006927 ## File path: flink-streaming-java/src/main/java/org/apache/flink/st

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r261995376 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/s

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262005789 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/ma

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r261997545 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/s

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r261997948 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/s

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r261996108 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/s

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r262002836 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r262003015 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r262002568 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[GitHub] [flink] JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r262001647 ## File path: flink-table/flink-table-runtime-blink/src/main/jav

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r261997361 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[jira] [Updated] (FLINK-11801) Port SqlParserException to flink-table-api-java

2019-03-04 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-11801: Summary: Port SqlParserException to flink-table-api-java (was: Port SqlParserException to flink-table-com

[GitHub] [flink] JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261996563 ## File path: flink-table/flink-table-runtime-blink/src/main/jav

[GitHub] [flink] JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261995509 ## File path: flink-table/flink-table-runtime-blink/src/main/jav

[GitHub] [flink] JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261995451 ## File path: flink-table/flink-table-runtime-blink/src/main/jav

[GitHub] [flink] flinkbot edited a comment on issue #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#issuecomment-468623662 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull re

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r261995328 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r261995487 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[GitHub] [flink] KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261984041 ## File path: flink-table/flink-table-runtime-blink/src/main/java

[GitHub] [flink] KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261989486 ## File path: flink-table/flink-table-runtime-blink/src/main/java

<    1   2   3   >