[jira] [Updated] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode

2017-09-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7508: Fix Version/s: (was: 1.3.3) > switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool

[jira] [Updated] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode

2017-09-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7508: Description: KinesisProducerLibrary (KPL) 0.10.x had been using a One-New-Thread-Per-Request model for all

[jira] [Updated] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode

2017-09-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7508: Description: KinesisProducerLibrary (KPL) 0.10.x had been using a One-New-Thread-Per-Request model for all

[jira] [Commented] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer

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

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

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

[GitHub] flink pull request #4526: [FLINK-7407] [kafka] Adapt AbstractPartitionDiscov...

2017-09-06 Thread tzulitai
Github user tzulitai closed the pull request at: https://github.com/apache/flink/pull/4526 ---

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-09-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4473 No problem! And really sorry for the wait. I'm waiting for a Travis run before merging: https://travis-ci.org/tzulitai/flink/builds/272758087?utm_source=github_status_medium=notification ---

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

2017-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156468#comment-16156468 ] ASF GitHub Bot commented on FLINK-7367: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-09-06 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4473 @tzulitai Thank you, Gordon! ---

[GitHub] flink issue #4526: [FLINK-7407] [kafka] Adapt AbstractPartitionDiscoverer to...

2017-09-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4526 @aljoscha not yet, this is still mixed in one of my unmerged bathces. Merging this now .. ---

[jira] [Commented] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer

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

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

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

[GitHub] flink pull request #4565: [FLINK-7429] [kinesis] Add migration test coverage...

2017-09-06 Thread tzulitai
Github user tzulitai closed the pull request at: https://github.com/apache/flink/pull/4565 ---

[jira] [Commented] (FLINK-7429) Add restore from 1.2 / 1.3 migration tests for FlinkKinesisConsumer

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

[GitHub] flink issue #4565: [FLINK-7429] [kinesis] Add migration test coverage for Fl...

2017-09-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4565 @aljoscha thanks! Closing .. ---

[jira] [Commented] (FLINK-7429) Add restore from 1.2 / 1.3 migration tests for FlinkKinesisConsumer

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

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-09-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4473 Hi @bowenli86, sorry about this. I had the commit ready to merge but was waiting for another test PR to be merged first. Merging this now! ---

[jira] [Updated] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode

2017-09-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7508: Description: KinesisProducerLibrary (KPL) 0.10.x had been using a One-New-Thread-Per-Request model for all

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

2017-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156424#comment-16156424 ] ASF GitHub Bot commented on FLINK-7367: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-09-06 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4473 @tzulitai or other Flink committers, can you please merge this so I can submit more PRs depend on this? Thanks! ---

[jira] [Updated] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode

2017-09-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7508: Priority: Critical (was: Major) > switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool

[jira] [Commented] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout

2017-09-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156416#comment-16156416 ] Bowen Li commented on FLINK-7590: - [~aljoscha] This also seems to be a bug in HadoopFS's S3

[jira] [Commented] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536)

2017-09-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156410#comment-16156410 ] Bowen Li commented on FLINK-7589: - After some research online, the root cause seems to be that AWSS3client

[jira] [Assigned] (FLINK-7521) Remove the 10MB limit from the current REST implementation.

2017-09-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7521: Assignee: Fang Yong > Remove the 10MB limit from the current REST implementation. >

[jira] [Commented] (FLINK-7594) Add a SQL CLI client

2017-09-06 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156356#comment-16156356 ] Kurt Young commented on FLINK-7594: --- +1 to this, it's a string improvement for usability (y) > Add a

[jira] [Comment Edited] (FLINK-7594) Add a SQL CLI client

2017-09-06 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156356#comment-16156356 ] Kurt Young edited comment on FLINK-7594 at 9/7/17 2:46 AM: --- +1 to this, it's a

[jira] [Commented] (FLINK-7521) Remove the 10MB limit from the current REST implementation.

2017-09-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156352#comment-16156352 ] Fang Yong commented on FLINK-7521: -- It might be better to add a config option to set this value instead

[jira] [Commented] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout

2017-09-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156347#comment-16156347 ] Bowen Li commented on FLINK-7590: - According to [1], this seems can be fixed by aws-sdk version. But I

