[jira] [Updated] (FLINK-13000) Remove JobID argument from SimpleSlotProvider

[ https://issues.apache.org/jira/browse/FLINK-13000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13000: - Fix Version/s: (was: 1.9.0) 1.10.0 > Remove JobID argument from

[jira] [Updated] (FLINK-12578) Use secure URLs for Maven repositories

[ https://issues.apache.org/jira/browse/FLINK-12578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12578: - Priority: Blocker (was: Major) > Use secure URLs for Maven repositories >

[GitHub] [flink] klion26 commented on a change in pull request #8967: [FLINK-13059][Cassandra Connector] Release Semaphore correctly on Exception in send()

klion26 commented on a change in pull request #8967: [FLINK-13059][Cassandra Connector] Release Semaphore correctly on Exception in send() URL: https://github.com/apache/flink/pull/8967#discussion_r303800310 ## File path:

[jira] [Created] (FLINK-13285) Connectors need to get rid of flink-table-planner dependence

Jingsong Lee created FLINK-13285: Summary: Connectors need to get rid of flink-table-planner dependence Key: FLINK-13285 URL: https://issues.apache.org/jira/browse/FLINK-13285 Project: Flink

[GitHub] [flink] flinkbot commented on issue #9128: [FLINK-13256] Ensure periodical checkpoint still valid when region failover abort pending checkpoints

flinkbot commented on issue #9128: [FLINK-13256] Ensure periodical checkpoint still valid when region failover abort pending checkpoints URL: https://github.com/apache/flink/pull/9128#issuecomment-511739267 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[jira] [Created] (FLINK-13286) Port SchemaValidator and others validators to table-common

Jingsong Lee created FLINK-13286: Summary: Port SchemaValidator and others validators to table-common Key: FLINK-13286 URL: https://issues.apache.org/jira/browse/FLINK-13286 Project: Flink

[GitHub] [flink] Myasuka commented on a change in pull request #8820: [FLINK-12916][tests] Retry cancelWithSavepoint on cancellation barrier in AbstractOperatorRestoreTestBase

Myasuka commented on a change in pull request #8820: [FLINK-12916][tests] Retry cancelWithSavepoint on cancellation barrier in AbstractOperatorRestoreTestBase URL: https://github.com/apache/flink/pull/8820#discussion_r303820550 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9111: [FLINK-13259] Fix typo about "access"

flinkbot edited a comment on issue #9111: [FLINK-13259] Fix typo about "access" URL: https://github.com/apache/flink/pull/9111#issuecomment-511309474 ## CI report: * 439d80022ebd673b66b87ddeeb02cd89a35e6083 : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/119283441)

[GitHub] [flink] zentol commented on issue #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest

zentol commented on issue #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest URL: https://github.com/apache/flink/pull/9123#issuecomment-511757139 Why are you adding a second vertex?

[jira] [Updated] (FLINK-12273) The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE, otherwise it cannot be recovered according to checkpoint after failure.

[ https://issues.apache.org/jira/browse/FLINK-12273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12273: - Fix Version/s: (was: 1.8.2) (was: 1.6.5)

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12302: - Fix Version/s: (was: 1.9.0) 1.10.0 > Fixed the wrong finalStatus

[jira] [Updated] (FLINK-12709) Implement RestartBackoffTimeStrategyFactoryLoader

[ https://issues.apache.org/jira/browse/FLINK-12709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12709: - Fix Version/s: (was: 1.9.0) 1.10.0 > Implement

[GitHub] [flink] GJL commented on a change in pull request #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option

GJL commented on a change in pull request #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option URL: https://github.com/apache/flink/pull/9113#discussion_r303864871 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java

[GitHub] [flink] flinkbot edited a comment on issue #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager

flinkbot edited a comment on issue #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager URL: https://github.com/apache/flink/pull/8471#issuecomment-510870797 ## CI report: *

[jira] [Created] (FLINK-13287) Port ExistingField to api-java and use new Expression in FieldComputer

Jingsong Lee created FLINK-13287: Summary: Port ExistingField to api-java and use new Expression in FieldComputer Key: FLINK-13287 URL: https://issues.apache.org/jira/browse/FLINK-13287 Project:

[jira] [Assigned] (FLINK-13286) Port SchemaValidator and others validators to table-common

[ https://issues.apache.org/jira/browse/FLINK-13286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13286: Assignee: Jingsong Lee > Port SchemaValidator and others validators to table-common >

[jira] [Assigned] (FLINK-9782) BucketingSink E2E test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-9782: - Assignee: (was: Kostas Kloudas) > BucketingSink E2E test fails on travis >

[jira] [Assigned] (FLINK-9782) BucketingSink E2E test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-9782: - Assignee: Kostas Kloudas > BucketingSink E2E test fails on travis >

[jira] [Assigned] (FLINK-9782) BucketingSink E2E test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-9782: - Assignee: Kostas Kloudas > BucketingSink E2E test fails on travis >

[jira] [Commented] (FLINK-13288) Blink planner doesn't compile with Scala 2.12

[ https://issues.apache.org/jira/browse/FLINK-13288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886106#comment-16886106 ] Chesnay Schepler commented on FLINK-13288: -- This really needs to stop; the table/sql/blink

[GitHub] [flink] Myasuka commented on a change in pull request #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest

Myasuka commented on a change in pull request #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest URL: https://github.com/apache/flink/pull/9123#discussion_r303903541 ## File path:

[GitHub] [flink] zjuwangg commented on issue #9118: [FLINK-13206][sql client]replace `use database xxx` with `use xxx` in sql client parser

zjuwangg commented on issue #9118: [FLINK-13206][sql client]replace `use database xxx` with `use xxx` in sql client parser URL: https://github.com/apache/flink/pull/9118#issuecomment-511819662 address the coments.cc @bowenli86

[jira] [Commented] (FLINK-13288) Blink planner doesn't compile with Scala 2.12

[ https://issues.apache.org/jira/browse/FLINK-13288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886117#comment-16886117 ] Kurt Young commented on FLINK-13288: Really sorry about this [~Zentol]. We didn't aware of this and

[jira] [Commented] (FLINK-11843) Dispatcher fails to recover jobs if leader change happens during JobManagerRunner termination

[ https://issues.apache.org/jira/browse/FLINK-11843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886119#comment-16886119 ] Kurt Young commented on FLINK-11843: Thanks [~till.rohrmann] > Dispatcher fails to recover jobs if

[jira] [Comment Edited] (FLINK-13249) Distributed Jepsen test fails with blocked TaskExecutor

[ https://issues.apache.org/jira/browse/FLINK-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885946#comment-16885946 ] Piotr Nowojski edited comment on FLINK-13249 at 7/16/19 8:53 AM: - I tend

[jira] [Commented] (FLINK-13279) not able to query table registered in catalogs in SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-13279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885949#comment-16885949 ] Danny Chan commented on FLINK-13279: +1 for the end to end tests > not able to query table

[jira] [Commented] (FLINK-13249) Distributed Jepsen test fails with blocked TaskExecutor

[ https://issues.apache.org/jira/browse/FLINK-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885946#comment-16885946 ] Piotr Nowojski commented on FLINK-13249: I tend to agree with [~till.rohrmann] that it would be

[jira] [Resolved] (FLINK-13193) Enable setting custom Flink config in test specs for Jepsen tests

[ https://issues.apache.org/jira/browse/FLINK-13193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao resolved FLINK-13193. -- Resolution: Fixed 1.9: 5f689b79e65a7318f763fdefa0d0a07dc821b88a 1.10:

[jira] [Closed] (FLINK-13193) Enable setting custom Flink config in test specs for Jepsen tests

[ https://issues.apache.org/jira/browse/FLINK-13193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-13193. > Enable setting custom Flink config in test specs for Jepsen tests >

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE

[jira] [Assigned] (FLINK-13150) defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-13150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chan reassigned FLINK-13150: -- Assignee: Danny Chan (was: Xuefu Zhang) > defaultCatalogName and defaultDatabaseName in

[GitHub] [flink] zhuzhurk commented on a change in pull request #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option

zhuzhurk commented on a change in pull request #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option URL: https://github.com/apache/flink/pull/9113#discussion_r303838329 ## File path:

[jira] [Updated] (FLINK-11428) BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11428: - Fix Version/s: (was: 1.9.0) > BufferFileWriterFileSegmentReaderTest#testWriteRead

[GitHub] [flink] flinkbot edited a comment on issue #9124: [FLINK-13280][table-planner-blink] Revert blink changes in DateTimeUt…

flinkbot edited a comment on issue #9124: [FLINK-13280][table-planner-blink] Revert blink changes in DateTimeUt… URL: https://github.com/apache/flink/pull/9124#issuecomment-511704721 ## CI report: * bc16d0284ddcd653a6a6387782ea9f12299566c0 : FAILURE

[jira] [Updated] (FLINK-13274) Refactor HiveTableSource Test using HiveRunner Test Frame

[ https://issues.apache.org/jira/browse/FLINK-13274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13274: --- Labels: pull-request-available (was: ) > Refactor HiveTableSource Test using HiveRunner

[GitHub] [flink] JingsongLi commented on issue #9129: [FLINK-13287][table-api] Port ExistingField to api-java and use new Expression in FieldComputer

JingsongLi commented on issue #9129: [FLINK-13287][table-api] Port ExistingField to api-java and use new Expression in FieldComputer URL: https://github.com/apache/flink/pull/9129#issuecomment-511806590 @twalthr @dawidwys Can you take a look?

[jira] [Commented] (FLINK-9782) BucketingSink E2E test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886109#comment-16886109 ] Kostas Kloudas commented on FLINK-9782: --- The workflow of the test seems to be: 1) we launch a job

[jira] [Commented] (FLINK-13245) Network stack is leaking files

[ https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886116#comment-16886116 ] Andrey Zagrebin commented on FLINK-13245: - Thanks for the clarification [~zjwang]! I have some

[jira] [Updated] (FLINK-12668) Introduce fromParallelElements for generating DataStreamSource

[ https://issues.apache.org/jira/browse/FLINK-12668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12668: - Fix Version/s: (was: 1.9.0) 1.10.0 > Introduce

[jira] [Updated] (FLINK-12826) Unify FunctionInterfacesWithException implementations

[ https://issues.apache.org/jira/browse/FLINK-12826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12826: - Fix Version/s: (was: 1.9.0) 1.10.0 > Unify

[jira] [Updated] (FLINK-12826) Unify FunctionInterfacesWithException implementations

[ https://issues.apache.org/jira/browse/FLINK-12826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12826: - Priority: Minor (was: Major) > Unify FunctionInterfacesWithException implementations >

[GitHub] [flink] zhuzhurk commented on a change in pull request #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option

zhuzhurk commented on a change in pull request #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option URL: https://github.com/apache/flink/pull/9113#discussion_r303838329 ## File path:

[jira] [Commented] (FLINK-13150) defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-13150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886023#comment-16886023 ] Danny Chan commented on FLINK-13150: Actually we have an internal discussion with

[GitHub] [flink] zhuzhurk commented on a change in pull request #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option

zhuzhurk commented on a change in pull request #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option URL: https://github.com/apache/flink/pull/9113#discussion_r303838329 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9117: [FLINK-13223][dist] Enable fine-grained recovery by default in distribution

flinkbot edited a comment on issue #9117: [FLINK-13223][dist] Enable fine-grained recovery by default in distribution URL: https://github.com/apache/flink/pull/9117#issuecomment-511392531 ## CI report: * c75968cc5631c40d54ee0f79dbc84f5b1098768f : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest

flinkbot edited a comment on issue #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest URL: https://github.com/apache/flink/pull/9123#issuecomment-511694972 ## CI report: * 18bce5a71e73470e1164479d9039a02644f3bdf1 : PENDING

[GitHub] [flink] flinkbot commented on issue #9130: [FLINK-13274]Refactor HiveTableSourceTest using HiveRunner

flinkbot commented on issue #9130: [FLINK-13274]Refactor HiveTableSourceTest using HiveRunner URL: https://github.com/apache/flink/pull/9130#issuecomment-511806926 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[jira] [Updated] (FLINK-12179) Remove legacy Instance

[ https://issues.apache.org/jira/browse/FLINK-12179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12179: - Fix Version/s: (was: 1.9.0) 1.10.0 > Remove legacy Instance >

[GitHub] [flink] zentol commented on issue #9071: FLINK-13044 [BuildSystem / Shaded] Fix for wrong shading of AWS SDK in flink-s3-fs-hadoop

zentol commented on issue #9071: FLINK-13044 [BuildSystem / Shaded] Fix for wrong shading of AWS SDK in flink-s3-fs-hadoop URL: https://github.com/apache/flink/pull/9071#issuecomment-511739934 If so, I'm wondering if we could solve this without having to rely on the shade-plugin removing

[jira] [Closed] (FLINK-12655) SlotCountExceedingParallelismTest failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12655. Resolution: Duplicate Fix Version/s: (was: 1.9.0) >

[jira] [Closed] (FLINK-13260) Typo in FieldAccessor

[ https://issues.apache.org/jira/browse/FLINK-13260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13260. Resolution: Duplicate > Typo in FieldAccessor > - > >

[jira] [Closed] (FLINK-13261) Typo in ReOpenableHashTableITCase

[ https://issues.apache.org/jira/browse/FLINK-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13261. Resolution: Duplicate > Typo in ReOpenableHashTableITCase >

[jira] [Updated] (FLINK-12655) SlotCountExceedingParallelismTest failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12655: - Priority: Blocker (was: Critical) > SlotCountExceedingParallelismTest failed on Travis

[jira] [Closed] (FLINK-13104) Flink Datadog metrics client callback does not check for errors on posting and fails silently

[ https://issues.apache.org/jira/browse/FLINK-13104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13104. Resolution: Fixed Fix Version/s: 1.10.0 master:

[jira] [Assigned] (FLINK-12273) The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE, otherwise it cannot be recovered according to checkpoint after failure.

[ https://issues.apache.org/jira/browse/FLINK-12273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-12273: Assignee: (was: vinoyang) > The default value of CheckpointRetentionPolicy should be

[GitHub] [flink] zentol merged pull request #8990: [FLINK-13104][metrics] Updated request callback to log warning on failure

zentol merged pull request #8990: [FLINK-13104][metrics] Updated request callback to log warning on failure URL: https://github.com/apache/flink/pull/8990 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result

flinkbot edited a comment on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result URL: https://github.com/apache/flink/pull/9120#issuecomment-511424128 ## CI report: * e907364a720f6c6086c903e75079fca0fc2ab4ac :

[GitHub] [flink] flinkbot edited a comment on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client

flinkbot edited a comment on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#issuecomment-511260167 ## CI report: * e290f6b65758fc7d199277e4345a75335de981b2 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

flinkbot edited a comment on issue #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#issuecomment-510464651 ## CI report: * b2821a6ae97fd943f3a66b672e85fbd2374126c4 : SUCCESS

[jira] [Updated] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12692: - Fix Version/s: (was: 1.9.0) 1.10.0 > Support disk spilling in

[jira] [Updated] (FLINK-12623) Flink on yarn encountered AMRMClientImpl does not update AMRM token properly

[ https://issues.apache.org/jira/browse/FLINK-12623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12623: - External issue URL: (was: https://issues.apache.org/jira/browse/YARN-3103) > Flink on

[jira] [Updated] (FLINK-12623) Flink on yarn encountered AMRMClientImpl does not update AMRM token properly

[ https://issues.apache.org/jira/browse/FLINK-12623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12623: - Labels: (was: patch) > Flink on yarn encountered AMRMClientImpl does not update AMRM

[jira] [Updated] (FLINK-12623) Flink on yarn encountered AMRMClientImpl does not update AMRM token properly

[ https://issues.apache.org/jira/browse/FLINK-12623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12623: - Affects Version/s: (was: 2.0.0) > Flink on yarn encountered AMRMClientImpl does not

[jira] [Closed] (FLINK-12623) Flink on yarn encountered AMRMClientImpl does not update AMRM token properly

[ https://issues.apache.org/jira/browse/FLINK-12623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12623. Resolution: Invalid Fix Version/s: (was: 1.9.0) (was:

[jira] [Updated] (FLINK-12623) Flink on yarn encountered AMRMClientImpl does not update AMRM token properly

[ https://issues.apache.org/jira/browse/FLINK-12623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12623: - External issue ID: (was: YARN-3103) > Flink on yarn encountered AMRMClientImpl does

[jira] [Updated] (FLINK-12901) Update build instructions for building Flink with a custom hadoop version

[ https://issues.apache.org/jira/browse/FLINK-12901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12901: - Priority: Blocker (was: Major) > Update build instructions for building Flink with a

[GitHub] [flink] NicoK commented on issue #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem

NicoK commented on issue #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem URL: https://github.com/apache/flink/pull/8215#issuecomment-511731126 @yanyan300300 strange - I do this quite frequently in my PRs - squashing WIP git history,

[GitHub] [flink] NicoK closed pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem

NicoK closed pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem URL: https://github.com/apache/flink/pull/8215 This is an automated message from the Apache

[GitHub] [flink] NicoK commented on issue #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem

NicoK commented on issue #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem URL: https://github.com/apache/flink/pull/8215#issuecomment-511741758 merged via 770a40476e7aea4c53babc39e3edc922a3d6a4e7

[jira] [Updated] (FLINK-13285) Connectors need to get rid of flink-table-planner dependence and check connector ITCase runnable in blink runner

[ https://issues.apache.org/jira/browse/FLINK-13285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13285: - Summary: Connectors need to get rid of flink-table-planner dependence and check connector

[GitHub] [flink] flinkbot commented on issue #9128: [FLINK-13256] Ensure periodical checkpoint still valid when region failover abort pending checkpoints

flinkbot commented on issue #9128: [FLINK-13256] Ensure periodical checkpoint still valid when region failover abort pending checkpoints URL: https://github.com/apache/flink/pull/9128#issuecomment-511742081 ## CI report: * 044dfa6e3fbaee8b4fec6ef4232ae539dbc94308 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client

flinkbot edited a comment on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#issuecomment-511260167 ## CI report: * e290f6b65758fc7d199277e4345a75335de981b2 : PENDING

[jira] [Commented] (FLINK-10958) Add overload support for user defined function

[ https://issues.apache.org/jira/browse/FLINK-10958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886028#comment-16886028 ] Chesnay Schepler commented on FLINK-10958: -- [~sunjincheng121] What's the state of this issue? I

[GitHub] [flink] flinkbot edited a comment on issue #9125: [FLINK-13275] Fix race condition in finishTask().

flinkbot edited a comment on issue #9125: [FLINK-13275] Fix race condition in finishTask(). URL: https://github.com/apache/flink/pull/9125#issuecomment-511704736 ## CI report: * 6b5e83707d10845369c9989b98283efe2873173c : SUCCESS

[jira] [Closed] (FLINK-8801) S3's eventual consistent read-after-write may fail yarn deployment of resources to S3

[ https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-8801. -- Resolution: Fixed Fix Version/s: 1.9.0 also merged to release-1.9 via b56234ce4e > S3's

[jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886089#comment-16886089 ] Konstantin Knauf commented on FLINK-11654: -- [~becket_qin] The principle you described sounds

[jira] [Reopened] (FLINK-8801) S3's eventual consistent read-after-write may fail yarn deployment of resources to S3

[ https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reopened FLINK-8801: > S3's eventual consistent read-after-write may fail yarn deployment of > resources to S3 >

[GitHub] [flink] zentol commented on a change in pull request #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest

zentol commented on a change in pull request #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest URL: https://github.com/apache/flink/pull/9123#discussion_r303898549 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #8966: [FLINK-13074][table-planner-blink] Add PartitionableTableSink bridge logic to flink …

flinkbot edited a comment on issue #8966: [FLINK-13074][table-planner-blink] Add PartitionableTableSink bridge logic to flink … URL: https://github.com/apache/flink/pull/8966#issuecomment-511712813 ## CI report: * 7abe4618172b34dfc190c67b3d28422afe4dd0ae : PENDING

[GitHub] [flink] zjuwangg commented on issue #9118: [FLINK-13206][sql client]replace `use database xxx` with `use xxx` in sql client parser

zjuwangg commented on issue #9118: [FLINK-13206][sql client]replace `use database xxx` with `use xxx` in sql client parser URL: https://github.com/apache/flink/pull/9118#issuecomment-511817701 > I'm thinking maybe we can keep 'USE DATABASE' to match 'USE CATALOG', and make both 'USE

[jira] [Updated] (FLINK-13193) Enable setting custom Flink config in test specs for Jepsen tests

[ https://issues.apache.org/jira/browse/FLINK-13193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-13193: - Fix Version/s: 1.9.0 > Enable setting custom Flink config in test specs for Jepsen tests >

[jira] [Updated] (FLINK-13193) Enable setting custom Flink config in test specs for Jepsen tests

[ https://issues.apache.org/jira/browse/FLINK-13193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-13193: - Fix Version/s: 1.10.0 > Enable setting custom Flink config in test specs for Jepsen tests >

[GitHub] [flink] flinkbot edited a comment on issue #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter

flinkbot edited a comment on issue #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter URL: https://github.com/apache/flink/pull/8621#issuecomment-511183092 ## CI report: * e21d12fa2c9b6305d90502ae05a9d574ce712fd1 : SUCCESS

[jira] [Closed] (FLINK-11428) BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) closed FLINK-11428. - Resolution: Cannot Reproduce >

[GitHub] [flink] flinkbot edited a comment on issue #9053: [FLINK-13182][Table SQL / Client] Fix Spelling mistake in flink-table

flinkbot edited a comment on issue #9053: [FLINK-13182][Table SQL / Client] Fix Spelling mistake in flink-table URL: https://github.com/apache/flink/pull/9053#issuecomment-511282008 ## CI report: * 3d8aa4ead36ebc700ba46936fe009a512b0e69ba : FAILURE

[jira] [Commented] (FLINK-11428) BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885950#comment-16885950 ] Congxian Qiu(klion26) commented on FLINK-11428: --- I've run this test locally thousands of

[GitHub] [flink] docete commented on issue #9124: [FLINK-13280][table-planner-blink] Revert blink changes in DateTimeUt…

docete commented on issue #9124: [FLINK-13280][table-planner-blink] Revert blink changes in DateTimeUt… URL: https://github.com/apache/flink/pull/9124#issuecomment-511743496 Travis passed except the SQL Client case(FLINK-13282) https://travis-ci.com/docete/flink/builds/119264081

[jira] [Closed] (FLINK-13215) Hive connector does not compile on Java 9

[ https://issues.apache.org/jira/browse/FLINK-13215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13215. Resolution: Fixed Fix Version/s: 1.10.0 master:

[jira] [Updated] (FLINK-11868) [filesystems] Introduce listStatusIterator API to file system

[ https://issues.apache.org/jira/browse/FLINK-11868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11868: - Issue Type: New Feature (was: Improvement) > [filesystems] Introduce

[jira] [Updated] (FLINK-11868) [filesystems] Introduce listStatusIterator API to file system

[ https://issues.apache.org/jira/browse/FLINK-11868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11868: - Fix Version/s: (was: 1.9.0) 1.10.0 > [filesystems] Introduce

[jira] [Closed] (FLINK-12523) "Kafka 0.11 end-to-end test" failed because it cannot find test-scripts

[ https://issues.apache.org/jira/browse/FLINK-12523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12523. Resolution: Duplicate Fix Version/s: (was: 1.9.0) > "Kafka 0.11 end-to-end

[GitHub] [flink] flinkbot edited a comment on issue #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

flinkbot edited a comment on issue #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#issuecomment-510464651 ## CI report: * b2821a6ae97fd943f3a66b672e85fbd2374126c4 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9110: [FLINK-13258] Add tests for LongHashPartition, StringCallGen and EqualiserCodeGenerator

flinkbot edited a comment on issue #9110: [FLINK-13258] Add tests for LongHashPartition, StringCallGen and EqualiserCodeGenerator URL: https://github.com/apache/flink/pull/9110#issuecomment-511305693 ## CI report: * 26f95bfde851137cb71fa6060df7587535340afe : FAILURE

[GitHub] [flink] zentol commented on a change in pull request #9038: [FLINK-13169][tests][coordination] IT test for fine-grained recovery (task executor failures)

zentol commented on a change in pull request #9038: [FLINK-13169][tests][coordination] IT test for fine-grained recovery (task executor failures) URL: https://github.com/apache/flink/pull/9038#discussion_r303853183 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #9038: [FLINK-13169][tests][coordination] IT test for fine-grained recovery (task executor failures)

zentol commented on a change in pull request #9038: [FLINK-13169][tests][coordination] IT test for fine-grained recovery (task executor failures) URL: https://github.com/apache/flink/pull/9038#discussion_r303859894 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #9038: [FLINK-13169][tests][coordination] IT test for fine-grained recovery (task executor failures)

zentol commented on a change in pull request #9038: [FLINK-13169][tests][coordination] IT test for fine-grained recovery (task executor failures) URL: https://github.com/apache/flink/pull/9038#discussion_r303854122 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #9038: [FLINK-13169][tests][coordination] IT test for fine-grained recovery (task executor failures)

zentol commented on a change in pull request #9038: [FLINK-13169][tests][coordination] IT test for fine-grained recovery (task executor failures) URL: https://github.com/apache/flink/pull/9038#discussion_r303854792 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest

zentol commented on a change in pull request #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest URL: https://github.com/apache/flink/pull/9123#discussion_r303862940 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest

zentol commented on a change in pull request #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest URL: https://github.com/apache/flink/pull/9123#discussion_r303864146 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest

zentol commented on a change in pull request #9123: [FLINK-13281] Fix the verify logic of AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest URL: https://github.com/apache/flink/pull/9123#discussion_r303867334 ## File path:

  1   2   3   4   5   >