[jira] [Resolved] (FLINK-9695) Add option for Mesos executor to forcefully pull Docker images

2018-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9695. -- Resolution: Fixed Fixed via b230bf0e3883ee2dba47e22e781009aa9d0f000e > Add option for Mesos

[jira] [Resolved] (FLINK-9686) Flink Kinesis Producer: Enable Kinesis authentication via AssumeRole

2018-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9686. -- Resolution: Fixed Fix Version/s: 1.6.0 Added via

[jira] [Resolved] (FLINK-9636) Network buffer leaks in requesting a batch of segments during canceling

2018-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9636. -- Resolution: Fixed Fixed via 1.6.0: efc87083e371eb00e801ef29c65ff49dfb170a4d 1.5.1:

[jira] [Resolved] (FLINK-9708) Network buffer leaks when buffer request fails during buffer redistribution

2018-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9708. -- Resolution: Fixed Fix Version/s: 1.6.0 Fixed via 1.6.0:

[jira] [Resolved] (FLINK-9633) Flink doesn't use the Savepoint path's filesystem to create the OuptutStream on Task.

2018-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9633. -- Resolution: Fixed Fixed via 1.6.0: 64bc4b348ddd1f0c63e806442ffd3aad5c367a28 1.5.1:

[GitHub] flink pull request #6221: [FLINK-9686] [kinesis] Enable Kinesis authenticati...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6221 ---

[jira] [Commented] (FLINK-9686) Flink Kinesis Producer: Enable Kinesis authentication via AssumeRole

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

[jira] [Commented] (FLINK-9636) Network buffer leaks in requesting a batch of segments during canceling

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

[jira] [Commented] (FLINK-9695) Add option for Mesos executor to forcefully pull Docker images

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

[GitHub] flink pull request #6238: [FLINK-9636][network] fix inconsistency with faile...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6238 ---

[GitHub] flink pull request #6232: [FLINK-9695] [mesos] Add option for Mesos executor...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6232 ---

[jira] [Commented] (FLINK-9633) Flink doesn't use the Savepoint path's filesystem to create the OuptutStream on Task.

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

[GitHub] flink pull request #6194: [FLINK-9633][checkpoint] Use savepoint path's file...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6194 ---

[jira] [Commented] (FLINK-8336) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test instability

2018-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532274#comment-16532274 ] Till Rohrmann commented on FLINK-8336: -- Another instance

[jira] [Assigned] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams

2018-07-03 Thread Mingdao Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingdao Yang reassigned FLINK-4582: --- Assignee: Mingdao Yang > Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams >

[jira] [Comment Edited] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

2018-07-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307281#comment-16307281 ] Ted Yu edited comment on FLINK-6105 at 7/4/18 4:09 AM: --- In

[jira] [Comment Edited] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

2018-07-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307281#comment-16307281 ] Ted Yu edited comment on FLINK-6105 at 7/4/18 4:08 AM: --- In

[jira] [Comment Edited] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

2018-07-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307281#comment-16307281 ] Ted Yu edited comment on FLINK-6105 at 7/4/18 4:08 AM: --- In

[jira] [Commented] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

2018-07-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532220#comment-16532220 ] Ted Yu commented on FLINK-4534: --- The synchronization should be added - if there is no concurrent call(s),

[jira] [Commented] (FLINK-9636) Network buffer leaks in requesting a batch of segments during canceling

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532207#comment-16532207 ] ASF GitHub Bot commented on FLINK-9636: --- Github user zhijiangW commented on the issue:

[GitHub] flink issue #6238: [FLINK-9636][network] fix inconsistency with failed buffe...

2018-07-03 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/6238 👍 ---

[jira] [Commented] (FLINK-9707) LocalFileSystem does not support concurrent directory creations

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532186#comment-16532186 ] ASF GitHub Bot commented on FLINK-9707: --- Github user lamber-ken commented on a diff in the pull