[jira] [Updated] (FLINK-7596) Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType)

2017-09-06 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-7596: -- Description: If two inputs with Any(GenericRelDataType), when they comes to Set Operation(Union,

[jira] [Updated] (FLINK-7596) Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType)

2017-09-06 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-7596: -- Description: If two inputs with Any(GenericRelDataType), when they comes to Set Operation(Union,

[jira] [Updated] (FLINK-7596) Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType)

2017-09-06 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-7596: -- Description: If two inputs with Any(GenericRelDataType), when they comes to Set Operation(Union,

[jira] [Updated] (FLINK-7596) Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType)

2017-09-06 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-7596: -- Description: If two inputs with Any(GenericRelDataType), when they comes to Set Operation(Union,

[jira] [Updated] (FLINK-7596) Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType)

2017-09-06 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-7596: -- Description: If two inputs with Any(GenericRelDataType), when they comes to Set Operation(Union,

[jira] [Created] (FLINK-7596) Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType)

2017-09-06 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-7596: - Summary: Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType) Key: FLINK-7596 URL: https://issues.apache.org/jira/browse/FLINK-7596 Project:

[jira] [Commented] (FLINK-7465) Add build-in BloomFilterCount on TableAPI

2017-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156251#comment-16156251 ] ASF GitHub Bot commented on FLINK-7465: --- GitHub user sunjincheng121 opened a pull request:

[GitHub] flink pull request #4652: [FLINK-7465][table]Add cardinality count for table...

2017-09-06 Thread sunjincheng121
GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/4652 [FLINK-7465][table]Add cardinality count for tableAPI and SQL. ## What is the purpose of the change *In this PR. we want add add CARDINALITY_COUNT for tableAPI and SQL.(Using

[jira] [Commented] (FLINK-7594) Add a SQL CLI client

2017-09-06 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156221#comment-16156221 ] Haohui Mai commented on FLINK-7594: --- We internally has a project (AthenaX) for this requirement and we

[jira] [Commented] (FLINK-7124) Allow to rescale JobGraph on JobManager

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

[GitHub] flink pull request #4510: [FLINK-7124] [flip-6] Add test to verify rescaling...

2017-09-06 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/4510#discussion_r137395149 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphRescalingTest.java --- @@ -0,0 +1,235 @@ +/* + *

[jira] [Commented] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

