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

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366685#comment-16366685 ] ASF GitHub Bot commented on FLINK-3655: --- Github user fhueske commented on the issue:

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

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5415 Will merge this. ---

[jira] [Updated] (FLINK-8667) expose key in KeyedBroadcastProcessFunction#onTimer()

[ https://issues.apache.org/jira/browse/FLINK-8667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8667: Description: [~aljoscha] [~pnowojski] Since KeyedBroadcastProcessFunction is about to get out of the

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

[ https://issues.apache.org/jira/browse/FLINK-8625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366531#comment-16366531 ] mingleizhang commented on FLINK-8625: - Hi, [~pnowojski] One thing I would like to confirm. We want to

[jira] [Updated] (FLINK-8335) Upgrade hbase connector dependency to 1.4.1

[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-8335: Summary: Upgrade hbase connector dependency to 1.4.1 (was: Upgrade hbase connector dependency to

[jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.0

[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366517#comment-16366517 ] ASF GitHub Bot commented on FLINK-8335: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #5488: [FLINK-8335] [hbase] Upgrade hbase connector depen...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5488#discussion_r168659459 --- Diff: flink-connectors/flink-hbase/pom.xml --- @@ -34,7 +34,7 @@ under the License. jar - 1.3.1 +

[jira] [Commented] (FLINK-8648) Allow for customization of emitRecordAndUpdateState in Kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366345#comment-16366345 ] ASF GitHub Bot commented on FLINK-8648: --- Github user tweise commented on the issue:

[GitHub] flink issue #5480: [FLINK-8648] [kinesis] Allow for customization of emitRec...

Github user tweise commented on the issue: https://github.com/apache/flink/pull/5480 @tzulitai see https://gist.github.com/tweise/7fad5d5df0abf54670a52d0d02d61179 for details. As indicated in the email thread, emit override will track watermark state and delegate the record

[GitHub] flink issue #5393: [FLINK-8516] Allow for custom hash function for shard to ...

Github user tweise commented on the issue: https://github.com/apache/flink/pull/5393 @tzulitai thanks for the review! ---

[jira] [Commented] (FLINK-8516) Allow custom shard-to-subtask assignment for the FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366303#comment-16366303 ] ASF GitHub Bot commented on FLINK-8516: --- Github user tweise commented on the issue:

[GitHub] flink issue #5497: Propose fixing some typos

Github user jeis2497052 commented on the issue: https://github.com/apache/flink/pull/5497 Sorry about the space issue. Shall I revert that doc? On Thu, Feb 15, 2018 at 4:27 PM Chesnay wrote: > *@zentol* commented on this pull request. >

[GitHub] flink pull request #5497: Propose fixing some typos

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/5497#discussion_r168616567 --- Diff: docs/dev/migration.md --- @@ -145,16 +145,16 @@ public class BufferingSink implements SinkFunction>,

[GitHub] flink pull request #5497: Propose fixing some typos

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5497#discussion_r168613102 --- Diff: docs/dev/migration.md --- @@ -145,16 +145,16 @@ public class BufferingSink implements SinkFunction>,

[GitHub] flink issue #5497: Propose fixing some typos

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/5497 +1 ---

[jira] [Commented] (FLINK-8667) expose key in KeyedBroadcastProcessFunction#onTimer()

[ https://issues.apache.org/jira/browse/FLINK-8667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366232#comment-16366232 ] ASF GitHub Bot commented on FLINK-8667: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #5500: [FLINK-8667] expose key in KeyedBroadcastProcessFunction#...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5500 cc @aljoscha @pnowojski ---

[jira] [Commented] (FLINK-8667) expose key in KeyedBroadcastProcessFunction#onTimer()

[ https://issues.apache.org/jira/browse/FLINK-8667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366231#comment-16366231 ] ASF GitHub Bot commented on FLINK-8667: --- GitHub user bowenli86 opened a pull request:

[GitHub] flink pull request #5500: [FLINK-8667] expose key in KeyedBroadcastProcessFu...

GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/5500 [FLINK-8667] expose key in KeyedBroadcastProcessFunction#onTimer() ## What is the purpose of the change Expose key in `KeyedBroadcastProcessFunction#onTimer(OnTimerContext)`.

[jira] [Created] (FLINK-8667) expose key in KeyedBroadcastProcessFunction#onTimer()

Bowen Li created FLINK-8667: --- Summary: expose key in KeyedBroadcastProcessFunction#onTimer() Key: FLINK-8667 URL: https://issues.apache.org/jira/browse/FLINK-8667 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8560) add KeyedProcessFunction to expose the key in onTimer() and other methods

[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366201#comment-16366201 ] ASF GitHub Bot commented on FLINK-8560: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #5481: [FLINK-8560] Access to the current key in ProcessFunction...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5481 @aljoscha @pnowojski Guys, quick question. I'm about to develop `KeyedProcessFunction` and its operator in a keyed stream. But I found there's already a `KeyedProcessOperator` which is for

[jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.0

[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366194#comment-16366194 ] ASF GitHub Bot commented on FLINK-8335: --- Github user greghogan commented on a diff in the pull

[GitHub] flink pull request #5488: [FLINK-8335] [hbase] Upgrade hbase connector depen...

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/5488#discussion_r168592172 --- Diff: flink-connectors/flink-hbase/pom.xml --- @@ -34,7 +34,7 @@ under the License. jar - 1.3.1 +

[jira] [Updated] (FLINK-8630) Add proper support for JSON formats

[ https://issues.apache.org/jira/browse/FLINK-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8630: Summary: Add proper support for JSON formats (was: To support JSON schema to TypeInformation

[jira] [Commented] (FLINK-8630) Add proper support for JSON formats

[ https://issues.apache.org/jira/browse/FLINK-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366144#comment-16366144 ] ASF GitHub Bot commented on FLINK-8630: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (FLINK-8630) Add proper support for JSON formats

[ https://issues.apache.org/jira/browse/FLINK-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8630. - Resolution: Fixed Fixed in 1.5.0: 6c09c057846fecd456bfbe3dacabb4800370 > Add proper support

[GitHub] flink pull request #5491: [FLINK-8630] [table] To support JSON schema to Typ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5491 ---

[jira] [Updated] (FLINK-8640) Disable japicmp on java 9

[ https://issues.apache.org/jira/browse/FLINK-8640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-8640: -- Description: The {{japicmp}} plugin does not work out-of-the-box with java 9 as per

[jira] [Commented] (FLINK-8666) Use AkkaUtils#testDispatcherConfig in MiniCluster

[ https://issues.apache.org/jira/browse/FLINK-8666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366117#comment-16366117 ] ASF GitHub Bot commented on FLINK-8666: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #5499: [FLINK-8666] [test] Use testDispatcherConfig in Mi...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5499 [FLINK-8666] [test] Use testDispatcherConfig in MiniCluster ## What is the purpose of the change Using the AkkaUtils#testDispatcherConfig reduces the number of started threads.

[jira] [Created] (FLINK-8666) Use AkkaUtils#testDispatcherConfig in MiniCluster

Till Rohrmann created FLINK-8666: Summary: Use AkkaUtils#testDispatcherConfig in MiniCluster Key: FLINK-8666 URL: https://issues.apache.org/jira/browse/FLINK-8666 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-8628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366112#comment-16366112 ] dejan miljkovic commented on FLINK-8628: Sorry can not reproduce the issue. Lost the pom.xml that

[jira] [Commented] (FLINK-8665) Allow RpcEndpoint#postStop to complete asynchronously

[ https://issues.apache.org/jira/browse/FLINK-8665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366110#comment-16366110 ] ASF GitHub Bot commented on FLINK-8665: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #5498: [FLINK-8665] [rest] Let RpcEndpoint#postStop retur...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5498 [FLINK-8665] [rest] Let RpcEndpoint#postStop return completion future ## What is the purpose of the change The RpcEndpoint#postStop method returns a CompletableFuture which is

[GitHub] flink pull request #5497: Propose fixing some typos

GitHub user jeis2497052 opened a pull request: https://github.com/apache/flink/pull/5497 Propose fixing some typos Just a doc change if this helps? *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help the

[jira] [Commented] (FLINK-8630) To support JSON schema to TypeInformation conversion

[ https://issues.apache.org/jira/browse/FLINK-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366101#comment-16366101 ] ASF GitHub Bot commented on FLINK-8630: --- Github user twalthr commented on the issue:

[GitHub] flink issue #5491: [FLINK-8630] [table] To support JSON schema to TypeInform...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5491 Merging... ---

[jira] [Created] (FLINK-8665) Allow RpcEndpoint#postStop to complete asynchronously

Till Rohrmann created FLINK-8665: Summary: Allow RpcEndpoint#postStop to complete asynchronously Key: FLINK-8665 URL: https://issues.apache.org/jira/browse/FLINK-8665 Project: Flink Issue

[jira] [Commented] (FLINK-8664) Change termination future type of RpcEndpoint to Void

[ https://issues.apache.org/jira/browse/FLINK-8664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366087#comment-16366087 ] ASF GitHub Bot commented on FLINK-8664: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #5496: [FLINK-8664] [rest] Change RpcEndpoint#Termination...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5496 [FLINK-8664] [rest] Change RpcEndpoint#TerminationFuture value type to Void ## What is the purpose of the change Change `RpcEndpoint#TerminationFuture` value type to `Void`.

[jira] [Created] (FLINK-8664) Change termination future type of RpcEndpoint to Void

Till Rohrmann created FLINK-8664: Summary: Change termination future type of RpcEndpoint to Void Key: FLINK-8664 URL: https://issues.apache.org/jira/browse/FLINK-8664 Project: Flink Issue

[jira] [Updated] (FLINK-8516) Allow custom shard-to-subtask assignment for the FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8516: --- Summary: Allow custom shard-to-subtask assignment for the FlinkKinesisConsumer (was:

[jira] [Resolved] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks

[ https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8516. Resolution: Fixed Fix Version/s: 1.5.0 Thanks for your contribution [~thw]!

[jira] [Updated] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks

[ https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8516: --- Affects Version/s: (was: 1.5.0) (was: 1.3.2)

[jira] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks

[ https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366056#comment-16366056 ] ASF GitHub Bot commented on FLINK-8516: --- Github user asfgit closed the pull request at:

[jira] [Updated] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks

[ https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8516: --- Issue Type: New Feature (was: Bug) > FlinkKinesisConsumer does not balance shards

[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5393 ---

[GitHub] flink issue #5480: [FLINK-8648] [kinesis] Allow for customization of emitRec...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5480 Just curious, before I proceed to merge this: could you briefly describe what your custom override would consist of? I'm asking because we may be able to find a cleaner solution (or not 😅

[jira] [Commented] (FLINK-8648) Allow for customization of emitRecordAndUpdateState in Kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366052#comment-16366052 ] ASF GitHub Bot commented on FLINK-8648: --- Github user tzulitai commented on the issue:

[jira] [Updated] (FLINK-8640) Disable japicmp on java 9

[ https://issues.apache.org/jira/browse/FLINK-8640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-8640: -- Description: The {{japicmp}} plugin does not work out-of-the-box with java 9 as per

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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365958#comment-16365958 ] 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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168545164 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/BackendRestorerProcedure.java --- @@ -0,0 +1,143 @@ +/*

[jira] [Commented] (FLINK-8653) Remove slot request timeout from SlotPool

[ https://issues.apache.org/jira/browse/FLINK-8653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365896#comment-16365896 ] ASF GitHub Bot commented on FLINK-8653: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #5483: [FLINK-8653] [flip6] Remove internal slot request timeout...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5483 Rebased onto the soon to be master. Merging once Travis gives green light. ---

[jira] [Commented] (FLINK-8614) Enable Flip-6 per default

[ https://issues.apache.org/jira/browse/FLINK-8614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365889#comment-16365889 ] ASF GitHub Bot commented on FLINK-8614: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #5437: [FLINK-8614] [flip6] Activate Flip-6 mode per default

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5437 Thanks for the review @GJL. Merging once Travis gives green light. ---

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

[ https://issues.apache.org/jira/browse/FLINK-8610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365875#comment-16365875 ] ASF GitHub Bot commented on FLINK-8610: --- Github user asfgit closed the pull request at:

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

[ https://issues.apache.org/jira/browse/FLINK-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365876#comment-16365876 ] ASF GitHub Bot commented on FLINK-8611: --- Github user asfgit closed the pull request at:

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

[ https://issues.apache.org/jira/browse/FLINK-8647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365874#comment-16365874 ] ASF GitHub Bot commented on FLINK-8647: --- Github user tillrohrmann closed the pull request at:

[GitHub] flink pull request #5434: [FLINK-8611] [flip6] Add result future to JobManag...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5434 ---

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

Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/5478 ---

[GitHub] flink pull request #5433: [FLINK-8610] [flip6] Remove RestfulGateway from Jo...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5433 ---

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

[ https://issues.apache.org/jira/browse/FLINK-8647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8647. Resolution: Fixed Fixed via 0f5c96bf16aee78b025b1bdecd7377f2681311d9 > Introduce

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

[ https://issues.apache.org/jira/browse/FLINK-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8611. Resolution: Fixed Fixed via 35ee062eab984c65ede3511e66ff13c2bca43770 > Add result future to

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

[ https://issues.apache.org/jira/browse/FLINK-8610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8610. Resolution: Fixed Fixed via a621e2f1308e120bcb149e9877b781062e59842b > Remove RestfulGateway from

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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365848#comment-16365848 ] 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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168530422 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/TestTaskStateManager.java --- @@ -118,12 +121,38 @@ public void

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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365846#comment-16365846 ] 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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168529743 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/TestTaskStateManager.java --- @@ -118,12 +121,38 @@ public void

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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365842#comment-16365842 ] 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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168529359 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/TestTaskStateManager.java --- @@ -118,12 +121,38 @@ public void

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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365834#comment-16365834 ] 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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365831#comment-16365831 ] 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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168528716 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/TaskStateManagerImplTest.java --- @@ -109,10 +111,10 @@ public void

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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168528536 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStore.java --- @@ -19,92 +19,224 @@ package

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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365829#comment-16365829 ] 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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168528301 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStore.java --- @@ -19,92 +19,224 @@ package

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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365826#comment-16365826 ] 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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168527958 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java --- @@ -59,58 +71,55 @@ public

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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365820#comment-16365820 ] 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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168526712 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java --- @@ -20,35 +20,47 @@

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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365818#comment-16365818 ] 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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168526304 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java --- @@ -75,7 +79,10 @@ public OperatorSubtaskState

[jira] [Commented] (FLINK-8614) Enable Flip-6 per default

[ https://issues.apache.org/jira/browse/FLINK-8614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365813#comment-16365813 ] ASF GitHub Bot commented on FLINK-8614: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5437: [FLINK-8614] [flip6] Activate Flip-6 mode per defa...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5437#discussion_r168525466 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MiniDispatcher.java --- @@ -100,6 +101,18 @@ public MiniDispatcher(

[jira] [Commented] (FLINK-8614) Enable Flip-6 per default

[ https://issues.apache.org/jira/browse/FLINK-8614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365812#comment-16365812 ] ASF GitHub Bot commented on FLINK-8614: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5437: [FLINK-8614] [flip6] Activate Flip-6 mode per defa...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5437#discussion_r168525199 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java --- @@ -402,6 +403,24 @@ public void start() throws

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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365810#comment-16365810 ] 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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168524862 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java --- @@ -525,19 +526,17 @@ public String

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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168524601 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStreamWithResultProvider.java --- @@ -0,0 +1,175 @@ +/* + *

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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365809#comment-16365809 ] 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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365775#comment-16365775 ] 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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365776#comment-16365776 ] ASF GitHub Bot commented on FLINK-8360: --- Github user tillrohrmann commented on a diff in the pull

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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365777#comment-16365777 ] ASF GitHub Bot commented on FLINK-8360: --- Github user tillrohrmann commented on a diff in the pull

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

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168514168 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStore.java --- @@ -166,20 +190,38 @@ public TaskStateSnapshot

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

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168514963 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/TaskStateManagerImplTest.java --- @@ -148,22 +150,22 @@ public void

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

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365774#comment-16365774 ] 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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168515077 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStore.java --- @@ -19,92 +19,224 @@ package

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

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168514913 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStore.java --- @@ -19,92 +19,224 @@ package

  1   2   3   4   >