[GitHub] flink pull request #6243: [FLINK-9707] Support concurrent directory creation...

2018-07-03 Thread lamber-ken
Github user lamber-ken commented on a diff in the pull request: https://github.com/apache/flink/pull/6243#discussion_r17861 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java --- @@ -254,7 +254,7 @@ else if (file.exists() &&

[jira] [Assigned] (FLINK-9733) Make location for job graph files configurable

2018-07-03 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9733: --- Assignee: vinoyang > Make location for job graph files configurable >

[jira] [Assigned] (FLINK-9732) Report more detailed error message on SobSubmissionFailure

2018-07-03 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9732: --- Assignee: vinoyang > Report more detailed error message on SobSubmissionFailure >

[jira] [Commented] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532167#comment-16532167 ] ASF GitHub Bot commented on FLINK-9328: --- Github user Myasuka commented on the issue:

[jira] [Updated] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9328: -- Labels: pull-request-available (was: ) > RocksDBStateBackend might use

[GitHub] flink issue #5984: [FLINK-9328][state] Fix RocksDBStateBackend restore probl...

2018-07-03 Thread Myasuka
Github user Myasuka commented on the issue: https://github.com/apache/flink/pull/5984 The failing UT JobManagerFailsITCase in [#25170.9-build](https://travis-ci.org/apache/flink/jobs/393258719) is not related with this PR, shall I re-trigger the CI process? ---

[jira] [Commented] (FLINK-9707) LocalFileSystem does not support concurrent directory creations

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

[GitHub] flink pull request #6243: [FLINK-9707] Support concurrent directory creation...

2018-07-03 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6243#discussion_r12317 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java --- @@ -254,7 +254,7 @@ else if (file.exists() &&

[jira] [Commented] (FLINK-9707) LocalFileSystem does not support concurrent directory creations

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532132#comment-16532132 ] ASF GitHub Bot commented on FLINK-9707: --- Github user lamber-ken commented on a diff in the pull

[GitHub] flink pull request #6243: [FLINK-9707] Support concurrent directory creation...

2018-07-03 Thread lamber-ken
Github user lamber-ken commented on a diff in the pull request: https://github.com/apache/flink/pull/6243#discussion_r199989644 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java --- @@ -254,7 +254,7 @@ else if (file.exists() &&

[jira] [Commented] (FLINK-9730) avoid access static via class reference

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532109#comment-16532109 ] ASF GitHub Bot commented on FLINK-9730: --- Github user lamber-ken commented on the issue:

[GitHub] flink issue #6247: [FLINK-9730] [code refactor] fix access static via class ...

2018-07-03 Thread lamber-ken
Github user lamber-ken commented on the issue: https://github.com/apache/flink/pull/6247 @zentol, @tillrohrmann hi, cc. I fixed some cases access static via class reference ---

[jira] [Commented] (FLINK-9666) short-circuit logic should be used in boolean contexts

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532104#comment-16532104 ] ASF GitHub Bot commented on FLINK-9666: --- Github user lamber-ken commented on the issue:

[GitHub] flink issue #6230: [FLINK-9666] short-circuit logic should be used in boolea...

2018-07-03 Thread lamber-ken
Github user lamber-ken commented on the issue: https://github.com/apache/flink/pull/6230 @zentol, hi, I found another occurrence just after the #6212 closed. but I can't reopen that pr, so I start a new pr refered to #6212. ---

[jira] [Updated] (FLINK-8864) Add CLI query history in SQL Client

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8864: -- Labels: pull-request-available (was: ) > Add CLI query history in SQL Client >

[jira] [Commented] (FLINK-8864) Add CLI query history in SQL Client

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532093#comment-16532093 ] ASF GitHub Bot commented on FLINK-8864: --- GitHub user snuyanzin opened a pull request:

[GitHub] flink pull request #6250: [FLINK-8864] added command history

