[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread tarun razdan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tarun razdan updated FLINK-7756: Attachment: taskmanager_without_cassandra.log > RocksDB state backend Checkpointing (Async and

[GitHub] flink pull request #5481: [FLINK-8560] Access to the current key in ProcessF...

2018-02-14 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5481#discussion_r168122242 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunction.scala --- @@ -162,7 +162,7 @@ class

[jira] [Commented] (FLINK-8560) Access to the current key in ProcessFunction#OnTimerContext after keyBy()

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

[jira] [Updated] (FLINK-8576) Log message for QueryableState loading failure too verbose

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8576: Fix Version/s: 1.4.2 > Log message for QueryableState loading failure too verbose >

[jira] [Updated] (FLINK-8576) Log message for QueryableState loading failure too verbose

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8576: Affects Version/s: 1.4.0 > Log message for QueryableState loading failure too verbose >

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363819#comment-16363819 ] Aljoscha Krettek commented on FLINK-7756: - There is only one TaskManager, correct? > RocksDB

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[GitHub] flink issue #5469: [FLINK-8475][config][docs] Integrate Core options

2018-02-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5469 merging. ---

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

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

[GitHub] flink issue #5458: [FLINK-8212] [network] Pull EnvironmentInformation out of...

2018-02-14 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5458 @tillrohrmann I updated the code. Could you take a look ? Thanks ~ ---

[jira] [Closed] (FLINK-5779) Auto generate configuration docs

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5779. --- Resolution: Fixed > Auto generate configuration docs > > >

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[jira] [Closed] (FLINK-8475) Move remaining sections to generated tables

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8475. --- Resolution: Fixed Fully addressed on master in: 8c8033eb6665d7e352fed4d067930c91b9507d82

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[jira] [Commented] (FLINK-8553) switch flink-metrics-datadog to async mode

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

[jira] [Commented] (FLINK-8576) Log message for QueryableState loading failure too verbose

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

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[GitHub] flink issue #5415: [FLINK-3655] [core] Support multiple paths in FileInputFo...

2018-02-14 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5415 Thanks for the review @zentol. I've addressed your feedback, improved the backwards compatibility as discussed offline, and added multi-path support to additional input formats. ---

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

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

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168168418 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -316,6 +316,11 @@ */ public static

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

2018-02-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363950#comment-16363950 ] Fabian Hueske commented on FLINK-3655: -- Hi [~sjwiesman], I've reworked the PR and opened a new one:

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168168381 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStore.java --- @@ -46,26 +52,63 @@ /** */ private

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

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

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

2018-02-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364044#comment-16364044 ] Till Rohrmann commented on FLINK-8459: -- Yes the better solution in terms of guarantees would be

[jira] [Commented] (FLINK-8520) CassandraConnectorITCase.testCassandraTableSink unstable on Travis

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

[GitHub] flink issue #5474: [FLINK-8520][cassandra] Fix race condition

2018-02-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5474 yes it should be 8520 (good catch!), will fix while merging. ---

[jira] [Commented] (FLINK-8600) BucketingSink errors out when used with Presto filesystem

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

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

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

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

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

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

2018-02-14 Thread zhangminglei
Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5458#discussion_r168180788 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java --- @@ -530,10 +538,12 @@ public static long

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

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

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

2018-02-14 Thread zhangminglei
Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5458#discussion_r168180756 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java --- @@ -270,10 +273,14 @@ public static

[jira] [Created] (FLINK-8655) Add a default keyspace to CassandraSink

2018-02-14 Thread Christopher Hughes (JIRA)
Christopher Hughes created FLINK-8655: - Summary: Add a default keyspace to CassandraSink Key: FLINK-8655 URL: https://issues.apache.org/jira/browse/FLINK-8655 Project: Flink Issue Type:

[GitHub] flink issue #5185: [FLINK-8297] [flink-rocksdb] Optionally store elements of...

2018-02-14 Thread je-ik
Github user je-ik commented on the issue: https://github.com/apache/flink/pull/5185 @aljoscha I updated the title. I'm a little concerned about the serialization in savepoint. If the serialization is *exactly* the same, doesn't that actually mean that again, the whole List will be

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168184825 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168184599 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java --- @@ -630,19 +506,210 @@ public int

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

2018-02-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5436#discussion_r168184923 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -325,26 +325,43 @@ public void onContainersCompleted(List list) {

[jira] [Commented] (FLINK-8649) Scala StreamExecutionEnvironment.createInput should pass on the TypeInfo

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

[GitHub] flink issue #5479: [FLINK-8649] [scala api] Pass on TypeInfo in StreamExecut...

2018-02-14 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5479 Thank you @ggevay. I will look at this soon. ---

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread tarun razdan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tarun razdan updated FLINK-7756: Attachment: (was: taskmanager.log) > RocksDB state backend Checkpointing (Async and

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread tarun razdan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tarun razdan updated FLINK-7756: Attachment: (was: jobmanager.log) > RocksDB state backend Checkpointing (Async and Incremental)

[jira] [Commented] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator

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

[jira] [Commented] (FLINK-8576) Log message for QueryableState loading failure too verbose

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

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

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

[GitHub] flink pull request #5420: [FLINK-8576][QS] Reduce verbosity when classes can...

2018-02-14 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5420#discussion_r168137274 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/query/QueryableStateUtils.java --- @@ -132,9 +134,7 @@ public static KvStateServer

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[GitHub] flink issue #5469: [FLINK-8475][config][docs] Integrate Core options

2018-02-14 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5469 Ok, sounds fine to me then. 👍 ---

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363826#comment-16363826 ] Aljoscha Krettek commented on FLINK-7756: - Also, did you ever try running this without any CEP

[GitHub] flink pull request #5484: [FLINK-8593][metrics] Update latency metric docs

2018-02-14 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5484 [FLINK-8593][metrics] Update latency metric docs This PR updates the documentation of the latency metric to be in line with the recent changes in

[jira] [Commented] (FLINK-8593) Latency metric docs are outdated

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

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

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

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

2018-02-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5430#discussion_r168148700 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/webmonitor/TestingRestfulGateway.java --- @@ -169,22 +192,26 @@ public static Builder

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

2018-02-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5430#discussion_r168149188 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobTerminationHeaders.java --- @@ -32,7 +32,7 @@ private static

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

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

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

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

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

2018-02-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5430#discussion_r168165205 --- 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-8360) Implement task-local state recovery

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

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168168634 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java --- @@ -104,10

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168168770 --- Diff: flink-core/src/test/java/org/apache/flink/util/MethodForwardingTestUtil.java --- @@ -0,0 +1,146 @@ +/* + * Licensed to the Apache

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168168705 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/LocalStateForwardingTest.java --- @@ -0,0 +1,213 @@ +/*

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168168472 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java --- @@ -686,4

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168168810 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/StateObjectCollectionTest.java --- @@ -0,0 +1,64 @@ +/* + *

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

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

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168168726 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java --- @@ -104,10

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168168796 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/LocalStateForwardingTest.java --- @@ -0,0 +1,213 @@ +/*

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

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

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

2018-02-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5432#discussion_r168173010 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java --- @@ -210,51 +225,72 @@ protected void run(String[] args) throws Exception

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

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

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168176306 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java --- @@ -501,4 +529,53 @@ public String

[GitHub] flink pull request #5272: [Flink-8397][Connectors]Support Row type for Cassa...

2018-02-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168176395 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraRowOutputFormat.java --- @@ -0,0

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

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

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

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

[GitHub] flink pull request #5272: [Flink-8397][Connectors]Support Row type for Cassa...

2018-02-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168175822 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormat.java --- @@ -95,15

[GitHub] flink pull request #5272: [Flink-8397][Connectors]Support Row type for Cassa...

2018-02-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168169354 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormat.java --- @@ -37,11

[GitHub] flink pull request #5272: [Flink-8397][Connectors]Support Row type for Cassa...

2018-02-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168169778 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraTupleOutputFormat.java --- @@ -0,0

[GitHub] flink pull request #5272: [Flink-8397][Connectors]Support Row type for Cassa...

2018-02-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168177338 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@

[GitHub] flink pull request #5272: [Flink-8397][Connectors]Support Row type for Cassa...

2018-02-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168177375 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-14 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5487 [FLINK-8656] [flip6] Add modify CLI command to rescale Flink jobs ## What is the purpose of the change Jobs can now be rescaled by calling flink modify -p . Internally, the

[jira] [Updated] (FLINK-8655) Add a default keyspace to CassandraSink

2018-02-14 Thread Christopher Hughes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christopher Hughes updated FLINK-8655: -- Description: Currently, to use the CassandraPojoSink, it is necessary for a user to

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

2018-02-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363802#comment-16363802 ] Xingcan Cui commented on FLINK-8538: Hi [~twalthr], I think Friday will be fine. Thought looks

[jira] [Commented] (FLINK-8553) switch flink-metrics-datadog to async mode

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

[jira] [Updated] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7286: Component/s: Metrics > Flink Dashboard fails to display bytes/records received by sources >

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

2018-02-14 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/5485 [FLINK-8411] Don't allow null in ListState.add()/addAll() R: @StefanRRichter, @bowenli86 It turns out that this is a bit trickier than assumed earlier: `ListState.addAll()` was not

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

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

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168169295 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskStateManager.java --- @@ -47,10 +47,11 @@ * @param

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168169149 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTerminationTest.java --- @@ -227,21 +229,13 @@

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168169168 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -916,57 +916,78 @@ private void

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

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

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

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

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168169451 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotContextSynchronousImpl.java --- @@ -109,14 +109,20 @@ public

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

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

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

2018-02-14 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168169484 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotContextSynchronousImpl.java --- @@ -130,7 +136,7 @@ public

[GitHub] flink pull request #5478: [FLINK-8647] [flip6] Introduce JobMasterConfigurat...

2018-02-14 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5478#discussion_r168171127 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java --- @@ -698,7 +707,7 @@ else if (numConsumers == 0) {

[GitHub] flink pull request #5282: [FLINK-6352] [kafka] Timestamp-based offset config...

2018-02-14 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5282#discussion_r167941419 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@ -343,6

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

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

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

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

  1   2   3   4   5   >