[jira] [Closed] (FLINK-9237) Some description about The FsStateBackend in the Docs。

2018-04-23 Thread liuzhixin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liuzhixin closed FLINK-9237. > Some description about The FsStateBackend in the Docs。 > -

[jira] [Resolved] (FLINK-9237) Some description about The FsStateBackend in the Docs。

2018-04-23 Thread liuzhixin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liuzhixin resolved FLINK-9237. -- Resolution: Fixed > Some description about The FsStateBackend in the Docs。 > ---

[jira] [Commented] (FLINK-9237) Some description about The FsStateBackend in the Docs。

2018-04-23 Thread liuzhixin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449261#comment-16449261 ] liuzhixin commented on FLINK-9237: -- Ok,I get,thank you.  “To disable this feature”  and t

[jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449241#comment-16449241 ] ASF GitHub Bot commented on FLINK-8689: --- Github user walterddr commented on a diff i

[jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449245#comment-16449245 ] ASF GitHub Bot commented on FLINK-8689: --- Github user walterddr commented on a diff i

[jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449238#comment-16449238 ] ASF GitHub Bot commented on FLINK-8689: --- Github user walterddr commented on a diff i

[jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449243#comment-16449243 ] ASF GitHub Bot commented on FLINK-8689: --- Github user walterddr commented on a diff i

[GitHub] flink pull request #5555: [FLINK-8689][table]Add runtime support of distinct...

2018-04-23 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/#discussion_r183222089 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -1439,7 +1467,47 @@ object Aggreg

[GitHub] flink pull request #5555: [FLINK-8689][table]Add runtime support of distinct...

2018-04-23 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/#discussion_r183222353 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala --- @@ -327,19 +392,41 @@ class Aggrega

[jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449242#comment-16449242 ] ASF GitHub Bot commented on FLINK-8689: --- Github user walterddr commented on a diff i

[GitHub] flink pull request #5555: [FLINK-8689][table]Add runtime support of distinct...

2018-04-23 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/#discussion_r183222457 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/OverAggregate.scala --- @@ -70,7 +70,12 @@ trait OverAggregate {

[jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449244#comment-16449244 ] ASF GitHub Bot commented on FLINK-8689: --- Github user walterddr commented on a diff i

[jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449239#comment-16449239 ] ASF GitHub Bot commented on FLINK-8689: --- Github user walterddr commented on a diff i

[GitHub] flink pull request #5555: [FLINK-8689][table]Add runtime support of distinct...

2018-04-23 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/#discussion_r183222451 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/DistinctAccumulator.scala --- @@ -0,0 +1,102 @@ +/*

[jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449240#comment-16449240 ] ASF GitHub Bot commented on FLINK-8689: --- Github user walterddr commented on a diff i

[GitHub] flink pull request #5555: [FLINK-8689][table]Add runtime support of distinct...

2018-04-23 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/#discussion_r183222077 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -1439,7 +1467,47 @@ object Aggreg

[GitHub] flink pull request #5555: [FLINK-8689][table]Add runtime support of distinct...

2018-04-23 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/#discussion_r18367 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala --- @@ -151,8 +157,15 @@ class Aggregat

[GitHub] flink pull request #5555: [FLINK-8689][table]Add runtime support of distinct...

2018-04-23 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/#discussion_r183598006 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/OverWindowITCase.scala --- @@ -50,6 +50,155 @@ class OverWi

[GitHub] flink pull request #5555: [FLINK-8689][table]Add runtime support of distinct...

2018-04-23 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/#discussion_r183222573 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/OverWindowITCase.scala --- @@ -50,6 +51,96 @@ class OverWin

[jira] [Updated] (FLINK-8554) Upgrade AWS SDK

2018-04-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8554: -- Description: AWS SDK 1.11.271 fixes a lot of bugs. One of which would exhibit the following: {code} Caused by:

[jira] [Updated] (FLINK-8933) Avoid calling Class#newInstance

2018-04-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8933: -- Description: Class#newInstance is deprecated starting in Java 9 - https://bugs.openjdk.java.net/browse/JDK-6850

[jira] [Updated] (FLINK-9150) Prepare for Java 10

2018-04-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9150: -- Description: Java 9 is not a LTS release. When compiling with Java 10, I see the following compilation error: {

[jira] [Updated] (FLINK-9243) SuccessAfterNetworkBuffersFailureITCase#testSuccessfulProgramAfterFailure is unstable

2018-04-23 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-9243: -- Priority: Blocker (was: Major) > SuccessAfterNetworkBuffersFailureITCase#testSuccessfulProgramAfterFail

[jira] [Created] (FLINK-9243) SuccessAfterNetworkBuffersFailureITCase#testSuccessfulProgramAfterFailure is unstable

2018-04-23 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-9243: - Summary: SuccessAfterNetworkBuffersFailureITCase#testSuccessfulProgramAfterFailure is unstable Key: FLINK-9243 URL: https://issues.apache.org/jira/browse/FLINK-9243 Projec

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449205#comment-16449205 ] ASF GitHub Bot commented on FLINK-9190: --- Github user sihuazhou commented on the issu

[GitHub] flink issue #5881: [FLINK-9190][yarn] fix YarnResourceManager sometimes does...

2018-04-23 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5881 @GJL I also noticed that this PR can only solve part of the problem...it can only make sure that the `TM` is registered with ResourceManager properly, but it can't make sure that the `TM` could con

[jira] [Commented] (FLINK-8537) Add a Kafka table source factory with Avro format support

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449199#comment-16449199 ] ASF GitHub Bot commented on FLINK-8537: --- Github user xccui commented on the issue:

[GitHub] flink issue #5610: [FLINK-8537][table]Add a Kafka table source factory with ...

2018-04-23 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/5610 Thanks for the review @twalthr. 😄 ---

[jira] [Commented] (FLINK-9175) Flink CEP with Checkpointing alway failed

2018-04-23 Thread godfrey johnson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449172#comment-16449172 ] godfrey johnson commented on FLINK-9175: [~kkl0u] [~sihuazhou][^CEPCal.java] Th

[jira] [Updated] (FLINK-9175) Flink CEP with Checkpointing alway failed

2018-04-23 Thread godfrey johnson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey johnson updated FLINK-9175: --- Attachment: CEPCal.java > Flink CEP with Checkpointing alway failed >

[jira] [Closed] (FLINK-7952) Add metrics for counting logging events

2018-04-23 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou closed FLINK-7952. --- Resolution: Won't Fix > Add metrics for counting logging events > >

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449153#comment-16449153 ] ASF GitHub Bot commented on FLINK-9194: --- Github user yuqi1129 commented on a diff in

[GitHub] flink pull request #5888: [FLINK-9194] [histroyserver] Finished jobs are not...

2018-04-23 Thread yuqi1129
Github user yuqi1129 commented on a diff in the pull request: https://github.com/apache/flink/pull/5888#discussion_r183392156 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java --- @@ -180,10 +180,22 @@ public voi

[jira] [Updated] (FLINK-9242) LocalEnvironment - Operator threads stuck on java.lang.Thread.State: WAITING

2018-04-23 Thread Miguel E. Coimbra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel E. Coimbra updated FLINK-9242: - Description: Hello, As per Fabian Hueske's advice on the mailing list, I am detailing the

[jira] [Updated] (FLINK-9242) LocalEnvironment - Operator threads stuck on java.lang.Thread.State: WAITING

2018-04-23 Thread Miguel E. Coimbra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel E. Coimbra updated FLINK-9242: - Description: Hello, As per Fabian Hueske's advice on the mailing list, I am detailing the

[jira] [Created] (FLINK-9242) LocalEnvironment - Operator threads stuck on java.lang.Thread.State: WAITING

2018-04-23 Thread Miguel E. Coimbra (JIRA)
Miguel E. Coimbra created FLINK-9242: Summary: LocalEnvironment - Operator threads stuck on java.lang.Thread.State: WAITING Key: FLINK-9242 URL: https://issues.apache.org/jira/browse/FLINK-9242 Pr

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448928#comment-16448928 ] ASF GitHub Bot commented on FLINK-9190: --- Github user GJL commented on the issue:

[GitHub] flink issue #5881: [FLINK-9190][yarn] fix YarnResourceManager sometimes does...

2018-04-23 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/5881 @sihuazhou I will take a look again. Unfortunately there are still sporadically problems with starting new containers. I am trying to debug this to see whether we should fix it now, or under a new ticket

[jira] [Commented] (FLINK-9241) Scala version of Gauge (metric) doesn't work

2018-04-23 Thread Julio Biason (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448813#comment-16448813 ] Julio Biason commented on FLINK-9241: - Related piece of code: {{  @transient private

[jira] [Created] (FLINK-9241) Scala version of Gauge (metric) doesn't work

2018-04-23 Thread Julio Biason (JIRA)
Julio Biason created FLINK-9241: --- Summary: Scala version of Gauge (metric) doesn't work Key: FLINK-9241 URL: https://issues.apache.org/jira/browse/FLINK-9241 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448635#comment-16448635 ] ASF GitHub Bot commented on FLINK-9235: --- GitHub user suez1224 opened a pull request:

[GitHub] flink pull request #5901: [FLINK-9235][Security] Add integration tests for Y...

2018-04-23 Thread suez1224
GitHub user suez1224 opened a pull request: https://github.com/apache/flink/pull/5901 [FLINK-9235][Security] Add integration tests for YARN kerberos integration. ## What is the purpose of the change Add integration tests for YARN kerberos integration. ## Brief

[jira] [Updated] (FLINK-9222) Add a Gradle Quickstart

2018-04-23 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9222: --- Component/s: Project Website > Add a Gradle Quickstart > --- > > K

[GitHub] flink pull request #5900: [FLINK-9222][docs] add documentation for setting u...

2018-04-23 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/5900 [FLINK-9222][docs] add documentation for setting up Gradle projects ## What is the purpose of the change Together with https://github.com/apache/flink-web/pull/105, this will add a project te

[jira] [Commented] (FLINK-9222) Add a Gradle Quickstart

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448452#comment-16448452 ] ASF GitHub Bot commented on FLINK-9222: --- GitHub user NicoK opened a pull request:

[jira] [Commented] (FLINK-9240) Avoid deprecated akka methods

2018-04-23 Thread Konrad Malawski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448410#comment-16448410 ] Konrad Malawski commented on FLINK-9240: Note that other than the long-deprecated

[jira] [Updated] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint

2018-04-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9212: Fix Version/s: 1.5.0 > Port SubtasksAllAccumulatorsHandler to new REST endpoint > --

[jira] [Created] (FLINK-9240) Avoid deprecated akka methods

2018-04-23 Thread Arnout Engelen (JIRA)
Arnout Engelen created FLINK-9240: - Summary: Avoid deprecated akka methods Key: FLINK-9240 URL: https://issues.apache.org/jira/browse/FLINK-9240 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-9202) AvroSerializer should not be serializing the target Avro type class

2018-04-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9202: Priority: Blocker (was: Critical) > AvroSerializer should not be serializing the target Avr

[jira] [Updated] (FLINK-9202) AvroSerializer should not be serializing the target Avro type class

2018-04-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9202: Fix Version/s: 1.6.0 > AvroSerializer should not be serializing the target Avro type class >

[jira] [Closed] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

2018-04-23 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8836. - Resolution: Fixed Fix Version/s: 1.4.0 1.6.0 Merged in: master: 321039f

[jira] [Comment Edited] (FLINK-9237) Some description about The FsStateBackend in the Docs。

2018-04-23 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447913#comment-16447913 ] yuqi edited comment on FLINK-9237 at 4/23/18 3:36 PM: -- Yes, according

[jira] [Commented] (FLINK-8999) Ensure the job has an operator with operator state.

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448315#comment-16448315 ] ASF GitHub Bot commented on FLINK-8999: --- Github user StefanRRichter commented on the

[GitHub] flink issue #5890: [FLINK-8999] [e2e] Ensure the job has an operator with op...

2018-04-23 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5890 Hi @zhangminglei . I think there might unfortunately be a small misunderstanding: this issue was a subtask for the task of creating a single general purpose test job, i.e. a single job that co

[jira] [Commented] (FLINK-8537) Add a Kafka table source factory with Avro format support

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448306#comment-16448306 ] ASF GitHub Bot commented on FLINK-8537: --- Github user twalthr commented on the issue:

[GitHub] flink issue #5610: [FLINK-8537][table]Add a Kafka table source factory with ...

2018-04-23 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5610 Thank you for the PR @xccui. The code very looks good to me. I will fix some minor things during merge. ---

[jira] [Updated] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job

2018-04-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9207: Priority: Blocker (was: Minor) > Client returns SUCCESS(0) return code for canceled job > -

[jira] [Updated] (FLINK-9113) Data loss in BucketingSink when writing to local filesystem

2018-04-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9113: Fix Version/s: 1.4.3 > Data loss in BucketingSink when writing to local filesystem > ---

[jira] [Commented] (FLINK-9113) Data loss in BucketingSink when writing to local filesystem

2018-04-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448259#comment-16448259 ] Timo Walther commented on FLINK-9113: - Fixed in 1.4.3: 896797be71e920110aa270402d03196

[jira] [Resolved] (FLINK-8600) BucketingSink errors out when used with Presto filesystem

2018-04-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8600. - Resolution: Fixed > BucketingSink errors out when used with Presto filesystem > --

[jira] [Updated] (FLINK-8600) BucketingSink errors out when used with Presto filesystem

2018-04-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8600: Fix Version/s: 1.4.3 > BucketingSink errors out when used with Presto filesystem > -

[jira] [Commented] (FLINK-8600) BucketingSink errors out when used with Presto filesystem

2018-04-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448255#comment-16448255 ] Timo Walther commented on FLINK-8600: - Fixed in 1.4.3: b4a886149cc5432fdb58c8785047399

[jira] [Reopened] (FLINK-8600) BucketingSink errors out when used with Presto filesystem

2018-04-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-8600: - > BucketingSink errors out when used with Presto filesystem >

[GitHub] flink issue #5899: Klink

2018-04-23 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5899 Hi @bitsilly thanks for the works. I think maybe it better to describe your purpose of this PR and link with the corresponding JIRA(if this is not a hotfix). There is a guide template when you open

[jira] [Commented] (FLINK-9215) TaskManager Releasing - org.apache.flink.util.FlinkException

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448212#comment-16448212 ] ASF GitHub Bot commented on FLINK-9215: --- Github user sihuazhou commented on the issu

[GitHub] flink issue #5879: [FLINK-9215][resoucemanager] Only log the exception when ...

2018-04-23 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5879 Hi @zentol I updated the PR, it's already for another review. ---

[GitHub] flink issue #5899: Klink

2018-04-23 Thread bitsilly
Github user bitsilly commented on the issue: https://github.com/apache/flink/pull/5899 OK ---

[GitHub] flink pull request #5899: Klink

2018-04-23 Thread bitsilly
GitHub user bitsilly opened a pull request: https://github.com/apache/flink/pull/5899 Klink *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help the community review your contribution in the best possible way, please g

[jira] [Commented] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak

2018-04-23 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448183#comment-16448183 ] Stefan Richter commented on FLINK-9080: --- [~rohsing] could you somehow provide your h

[GitHub] flink issue #5893: [FLINK-9212][flip6] Port SubtasksAllAccumulatorsHandler t...

2018-04-23 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/5893 @zentol thanks you. I updated the code. :laughing: ---

[jira] [Commented] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448178#comment-16448178 ] ASF GitHub Bot commented on FLINK-9212: --- Github user yew1eb commented on the issue:

[jira] [Commented] (FLINK-9215) TaskManager Releasing - org.apache.flink.util.FlinkException

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448172#comment-16448172 ] ASF GitHub Bot commented on FLINK-9215: --- Github user sihuazhou commented on the issu

[GitHub] flink issue #5879: [FLINK-9215][resoucemanager] Only log the exception when ...

2018-04-23 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5879 @zentol Thanks for you reply, I prefer the way to introduce a `ExpectedLifecycleException`, I think maybe it could be used in some other places in the future. Addressing this... ---

[jira] [Commented] (FLINK-9215) TaskManager Releasing - org.apache.flink.util.FlinkException

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448160#comment-16448160 ] ASF GitHub Bot commented on FLINK-9215: --- Github user zentol commented on the issue:

[GitHub] flink issue #5879: [FLINK-9215][resoucemanager] Only log the exception when ...

2018-04-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5879 I think it is fine that exceptions are logged under debug, it's just that we use exceptions in the normal life-cycle. I'm wondering if we could replace these kind of exceptions with a special `Expecte

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-04-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448142#comment-16448142 ] Ted Yu commented on FLINK-9231: --- Sounds good to me. > Enable SO_REUSEADDR on listen sockets

[jira] [Commented] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448136#comment-16448136 ] ASF GitHub Bot commented on FLINK-9212: --- Github user zentol commented on the issue:

[GitHub] flink issue #5893: [FLINK-9212][flip6] Port SubtasksAllAccumulatorsHandler t...

2018-04-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5893 see `JobVertexDetailsInfo` on how to use it. ---

[jira] [Commented] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448110#comment-16448110 ] ASF GitHub Bot commented on FLINK-9212: --- Github user zentol commented on the issue:

[GitHub] flink issue #5893: [FLINK-9212][flip6] Port SubtasksAllAccumulatorsHandler t...

2018-04-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5893 You have to use the `JobVertexIDSerializer` for that field. ---

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448092#comment-16448092 ] ASF GitHub Bot commented on FLINK-9194: --- Github user zentol commented on the issue:

[GitHub] flink issue #5888: [FLINK-9194] [histroyserver] Finished jobs are not archiv...

2018-04-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5888 I'm currently preparing a PR for adding HistoryServer support to Flip6 and will integrate this PR into that one. ---

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-04-23 Thread Triones Deng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448079#comment-16448079 ] Triones Deng commented on FLINK-9231: - [~yuzhih...@gmail.com] I notice that there are

[GitHub] flink issue #5893: [FLINK-9212][flip6] Port SubtasksAllAccumulatorsHandler t...

2018-04-23 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/5893 i saw legacy/SubtasksAllAccumulatorsHandler.java used gen.writeStringField("id", jobVertex.getJobVertexId().toString());. if i change the type of `SubtasksAllAccumulatorsInfo#jobVertexId` to

[jira] [Commented] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448042#comment-16448042 ] ASF GitHub Bot commented on FLINK-9212: --- Github user yew1eb commented on the issue:

[GitHub] flink issue #5893: [FLINK-9212][flip6] Port SubtasksAllAccumulatorsHandler t...

2018-04-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5893 You have not changed the type of `SubtasksAllAccumulatorsInfo#jobVertexId` to `JobVertexID`. ---

[jira] [Commented] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448040#comment-16448040 ] ASF GitHub Bot commented on FLINK-9212: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-9239) Reintroduce example program in quickstarts

2018-04-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448038#comment-16448038 ] Timo Walther commented on FLINK-9239: - What is your opinion on this [~StephanEwen]? >

[jira] [Commented] (FLINK-9113) Data loss in BucketingSink when writing to local filesystem

2018-04-23 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448035#comment-16448035 ] Kostas Kloudas commented on FLINK-9113: --- I am fine with backporting the fix to 1.4,

[jira] [Commented] (FLINK-8999) Ensure the job has an operator with operator state.

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448034#comment-16448034 ] ASF GitHub Bot commented on FLINK-8999: --- Github user zhangminglei commented on the i

[GitHub] flink issue #5890: [FLINK-8999] [e2e] Ensure the job has an operator with op...

2018-04-23 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5890 Hello, @StefanRRichter . Could you review this code please ? ---

[jira] [Commented] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448030#comment-16448030 ] ASF GitHub Bot commented on FLINK-9212: --- Github user yew1eb commented on the issue:

[GitHub] flink issue #5893: [FLINK-9212][flip6] Port SubtasksAllAccumulatorsHandler t...

2018-04-23 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/5893 @zentol thanks for your review. I have updated the PR. ---

[jira] [Commented] (FLINK-9113) Data loss in BucketingSink when writing to local filesystem

2018-04-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448029#comment-16448029 ] Timo Walther commented on FLINK-9113: - I will also apply this fix to the 1.4 branch. F

[jira] [Commented] (FLINK-9239) Reintroduce example program in quickstarts

2018-04-23 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448027#comment-16448027 ] mingleizhang commented on FLINK-9239: - After thinking a little while, Only for you sai

[jira] [Commented] (FLINK-9239) Reintroduce example program in quickstarts

2018-04-23 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448018#comment-16448018 ] mingleizhang commented on FLINK-9239: - Hi, [~twalthr] It is a good idea. How about usi

[jira] [Commented] (FLINK-9229) Fix literal handling in code generation

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448013#comment-16448013 ] ASF GitHub Bot commented on FLINK-9229: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #5898: [FLINK-9229] [table] Fix literal handling in code ...

2018-04-23 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5898 [FLINK-9229] [table] Fix literal handling in code generation ## What is the purpose of the change This PR fixes wrong usages of `generateNonNullLiteral`. It has been used at locations where

[jira] [Commented] (FLINK-9239) Reintroduce example program in quickstarts

2018-04-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448007#comment-16448007 ] Timo Walther commented on FLINK-9239: - We should discuss this issue first. Maybe a lit

[jira] [Commented] (FLINK-9239) Reintroduce example program in quickstarts

2018-04-23 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447998#comment-16447998 ] mingleizhang commented on FLINK-9239: - I would choose a {{WordCount}} as an example fo

  1   2   >