2018-07-03 Thread snuyanzin
GitHub user snuyanzin opened a pull request: https://github.com/apache/flink/pull/6250 [FLINK-8864] added command history ## What is the purpose of the change *This PR adds history for sql queries/sqlclient commands* ## Brief change log - *Added

[jira] [Assigned] (FLINK-8864) Add CLI query history in SQL Client

2018-07-03 Thread Sergey Nuyanzin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-8864: -- Assignee: Sergey Nuyanzin > Add CLI query history in SQL Client >

[jira] [Closed] (FLINK-9731) Kafka source subtask begins to consume from earliest offset

2018-07-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy closed FLINK-9731. - Resolution: Invalid > Kafka source subtask begins to consume from earliest offset >

[jira] [Commented] (FLINK-9731) Kafka source subtask begins to consume from earliest offset

2018-07-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532040#comment-16532040 ] Elias Levy commented on FLINK-9731: --- Closing as I suspect the error is on the Kafka side.  Logs

[jira] [Updated] (FLINK-9734) Typo in ' field-deleimiter'

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9734: -- Labels: pull-request-available (was: ) > Typo in ' field-deleimiter' >

[jira] [Commented] (FLINK-9734) Typo in ' field-deleimiter'

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532026#comment-16532026 ] ASF GitHub Bot commented on FLINK-9734: --- GitHub user snuyanzin opened a pull request:

[GitHub] flink pull request #6249: [hotfix] [docs] [FLINK-9734] Fix 'deleimiter' typo

2018-07-03 Thread snuyanzin
GitHub user snuyanzin opened a pull request: https://github.com/apache/flink/pull/6249 [hotfix] [docs] [FLINK-9734] Fix 'deleimiter' typo ## What is the purpose of the change *This PR fixes typo in deleimeter word at

[jira] [Created] (FLINK-9734) Typo in ' field-deleimiter'

2018-07-03 Thread Sergey Nuyanzin (JIRA)
Sergey Nuyanzin created FLINK-9734: -- Summary: Typo in ' field-deleimiter' Key: FLINK-9734 URL: https://issues.apache.org/jira/browse/FLINK-9734 Project: Flink Issue Type: Bug

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

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

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

2018-07-03 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/6201#discussion_r199951101 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/connector/TableConnectorFactory.scala --- @@ -16,21 +16,18 @@ *

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

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531920#comment-16531920 ] ASF GitHub Bot commented on FLINK-8866: --- Github user suez1224 commented on the issue:

[GitHub] flink issue #6201: [FLINK-8866][Table API & SQL] Add support for unified tab...

2018-07-03 Thread suez1224
Github user suez1224 commented on the issue: https://github.com/apache/flink/pull/6201 @twalthr @fhueske sounds good to me. We can do that in a follow-up issue for `from-source`, and we will not support `from-source` in this PR. ---

[jira] [Updated] (FLINK-9311) PubSub connector

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9311: -- Labels: pull-request-available (was: ) > PubSub connector > > >

[jira] [Commented] (FLINK-9311) PubSub connector

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531854#comment-16531854 ] ASF GitHub Bot commented on FLINK-9311: --- GitHub user Xeli opened a pull request:

[GitHub] flink pull request #6248: [FLINK-9311] [pubsub] Added PubSub connector with ...

2018-07-03 Thread Xeli
GitHub user Xeli opened a pull request: https://github.com/apache/flink/pull/6248 [FLINK-9311] [pubsub] Added PubSub connector with support for checkpointing ## What is the purpose of the change Adding a PubSub connector with support for Checkpointing ## Verifying

[jira] [Updated] (FLINK-9731) Kafka source subtask begins to consume from earliest offset

2018-07-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy updated FLINK-9731: -- Description: On Jun 30th 2018, at 9:35 am UTC, the Kafka source in subtask 7 in a Flink job instance

[jira] [Commented] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions

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

