[jira] [Updated] (FLINK-8257) Unify the value checks for setParallelism()

[ https://issues.apache.org/jira/browse/FLINK-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-8257: --- Description: The {{setParallelism()}} method exist in many components from different levels. Some of t

[jira] [Assigned] (FLINK-8257) Unify the value checks for setParallelism()

[ https://issues.apache.org/jira/browse/FLINK-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-8257: -- Assignee: Xingcan Cui > Unify the value checks for setParallelism() > -

[jira] [Commented] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress

[ https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16297920#comment-16297920 ] shuai.xu commented on FLINK-8289: - Hi [~eronwright], yes, what we need is the advertised a

[jira] [Commented] (FLINK-8295) Netty shading does not work properly

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

[GitHub] flink issue #5183: [FLINK-8295][cassandra][build] properly shade netty for t...

Github user mcfongtw commented on the issue: https://github.com/apache/flink/pull/5183 +1 for this change, @NicoK . I did not see this error as I was working on FLINK-6805 - my bad :(. Also, you might want to remove those comment to avoid future confusion. ---

[GitHub] flink pull request #5187: Merge pull request #1 from apache/master

GitHub user laolang113 opened a pull request: https://github.com/apache/flink/pull/5187 Merge pull request #1 from apache/master update from apache *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help the

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

Github user djh4230 commented on the issue: https://github.com/apache/flink/pull/4926  The hadoop config files are in the flink lauched classpath ---

[jira] [Commented] (FLINK-7951) YarnApplicationMaster does not load HDFSConfiguration

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

[jira] [Commented] (FLINK-8288) Register the web interface url to yarn for yarn job mode

[ https://issues.apache.org/jira/browse/FLINK-8288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16297807#comment-16297807 ] ASF GitHub Bot commented on FLINK-8288: --- GitHub user shuai-xu opened a pull request:

[GitHub] flink pull request #5186: [FLINK-8288] [runtime] register job master rest en...

GitHub user shuai-xu opened a pull request: https://github.com/apache/flink/pull/5186 [FLINK-8288] [runtime] register job master rest endpoint url to yarn ## What is the purpose of the change This pull request pass the endpoint url of job master rest server to resource

[jira] [Commented] (FLINK-5880) Add documentation for object reuse for DataStream API

[ https://issues.apache.org/jira/browse/FLINK-5880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16297798#comment-16297798 ] Elias Levy commented on FLINK-5880: --- Came across here to open this issue after reading t

[jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

[ https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16297661#comment-16297661 ] ASF GitHub Bot commented on FLINK-8162: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

[ https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16297662#comment-16297662 ] ASF GitHub Bot commented on FLINK-8162: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5182: [FLINK-8162] [kinesis-connector] Emit Kinesis' mil...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5182#discussion_r157907331 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -96,6 +100

[GitHub] flink pull request #5182: [FLINK-8162] [kinesis-connector] Emit Kinesis' mil...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5182#discussion_r157907259 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -96,6 +100

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

[ https://issues.apache.org/jira/browse/FLINK-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16297476#comment-16297476 ] ASF GitHub Bot commented on FLINK-8297: --- GitHub user je-ik opened a pull request:

[GitHub] flink pull request #5185: [FLINK-8297] [flink-rocksdb] optionally use RocksD...

GitHub user je-ik opened a pull request: https://github.com/apache/flink/pull/5185 [FLINK-8297] [flink-rocksdb] optionally use RocksDBMapState internally for storing lists ## What is the purpose of the change Enable storing lists not fitting to memory per single key.

[jira] [Updated] (FLINK-8233) Retrieve ExecutionResult by REST polling

[ https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8233: Priority: Blocker (was: Major) > Retrieve ExecutionResult by REST polling > ---

[jira] [Updated] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8234: Priority: Blocker (was: Major) > Cache JobExecutionResult from finished JobManagerRunners > ---

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

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

[GitHub] flink pull request #5184: [FLINK-8234][flip6] Cache JobExecutionResult in Di...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5184#discussion_r157878862 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java --- @@ -358,12 +360,12 @@ private DetachedFinalizer(Job

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

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

[GitHub] flink pull request #5184: [FLINK-8234][flip6] Cache JobExecutionResult in Di...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5184#discussion_r157877969 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobExecutionResult.java --- @@ -0,0 +1,124 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

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

[GitHub] flink pull request #5184: [FLINK-8234][flip6] Cache JobExecutionResult in Di...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5184#discussion_r157877406 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java --- @@ -458,7 +465,14 @@ public JobExecutionResult getR

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

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

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

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

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

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

[GitHub] flink pull request #5184: [FLINK-8234][flip6] Cache JobExecutionResult in Di...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5184#discussion_r157876761 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java --- @@ -92,4 +94,42 @@ * @return Future containing the co

[GitHub] flink pull request #5184: [FLINK-8234][flip6] Cache JobExecutionResult in Di...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5184#discussion_r157876793 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java --- @@ -92,4 +94,42 @@ * @return Future containing the co

[GitHub] flink pull request #5184: [FLINK-8234][flip6] Cache JobExecutionResult in Di...

GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5184 [FLINK-8234][flip6] Cache JobExecutionResult in Dispatcher ## What is the purpose of the change Cache `JobExecutionResult` in `Dispatcher`, and add methods to `RestfulGateway` to enable retriev

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

Jan Lukavský created FLINK-8297: --- Summary: RocksDBListState stores whole list in single byte[] Key: FLINK-8297 URL: https://issues.apache.org/jira/browse/FLINK-8297 Project: Flink Issue Type: I

[jira] [Created] (FLINK-8296) Rework FlinkKafkaConsumerBestTest to not use Java reflection for dependency injection

Tzu-Li (Gordon) Tai created FLINK-8296: -- Summary: Rework FlinkKafkaConsumerBestTest to not use Java reflection for dependency injection Key: FLINK-8296 URL: https://issues.apache.org/jira/browse/FLINK-8296

[jira] [Comment Edited] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress

[ https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16297187#comment-16297187 ] Eron Wright edited comment on FLINK-8289 at 12/19/17 6:21 PM: -

[jira] [Commented] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress

[ https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16297187#comment-16297187 ] Eron Wright commented on FLINK-8289: - I'll use the terms 'advertised' versus 'bind' a

[jira] [Commented] (FLINK-8295) Netty shading does not work properly

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

[GitHub] flink pull request #5183: [FLINK-8295][cassandra][build] properly shade nett...

GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/5183 [FLINK-8295][cassandra][build] properly shade netty for the datastax driver ## What is the purpose of the change `com.datastax.driver.core.NettyUtil` expects netty to be present either at its

[jira] [Commented] (FLINK-7594) Add a SQL client

[ https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16297096#comment-16297096 ] Timo Walther commented on FLINK-7594: - I published an initial design document under FL

[jira] [Assigned] (FLINK-8295) Netty shading does not work properly

[ https://issues.apache.org/jira/browse/FLINK-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-8295: -- Assignee: Nico Kruber > Netty shading does not work properly >

[jira] [Commented] (FLINK-7594) Add a SQL client

[ https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16297045#comment-16297045 ] sunjincheng commented on FLINK-7594: +1, It's a good enhancement to flink. > Add a SQ

issues@flink.apache.org

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296984#comment-16296984 ] ASF GitHub Bot commented on FLINK-7465: --- Github user sunjincheng121 closed the pull

[GitHub] flink pull request #4652: [FLINK-7465][table]Add cardinality count for table...

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

[jira] [Created] (FLINK-8295) Netty shading does not work properly

Timo Walther created FLINK-8295: --- Summary: Netty shading does not work properly Key: FLINK-8295 URL: https://issues.apache.org/jira/browse/FLINK-8295 Project: Flink Issue Type: Bug Co

[jira] [Updated] (FLINK-8295) Netty shading does not work properly

[ https://issues.apache.org/jira/browse/FLINK-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8295: Affects Version/s: 1.4.0 > Netty shading does not work properly > --

issues@flink.apache.org

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-7465. -- Resolution: Workaround > Add build-in BloomFilterCount on TableAPI&SQL > ---

issues@flink.apache.org

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296981#comment-16296981 ] sunjincheng commented on FLINK-7465: I close this issue because I notices that current

[jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

[ https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296973#comment-16296973 ] ASF GitHub Bot commented on FLINK-8162: --- GitHub user casidiablo opened a pull reques

[GitHub] flink pull request #5182: [FLINK-8162] [kinesis-connector] Emit Kinesis' mil...

GitHub user casidiablo opened a pull request: https://github.com/apache/flink/pull/5182 [FLINK-8162] [kinesis-connector] Emit Kinesis' millisBehindLatest metric ## What is the purpose of the change - Emits [Kinesis' millisBehindLatest](http://docs.aws.amazon.com/kinesis/lat

[jira] [Commented] (FLINK-7951) YarnApplicationMaster does not load HDFSConfiguration

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

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4926 @djh4230 could you check whether the Hadoop configuration directory is in the classpath of the launched Flink components? ---

[jira] [Commented] (FLINK-8291) For security, Job Manager web UI should be accessed with username/password

[ https://issues.apache.org/jira/browse/FLINK-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296829#comment-16296829 ] Till Rohrmann commented on FLINK-8291: -- [~lynchlee], you are right. We should add at

[GitHub] flink issue #5158: [hotfix][docs] Update debugging class loading doc to Java...

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/5158 Thanks! ---

[jira] [Updated] (FLINK-8284) Custom metrics not being exposed for Prometheus

[ https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julio Biason updated FLINK-8284: Description: Following the documentation, we changed our filter that removes events with missing fi

[jira] [Created] (FLINK-8294) Missing examples/links in Data Sink docs

Julio Biason created FLINK-8294: --- Summary: Missing examples/links in Data Sink docs Key: FLINK-8294 URL: https://issues.apache.org/jira/browse/FLINK-8294 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-7594) Add a SQL client

[ https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7594: Summary: Add a SQL client (was: Add a SQL CLI client) > Add a SQL client > > >

[jira] [Commented] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min

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

[GitHub] flink issue #5181: [FLINK-8283] [kafka] Fix mock verification on final metho...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5181 I'm not yet certain this fix is the root cause of the stalling tests mentioned in https://issues.apache.org/jira/browse/FLINK-8283. It's something I stumbled across while investigating the failing t

[jira] [Commented] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min

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

[GitHub] flink pull request #5181: [FLINK-8283] [kafka] Fix mock verification on fina...

GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5181 [FLINK-8283] [kafka] Fix mock verification on final method in FlinkKafkaConsumerBaseTest ## What is the purpose of the change Prior to this PR, `FlinkKafkaConsumerBaseTest::testSnapsh

[jira] [Resolved] (FLINK-8215) Support implicit type widening for array/map constructors in SQL

[ https://issues.apache.org/jira/browse/FLINK-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8215. - Resolution: Fixed Fix Version/s: 1.5.0 Fixed in 1.5: 2142eeda9df262e989951c4b31273cbd934656

[jira] [Updated] (FLINK-8215) Support implicit type widening for array/map constructors in SQL

[ https://issues.apache.org/jira/browse/FLINK-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8215: Summary: Support implicit type widening for array/map constructors in SQL (was: upport implicit typ

[jira] [Commented] (FLINK-8215) Support implicit type widening for array/map constructors in SQL

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

[GitHub] flink pull request #5148: [FLINK-8215][Table] fix codegen issue on array/map...

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

[jira] [Updated] (FLINK-8215) upport implicit type widening for array/map constructors in SQL

[ https://issues.apache.org/jira/browse/FLINK-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8215: Summary: upport implicit type widening for array/map constructors in SQL (was: Collections codegen

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296581#comment-16296581 ] ASF GitHub Bot commented on FLINK-7468: --- Github user zhijiangW commented on a diff i

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157709904 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java --- @@ -52,6 +54,10 @@ /** Flag ind

[jira] [Commented] (FLINK-8215) Collections codegen exception when constructing Array or Map via SQL API

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

[GitHub] flink issue #5148: [FLINK-8215][Table] fix codegen issue on array/map value ...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5148 Thank for this fix @walterddr. The code looks good. I will merge this... ---

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296562#comment-16296562 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in th

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157707628 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java --- @@ -99,6 +82,23 @@ protected Throwable getFail

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296558#comment-16296558 ] ASF GitHub Bot commented on FLINK-7468: --- Github user zhijiangW commented on a diff i

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296559#comment-16296559 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in th

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157706995 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java --- @@ -52,6 +54,10 @@ /** Flag indicat

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157706951 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java --- @@ -99,6 +82,23 @@ protected Throwable get

[GitHub] flink pull request #5158: [hotfix][docs] Update debugging class loading doc ...

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

[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources

[ https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296546#comment-16296546 ] Timo Walther commented on FLINK-8240: - Thanks for your response [~wheat9]. We need to

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296538#comment-16296538 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in th

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157703075 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java --- @@ -99,6 +82,23 @@ protected Throwable getFail

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296475#comment-16296475 ] ASF GitHub Bot commented on FLINK-7468: --- Github user zhijiangW commented on a diff i

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157694294 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SubpartitionTestBase.java --- @@ -47,7 +48,14 @@ public void testAddAf

[jira] [Assigned] (FLINK-4352) Refactor CLI to use RESTful client for cluster communication

[ https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4352: Assignee: Till Rohrmann > Refactor CLI to use RESTful client for cluster communication > --

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157693477 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java --- @@ -181,10 +182,27 @@ public void t

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296468#comment-16296468 ] ASF GitHub Bot commented on FLINK-7468: --- Github user zhijiangW commented on a diff i

[jira] [Created] (FLINK-8293) Rework Flink's type and serialization docs

Timo Walther created FLINK-8293: --- Summary: Rework Flink's type and serialization docs Key: FLINK-8293 URL: https://issues.apache.org/jira/browse/FLINK-8293 Project: Flink Issue Type: Improvemen

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296452#comment-16296452 ] ASF GitHub Bot commented on FLINK-7468: --- Github user zhijiangW commented on a diff i

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157691096 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java --- @@ -52,6 +54,10 @@ /** Flag ind

[jira] [Updated] (FLINK-7736) Fix some of the alerts raised by lgtm.com

[ https://issues.apache.org/jira/browse/FLINK-7736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Malcolm Taylor updated FLINK-7736: -- Issue Type: Bug (was: Improvement) > Fix some of the alerts raised by lgtm.com > --

[jira] [Resolved] (FLINK-7452) Add helper methods for all built-in Flink types to Types

[ https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-7452. - Resolution: Fixed Fix Version/s: 1.5.0 Fixed in 1.5: e30066dbd1ebf3c5780df89d766554042c8345

[jira] [Commented] (FLINK-7951) YarnApplicationMaster does not load HDFSConfiguration

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

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

Github user djh4230 commented on the issue: https://github.com/apache/flink/pull/4926  Not work! still can't read hdfs-site.xml and can't read hdfs namespace

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

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

[jira] [Commented] (FLINK-8292) Remove unnecessary force cast in DataStreamSource

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

[GitHub] flink pull request #5180: [FLINK-8292] Remove unnecessary force cast in Data...

GitHub user Matrix42 opened a pull request: https://github.com/apache/flink/pull/5180 [FLINK-8292] Remove unnecessary force cast in DataStreamSource ## What is the purpose of the change Remove unnecessary force cast in DataStreamSource ## Brief change log *

[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources

[ https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296435#comment-16296435 ] Haohui Mai commented on FLINK-8240: --- It seems that it is a great use case of layered tab

[jira] [Commented] (FLINK-8291) For security, Job Manager web UI should be accessed with username/password

[ https://issues.apache.org/jira/browse/FLINK-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296434#comment-16296434 ] Lynch Lee commented on FLINK-8291: -- [~till.rohrmann] Do you aggree with me ?? > For sec

[jira] [Created] (FLINK-8292) Remove unnecessary force cast in DataStreamSource

Matrix42 created FLINK-8292: --- Summary: Remove unnecessary force cast in DataStreamSource Key: FLINK-8292 URL: https://issues.apache.org/jira/browse/FLINK-8292 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-8292) Remove unnecessary force cast in DataStreamSource

[ https://issues.apache.org/jira/browse/FLINK-8292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matrix42 updated FLINK-8292: Fix Version/s: 1.4.1 1.5.0 > Remove unnecessary force cast in DataStreamSource >

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296431#comment-16296431 ] ASF GitHub Bot commented on FLINK-7468: --- Github user zhijiangW commented on a diff i

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157686388 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java --- @@ -99,6 +82,23 @@ protected Throwable get

  1   2   >