[jira] [Created] (FLINK-8621) PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable on Travis

2018-02-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8621: Summary: PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable on Travis Key: FLINK-8621 URL: https://issues.apache.org/jira/browse/FLINK-8621

[jira] [Created] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-02-09 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-8620: --- Summary: Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache Key: FLINK-8620 URL: https://issues.apache.org/jira/browse/FLINK-8620

[jira] [Created] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis

2018-02-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8623: Summary: ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis Key: FLINK-8623 URL: https://issues.apache.org/jira/browse/FLINK-8623

[jira] [Created] (FLINK-8622) flink-mesos: High memory usage of scheduler + job manager. GC never kicks in.

2018-02-09 Thread Bhumika Bayani (JIRA)
Bhumika Bayani created FLINK-8622: - Summary: flink-mesos: High memory usage of scheduler + job manager. GC never kicks in. Key: FLINK-8622 URL: https://issues.apache.org/jira/browse/FLINK-8622

[jira] [Updated] (FLINK-8621) PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable on Travis

2018-02-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8621: - Component/s: Tests > PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable

[jira] [Updated] (FLINK-8622) flink-mesos: High memory usage of scheduler + job manager. GC never kicks in.

2018-02-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8622: - Component/s: Mesos > flink-mesos: High memory usage of scheduler + job manager. GC never kicks

[GitHub] flink pull request #5439: [FLINK-8571] [DataStream] [Backport] Introduce uti...

2018-02-09 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/5439 [FLINK-8571] [DataStream] [Backport] Introduce utility function that reinterprets a data stream as keyed stream This PR is a backport of #5424 to Flink 1.4. You can merge this pull request

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358214#comment-16358214 ] ASF GitHub Bot commented on FLINK-8571: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #5439: [FLINK-8571] [DataStream] [Backport] Introduce utility fu...

2018-02-09 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5439 CC @aljoscha @tzulitai ---

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358212#comment-16358212 ] ASF GitHub Bot commented on FLINK-8571: --- GitHub user StefanRRichter opened a pull request:

[jira] [Commented] (FLINK-8601) Introduce PartitionedBloomFilter for Approximate calculation and other situations of performance optimization

2018-02-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358222#comment-16358222 ] Fabian Hueske commented on FLINK-8601: -- Thanks for the detailed design document [~sihuazhou]! Now I

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

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

[GitHub] flink pull request #5439: [FLINK-8571] [DataStream] [Backport] Introduce uti...

2018-02-09 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5439#discussion_r167196102 --- Diff: flink-contrib/flink-streaming-contrib/src/test/java/org/apache/flink/contrib/streaming/ReinterpretAsKeyedStreamITCase.java --- @@ -0,0 +1,235 @@

[GitHub] flink pull request #5439: [FLINK-8571] [DataStream] [Backport] Introduce uti...

2018-02-09 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5439#discussion_r167197709 --- Diff: flink-contrib/flink-streaming-contrib/src/test/java/org/apache/flink/contrib/streaming/ReinterpretAsKeyedStreamITCase.java --- @@ -0,0 +1,235 @@

[GitHub] flink pull request #5424: FLINK-8571] [DataStream] Introduce utility functio...

2018-02-09 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5424#discussion_r167198202 --- Diff: docs/dev/api_concepts.md --- @@ -896,11 +896,16 @@ result type ```R``` for the final result. E.g. for a histogram, ```V``` is a num {%

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

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

[jira] [Commented] (FLINK-8556) Add proxy feature to Kinesis Connector to acces its endpoint

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358261#comment-16358261 ] ASF GitHub Bot commented on FLINK-8556: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5411: [FLINK-8556] [Kinesis Connector] Add proxy feature to the...

2018-02-09 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5411 Thanks for the contribution @pduveau. I'll try to take a look at this soon. ---

[jira] [Created] (FLINK-8618) Add S3 to the list of sinks on the delivery guarantees page

2018-02-09 Thread chris snow (JIRA)
chris snow created FLINK-8618: - Summary: Add S3 to the list of sinks on the delivery guarantees page Key: FLINK-8618 URL: https://issues.apache.org/jira/browse/FLINK-8618 Project: Flink Issue

[GitHub] flink pull request #5400: [FLINK-8547][network] Implement CheckpointBarrierH...

2018-02-09 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5400#discussion_r167162743 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTestBase.java --- @@ -0,0 +1,194 @@ +/* + *

[jira] [Updated] (FLINK-8619) Some thing about Flink SQL distinct, I need help

