[jira] [Updated] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart

2018-06-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9646: - Fix Version/s: 1.5.1 > ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart >

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520532#comment-16520532 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #6203: [FLINK-9280][rest] Rework JobSubmitHandler to acce...

2018-06-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6203#discussion_r197492045 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java --- @@ -54,18 +69,89 @@ public JobSubmitHandler(

[jira] [Created] (FLINK-9649) TaskManagers are not scheduled on Mesos

2018-06-22 Thread Leonid Ishimnikov (JIRA)
Leonid Ishimnikov created FLINK-9649: Summary: TaskManagers are not scheduled on Mesos Key: FLINK-9649 URL: https://issues.apache.org/jira/browse/FLINK-9649 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart

2018-06-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-9646: Assignee: Till Rohrmann > ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart

[jira] [Closed] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart

2018-06-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9646. Resolution: Fixed Fixed via 1.6.0: 8561f4cce47bda416d7c09071ea18515ab2c75e1 1.5.1:

[jira] [Closed] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool

2018-06-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9493. Resolution: Fixed Fixed via 1.6.0: 537281323adcbcf71cddfd824c56677e66c718ff 1.5.1:

[jira] [Commented] (FLINK-9649) TaskManagers are not scheduled on Mesos

2018-06-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520689#comment-16520689 ] Chesnay Schepler commented on FLINK-9649: - What happens when you submit a job? > TaskManagers

[jira] [Comment Edited] (FLINK-9649) TaskManagers are not scheduled on Mesos

2018-06-22 Thread Leonid Ishimnikov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520739#comment-16520739 ] Leonid Ishimnikov edited comment on FLINK-9649 at 6/22/18 8:05 PM: ---

[jira] [Commented] (FLINK-9649) TaskManagers are not scheduled on Mesos

2018-06-22 Thread Leonid Ishimnikov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520739#comment-16520739 ] Leonid Ishimnikov commented on FLINK-9649: -- After submitting a job, the framework did start

[jira] [Commented] (FLINK-6846) Add TIMESTAMPADD supported in TableAPI

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520954#comment-16520954 ] ASF GitHub Bot commented on FLINK-6846: --- Github user hequn8128 commented on the issue:

[GitHub] flink issue #6188: [FLINK-6846][Table API] add timestampAdd tableApi

2018-06-22 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/6188 @xueyumusic Great that you step out to contribute to flink, I will take a look this weekend :-) ---

[jira] [Assigned] (FLINK-9648) Do not store distributed cache entries in ExecutionConfig

2018-06-22 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9648: --- Assignee: vinoyang > Do not store distributed cache entries in ExecutionConfig >

[GitHub] flink pull request #6202: [FLINK-9493] Forward cause when releasing a TaskMa...

2018-06-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6202 ---

[jira] [Commented] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520518#comment-16520518 ] ASF GitHub Bot commented on FLINK-9493: --- Github user asfgit closed the pull request at:

[jira] [Updated] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart

2018-06-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9646: - Affects Version/s: 1.5.0 > ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart >

[GitHub] flink pull request #6186: [FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrapp...

2018-06-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6186#discussion_r197494851 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlMapState.java --- @@ -0,0 +1,132 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-9624) Move jar/artifact upload logic out of JobGraph

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520543#comment-16520543 ] ASF GitHub Bot commented on FLINK-9624: --- Github user zentol commented on a diff in the pull

[jira] [Created] (FLINK-9648) Do not store distributed cache entries in ExecutionConfig

2018-06-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9648: --- Summary: Do not store distributed cache entries in ExecutionConfig Key: FLINK-9648 URL: https://issues.apache.org/jira/browse/FLINK-9648 Project: Flink

[GitHub] flink pull request #6199: [FLINK-9624][runtime] Move jar/artifact upload out...

2018-06-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6199#discussion_r197496529 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java --- @@ -552,96 +550,33 @@ public boolean hasUsercodeJarFiles() {

[jira] [Commented] (FLINK-9513) Wrap state binder with TTL logic

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520552#comment-16520552 ] ASF GitHub Bot commented on FLINK-9513: --- Github user azagrebin commented on a diff in the pull

[jira] [Commented] (FLINK-9514) Create wrapper with TTL logic for value state

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520540#comment-16520540 ] ASF GitHub Bot commented on FLINK-9514: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #6186: [FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrapp...

2018-06-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6186#discussion_r197502165 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlFoldFunction.java --- @@ -0,0 +1,43 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-9514) Create wrapper with TTL logic for value state

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520570#comment-16520570 ] ASF GitHub Bot commented on FLINK-9514: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-9280) Extend JobSubmitHandler to accept jar files

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520535#comment-16520535 ] ASF GitHub Bot commented on FLINK-9280: --- Github user zentol commented on a diff in the pull