2017-09-06 Thread Peter Ertl (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16155874#comment-16155874 ] Peter Ertl commented on FLINK-7430: --- Thanks for your great help guys! :) > ContinuousFileReaderOperator

[jira] [Commented] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work

2017-09-06 Thread Peter Ertl (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16155873#comment-16155873 ] Peter Ertl commented on FLINK-7567: --- if the parallelism of the feedback stream MUST be equal to the

[jira] [Commented] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer

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

[GitHub] flink issue #4526: [FLINK-7407] [kafka] Adapt AbstractPartitionDiscoverer to...

2017-09-06 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4526 @tzulitai Did you end up merging this? ---

[jira] [Commented] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window

2017-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16155848#comment-16155848 ] ASF GitHub Bot commented on FLINK-7357: --- Github user walterddr commented on the issue:

[GitHub] flink issue #4521: [FLINK-7357] [table] Created extended rules for WindowSta...

2017-09-06 Thread walterddr
Github user walterddr commented on the issue: https://github.com/apache/flink/pull/4521 @twalthr looks like this should resolve the last filter issue. Please kindly take a look and see if this looks good to go in :-) ---

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137292784 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobService.java --- @@ -0,0 +1,171 @@ +/* + * Licensed to the

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137291887 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCache.java --- @@ -0,0 +1,322 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137287126 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/PermanentBlobService.java --- @@ -0,0 +1,54 @@ +/* + * Licensed to the

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137270473 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java --- @@ -389,95 +413,332 @@ public File getFile(JobID jobId, BlobKey

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137291176 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCache.java --- @@ -0,0 +1,322 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137295883 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/PermanentBlobCache.java --- @@ -0,0 +1,429 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137302842 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java --- @@ -174,7 +176,6 @@ public ServerSocket createSocket(int port)

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137271569 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java --- @@ -389,95 +413,332 @@ public File getFile(JobID jobId, BlobKey

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137268133 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobClient.java --- @@ -601,7 +564,39 @@ public void deleteInternal(@Nullable JobID

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137262572 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -158,7 +151,7 @@ protected

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137289123 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/PermanentBlobCache.java --- @@ -0,0 +1,429 @@ +/* + * Licensed to the

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137259798 --- Diff: flink-fs-tests/src/test/java/org/apache/flink/hdfstests/HDFSTest.java --- @@ -257,7 +265,88 @@ public void testBlobServerRecovery() throws

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137266698 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobClient.java --- @@ -220,19 +260,27 @@ InputStream getInternal(@Nullable JobID

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137259815 --- Diff: flink-fs-tests/src/test/java/org/apache/flink/hdfstests/HDFSTest.java --- @@ -257,7 +265,88 @@ public void testBlobServerRecovery() throws

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137293376 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java --- @@ -215,10 +215,10 @@ public static ClassLoader

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137303136 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobService.java --- @@ -18,61 +18,31 @@ package

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137266916 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobClient.java --- @@ -220,19 +260,27 @@ InputStream getInternal(@Nullable JobID

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137268826 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobClient.java --- @@ -415,13 +393,17 @@ private BlobKey putBuffer(@Nullable JobID

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137291080 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCache.java --- @@ -0,0 +1,322 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137266511 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobClient.java --- @@ -220,19 +260,27 @@ InputStream getInternal(@Nullable JobID

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

2017-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137259367 --- Diff: flink-fs-tests/src/test/java/org/apache/flink/hdfstests/HDFSTest.java --- @@ -257,7 +265,88 @@ public void testBlobServerRecovery() throws

[jira] [Commented] (FLINK-6988) Add Apache Kafka 0.11 connector

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

[GitHub] flink issue #4239: [FLINK-6988] flink-connector-kafka-0.11 with exactly-once...

2017-09-06 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4239 What were the bugs that you fixed? ---

[GitHub] flink pull request #4575: [FLINK-7494][travis] Add license headers to '.trav...

2017-09-06 Thread yew1eb
Github user yew1eb commented on a diff in the pull request: https://github.com/apache/flink/pull/4575#discussion_r137297560 --- Diff: .travis.yml --- @@ -1,4 +1,19 @@ -# s3 deployment based on http://about.travis-ci.org/blog/2012-12-18-travis-artifacts/ --- End diff --

[jira] [Commented] (FLINK-7494) No license headers in ".travis.yml" file

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

[jira] [Commented] (FLINK-7494) No license headers in ".travis.yml" file

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

[GitHub] flink pull request #4575: [FLINK-7494][travis] Add license headers to '.trav...

2017-09-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4575#discussion_r137295825 --- Diff: .travis.yml --- @@ -1,4 +1,19 @@ -# s3 deployment based on http://about.travis-ci.org/blog/2012-12-18-travis-artifacts/ --- End diff --

[GitHub] flink issue #4646: [FLINK-7583] [REST] Use static constant for CONTENT_TYPE ...

2017-09-06 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/4646 I see. Thanks @zentol. So +1 to merge from me. ---

[jira] [Commented] (FLINK-7583) Create singleton isntance for the content type header

2017-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16155468#comment-16155468 ] ASF GitHub Bot commented on FLINK-7583: --- Github user kl0u commented on the issue:

[jira] [Commented] (FLINK-6369) Better support for overlay networks

2017-09-06 Thread Patrick Lucas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16155461#comment-16155461 ] Patrick Lucas commented on FLINK-6369: -- [~till.rohrmann]: yeah that's what I was getting at. It

[GitHub] flink issue #4631: [hotfix][kafka][docs] Add warning regarding data losses w...

2017-09-06 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4631 Merged! 😃 Could you please close this PR if it doesn't auto-merge? ---

[jira] [Commented] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

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

[GitHub] flink pull request #4650: [FLINK-7430] Set StreamTask.isRunning to false aft...

2017-09-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4650 ---

[jira] [Resolved] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

2017-09-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7430. -- Resolution: Fixed Fix Version/s: 1.4.0 Fixed via

  1   2   3   >