2018-02-09 Thread Lynch Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lynch Lee updated FLINK-8619: - Description: I do some test about distinct on mysql below:     mysql> CREATE TABLE `rpt_tt` (     ->  

[jira] [Commented] (FLINK-6428) Add support DISTINCT in dataStream SQL

2018-02-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358201#comment-16358201 ] Fabian Hueske commented on FLINK-6428: -- Hi [~lynchlee] The query {{SELECT DISTINCT a, b, c FROM t

[jira] [Updated] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-02-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8500: Fix Version/s: (was: 1.4.2) > Get the timestamp of the Kafka message from kafka

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

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

[GitHub] flink issue #5439: [FLINK-8571] [DataStream] [Backport] Introduce utility fu...

2018-02-09 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5439 The changes look good! But as @tzulitai mentioned the missing Scala tests seem strange. ---

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358254#comment-16358254 ] ASF GitHub Bot commented on FLINK-8571: --- Github user aljoscha commented on the issue:

[jira] [Created] (FLINK-8624) flink-mesos: The flink rest-api sometimes becomes unresponsive

2018-02-09 Thread Bhumika Bayani (JIRA)
Bhumika Bayani created FLINK-8624: - Summary: flink-mesos: The flink rest-api sometimes becomes unresponsive Key: FLINK-8624 URL: https://issues.apache.org/jira/browse/FLINK-8624 Project: Flink

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358257#comment-16358257 ] ASF GitHub Bot commented on FLINK-8571: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #5424: FLINK-8571] [DataStream] Introduce utility function that ...

2018-02-09 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5424 Still looks good, except that I'd like to see the new doc in a completely separate section of the doc. ---

[GitHub] flink issue #5438: [FLINK-8617][TableAPI & SQL] Fix code generation bug whil...

2018-02-09 Thread Xpray
Github user Xpray commented on the issue: https://github.com/apache/flink/pull/5438 I've removed the ITCase and add some tests to ```org.apache.flink.table.expressions.MapTypeTest ``` ---

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

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

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

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

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-09 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167249371 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadResponseBody.java --- @@ -0,0 +1,58 @@ +/* + *

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-09 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167250379 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java --- @@ -0,0 +1,103 @@ +/* + * Licensed

[GitHub] flink issue #5425: [FLINK-8456] Add Scala API for Connected Streams with Bro...

2018-02-09 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5425 I think this looks good now. ---

[GitHub] flink issue #5424: FLINK-8571] [DataStream] Introduce utility function that ...

2018-02-09 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5424 Thanks for the review @aljoscha. Will merge. ---

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358699#comment-16358699 ] ASF GitHub Bot commented on FLINK-8571: --- Github user StefanRRichter commented on the issue:

[jira] [Closed] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8571. - Resolution: Fixed Fix Version/s: 1.4.1 1.5.0 Merged in 91eea376ee.

[jira] [Created] (FLINK-8628) BucketingSink does not work wit S3

2018-02-09 Thread dejan miljkovic (JIRA)
dejan miljkovic created FLINK-8628: -- Summary: BucketingSink does not work wit S3 Key: FLINK-8628 URL: https://issues.apache.org/jira/browse/FLINK-8628 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8628) BucketingSink does not work with S3

2018-02-09 Thread dejan miljkovic (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dejan miljkovic updated FLINK-8628: --- Description: BucketingSink does not work wit S3. Followed instructions provided on 

[jira] [Created] (FLINK-8627) Introduce SUSPENDING state

2018-02-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8627: Summary: Introduce SUSPENDING state Key: FLINK-8627 URL: https://issues.apache.org/jira/browse/FLINK-8627 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8627) Introduce SUSPENDING state

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358780#comment-16358780 ] ASF GitHub Bot commented on FLINK-8627: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #5445: [FLINK-8627] Introduce new JobStatus#SUSPENDING

2018-02-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5445 [FLINK-8627] Introduce new JobStatus#SUSPENDING ## What is the purpose of the change The new JobStatus#SUSPENDING says that an ExecutionGraph has been suspended but its clean up

[jira] [Commented] (FLINK-8607) Add a basic embedded SQL CLI client

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

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

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

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-09 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167249729 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java --- @@ -207,6 +215,53 @@ public static WebMonitor

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-09 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167249950 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java --- @@ -207,6 +215,53 @@ public static WebMonitor

[GitHub] flink pull request #5444: [FLINK-8546] [flip6] Respect savepoints and restor...

2018-02-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5444 [FLINK-8546] [flip6] Respect savepoints and restore from latest checkpoints ## What is the purpose of the change Let the JobMaster respect checkpoints and savepoints. The JobMaster

[jira] [Commented] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358582#comment-16358582 ] ASF GitHub Bot commented on FLINK-8456: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358624#comment-16358624 ] ASF GitHub Bot commented on FLINK-8571: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #5439: [FLINK-8571] [DataStream] [Backport] Introduce utility fu...

2018-02-09 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5439 Thanks for the reviews! Will merge. ---

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

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

[GitHub] flink pull request #5424: FLINK-8571] [DataStream] Introduce utility functio...

2018-02-09 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/5424 ---

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

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

[jira] [Commented] (FLINK-8573) Print JobID for failed jobs

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358511#comment-16358511 ] ASF GitHub Bot commented on FLINK-8573: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #5439: [FLINK-8571] [DataStream] [Backport] Introduce utility fu...

2018-02-09 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5439 LGTM once Travis is green. We should also remove the redundant mention of FLINK-8571 in `ReinterpretAsKeyedStreamITCase` while merging. ---

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358559#comment-16358559 ] ASF GitHub Bot commented on FLINK-8571: --- Github user tzulitai commented on the issue:

[jira] [Closed] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

2018-02-09 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-8456. - Resolution: Fixed Merged on master at 9628dc8917b2f69bb04119c1d41932076632de01 > Add Scala API

[jira] [Updated] (FLINK-8625) Move OutputFlusher thread to Netty scheduled executor

2018-02-09 Thread Ken Krugler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Krugler updated FLINK-8625: --- Summary: Move OutputFlusher thread to Netty scheduled executor (was: Move OutputFlasherThread to

[jira] [Created] (FLINK-8626) Introduce BackPressureStatsTracker interface

2018-02-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8626: Summary: Introduce BackPressureStatsTracker interface Key: FLINK-8626 URL: https://issues.apache.org/jira/browse/FLINK-8626 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8546) Respect savepoint settings and recover from latest checkpoint in Flip-6

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358518#comment-16358518 ] ASF GitHub Bot commented on FLINK-8546: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #5439: [FLINK-8571] [DataStream] [Backport] Introduce uti...

2018-02-09 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/5439 ---

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

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

[GitHub] flink pull request #5441: [FLINK-8607] [table] Add a basic embedded SQL CLI ...

2018-02-09 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5441 [FLINK-8607] [table] Add a basic embedded SQL CLI client ## What is the purpose of the change This PR implements the first part of the implementation plan described in FLIP-24.

[jira] [Commented] (FLINK-8617) Fix code generation bug while accessing Map type

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358470#comment-16358470 ] ASF GitHub Bot commented on FLINK-8617: --- Github user Xpray commented on the issue:

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

2018-02-09 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358494#comment-16358494 ] Xingcan Cui commented on FLINK-8538: Thanks for the comments [~twalthr] and [~fhueske]. Actually, I've

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

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

[jira] [Commented] (FLINK-8626) Introduce BackPressureStatsTracker interface

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358509#comment-16358509 ] ASF GitHub Bot commented on FLINK-8626: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #5443: [FLINK-8626] Introduce BackPressureStatsTracker in...

2018-02-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5443 [FLINK-8626] Introduce BackPressureStatsTracker interface ## What is the purpose of the change Renames BackPressureStatsTracker into BackPressureStatsTrackerImpl and introduce a

[GitHub] flink issue #5048: [Flink-7871] [flip6] SlotPool should release unused slots...

2018-02-09 Thread ifndef-SleePy
Github user ifndef-SleePy commented on the issue: https://github.com/apache/flink/pull/5048 Hi @tillrohrmann , I just updated the PR, sorry for delaying so long. ---

[jira] [Closed] (FLINK-8597) Add examples for Connected Streams with Broadcast State.

2018-02-09 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-8597. - Resolution: Fixed Merged on master at dea4172604126fc40fc8fbf7f83a632733bd0dfb > Add examples

[GitHub] flink pull request #5425: [FLINK-8456] Add Scala API for Connected Streams w...

2018-02-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5425 ---

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-09 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5442 [FLINK-7713][flip6] Implement JarUploadHandler ## What is the purpose of the change *Allow uploading jars through HTTP to enable job submissions from the web ui.* cc: @tillrohrmann

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-09 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167249285 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java --- @@ -0,0 +1,103 @@ +/* + * Licensed

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358498#comment-16358498 ] ASF GitHub Bot commented on FLINK-7713: --- GitHub user GJL opened a pull request:

[GitHub] flink issue #5421: [FLINK-8573] [client] Add more information for printing J...

2018-02-09 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5421 The CI error does not relevant to this PR. ```BackPressureStatsTrackerITCase``` test failed. ---

[GitHub] flink pull request #5443: [FLINK-8626] Introduce BackPressureStatsTracker in...

2018-02-09 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5443#discussion_r167267838 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java --- @@ -143,7 +143,7 @@ private final

[jira] [Commented] (FLINK-8626) Introduce BackPressureStatsTracker interface

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

[jira] [Commented] (FLINK-8626) Introduce BackPressureStatsTracker interface

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

[GitHub] flink pull request #5443: [FLINK-8626] Introduce BackPressureStatsTracker in...

2018-02-09 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5443#discussion_r167268048 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/VoidBackPressureStatsTracker.java --- @@ -0,0 +1,36 @@

[jira] [Commented] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

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

[jira] [Commented] (FLINK-8629) Allow JobMaster to rescale jobs

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358897#comment-16358897 ] ASF GitHub Bot commented on FLINK-8629: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #5446: [FLINK-8629] [flip6] Allow JobMaster to rescale jo...

2018-02-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5446 [FLINK-8629] [flip6] Allow JobMaster to rescale jobs ## What is the purpose of the change This commit adds the functionality to rescale a job or parts of it to the JobMaster. In

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167357375 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167356732 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167354757 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167357486 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167354956 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167355583 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167356561 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167356422 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167389638 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167357164 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167356160 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167355160 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

  1   2   >