[jira] [Commented] (FLINK-9291) Checkpoint failure (CIRCULAR REFERENCE:java.lang.NegativeArraySizeException)

2018-05-03 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462025#comment-16462025 ] Stefan Richter commented on FLINK-9291: --- Yes, this is basically a duplicate, just th

[jira] [Assigned] (FLINK-9284) Update CLI page

2018-05-03 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9284: --- Assignee: (was: yuqi) > Update CLI page > --- > > Key: FLINK-9284 >

[GitHub] flink pull request #5921: [FLINK-9254] Move NotSoMiniClusterIterations to be...

2018-05-03 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5921#discussion_r185711958 --- Diff: flink-end-to-end-tests/test-scripts/test_high_parallelism_iterations.sh --- @@ -0,0 +1,70 @@ +#!/usr/bin/env bash +

[jira] [Commented] (FLINK-9254) Move NotSoMiniClusterIterations to be an end-to-end test

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462041#comment-16462041 ] ASF GitHub Bot commented on FLINK-9254: --- Github user StefanRRichter commented on a d

[jira] [Resolved] (FLINK-9291) Checkpoint failure (CIRCULAR REFERENCE:java.lang.NegativeArraySizeException)

2018-05-03 Thread Narayanan Arunachalam (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narayanan Arunachalam resolved FLINK-9291. -- Resolution: Duplicate > Checkpoint failure (CIRCULAR REFERENCE:java.lang.Negativ

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

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

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

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

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

2018-05-03 Thread Narayanan Arunachalam (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462051#comment-16462051 ] Narayanan Arunachalam commented on FLINK-9268: -- Is the 2GB Rocksdb limit appl

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

2018-05-03 Thread Narayanan Arunachalam (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narayanan Arunachalam resolved FLINK-9290. -- Resolution: Duplicate > The job is unable to recover from a checkpoint > ---

[GitHub] flink issue #5933: [FLINK-9125] MiniClusterResource should set CoreOptions.T...

2018-05-03 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5933 @zentol @GJL removed unnecessary annotation, please review it again thanks. ---

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

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

[GitHub] flink pull request #5950: [FLINK-9169] [state-backend] Allow absence of old ...

2018-05-03 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5950 [FLINK-9169] [state-backend] Allow absence of old serializers when restoring RocksDBStateBackend ## What is the purpose of the change This PR contains 2 commits that overall allows absence

[jira] [Commented] (FLINK-9169) NPE when restoring from old savepoint and state serializer could not be deserialized

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

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

2018-05-03 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462068#comment-16462068 ] Stefan Richter commented on FLINK-9268: --- The 2GB limit actually applies on a per-key

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

2018-05-03 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462072#comment-16462072 ] Stefan Richter commented on FLINK-9268: --- Maybe what your are looking for is using a

[GitHub] flink issue #5945: [FLINK-9169] [runtime] Allow KeyedBackendSerializationPro...

2018-05-03 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5945 I've opened a new PR #5950 which has a cleaner approach to this. That new PR subsumes this one. ---

[GitHub] flink pull request #5945: [FLINK-9169] [runtime] Allow KeyedBackendSerializa...

2018-05-03 Thread tzulitai
Github user tzulitai closed the pull request at: https://github.com/apache/flink/pull/5945 ---

[jira] [Issue Comment Deleted] (FLINK-9268) RockDB errors from WindowOperator

2018-05-03 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-9268: -- Comment: was deleted (was: Maybe what your are looking for is using a window with aggregate func

[jira] [Commented] (FLINK-9169) NPE when restoring from old savepoint and state serializer could not be deserialized

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

[jira] [Commented] (FLINK-9169) NPE when restoring from old savepoint and state serializer could not be deserialized

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462076#comment-16462076 ] ASF GitHub Bot commented on FLINK-9169: --- Github user tzulitai closed the pull reques

[jira] [Assigned] (FLINK-9046) Improve error messages when receiving unexpected messages.

2018-05-03 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9046: --- Assignee: (was: vinoyang) > Improve error messages when receiving unexpected messages. >

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

2018-05-03 Thread Narayanan Arunachalam (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462080#comment-16462080 ] Narayanan Arunachalam commented on FLINK-9268: -- `Is it possible for a session

[GitHub] flink pull request #5515: [FLINK-8683][docs] Add test for configuration docs...

2018-05-03 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5515#discussion_r185720854 --- Diff: flink-docs/src/test/java/org/apache/flink/docs/configuration/ConfigOptionsDocsCompletenessTest.java --- @@ -0,0 +1,225 @@ +/* + * License

[jira] [Closed] (FLINK-9291) Checkpoint failure (CIRCULAR REFERENCE:java.lang.NegativeArraySizeException)

2018-05-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-9291. --- > Checkpoint failure (CIRCULAR REFERENCE:java.lang.NegativeArraySizeException) > -

[jira] [Commented] (FLINK-8683) Add test for configuration docs completeness

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

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

2018-05-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-9273. - Resolution: Not A Problem > Class cast exception > > > Key: F

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

2018-05-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-9273. --- > Class cast exception > > > Key: FLINK-9273 > URL: h

[jira] [Commented] (FLINK-9271) flink-1.4.2-bin-scala_2.11.tgz is not in gzip format

2018-05-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462084#comment-16462084 ] Stephan Ewen commented on FLINK-9271: - Thanks for sharing. Seems Chrome eagerly de-gzi

[jira] [Closed] (FLINK-9271) flink-1.4.2-bin-scala_2.11.tgz is not in gzip format

2018-05-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-9271. --- > flink-1.4.2-bin-scala_2.11.tgz is not in gzip format > -

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

2018-05-03 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462086#comment-16462086 ] Stefan Richter commented on FLINK-9268: --- Yes, you could have duplicates in AT_LEAST_

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

2018-05-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-9290. --- > The job is unable to recover from a checkpoint > -- > >

[jira] [Commented] (FLINK-9179) Deduplicate WebOptions.PORT and RestOptions.REST_PORT

2018-05-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462088#comment-16462088 ] Aljoscha Krettek commented on FLINK-9179: - [~Zentol] Ok, let's deprecate it then.

[jira] [Commented] (FLINK-8933) Avoid calling Class#newInstance

2018-05-03 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462094#comment-16462094 ] vinoyang commented on FLINK-8933: - [~StephanEwen] , [~fhueske] what's your opinion about t

[GitHub] flink pull request #5515: [FLINK-8683][docs] Add test for configuration docs...

2018-05-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5515#discussion_r185725912 --- Diff: flink-docs/src/test/java/org/apache/flink/docs/configuration/ConfigOptionsDocsCompletenessTest.java --- @@ -0,0 +1,225 @@ +/* + * Licensed

[GitHub] flink issue #5515: [FLINK-8683][docs] Add test for configuration docs comple...

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

[jira] [Commented] (FLINK-8683) Add test for configuration docs completeness

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462100#comment-16462100 ] ASF GitHub Bot commented on FLINK-8683: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-8683) Add test for configuration docs completeness

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

[GitHub] flink pull request #5515: [FLINK-8683][docs] Add test for configuration docs...

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

[jira] [Commented] (FLINK-8683) Add test for configuration docs completeness

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

[jira] [Closed] (FLINK-4969) TypeInfoParser needs to be extended to parse the java.sql.* types into the corresponding TypeInfos.

2018-05-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4969. --- > TypeInfoParser needs to be extended to parse the java.sql.* types into the > corresponding TypeInfos. >

[jira] [Resolved] (FLINK-4969) TypeInfoParser needs to be extended to parse the java.sql.* types into the corresponding TypeInfos.

2018-05-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4969. - Resolution: Won't Fix > TypeInfoParser needs to be extended to parse the java.sql.* types into the

[jira] [Created] (FLINK-9292) Remove TypeInfoParser

2018-05-03 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-9292: --- Summary: Remove TypeInfoParser Key: FLINK-9292 URL: https://issues.apache.org/jira/browse/FLINK-9292 Project: Flink Issue Type: Task Components: Core

[jira] [Closed] (FLINK-8683) Add test for configuration docs completeness

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

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

2018-05-03 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5860 Thanks for the update @glaksh100! The changes look good to me. What do you think @aljoscha? ---

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

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

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

2018-05-03 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5949 Looks good, thanks, merging this... ---

[jira] [Created] (FLINK-9293) SlotPool should check slot id when accepting a slot offer with existing allocation id

2018-05-03 Thread shuai.xu (JIRA)
shuai.xu created FLINK-9293: --- Summary: SlotPool should check slot id when accepting a slot offer with existing allocation id Key: FLINK-9293 URL: https://issues.apache.org/jira/browse/FLINK-9293 Project: Fl

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

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

[jira] [Commented] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled

2018-05-03 Thread Edward Rojas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462124#comment-16462124 ] Edward Rojas commented on FLINK-9261: - I just want to point out that even with *web.ss

[GitHub] flink pull request #5860: [FLINK-9138][filesystem-connectors] Implement time...

2018-05-03 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5860#discussion_r185731699 --- Diff: flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@ -908,6 +929,20

[GitHub] flink pull request #5948: [FLINK-9286][docs] Update classloading docs

2018-05-03 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5948#discussion_r185731303 --- Diff: docs/monitoring/debugging_classloading.md --- @@ -69,9 +69,9 @@ cases. By default, Java ClassLoaders will first look for classes in the parent

[jira] [Commented] (FLINK-9286) Update classloading debugging page

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462126#comment-16462126 ] ASF GitHub Bot commented on FLINK-9286: --- Github user StephanEwen commented on a diff

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

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

[GitHub] flink pull request #5944: [FLINK-8900] [yarn] Set correct application status...

2018-05-03 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5944#discussion_r185732539 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MiniDispatcher.java --- @@ -109,7 +119,11 @@ public MiniDispatcher(

[GitHub] flink pull request #5944: [FLINK-8900] [yarn] Set correct application status...

2018-05-03 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5944#discussion_r185732507 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MiniDispatcher.java --- @@ -109,7 +119,11 @@ public MiniDispatcher(

[jira] [Commented] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462130#comment-16462130 ] ASF GitHub Bot commented on FLINK-8900: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462131#comment-16462131 ] ASF GitHub Bot commented on FLINK-8900: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #5860: [FLINK-9138][filesystem-connectors] Implement time...

2018-05-03 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5860#discussion_r185732573 --- Diff: flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@ -473,6 +48

[GitHub] flink pull request #5944: [FLINK-8900] [yarn] Set correct application status...

2018-05-03 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5944#discussion_r185732563 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnJobClusterEntrypoint.java --- @@ -131,6 +133,17 @@ protected JobGraph retrieveJo

[jira] [Commented] (FLINK-8497) KafkaConsumer throws NPE if topic doesn't exist

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

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

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

[GitHub] flink pull request #5929: [FLINK-8497] [connectors] KafkaConsumer throws NPE...

2018-05-03 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5929#discussion_r185732772 --- Diff: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09PartitionDiscoverer.java ---

[jira] [Commented] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462132#comment-16462132 ] ASF GitHub Bot commented on FLINK-8900: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #5948: [FLINK-9286][docs] Update classloading docs

2018-05-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5948#discussion_r185733106 --- Diff: docs/monitoring/debugging_classloading.md --- @@ -69,9 +69,9 @@ cases. By default, Java ClassLoaders will first look for classes in the parent C

[jira] [Commented] (FLINK-9286) Update classloading debugging page

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462135#comment-16462135 ] ASF GitHub Bot commented on FLINK-9286: --- Github user zentol commented on a diff in t

[GitHub] flink issue #5948: [FLINK-9286][docs] Update classloading docs

2018-05-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5948 I agree that the default shouldn't be listed in the common section. The "Common Options" section will be reworked soon to also be generated (in this [PR](https://github.com/apache/flink/pull/5

[jira] [Commented] (FLINK-9286) Update classloading debugging page

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

[GitHub] flink issue #5939: [FLINK-8500] [Kafka Connector] Get the timestamp of the K...

2018-05-03 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5939 The feature is a nice addition. Flink currently already adds the timestamp as the record's event time timestamp. You can access it via a ProcessFunction. That is a tad bit more clumsy, t

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

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

[GitHub] flink issue #5936: [FLINK-9265] Upgrade Prometheus version

2018-05-03 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5936 Could you add the dependency tree of the upgraded Prometheus dependency to check? ---

[jira] [Commented] (FLINK-9265) Upgrade Prometheus version

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

[GitHub] flink issue #5939: [FLINK-8500] [Kafka Connector] Get the timestamp of the K...

2018-05-03 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5939 @StephanEwen we have some follow-up discussion on how to approach this on the JIRA ticket. Do you want to take a look at that? https://issues.apache.org/jira/browse/FLINK-8500 The general i

[GitHub] flink issue #5929: [FLINK-8497] [connectors] KafkaConsumer throws NPE if top...

2018-05-03 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5929 I am not sure if failing is the right behavior here. What is someone has a Flink job running and one of the topics for which partitions are discovered gets deleted? That would fail the jo

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

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

[jira] [Commented] (FLINK-8497) KafkaConsumer throws NPE if topic doesn't exist

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

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

2018-05-03 Thread Narayanan Arunachalam (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462154#comment-16462154 ] Narayanan Arunachalam commented on FLINK-9268: -- The window when triggered, al

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

2018-05-03 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5928 In Flink 1.5, all checkpoints are externalized. There is no notion of externalized checkpoints any more, just a setting to configure the retention (retain on cancel, retain on fail, never retain)

[GitHub] flink issue #5936: [FLINK-9265] Upgrade Prometheus version

2018-05-03 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5936 Is there any problem about this upgrading? Does you mean I should add the dependency tree here as a comment? ---

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

2018-05-03 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5928#discussion_r185737131 --- Diff: docs/ops/state/state_backends.md --- @@ -152,7 +152,7 @@ Possible values for the config entry are *jobmanager* (MemoryStateBackend), *fil

[jira] [Commented] (FLINK-9265) Upgrade Prometheus version

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

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

2018-05-03 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462164#comment-16462164 ] Stefan Richter commented on FLINK-9268: --- It is hard to make any assumptions about yo

[jira] [Assigned] (FLINK-9292) Remove TypeInfoParser

2018-05-03 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9292: --- Assignee: vinoyang > Remove TypeInfoParser > - > > Key: FLINK-929

[GitHub] flink pull request #5944: [FLINK-8900] [yarn] Set correct application status...

2018-05-03 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5944#discussion_r185739056 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MiniDispatcher.java --- @@ -109,7 +119,11 @@ public MiniDispatcher(

[jira] [Commented] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

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

[GitHub] flink issue #5847: [FLINK-9174][datastream]Fix the type of state created in ...

2018-05-03 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5847 Hi @aljoscha does this PR look good to you now? ---

[jira] [Commented] (FLINK-9174) The type of state created in ProccessWindowFunction.proccess() is inconsistency

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462176#comment-16462176 ] ASF GitHub Bot commented on FLINK-9174: --- Github user sihuazhou commented on the issu

[GitHub] flink pull request #5951: [FLINK-9293] [runtime] SlotPool should check slot ...

2018-05-03 Thread shuai-xu
GitHub user shuai-xu opened a pull request: https://github.com/apache/flink/pull/5951 [FLINK-9293] [runtime] SlotPool should check slot id when accepting a slot offer with existing allocation id ## What is the purpose of the change *This pull request fix that job maste

[jira] [Updated] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job

2018-05-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9207: Fix Version/s: (was: 1.5.0) 1.6.0 > Client returns SUCCESS(0) return

[jira] [Commented] (FLINK-9293) SlotPool should check slot id when accepting a slot offer with existing allocation id

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462182#comment-16462182 ] ASF GitHub Bot commented on FLINK-9293: --- GitHub user shuai-xu opened a pull request:

[jira] [Updated] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job

2018-05-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9207: Priority: Major (was: Blocker) > Client returns SUCCESS(0) return code for canceled job > -

[jira] [Updated] (FLINK-9293) SlotPool should check slot id when accepting a slot offer with existing allocation id

2018-05-03 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-9293: Priority: Blocker (was: Major) > SlotPool should check slot id when accepting a slot offer with existing >

[jira] [Updated] (FLINK-9109) Add flink modify command to documentation

2018-05-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9109: Priority: Major (was: Blocker) > Add flink modify command to documentation > --

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

2018-05-03 Thread Narayanan Arunachalam (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462187#comment-16462187 ] Narayanan Arunachalam commented on FLINK-9268: -- True > RockDB errors from Wi

[jira] [Commented] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak

2018-05-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462190#comment-16462190 ] Aljoscha Krettek commented on FLINK-9080: - [~rohsing] when you put the jar in the

[jira] [Updated] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak

2018-05-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9080: Priority: Critical (was: Blocker) > Flink Scheduler goes OOM, suspecting a memory leak > --

[jira] [Updated] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak

2018-05-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9080: Fix Version/s: (was: 1.5.0) 1.5.1 1.6.0 > Flink Sc

[GitHub] flink pull request #5908: [FLINK-9182]async checkpoints for timer service

2018-05-03 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5908#discussion_r185734334 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java --- @@ -395,36 +402,102 @@ public f

[GitHub] flink pull request #5908: [FLINK-9182]async checkpoints for timer service

2018-05-03 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5908#discussion_r185729269 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java --- @@ -49,13 +50,13 @@ /

[jira] [Commented] (FLINK-9182) async checkpoints for timer service

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462198#comment-16462198 ] ASF GitHub Bot commented on FLINK-9182: --- Github user StefanRRichter commented on a d

[jira] [Commented] (FLINK-9182) async checkpoints for timer service

2018-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462197#comment-16462197 ] ASF GitHub Bot commented on FLINK-9182: --- Github user StefanRRichter commented on a d

  1   2   3   >