[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9294: - Description: Most of the UDF function signatures that includes composite types such as *{{MAP}}*,

[jira] [Commented] (FLINK-9178) Add rate control for kafka source

[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461994#comment-16461994 ] Tarush Grover commented on FLINK-9178: -- [~tzulitai] Actually I had checked this

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

Narayanan Arunachalam created FLINK-9291: Summary: Checkpoint failure (CIRCULAR REFERENCE:java.lang.NegativeArraySizeException) Key: FLINK-9291 URL: https://issues.apache.org/jira/browse/FLINK-9291

[jira] [Comment Edited] (FLINK-9178) Add rate control for kafka source

[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461994#comment-16461994 ] Tarush Grover edited comment on FLINK-9178 at 5/3/18 6:31 AM: -- [~tzulitai]

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

[ https://issues.apache.org/jira/browse/FLINK-9291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462005#comment-16462005 ] Sihua Zhou commented on FLINK-9291: --- I think this looks like the same problem as what happen in

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

[ https://issues.apache.org/jira/browse/FLINK-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462010#comment-16462010 ] Sihua Zhou commented on FLINK-9290: --- Hi [~narayaruna] could you please close this? Cause it is the same

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

[ https://issues.apache.org/jira/browse/FLINK-9291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462025#comment-16462025 ] Stefan Richter commented on FLINK-9291: --- Yes, this is basically a duplicate, just the access to the

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

[ 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...

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

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

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

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

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

[ 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...

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-9169) NPE when restoring from old savepoint and state serializer could not be deserialized

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

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

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

[ 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

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

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

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

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. ---

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

[ 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. >

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

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 @@ +/* + *

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

[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462080#comment-16462080 ] Narayanan Arunachalam commented on FLINK-9268: -- `Is it possible for a session window to

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

[ 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] [Closed] (FLINK-9273) Class cast exception

[ 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:

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

[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462086#comment-16462086 ] Stefan Richter commented on FLINK-9268: --- Yes, you could have duplicates in AT_LEAST_ONCE. But if

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

[ 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-9179) Deduplicate WebOptions.PORT and RestOptions.REST_PORT

[ https://issues.apache.org/jira/browse/FLINK-9179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462088#comment-16462088 ] Aljoscha Krettek commented on FLINK-9179: - [~Zentol] Ok, let's deprecate it then. > Deduplicate

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

[ 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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462051#comment-16462051 ] Narayanan Arunachalam commented on FLINK-9268: -- Is the 2GB Rocksdb limit apply to the size of

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462068#comment-16462068 ] Stefan Richter commented on FLINK-9268: --- The 2GB limit actually applies on a per-key-per-window

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

[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462072#comment-16462072 ] Stefan Richter commented on FLINK-9268: --- Maybe what your are looking for is using a window with

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

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

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

[ 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:

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

[ https://issues.apache.org/jira/browse/FLINK-9271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462084#comment-16462084 ] Stephan Ewen commented on FLINK-9271: - Thanks for sharing. Seems Chrome eagerly de-gziped the file...

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

[ 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-8933) Avoid calling Class#newInstance

[ https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462094#comment-16462094 ] vinoyang commented on FLINK-8933: - [~StephanEwen] , [~fhueske] what's your opinion about this refactor? 

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

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

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

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...

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

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

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

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

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

[ 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

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

[ 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] [Created] (FLINK-9292) Remove TypeInfoParser

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:

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

[ 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:

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

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

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

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

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

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

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

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:

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

[ https://issues.apache.org/jira/browse/FLINK-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462124#comment-16462124 ] Edward Rojas commented on FLINK-9261: - I just want to point out that even with *web.ssl.enabled* set

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

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

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

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

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

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

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

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

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

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

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

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

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

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(

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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,

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

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

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

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-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

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

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462154#comment-16462154 ] Narayanan Arunachalam commented on FLINK-9268: -- The window when triggered, all the events in

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

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

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

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

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

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? ---

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

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

[ https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462164#comment-16462164 ] Stefan Richter commented on FLINK-9268: --- It is hard to make any assumptions about your job without

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

[ 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:

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

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

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

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

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

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

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

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

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

[ 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

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

[ 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] [Assigned] (FLINK-9284) Update CLI page

[ https://issues.apache.org/jira/browse/FLINK-9284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-9284: --- Assignee: Triones Deng > Update CLI page > --- > > Key:

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

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

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

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

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

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5950 Please also check the travis build, some related tests seem to fail: Tests in error:

  1   2   3   >