[GitHub] flink pull request #6186: [FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrapp...

2018-06-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6186#discussion_r197501902 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlFoldFunction.java --- @@ -0,0 +1,43 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-9514) Create wrapper with TTL logic for value state

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520566#comment-16520566 ] ASF GitHub Bot commented on FLINK-9514: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #6083: [FLINK-8983] End-to-end test: Confluent schema reg...

2018-06-22 Thread medcv
Github user medcv commented on a diff in the pull request: https://github.com/apache/flink/pull/6083#discussion_r197493383 --- Diff: flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml --- @@ -0,0 +1,155 @@ + +http://maven.apache.org/POM/4.0.0; +

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520538#comment-16520538 ] ASF GitHub Bot commented on FLINK-8983: --- Github user medcv commented on a diff in the pull request:

[GitHub] flink pull request #6203: [FLINK-9280][rest] Rework JobSubmitHandler to acce...

2018-06-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6203#discussion_r197493894 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java --- @@ -54,18 +69,89 @@ public JobSubmitHandler(

[jira] [Created] (FLINK-9647) Files uploaded to blobservice during job submission aren't rmeoved on failure

2018-06-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9647: --- Summary: Files uploaded to blobservice during job submission aren't rmeoved on failure Key: FLINK-9647 URL: https://issues.apache.org/jira/browse/FLINK-9647

[jira] [Commented] (FLINK-9280) Extend JobSubmitHandler to accept jar files

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520539#comment-16520539 ] ASF GitHub Bot commented on FLINK-9280: --- Github user zentol commented on a diff in the pull

[GitHub] flink pull request #6186: [FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrapp...

2018-06-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6186#discussion_r197498126 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlMapState.java --- @@ -0,0 +1,132 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-9514) Create wrapper with TTL logic for value state

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520577#comment-16520577 ] ASF GitHub Bot commented on FLINK-9514: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #6186: [FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrapp...

2018-06-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6186#discussion_r197503773 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlAggregatingState.java --- @@ -0,0 +1,80 @@ +/* + * Licensed to

[GitHub] flink pull request #6203: [FLINK-9280][rest] Rework JobSubmitHandler to acce...

2018-06-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6203#discussion_r197487718 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java --- @@ -54,18 +69,89 @@ public JobSubmitHandler(

[GitHub] flink pull request #6199: [FLINK-9624][runtime] Move jar/artifact upload out...

2018-06-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6199#discussion_r197487498 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java --- @@ -552,96 +550,33 @@ public boolean hasUsercodeJarFiles() {

[jira] [Commented] (FLINK-9624) Move jar/artifact upload logic out of JobGraph

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520512#comment-16520512 ] ASF GitHub Bot commented on FLINK-9624: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #6196: [FLINK-9513] Implement TTL state wrappers factory ...

2018-06-22 Thread azagrebin
Github user azagrebin commented on a diff in the pull request: https://github.com/apache/flink/pull/6196#discussion_r197498439 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java --- @@ -0,0 +1,207 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-9514) Create wrapper with TTL logic for value state

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520549#comment-16520549 ] ASF GitHub Bot commented on FLINK-9514: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-9280) Extend JobSubmitHandler to accept jar files

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520513#comment-16520513 ] ASF GitHub Bot commented on FLINK-9280: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #6083: [FLINK-8983] End-to-end test: Confluent schema reg...

2018-06-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6083#discussion_r197490130 --- Diff: flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml --- @@ -0,0 +1,228 @@ + +http://maven.apache.org/POM/4.0.0; +

[GitHub] flink pull request #6083: [FLINK-8983] End-to-end test: Confluent schema reg...

2018-06-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6083#discussion_r197490378 --- Diff: flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml --- @@ -0,0 +1,155 @@ + +http://maven.apache.org/POM/4.0.0; +

[GitHub] flink pull request #6083: [FLINK-8983] End-to-end test: Confluent schema reg...

2018-06-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6083#discussion_r197490677 --- Diff: flink-end-to-end-tests/test-scripts/test-confluent-schema-registry.sh --- @@ -0,0 +1,106 @@ +#!/usr/bin/env bash

[GitHub] flink pull request #6083: [FLINK-8983] End-to-end test: Confluent schema reg...

2018-06-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6083#discussion_r197490461 --- Diff: flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml --- @@ -0,0 +1,155 @@ + +http://maven.apache.org/POM/4.0.0; +

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520530#comment-16520530 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520529#comment-16520529 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520531#comment-16520531 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Updated] (FLINK-9280) Extend JobSubmitHandler to accept jar files

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9280: -- Labels: pull-request-available (was: ) > Extend JobSubmitHandler to accept jar files >

