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

2018-02-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7713. -- Resolution: Fixed Fixed via 39df56d6aebb3911f19593dbf120d42789e8db5a > Port JarUploadHandler to

[jira] [Closed] (FLINK-8212) Pull EnvironmentInformation out of TaskManagerServices

2018-02-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8212. Resolution: Fixed Fixed via e3e601b39492291b5837e58741bf7da46c76404a > Pull EnvironmentInformation

[jira] [Commented] (FLINK-8529) Let Yarn entry points use YarnConfigOptions#APPLICATION_MASTER_PORT

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

[jira] [Commented] (FLINK-8613) Return excess container in YarnResourceManager

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

[jira] [Commented] (FLINK-8604) Move JobTerminationHandler to WebMonitorEndpoint

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

[jira] [Closed] (FLINK-8530) Enable detached job submission for RestClusterClient

2018-02-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8530. Resolution: Fixed Fixed via f57b9833aaf7649f79b72efd4a033fbfb4f8e218 > Enable detached job submissi

[jira] [Closed] (FLINK-8643) Use JobManagerOptions#SLOT_REQUEST_TIMEOUT in ExecutionGraph

2018-02-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8643. Resolution: Fixed Fixed via 1321c17047daed756ce4216814b8708162a57e83 > Use JobManagerOptions#SLOT_R

[jira] [Commented] (FLINK-8605) Enable job cancellation from the web UI

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

[jira] [Commented] (FLINK-8609) Add support to deploy detached job mode clusters

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

[jira] [Closed] (FLINK-8644) Shut down AkkaRpcActors with PoisonPill

2018-02-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8644. Resolution: Fixed Fixed via 5ed180c8121992d1b64dc879c9b6d78d00e57c92 > Shut down AkkaRpcActors with

[jira] [Commented] (FLINK-8212) Pull EnvironmentInformation out of TaskManagerServices

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

[jira] [Commented] (FLINK-8603) Split RestClusterClient#submitJob into submitJob and requestJobResult

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

[jira] [Commented] (FLINK-8644) Shut down AkkaRpcActors with PoisonPill

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

[jira] [Commented] (FLINK-8608) Add MiniDispatcher for job mode

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

[jira] [Commented] (FLINK-8530) Enable detached job submission for RestClusterClient

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

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

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

[jira] [Commented] (FLINK-8643) Use JobManagerOptions#SLOT_REQUEST_TIMEOUT in ExecutionGraph

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

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

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

[GitHub] flink pull request #5430: [FLINK-8605] [rest] Enable job cancellation from t...

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

[GitHub] flink pull request #5388: [FLINK-8529] [flip6] Let Yarn entry points use APP...

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

[GitHub] flink pull request #5432: [FLINK-8609] [flip6] Enable Flip-6 job mode in Cli...

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

[GitHub] flink pull request #5429: [FLINK-8604] [rest] Move JobTerminationHandler int...

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

[GitHub] flink pull request #5476: [FLINK-8644] [flip6] Shut down AkkaRpcActors with ...

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

[GitHub] flink pull request #5475: [FLINK-8643] [flip6] Use JobManagerOptions#SLOT_RE...

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

[GitHub] flink pull request #5431: [FLINK-8608] [flip6] Implement MiniDispatcher for ...

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

[GitHub] flink pull request #5458: [FLINK-8212] [network] Pull EnvironmentInformation...

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

[GitHub] flink pull request #5466: [FLINK-8530] [flip6] Enable detached job mode subm...

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

[GitHub] flink pull request #5436: [FLINK-8613] [flip6] [yarn] Return excess containe...

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

[GitHub] flink pull request #5428: [FLINK-8603] [flip6] Split submitJob into job subm...

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

[jira] [Commented] (FLINK-8662) FutureUtilsTest#testRetryWithDelay unstable

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

[GitHub] flink pull request #5494: [FLINK-8662] [tests] Harden FutureUtilsTest#testRe...

2018-02-15 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5494 [FLINK-8662] [tests] Harden FutureUtilsTest#testRetryWithDelay ## What is the purpose of the change This commit moves the start of the time measurement before the triggering of the