[jira] [Commented] (FLINK-9289) Parallelism of generated operators should have max parallism of input

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

[jira] [Created] (FLINK-9733) Make location for job graph files configurable

2018-07-03 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9733: --- Summary: Make location for job graph files configurable Key: FLINK-9733 URL: https://issues.apache.org/jira/browse/FLINK-9733 Project: Flink Issue

[GitHub] flink pull request #6222: [FLINK-8785][rest] Handle JobSubmissionExceptions

2018-07-03 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/6222 ---

[GitHub] flink pull request #6241: [backport][FLINK-9289][rest] Rework JobSubmitHandl...

2018-07-03 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/6241 ---

[jira] [Created] (FLINK-9732) Report more detailed error message on SobSubmissionFailure

2018-07-03 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9732: --- Summary: Report more detailed error message on SobSubmissionFailure Key: FLINK-9732 URL: https://issues.apache.org/jira/browse/FLINK-9732 Project: Flink

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

2018-07-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9280. --- Resolution: Fixed master: a25cd3feddd19e75456db32a704ee5509e85dd47 1.5:

[jira] [Closed] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions

2018-07-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8785. --- Resolution: Fixed Fix Version/s: 1.5.1 1.6.0 master:

[jira] [Closed] (FLINK-9301) NotSoMiniClusterIterations job fails on travis

2018-07-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9301. --- Resolution: Fixed Fix Version/s: (was: 1.5.1) 1.6.0 master:

[jira] [Created] (FLINK-9731) Kafka source subtask begins to consume from earliest offset

2018-07-03 Thread Elias Levy (JIRA)
Elias Levy created FLINK-9731: - Summary: Kafka source subtask begins to consume from earliest offset Key: FLINK-9731 URL: https://issues.apache.org/jira/browse/FLINK-9731 Project: Flink Issue

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

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

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

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6203 ---

[jira] [Commented] (FLINK-9301) NotSoMiniClusterIterations job fails on travis

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

[jira] [Updated] (FLINK-9301) NotSoMiniClusterIterations job fails on travis

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9301: -- Labels: pull-request-available (was: ) > NotSoMiniClusterIterations job fails on travis >

[GitHub] flink pull request #6024: [FLINK-9301] [e2e test] Add back "not so mini clus...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6024 ---

[jira] [Commented] (FLINK-9666) short-circuit logic should be used in boolean contexts

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

[GitHub] flink issue #6230: [FLINK-9666] short-circuit logic should be used in boolea...

2018-07-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6230 wait. Is this a _backport_ of #6212 for 1.5, or an _extension_ that fixes another occurrence? ---

[jira] [Commented] (FLINK-9730) avoid access static via class reference

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531794#comment-16531794 ] ASF GitHub Bot commented on FLINK-9730: --- GitHub user lamber-ken opened a pull request:

[jira] [Updated] (FLINK-9730) avoid access static via class reference

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9730: -- Labels: pull-request-available (was: ) > avoid access static via class reference >

[jira] [Updated] (FLINK-9730) avoid access static via class reference