[jira] [Commented] (FLINK-9280) Extend JobSubmitHandler to accept jar files

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520395#comment-16520395 ] ASF GitHub Bot commented on FLINK-9280: --- Github user zentol commented on a diff in the pull

[GitHub] flink pull request #6203: [FLINK-9280][rest] Rework JobSubmitHandler to acce...

2018-06-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6203#discussion_r197456037 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java --- @@ -54,18 +69,89 @@ public JobSubmitHandler(

[GitHub] flink pull request #6186: [FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrapp...

2018-06-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6186#discussion_r197457017 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java --- @@ -0,0 +1,99 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-9514) Create wrapper with TTL logic for value state

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520397#comment-16520397 ] ASF GitHub Bot commented on FLINK-9514: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Created] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart

2018-06-22 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9646: Summary: ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart Key: FLINK-9646 URL: https://issues.apache.org/jira/browse/FLINK-9646 Project: Flink

[jira] [Commented] (FLINK-9514) Create wrapper with TTL logic for value state

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520401#comment-16520401 ] ASF GitHub Bot commented on FLINK-9514: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #6186: [FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrapp...

2018-06-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6186#discussion_r197458219 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java --- @@ -0,0 +1,99 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520405#comment-16520405 ] ASF GitHub Bot commented on FLINK-9524: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #6180: [FLINK-9524][Table API & SQL] check whether a clea...

2018-06-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/6180#discussion_r197453796 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala --- @@ -132,74 +132,80 @@

[GitHub] flink pull request #6180: [FLINK-9524][Table API & SQL] check whether a clea...

2018-06-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/6180#discussion_r197453235 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala --- @@ -132,74 +132,80 @@

[jira] [Commented] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520404#comment-16520404 ] ASF GitHub Bot commented on FLINK-9524: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #6186: [FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrapp...

2018-06-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6186#discussion_r197459764 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java --- @@ -0,0 +1,99 @@ +/* + * Licensed to

[jira] [Updated] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9524: -- Labels: pull-request-available (was: ) > NPE from ProcTimeBoundedRangeOver.scala >

[jira] [Commented] (FLINK-9514) Create wrapper with TTL logic for value state

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520406#comment-16520406 ] ASF GitHub Bot commented on FLINK-9514: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink issue #6163: [hotfix][table] Fix a incorrect exception message.

2018-06-22 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/6163 Thanks for the PR @kisimple +1 to merge. Best, Fabian ---

[jira] [Commented] (FLINK-9514) Create wrapper with TTL logic for value state

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520409#comment-16520409 ] ASF GitHub Bot commented on FLINK-9514: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #6186: [FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrapp...

2018-06-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6186#discussion_r197460522 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java --- @@ -0,0 +1,99 @@ +/* + * Licensed to

[GitHub] flink pull request #6203: [FLINK-9280][rest] Rework JobSubmitHandler to acce...

2018-06-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6203#discussion_r197461746 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java --- @@ -54,18 +69,89 @@ public JobSubmitHandler(

[jira] [Commented] (FLINK-9280) Extend JobSubmitHandler to accept jar files

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520412#comment-16520412 ] ASF GitHub Bot commented on FLINK-9280: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9588) Reuse the same conditionContext with in a same computationState

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520411#comment-16520411 ] ASF GitHub Bot commented on FLINK-9588: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #6168: [FLINK-9588][CEP]Reused context with same computat...

2018-06-22 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6168#discussion_r197461704 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -609,7 +611,7 @@ public void close() throws Exception {

[jira] [Updated] (FLINK-9588) Reuse the same conditionContext with in a same computationState

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9588: -- Labels: pull-request-available (was: ) > Reuse the same conditionContext with in a same

[jira] [Updated] (FLINK-8255) Key expressions on named row types do not work

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8255: -- Labels: pull-request-available (was: ) > Key expressions on named row types do not work >

[jira] [Commented] (FLINK-8255) Key expressions on named row types do not work

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520422#comment-16520422 ] ASF GitHub Bot commented on FLINK-8255: --- Github user snuyanzin commented on the issue:

[GitHub] flink issue #5961: [FLINK-8255][DataSet API, DataStream API] key expressions...

2018-06-22 Thread snuyanzin
Github user snuyanzin commented on the issue: https://github.com/apache/flink/pull/5961 commits squashed into one ---

[jira] [Commented] (FLINK-9624) Move jar/artifact upload logic out of JobGraph

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520442#comment-16520442 ] ASF GitHub Bot commented on FLINK-9624: --- Github user zentol commented on a diff in the pull

