[jira] [Comment Edited] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-05-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461960#comment-16461960 ] Tzu-Li (Gordon) Tai edited comment on FLINK-8500 at 5/3/18 5:43 AM:

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-05-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461960#comment-16461960 ] Tzu-Li (Gordon) Tai commented on FLINK-8500: I'm still leaning towards the second approach,

[jira] [Issue Comment Deleted] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-05-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8500: --- Comment: was deleted (was: Let's go with the second approach. I've quickly checked

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-05-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461955#comment-16461955 ] Tzu-Li (Gordon) Tai commented on FLINK-8500: Let's go with the second approach. I've quickly

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-05-02 Thread Fred Teunissen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461953#comment-16461953 ] Fred Teunissen commented on FLINK-8500: --- Both approaches will work, but we have to choose. The first

[jira] [Commented] (FLINK-9288) clarify a few points in the event time / watermark docs

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

[GitHub] flink pull request #5949: [FLINK-9288][docs] clarify the event time / waterm...

2018-05-02 Thread alpinegizmo
GitHub user alpinegizmo reopened a pull request: https://github.com/apache/flink/pull/5949 [FLINK-9288][docs] clarify the event time / watermark docs This PR only affects the documentation (for event time and watermarks). I wanted to make a couple of things clearer, and to provide

[jira] [Commented] (FLINK-9288) clarify a few points in the event time / watermark docs

2018-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461942#comment-16461942 ] ASF GitHub Bot commented on FLINK-9288: --- GitHub user alpinegizmo reopened a pull request:

[jira] [Commented] (FLINK-9288) clarify a few points in the event time / watermark docs

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

[GitHub] flink pull request #5949: [FLINK-9288][docs] clarify the event time / waterm...

2018-05-02 Thread alpinegizmo
Github user alpinegizmo closed the pull request at: https://github.com/apache/flink/pull/5949 ---

[GitHub] flink issue #5949: [FLINK-9288][docs] clarify the event time / watermark doc...

2018-05-02 Thread alpinegizmo
Github user alpinegizmo commented on the issue: https://github.com/apache/flink/pull/5949 @bowenli86 Thanks for the feedback. I've reworked that event time section. Hopefully it's now more complete and accurate without being too complex. ---

[jira] [Assigned] (FLINK-9276) Improve error message when TaskManager fails

2018-05-02 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9276: --- Assignee: vinoyang > Improve error message when TaskManager fails >

[GitHub] flink issue #5928: [hotfix][doc] fix doc of externalized checkpoint

2018-05-02 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5928 @zentol I have addressed your comments. ---

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

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

[GitHub] flink issue #5860: [FLINK-9138][filesystem-connectors] Implement time based ...

2018-05-02 Thread glaksh100
Github user glaksh100 commented on the issue: https://github.com/apache/flink/pull/5860 @fhueske Can you PTAL and merge this PR? ---

[jira] [Commented] (FLINK-9273) Class cast exception

2018-05-02 Thread Bob Lau (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461701#comment-16461701 ] Bob Lau commented on FLINK-9273: [~fhueske] Thanks for your response!  I've resolved the problem. As you

[jira] [Commented] (FLINK-9281) LogBack not working

2018-05-02 Thread Tim (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461564#comment-16461564 ] Tim commented on FLINK-9281: Update:   Looks like this works with logback v1.1.3, but does not work with

[jira] [Commented] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for FLIP-6

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

[GitHub] flink pull request #5896: [FLINK-8286][Security] Fix kerberos security confi...

2018-05-02 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5896#discussion_r185606093 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskExecutorRunnerFactory.java --- @@ -73,61 +105,68 @@ public static void main(String[]

[jira] [Commented] (FLINK-9136) Remove StreamingProgramTestBase

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

[GitHub] flink pull request #5817: [FLINK-9136][tests] Remove StreamingProgramTestBas...

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

[jira] [Closed] (FLINK-9136) Remove StreamingProgramTestBase

2018-05-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9136. --- Resolution: Fixed master: de10b40095bc0109faec3874d452b33586f35e7a > Remove

[jira] [Commented] (FLINK-9125) MiniClusterResource should set CoreOptions.TMP_DIRS

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

[GitHub] flink pull request #5933: [FLINK-9125] MiniClusterResource should set CoreOp...

2018-05-02 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5933#discussion_r185596918 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java --- @@ -137,6 +142,7 @@ public int

[jira] [Commented] (FLINK-9288) clarify a few points in the event time / watermark docs

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

[GitHub] flink pull request #5949: [FLINK-9288][docs] clarify the event time / waterm...

2018-05-02 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5949#discussion_r185588020 --- Diff: docs/dev/event_time.md --- @@ -35,30 +35,32 @@ Flink supports different notions of *time* in streaming programs. respective operation.

[jira] [Assigned] (FLINK-8726) Code highlighting partially broken

2018-05-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-8726: --- Assignee: Chesnay Schepler > Code highlighting partially broken >

[jira] [Updated] (FLINK-9218) Docs for old versions aren't building successfully

2018-05-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9218: Description: The [1.0|https://ci.apache.org/builders/flink-docs-release-1.0],

[GitHub] flink pull request #5928: [hotfix][doc] fix doc of externalized checkpoint

2018-05-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5928#discussion_r185569814 --- Diff: docs/dev/stream/state/checkpointing.md --- @@ -137,11 +137,9 @@ Some more parameters and/or defaults may be set via `conf/flink-conf.yaml` (see

[GitHub] flink pull request #5928: [hotfix][doc] fix doc of externalized checkpoint

2018-05-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5928#discussion_r185569523 --- Diff: docs/dev/stream/state/checkpointing.md --- @@ -137,11 +137,9 @@ Some more parameters and/or defaults may be set via `conf/flink-conf.yaml` (see

[GitHub] flink pull request #5928: [hotfix][doc] fix doc of externalized checkpoint

2018-05-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5928#discussion_r185568867 --- Diff: docs/ops/state/checkpoints.md --- @@ -60,25 +60,29 @@ The `ExternalizedCheckpointCleanup` mode configures what happens with externaliz

[jira] [Commented] (FLINK-9125) MiniClusterResource should set CoreOptions.TMP_DIRS

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

[jira] [Closed] (FLINK-9119) example code error in Concepts & Common API

2018-05-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9119. --- Resolution: Fixed Fix Version/s: 1.4.3 1.5.0 master:

[GitHub] flink pull request #5933: [FLINK-9125] MiniClusterResource should set CoreOp...

2018-05-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5933#discussion_r184928655 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java --- @@ -59,6 +61,9 @@

[jira] [Commented] (FLINK-9125) MiniClusterResource should set CoreOptions.TMP_DIRS

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

[jira] [Commented] (FLINK-9119) example code error in Concepts & Common API

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

[GitHub] flink pull request #5935: [FLINK-9119] example code error in Concepts & Comm...

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

[GitHub] flink pull request #5933: [FLINK-9125] MiniClusterResource should set CoreOp...

2018-05-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5933#discussion_r184928993 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java --- @@ -137,6 +142,7 @@ public int

[jira] [Commented] (FLINK-9119) example code error in Concepts & Common API

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

[GitHub] flink issue #5935: [FLINK-9119] example code error in Concepts & Common API

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

[jira] [Updated] (FLINK-9136) Remove StreamingProgramTestBase

2018-05-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9136: Fix Version/s: 1.6.0 > Remove StreamingProgramTestBase > --- >

[jira] [Closed] (FLINK-9216) Fix comparator violation

2018-05-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9216. --- Resolution: Fixed 1.4: 9b59e6ff5adeeef63a696c2837a47b77f4741a57 > Fix comparator violation >

[jira] [Assigned] (FLINK-9061) add entropy to s3 path for better scalability

2018-05-02 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu reassigned FLINK-9061: - Assignee: Indrajit Roychoudhury Summary: add entropy to s3 path for better

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

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

[GitHub] flink issue #5580: [FLINK-8620] Enable shipping custom files to BlobStore an...

2018-05-02 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/5580 I've addressed @zentol last comments and rebased to fix conflicts. Will merge after travis gives green. ---

[jira] [Commented] (FLINK-9268) RockDB errors from WindowOperator

2018-05-02 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461231#comment-16461231 ] Stefan Richter commented on FLINK-9268: --- I don't think that is the cause. The exception comes right

[jira] [Commented] (FLINK-8978) End-to-end test: Job upgrade

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

[jira] [Commented] (FLINK-8978) End-to-end test: Job upgrade

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

[jira] [Commented] (FLINK-8978) End-to-end test: Job upgrade

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

[GitHub] flink pull request #5947: [FLINK-8978] Stateful generic stream job upgrade e...

2018-05-02 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5947#discussion_r185537704 --- Diff:

[GitHub] flink pull request #5947: [FLINK-8978] Stateful generic stream job upgrade e...

2018-05-02 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5947#discussion_r185537151 --- Diff:

[GitHub] flink pull request #5947: [FLINK-8978] Stateful generic stream job upgrade e...

2018-05-02 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5947#discussion_r185541401 --- Diff:

[jira] [Commented] (FLINK-9268) RockDB errors from WindowOperator

2018-05-02 Thread Narayanan Arunachalam (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461215#comment-16461215 ] Narayanan Arunachalam commented on FLINK-9268: -- Not sure it is related but I don't see this

[jira] [Closed] (FLINK-6306) Sink for eventually consistent file systems

2018-05-02 Thread Seth Wiesman (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-6306. --- Resolution: Won't Do Instead of having multiple filesystem sink, improvements will be made to the

[jira] [Commented] (FLINK-6306) Sink for eventually consistent file systems

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

[GitHub] flink pull request #4607: [FLINK-6306][connectors] Sink for eventually consi...

2018-05-02 Thread sjwiesman
Github user sjwiesman closed the pull request at: https://github.com/apache/flink/pull/4607 ---

[jira] [Commented] (FLINK-6306) Sink for eventually consistent file systems

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

[GitHub] flink issue #4607: [FLINK-6306][connectors] Sink for eventually consistent f...

2018-05-02 Thread sjwiesman
Github user sjwiesman commented on the issue: https://github.com/apache/flink/pull/4607 * clicked the wrong button ---

[jira] [Commented] (FLINK-6306) Sink for eventually consistent file systems

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

[GitHub] flink issue #4607: [FLINK-6306][connectors] Sink for eventually consistent f...

2018-05-02 Thread sjwiesman
Github user sjwiesman commented on the issue: https://github.com/apache/flink/pull/4607 I'm going to go ahead and close this pr and issue to avoid confusion. ---

[jira] [Assigned] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code

2018-05-02 Thread Florian Schmidt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9257: -- Assignee: Florian Schmidt > End-to-end tests prints "All tests PASS" even if

[jira] [Commented] (FLINK-8297) RocksDBListState stores whole list in single byte[]

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

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

2018-05-02 Thread je-ik
Github user je-ik commented on the issue: https://github.com/apache/flink/pull/5185 @StefanRRichter I think that was exactly the initial idea, but then we came into troubles with the savepoints and changing list type. Also as @aljoscha mentioned, it can be confusing for users to see

[jira] [Comment Edited] (FLINK-9290) The job is unable to recover from a checkpoint

2018-05-02 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461153#comment-16461153 ] Sihua Zhou edited comment on FLINK-9290 at 5/2/18 3:21 PM: --- This looks like the

[jira] [Commented] (FLINK-9290) The job is unable to recover from a checkpoint

2018-05-02 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461167#comment-16461167 ] Stefan Richter commented on FLINK-9290: --- [~sihuazhou] yes, looks like it. > The job is unable to

[jira] [Updated] (FLINK-9287) KafkaProducer011 seems to leak threads when not in exactly-once mode

2018-05-02 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9287: -- Priority: Blocker (was: Minor) > KafkaProducer011 seems to leak threads when not in

[jira] [Updated] (FLINK-9287) KafkaProducer011 seems to leak threads when not in exactly-once mode

2018-05-02 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9287: -- Affects Version/s: 1.5.0 > KafkaProducer011 seems to leak threads when not in exactly-once mode

[jira] [Commented] (FLINK-8297) RocksDBListState stores whole list in single byte[]

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

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

2018-05-02 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5185 Just a thought, how about having all this implemented on top of a map state, and also include the current size as a special entry in the map (with the size field having a key that makes it

[jira] [Commented] (FLINK-9287) KafkaProducer011 seems to leak threads when not in exactly-once mode

2018-05-02 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461158#comment-16461158 ] Piotr Nowojski commented on FLINK-9287: --- Yes, indeed there is such bug. The problem boils down to

[jira] [Updated] (FLINK-9290) The job is unable to recover from a checkpoint

2018-05-02 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-9290: -- Priority: Blocker (was: Major) > The job is unable to recover from a checkpoint >

[jira] [Commented] (FLINK-9290) The job is unable to recover from a checkpoint

2018-05-02 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461153#comment-16461153 ] Sihua Zhou commented on FLINK-9290: --- This looks like the same problem as what have been fixed in

[jira] [Created] (FLINK-9290) The job is unable to recover from a checkpoint

2018-05-02 Thread Narayanan Arunachalam (JIRA)
Narayanan Arunachalam created FLINK-9290: Summary: The job is unable to recover from a checkpoint Key: FLINK-9290 URL: https://issues.apache.org/jira/browse/FLINK-9290 Project: Flink

[jira] [Updated] (FLINK-9287) KafkaProducer011 seems to leak threads when not in exactly-once mode

2018-05-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9287: Description: {{KafkaProducer011}} appears to be leaking {{kafka-producer-network-thread}}

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

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

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-05-02 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r185517079 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/filecache/FileCacheDirectoriesTest.java --- @@ -0,0 +1,209 @@ +/* + * Licensed to

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

2018-05-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-9289: -- Assignee: Xingcan Cui > Parallelism of generated operators should have max parallism of input

[jira] [Commented] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async

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

[jira] [Commented] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async

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

[GitHub] flink issue #5934: [FLINK-9269][state] fix concurrency problem when performi...

2018-05-02 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5934 Thanks! Will merge once my travis run is green. ---

[GitHub] flink pull request #5934: [FLINK-9269][state] fix concurrency problem when p...

2018-05-02 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5934#discussion_r185508430 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java --- @@ -3594,6 +3599,58 @@ public String fold(String

[jira] [Commented] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

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

[GitHub] flink issue #5887: [FLINK-6719] [docs] Add details about fault-tolerance of ...

2018-05-02 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5887 Thanks for the update @bowenli86. I'll merge the PR later. ---

[jira] [Commented] (FLINK-9273) Class cast exception

2018-05-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461060#comment-16461060 ] Fabian Hueske commented on FLINK-9273: -- Hi [~bob365], Flink cannot automatically extract the field

[jira] [Closed] (FLINK-9213) Revert breaking change in checkpoint detail URL

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

[jira] [Closed] (FLINK-9041) Refactor StreamTaskTest to not use scala and akka

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

[jira] [Commented] (FLINK-9216) Fix comparator violation

2018-05-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461020#comment-16461020 ] Chesnay Schepler commented on FLINK-9216: - master: 3242214bac3719d057aeaeb34259039dbbf09fb2 1.5:

[jira] [Closed] (FLINK-9249) Add convenience profile for skipping non-essential plugins

2018-05-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9249. --- Resolution: Fixed master: 678ab6cb2f810a93c9b9599cde56d821d09801af 1.5:

[jira] [Commented] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes

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

[jira] [Closed] (FLINK-9154) Include WebSubmissionExtension in REST API docs

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

[jira] [Commented] (FLINK-9041) Refactor StreamTaskTest to not use scala and akka

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

[jira] [Commented] (FLINK-9213) Revert breaking change in checkpoint detail URL

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

[jira] [Commented] (FLINK-9154) Include WebSubmissionExtension in REST API docs

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

[jira] [Commented] (FLINK-9216) Fix comparator violation

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

[jira] [Commented] (FLINK-8743) Add annotation to override documented default

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

[jira] [Commented] (FLINK-9249) Add convenience profile for skipping non-essential plugins

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

[jira] [Closed] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes

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

[jira] [Closed] (FLINK-8743) Add annotation to override documented default

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

[GitHub] flink pull request #5878: [FLINK-9216][Streaming] Fix comparator violation

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

[GitHub] flink pull request #5919: [hotfix][state.md]modify typo in the state.md

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

  1   2   3   >