2018-07-03 Thread lamber-ken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-9730: -- Description: [code refactor] access static via class reference (was: [code refactore] access static

[GitHub] flink pull request #6247: [FLINK-9730] [code refactor] fix access static via...

2018-07-03 Thread lamber-ken
GitHub user lamber-ken opened a pull request: https://github.com/apache/flink/pull/6247 [FLINK-9730] [code refactor] fix access static via class reference ## What is the purpose of the change - fix access static via class reference ## Brief change log - fix

[jira] [Commented] (FLINK-9641) Pulsar Source Connector

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

[jira] [Commented] (FLINK-9641) Pulsar Source Connector

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

[GitHub] flink pull request #6200: [FLINK-9641] [streaming-connectors] Flink pulsar s...

2018-07-03 Thread cckellogg
Github user cckellogg commented on a diff in the pull request: https://github.com/apache/flink/pull/6200#discussion_r199909793 --- Diff: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSourceTests.java --- @@ -0,0

[GitHub] flink pull request #6200: [FLINK-9641] [streaming-connectors] Flink pulsar s...

2018-07-03 Thread cckellogg
Github user cckellogg commented on a diff in the pull request: https://github.com/apache/flink/pull/6200#discussion_r199909775 --- Diff: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarSourceBase.java --- @@ -0,0 +1,30 @@

[jira] [Commented] (FLINK-9641) Pulsar Source Connector

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

[jira] [Commented] (FLINK-9641) Pulsar Source Connector

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

[GitHub] flink pull request #6200: [FLINK-9641] [streaming-connectors] Flink pulsar s...

2018-07-03 Thread cckellogg
Github user cckellogg commented on a diff in the pull request: https://github.com/apache/flink/pull/6200#discussion_r199909645 --- Diff: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/Defaults.java --- @@ -0,0 +1,30 @@ +/*

[GitHub] flink pull request #6200: [FLINK-9641] [streaming-connectors] Flink pulsar s...

2018-07-03 Thread cckellogg
Github user cckellogg commented on a diff in the pull request: https://github.com/apache/flink/pull/6200#discussion_r199909617 --- Diff: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSource.java --- @@ -0,0 +1,203

[jira] [Created] (FLINK-9730) avoid access static via class reference

2018-07-03 Thread lamber-ken (JIRA)
lamber-ken created FLINK-9730: - Summary: avoid access static via class reference Key: FLINK-9730 URL: https://issues.apache.org/jira/browse/FLINK-9730 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-9666) short-circuit logic should be used in boolean contexts

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531734#comment-16531734 ] ASF GitHub Bot commented on FLINK-9666: --- Github user lamber-ken commented on the issue:

[GitHub] flink issue #6230: [FLINK-9666] short-circuit logic should be used in boolea...

2018-07-03 Thread lamber-ken
Github user lamber-ken commented on the issue: https://github.com/apache/flink/pull/6230 @zentol, thanks for review. by the way, what's the best way to backport refactorings and code-cleanups? ---

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

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

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

2018-07-03 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6196#discussion_r199894398 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeSerializer.java --- @@ -272,4 +254,60 @@ public int getVersion() {

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

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

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

2018-07-03 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6196#discussion_r199894217 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeSerializer.java --- @@ -272,4 +254,60 @@ public int getVersion() {

[jira] [Closed] (FLINK-9491) Implement timer data structure based on RocksDB

2018-07-03 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9491. - Resolution: Implemented Merged in: master: c6ad421e2b > Implement timer data structure based on

[jira] [Commented] (FLINK-9491) Implement timer data structure based on RocksDB

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

[GitHub] flink pull request #6228: [FLINK-9491] Implement timer data structure based ...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6228 ---

[jira] [Commented] (FLINK-9221) Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B]

2018-07-03 Thread Josh Lemer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531680#comment-16531680 ] Josh Lemer commented on FLINK-9221: --- [~yanghua]You may be right. One reason why it may be wrong to put

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

2018-07-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531618#comment-16531618 ] 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-07-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6203#discussion_r199867852 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java --- @@ -315,36 +315,61 @@ public JobSubmissionResult

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

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

[jira] [Commented] (FLINK-9688) ATAN2 Sql Function support

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

[GitHub] flink pull request #6223: [FLINK-9688] ATAN2 sql function support

2018-07-03 Thread snuyanzin
Github user snuyanzin commented on a diff in the pull request: https://github.com/apache/flink/pull/6223#discussion_r199866207 --- Diff: docs/dev/table/tableApi.md --- @@ -2184,6 +2184,17 @@ NUMERIC.atan() + + +{% highlight

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

2018-07-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6203#discussion_r199866326 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java --- @@ -315,36 +315,61 @@ public JobSubmissionResult

  1   2   3   4   5   >