[GitHub] flink pull request #6199: [FLINK-9624][runtime] Move jar/artifact upload out...

2018-06-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6199#discussion_r197467939 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/client/ClientUtilsTest.java --- @@ -0,0 +1,138 @@ +/* + * Licensed to the Apache

[jira] [Created] (FLINK-9643) Flink allowing TLS 1.1 in spite of configuring TLS 1.2

2018-06-22 Thread Vinay (JIRA)
Vinay created FLINK-9643: Summary: Flink allowing TLS 1.1 in spite of configuring TLS 1.2 Key: FLINK-9643 URL: https://issues.apache.org/jira/browse/FLINK-9643 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9642) Reduce the count to deal with state during a CEP process

2018-06-22 Thread aitozi (JIRA)
aitozi created FLINK-9642: - Summary: Reduce the count to deal with state during a CEP process Key: FLINK-9642 URL: https://issues.apache.org/jira/browse/FLINK-9642 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-8944) Use ListShards for shard discovery in the flink kinesis connector

2018-06-22 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8944. Resolution: Fixed Fix Version/s: 1.6.0 Merged for 1.6.0: 

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520054#comment-16520054 ] ASF GitHub Bot commented on FLINK-9599: --- Github user zentol commented on the issue:

[GitHub] flink issue #6189: [FLINK-9599][rest] RestClient supports FileUploads

2018-06-22 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6189 merging. ---

[jira] [Commented] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks

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

[GitHub] flink pull request #6201: [FLINK-8866][Table API & SQL] Add support for unif...

2018-06-22 Thread suez1224
GitHub user suez1224 opened a pull request: https://github.com/apache/flink/pull/6201 [FLINK-8866][Table API & SQL] Add support for unified table sink instantiation **(The sections below can be removed for hotfixes of typos)** ## What is the purpose of the change

[jira] [Updated] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8866: -- Labels: pull-request-available (was: ) > Create unified interfaces to configure and

[GitHub] flink pull request #6038: [FLINK-9394] [e2e] Test rescaling when resuming fr...

2018-06-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6038 ---

[jira] [Commented] (FLINK-8795) Scala shell broken for Flip6

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520078#comment-16520078 ] ASF GitHub Bot commented on FLINK-8795: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #6172: [FLINK-9594][E2E tests] Improve docs for new test ...

2018-06-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6172 ---

[jira] [Updated] (FLINK-8944) Use ListShards for shard discovery in the flink kinesis connector

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8944: -- Labels: pull-request-available (was: ) > Use ListShards for shard discovery in the flink

[jira] [Commented] (FLINK-9594) Add documentation for e2e test changes introduced with FLINK-9257

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520079#comment-16520079 ] ASF GitHub Bot commented on FLINK-9594: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9638) Add helper script to run single e2e test

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520080#comment-16520080 ] ASF GitHub Bot commented on FLINK-9638: --- Github user asfgit closed the pull request at:

[jira] [Updated] (FLINK-9394) Let externalized checkpoint resume e2e also test rescaling

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9394: -- Labels: pull-request-available (was: ) > Let externalized checkpoint resume e2e also test

[GitHub] flink pull request #6193: [hotfix] [docs] Fix typo in index.md

2018-06-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6193 ---

[GitHub] flink pull request #5992: [FLINK-8944] [Kinesis Connector] Use listShards in...

2018-06-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5992 ---

[GitHub] flink pull request #6182: [FLINK-8795] Fixed local scala shell for Flip6

2018-06-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6182 ---

[jira] [Commented] (FLINK-9394) Let externalized checkpoint resume e2e also test rescaling

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520081#comment-16520081 ] ASF GitHub Bot commented on FLINK-9394: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #6197: [FLINK-9638][E2E Tests] Add helper script to run s...

2018-06-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6197 ---

[jira] [Commented] (FLINK-8944) Use ListShards for shard discovery in the flink kinesis connector

2018-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520077#comment-16520077 ] ASF GitHub Bot commented on FLINK-8944: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-4301) Parameterize Flink version in Quickstart bash script

2018-06-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520082#comment-16520082 ] Fabian Hueske commented on FLINK-4301: -- Yes, this issue refers to that script. It is located in the 

[jira] [Assigned] (FLINK-8944) Use ListShards for shard discovery in the flink kinesis connector

2018-06-22 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-8944: -- Assignee: Kailash Hassan Dayanand > Use ListShards for shard discovery in the

[GitHub] flink pull request #6199: [FLINK-9624][runtime] Move jar/artifact upload out...

2018-06-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6199#discussion_r197375181 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/client/ClientUtils.java --- @@ -0,0 +1,96 @@ +/* + * Licensed to the Apache Software

  1   2   3   >