[jira] [Updated] (FLINK-8662) FutureUtilsTest#testRetryWithDelay unstable

2018-02-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8662: - Description: The {{FutureUtilsTes#testRetryWithDelay}} is unstable on Travis: [https://travis-ci.

[jira] [Assigned] (FLINK-8662) FutureUtilsTest#testRetryWithDelay unstable

2018-02-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-8662: Assignee: Till Rohrmann > FutureUtilsTest#testRetryWithDelay unstable > ---

[jira] [Created] (FLINK-8662) FutureUtilsTest#testRetryWithDelay unstable

2018-02-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8662: Summary: FutureUtilsTest#testRetryWithDelay unstable Key: FLINK-8662 URL: https://issues.apache.org/jira/browse/FLINK-8662 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7857) Port JobVertexDetails to REST endpoint

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

[jira] [Commented] (FLINK-8657) Fix incorrect description for external checkpoint vs savepoint

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

[GitHub] flink pull request #5493: [FLINK-7857][flip6] Port JobVertexDetails to REST ...

2018-02-15 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5493 [FLINK-7857][flip6] Port JobVertexDetails to REST endpoint ## What is the purpose of the change *Port JobVertexDetails to REST endpoint)* This PR is based on #5035 cc: @tillro

[GitHub] flink issue #5490: [FLINK-8657][doc]Fix incorrect description in the documen...

2018-02-15 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5490 The docs are not "incorrect" and this is on purpose. Background is that, in general, externalized checkpoints are only required to support a subset of the features that savepoints provide and

[jira] [Commented] (FLINK-8657) Fix incorrect description for external checkpoint vs savepoint

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

[GitHub] flink issue #5490: [FLINK-8657][doc]Fix incorrect description in the documen...

2018-02-15 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5490 @StefanRRichter Could you have a look at this? ---

[jira] [Commented] (FLINK-7856) Port JobVertexBackPressureHandler to REST endpoint

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

[GitHub] flink issue #4893: [FLINK-7856][flip6] Port JobVertexBackPressureHandler to ...

2018-02-15 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/4893 @zjureel Can you close this PR? Your changes were merged. ---

[GitHub] flink issue #5435: [FLINK-8612] [flip6] Enable non-detached job mode

2018-02-15 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5435 Rebased onto the soon to be master. ---

[jira] [Commented] (FLINK-8612) Add non-detached job mode

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

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

2018-02-15 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/5441#discussion_r168429967 --- Diff: flink-libraries/flink-sql-client/pom.xml --- @@ -0,0 +1,149 @@ + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/20

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

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

[jira] [Commented] (FLINK-8611) Add result future to JobManagerRunner

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

[GitHub] flink issue #5434: [FLINK-8611] [flip6] Add result future to JobManagerRunne...

2018-02-15 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5434 Rebased onto the soon to be master. ---

[jira] [Commented] (FLINK-8610) Remove RestfulGateway from JobMasterGateway

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

[GitHub] flink issue #5433: [FLINK-8610] [flip6] Remove RestfulGateway from JobMaster...

2018-02-15 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5433 Rebased onto the latest soon to be master. ---

[jira] [Commented] (FLINK-8647) Introduce JobMasterConfiguration

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

[GitHub] flink issue #5272: [Flink-8397][Connectors]Support Row type for Cassandra Ou...

2018-02-15 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5272 Hi @suez1224, thanks for the update. The PR looks good. Will merge it. Btw. please do not squash commits when you update a PR. This makes tracking the changes much harder. It would also b

[GitHub] flink issue #5478: [FLINK-8647] [flip6] Introduce JobMasterConfiguration

2018-02-15 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5478 Thanks for the review @zhangminglei. Merging this PR. ---

[jira] [Commented] (FLINK-8401) Allow subclass to override write-failure behavior in CassandraOutputFormat

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

[GitHub] flink issue #5274: [FLINK-8401][Cassandra Connector]Refactor CassandraOutput...

2018-02-15 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5274 Looks good to me. Will merge this. ---

[jira] [Commented] (FLINK-8605) Enable job cancellation from the web UI

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

[GitHub] flink pull request #5430: [FLINK-8605] [rest] Enable job cancellation from t...

2018-02-15 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5430#discussion_r168420232 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java --- @@ -593,6 +617,8 @@ public void shutdown(Time timeout) {

[jira] [Commented] (FLINK-5728) FlinkKafkaProducer should flush on checkpoint by default

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

[GitHub] flink issue #5492: [FLINK-5728] [kafka] Let FlinkKafkaProducers flush on che...

2018-02-15 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5492 LGTM! I will merge as soon as travis is green ---

[jira] [Commented] (FLINK-8411) HeapListState#add(null) will wipe out entire list state

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

[GitHub] flink issue #5485: [FLINK-8411] Don't allow null in ListState.add()/addAll()

2018-02-15 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5485 @zentol pushed a fixup. What about the rest of the PR? ---

[jira] [Commented] (FLINK-8411) HeapListState#add(null) will wipe out entire list state

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

[GitHub] flink pull request #5485: [FLINK-8411] Don't allow null in ListState.add()/a...

2018-02-15 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5485#discussion_r168414749 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java --- @@ -696

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

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

[GitHub] flink issue #5282: [FLINK-6352] [kafka] Timestamp-based offset configuration...

2018-02-15 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5282 Yes, that was my main concern. With a loop it could work, yes. 👍 ---

[jira] [Commented] (FLINK-8660) Enable the user to provide custom HAServices implementation

2018-02-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16365244#comment-16365244 ] Till Rohrmann commented on FLINK-8660: -- This sounds like a really good idea [~kbialek

[jira] [Updated] (FLINK-8660) Enable the user to provide custom HAServices implementation

2018-02-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8660: - Fix Version/s: (was: 1.4.2) (was: 1.5.0) 1.6.0 > Ena

[jira] [Updated] (FLINK-8660) Enable the user to provide custom HAServices implementation

2018-02-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8660: - Affects Version/s: 1.5.0 > Enable the user to provide custom HAServices implementation >

[jira] [Commented] (FLINK-8408) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on Travis

2018-02-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16365235#comment-16365235 ] Till Rohrmann commented on FLINK-8408: -- Another instance: https://api.travis-ci.org/v

[jira] [Commented] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization

2018-02-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16365234#comment-16365234 ] ASF GitHub Bot commented on FLINK-8533: --- Github user StephanEwen commented on the is

[GitHub] flink issue #5427: [FLINK-8533] [checkpointing] Support MasterTriggerRestore...

2018-02-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5427 I think we are talking about two different things here: 1. We DO need a new method on the hook interface to reinitialize the reader group. I think the one suggested by Eron works.

[jira] [Commented] (FLINK-5728) FlinkKafkaProducer should flush on checkpoint by default

2018-02-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16365231#comment-16365231 ] Tzu-Li (Gordon) Tai commented on FLINK-5728: Discussed offline that it would s

[jira] [Updated] (FLINK-5728) FlinkKafkaProducer should flush on checkpoint by default

2018-02-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5728: --- Fix Version/s: 1.5.0 > FlinkKafkaProducer should flush on checkpoint by default >

[jira] [Reopened] (FLINK-5728) FlinkKafkaProducer should flush on checkpoint by default

2018-02-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-5728: Assignee: Tzu-Li (Gordon) Tai > FlinkKafkaProducer should flush on checkpoint by d

[jira] [Commented] (FLINK-5728) FlinkKafkaProducer should flush on checkpoint by default

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

[GitHub] flink pull request #5492: [FLINK-5728] [kafka] Let FlinkKafkaProducers flush...

2018-02-15 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5492 [FLINK-5728] [kafka] Let FlinkKafkaProducers flush on checkpoints by default ## What is the purpose of the change This pull request makes flushing on checkpoints in the Kafka producer the

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

2018-02-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16365216#comment-16365216 ] Aljoscha Krettek commented on FLINK-8628: - Could you please also comment on what i

<    1   2   3   4