[jira] [Assigned] (FLINK-11747) Elasticsearch 6 connector - Expose RestHighLevelClient to allow for custom sniffing

[ https://issues.apache.org/jira/browse/FLINK-11747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Salatich reassigned FLINK-11747: -- Assignee: Aleksandr Salatich > Elasticsearch 6 connector - Expose RestHighLev

[GitHub] zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r260636298 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] flinkbot edited a comment on issue #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

flinkbot edited a comment on issue #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#issuecomment-459738324 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I h

[jira] [Updated] (FLINK-11771) Serializer snapshot cannot be read if directly upgraded in-place to a TypeSerializerSnapshot from a TypeSerializerConfigSnapshot written in 1.7+

[ https://issues.apache.org/jira/browse/FLINK-11771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11771: Description: This is a upgrade path that was overlooked in {{TypeSerializerSnapsh

[jira] [Updated] (FLINK-11771) Serializer snapshot cannot be read if directly upgraded in-place to a TypeSerializerSnapshot from a TypeSerializerConfigSnapshot written in 1.7+

[ https://issues.apache.org/jira/browse/FLINK-11771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11771: Description: This is a upgrade path that was overlooked in {{TypeSerializerSnapsh

[GitHub] uce commented on issue #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

uce commented on issue #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#issuecomment-467774635 After an offline discussion with Chesnay and Till, we decided to make the `job-classname` argument optional and scan

[GitHub] godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType

godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType URL: https://github.com/apache/flink/pull/7817#discussion_r260618012 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

[GitHub] godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType

godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType URL: https://github.com/apache/flink/pull/7817#discussion_r260616916 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

[GitHub] godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType

godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType URL: https://github.com/apache/flink/pull/7817#discussion_r260621495 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

[GitHub] godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType

godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType URL: https://github.com/apache/flink/pull/7817#discussion_r260623802 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

[GitHub] godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType

godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType URL: https://github.com/apache/flink/pull/7817#discussion_r260617527 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

[GitHub] godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType

godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType URL: https://github.com/apache/flink/pull/7817#discussion_r260618527 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

[GitHub] flinkbot edited a comment on issue #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

flinkbot edited a comment on issue #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#issuecomment-464113787 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType

godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType URL: https://github.com/apache/flink/pull/7817#discussion_r260617292 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

[GitHub] godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType

godfreyhe commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType URL: https://github.com/apache/flink/pull/7817#discussion_r260622214 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

[jira] [Updated] (FLINK-11771) Serializer snapshot cannot be read if directly upgraded in-place to a TypeSerializerSnapshot from a TypeSerializerConfigSnapshot written in 1.7+

[ https://issues.apache.org/jira/browse/FLINK-11771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11771: Issue Type: Bug (was: Improvement) > Serializer snapshot cannot be read if direct

[jira] [Created] (FLINK-11771) Serializer snapshot cannot be read if directly upgraded in-place to a TypeSerializerSnapshot from a TypeSerializerConfigSnapshot written in 1.7+

Tzu-Li (Gordon) Tai created FLINK-11771: --- Summary: Serializer snapshot cannot be read if directly upgraded in-place to a TypeSerializerSnapshot from a TypeSerializerConfigSnapshot written in 1.7+ Key: FLINK-11771

[GitHub] zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r260644919 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] uce commented on issue #7843: [FLINK-11752] [dist] Move flink-python to opt

uce commented on issue #7843: [FLINK-11752] [dist] Move flink-python to opt URL: https://github.com/apache/flink/pull/7843#issuecomment-46354 The test failure seems unrelated to this change. I retriggered the build. This i

[jira] [Updated] (FLINK-8862) Support HBase snapshot read

[ https://issues.apache.org/jira/browse/FLINK-8862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-8862: -- Component/s: (was: Batch Connectors and Input/Output Formats) Connectors /

[jira] [Updated] (FLINK-8244) There are two zookeeper client created when read data from hbase in the flink yarn session model

[ https://issues.apache.org/jira/browse/FLINK-8244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-8244: -- Component/s: (was: Batch Connectors and Input/Output Formats) Connectors /

[GitHub] zentol commented on issue #7843: [FLINK-11752] [dist] Move flink-python to opt

zentol commented on issue #7843: [FLINK-11752] [dist] Move flink-python to opt URL: https://github.com/apache/flink/pull/7843#issuecomment-467781578 @flinkbot approve description consensus attention How does the `pyflink.sh` script react to the jar not being present? It is not docu

[GitHub] flinkbot edited a comment on issue #7843: [FLINK-11752] [dist] Move flink-python to opt

flinkbot edited a comment on issue #7843: [FLINK-11752] [dist] Move flink-python to opt URL: https://github.com/apache/flink/pull/7843#issuecomment-467624899 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull reque

[GitHub] StefanRRichter commented on a change in pull request #7841: [FLINK-11743] Fix RocksDB incremental restore from local state after refactoring

StefanRRichter commented on a change in pull request #7841: [FLINK-11743] Fix RocksDB incremental restore from local state after refactoring URL: https://github.com/apache/flink/pull/7841#discussion_r260651541 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/j

[GitHub] fengli commented on a change in pull request #7726: [FLINK-10342] Filter restored partitions with discovered partitions b…

fengli commented on a change in pull request #7726: [FLINK-10342] Filter restored partitions with discovered partitions b… URL: https://github.com/apache/flink/pull/7726#discussion_r260651429 ## File path: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/s

[jira] [Updated] (FLINK-11771) Serializer snapshot cannot be read if directly upgraded in-place to a TypeSerializerSnapshot from a TypeSerializerConfigSnapshot written in 1.7+

[ https://issues.apache.org/jira/browse/FLINK-11771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11771: Description: This is a upgrade path that was overlooked in {{TypeSerializerSnapsh

[GitHub] GJL commented on issue #7833: [FLINK-10881] Fix SavepointITCase test instability.

GJL commented on issue #7833: [FLINK-10881] Fix SavepointITCase test instability. URL: https://github.com/apache/flink/pull/7833#issuecomment-467783492 Does this fix the deadlock? This is an automated message from the Apache

[GitHub] zentol commented on issue #7833: [FLINK-10881] Fix SavepointITCase test instability.

zentol commented on issue #7833: [FLINK-10881] Fix SavepointITCase test instability. URL: https://github.com/apache/flink/pull/7833#issuecomment-467783500 This doesn't make sense. Whether you shutdown the cluster or not, we are shutting the cluster which _must_ implicitly do that as well.

[GitHub] zentol edited a comment on issue #7833: [FLINK-10881] Fix SavepointITCase test instability.

zentol edited a comment on issue #7833: [FLINK-10881] Fix SavepointITCase test instability. URL: https://github.com/apache/flink/pull/7833#issuecomment-467783500 This doesn't make sense. Regardless of whether you shutdown the job or not, we are shutting down the cluster which _must_ implic

[GitHub] zentol edited a comment on issue #7833: [FLINK-10881] Fix SavepointITCase test instability.

zentol edited a comment on issue #7833: [FLINK-10881] Fix SavepointITCase test instability. URL: https://github.com/apache/flink/pull/7833#issuecomment-467783500 This doesn't make sense. Regardless of whether you shutdown the job or not, we are shutting the cluster which _must_ implicitly

[GitHub] tzulitai commented on issue #7845: [FLINK-11753][tests] Add utilities to ease TypeSerializerSchemaCompatibility testing

tzulitai commented on issue #7845: [FLINK-11753][tests] Add utilities to ease TypeSerializerSchemaCompatibility testing URL: https://github.com/apache/flink/pull/7845#issuecomment-467786642 @flinkbot approve all This is an a

[GitHub] flinkbot edited a comment on issue #7845: [FLINK-11753][tests] Add utilities to ease TypeSerializerSchemaCompatibility testing

flinkbot edited a comment on issue #7845: [FLINK-11753][tests] Add utilities to ease TypeSerializerSchemaCompatibility testing URL: https://github.com/apache/flink/pull/7845#issuecomment-467733316 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help th

[GitHub] tzulitai commented on issue #7845: [FLINK-11753][tests] Add utilities to ease TypeSerializerSchemaCompatibility testing

tzulitai commented on issue #7845: [FLINK-11753][tests] Add utilities to ease TypeSerializerSchemaCompatibility testing URL: https://github.com/apache/flink/pull/7845#issuecomment-467787308 I like the changes! Thanks @igalshilman. Especially now that the tested properties are immediatel

[jira] [Updated] (FLINK-5944) Flink should support reading Snappy Files

[ https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5944: -- Component/s: (was: Batch Connectors and Input/Output Formats) Connectors /

[GitHub] tzulitai commented on issue #7726: [FLINK-10342] Filter restored partitions with discovered partitions b…

tzulitai commented on issue #7726: [FLINK-10342] Filter restored partitions with discovered partitions b… URL: https://github.com/apache/flink/pull/7726#issuecomment-467789811 This looks good to merge now! Thanks a lot for the contribution @fengli. I'll proceed to clean this PR up

[jira] [Updated] (FLINK-11756) Update migration tests for Flink 1.8

[ https://issues.apache.org/jira/browse/FLINK-11756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11756: - Description: Once 1.8.0 is release we should update existing migration tests to cover r

[jira] [Assigned] (FLINK-11007) Update documentation to describe new checkpoint metadata file behavior

[ https://issues.apache.org/jira/browse/FLINK-11007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-11007: -- Assignee: Stefan Richter > Update documentation to describe new checkpoint metadata f

[jira] [Commented] (FLINK-10705) Rework Flink Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16779066#comment-16779066 ] Chesnay Schepler commented on FLINK-10705: -- [~rmetzger] yes we should have the

[GitHub] uce commented on issue #7843: [FLINK-11752] [dist] Move flink-python to opt

uce commented on issue #7843: [FLINK-11752] [dist] Move flink-python to opt URL: https://github.com/apache/flink/pull/7843#issuecomment-467797122 @zentol I did not find any reference to the opt dependency in the Python streaming API docs. For the scripts, we have the following situat

[GitHub] zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r260668512 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[jira] [Comment Edited] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16779070#comment-16779070 ] Chesnay Schepler edited comment on FLINK-11143 at 2/27/19 9:51 AM: ---

[jira] [Commented] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16779070#comment-16779070 ] Chesnay Schepler commented on FLINK-11143: -- The MiniCluster should respect the

[GitHub] StefanRRichter commented on a change in pull request #7813: [FLINK-10712] Support to restore state when using RestartPipelinedRegionStrategy

StefanRRichter commented on a change in pull request #7813: [FLINK-10712] Support to restore state when using RestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/7813#discussion_r260672842 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/execu

[GitHub] StefanRRichter commented on issue #7586: [FLINK-10912][rocksdb] Configurable RocksDBStateBackend options

StefanRRichter commented on issue #7586: [FLINK-10912][rocksdb] Configurable RocksDBStateBackend options URL: https://github.com/apache/flink/pull/7586#issuecomment-467802321 Thanks for addressing all comments. Changes LGTM, merging 👍 --

[jira] [Closed] (FLINK-10895) TypeSerializerSnapshotMigrationITCase.testSavepoint test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-10895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10895. --- Resolution: Fixed > TypeSerializerSnapshotMigrationITCase.testSavepoint test failed

[jira] [Commented] (FLINK-10895) TypeSerializerSnapshotMigrationITCase.testSavepoint test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-10895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16779091#comment-16779091 ] Tzu-Li (Gordon) Tai commented on FLINK-10895: - I've been running this test i

[GitHub] asfgit closed pull request #7841: [FLINK-11743] Fix RocksDB incremental restore from local state after refactoring

asfgit closed pull request #7841: [FLINK-11743] Fix RocksDB incremental restore from local state after refactoring URL: https://github.com/apache/flink/pull/7841 This is an automated message from the Apache Git Service. To r

[GitHub] JingsongLi commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType

JingsongLi commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType URL: https://github.com/apache/flink/pull/7817#discussion_r260679989 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apa

[jira] [Closed] (FLINK-11743) Sticky E2E tests failed on travis

[ https://issues.apache.org/jira/browse/FLINK-11743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-11743. -- Resolution: Fixed Merged in: master: 7a078a632c release-1.8: 060d0e6837 > Sticky E2E tests fa

[GitHub] asfgit closed pull request #7586: [FLINK-10912][rocksdb] Configurable RocksDBStateBackend options

asfgit closed pull request #7586: [FLINK-10912][rocksdb] Configurable RocksDBStateBackend options URL: https://github.com/apache/flink/pull/7586 This is an automated message from the Apache Git Service. To respond to the mes

[jira] [Closed] (FLINK-10912) Configurable RocksDBStateBackend options factory

[ https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10912. -- Resolution: Implemented Fix Version/s: 1.8.0 Merged in: master: a8580ca08d release-1.8:

[GitHub] StefanRRichter commented on issue #7830: [hotfix] Reduce and simplify code for column creation in RocksDB backend

StefanRRichter commented on issue #7830: [hotfix] Reduce and simplify code for column creation in RocksDB backend URL: https://github.com/apache/flink/pull/7830#issuecomment-467809344 @azagrebin Can you rebase and have also have one build triggered? Then I will take a look. --

[jira] [Updated] (FLINK-10705) Rework Flink Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yadong Xie updated FLINK-10705: --- Attachment: 3rdpartylicenses.txt > Rework Flink Web Dashboard > -- > >

[jira] [Commented] (FLINK-10705) Rework Flink Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16779124#comment-16779124 ] Yadong Xie commented on FLINK-10705: @angular/cli can generate 3rdpartylicenses.txt

[jira] [Comment Edited] (FLINK-10705) Rework Flink Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16779124#comment-16779124 ] Yadong Xie edited comment on FLINK-10705 at 2/27/19 10:34 AM:

[GitHub] jianbin-allseeing commented on issue #7801: [FLINK-11722][javadocs] Fix the outdated java doc in AkkaRpcServiceUtils

jianbin-allseeing commented on issue #7801: [FLINK-11722][javadocs] Fix the outdated java doc in AkkaRpcServiceUtils URL: https://github.com/apache/flink/pull/7801#issuecomment-467818827 @flinkbot approve all This is an autom

[GitHub] flinkbot edited a comment on issue #7801: [FLINK-11722][javadocs] Fix the outdated java doc in AkkaRpcServiceUtils

flinkbot edited a comment on issue #7801: [FLINK-11722][javadocs] Fix the outdated java doc in AkkaRpcServiceUtils URL: https://github.com/apache/flink/pull/7801#issuecomment-466295037 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] zentol commented on issue #7843: [FLINK-11752] [dist] Move flink-python to opt

zentol commented on issue #7843: [FLINK-11752] [dist] Move flink-python to opt URL: https://github.com/apache/flink/pull/7843#issuecomment-467821326 If `pyflink-stream.sh` loads a jar from `/opt` then the script should be changed. Nothing in `/opt` should be accessed; it only serves as a co

[GitHub] azagrebin opened a new pull request #7846: [FLINK-9003][E2E] Add operators with input type that goes through custom, stateful serialization

azagrebin opened a new pull request #7846: [FLINK-9003][E2E] Add operators with input type that goes through custom, stateful serialization URL: https://github.com/apache/flink/pull/7846 ## What is the purpose of the change Introduces testing of stateful custom serialisation used in

[GitHub] flinkbot commented on issue #7846: [FLINK-9003][E2E] Add operators with input type that goes through custom, stateful serialization

flinkbot commented on issue #7846: [FLINK-9003][E2E] Add operators with input type that goes through custom, stateful serialization URL: https://github.com/apache/flink/pull/7846#issuecomment-467821739 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I hel

[jira] [Updated] (FLINK-9003) Add operators with input type that goes through custom, stateful serialization

[ https://issues.apache.org/jira/browse/FLINK-9003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9003: -- Labels: pull-request-available (was: ) > Add operators with input type that goes through custo

[GitHub] asfgit closed pull request #7808: [FLINK-11718][rpc] Add onStart method to RpcEndpoint

asfgit closed pull request #7808: [FLINK-11718][rpc] Add onStart method to RpcEndpoint URL: https://github.com/apache/flink/pull/7808 This is an automated message from the Apache Git Service. To respond to the message, pleas

[jira] [Closed] (FLINK-11718) Add onStart method to RpcEndpoint which is run in the actor's main thread

[ https://issues.apache.org/jira/browse/FLINK-11718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11718. - Resolution: Fixed Fix Version/s: 1.8.0 Fixed via master: ba089aa593 579f5e0824 af69289935

[GitHub] JingsongLi opened a new pull request #7847: [FLINK-11724][core] Add util method to MemorySegment

JingsongLi opened a new pull request #7847: [FLINK-11724][core] Add util method to MemorySegment URL: https://github.com/apache/flink/pull/7847 ## What is the purpose of the change Improve MemorySegment to provide copyToUnsafe copyFromUnsafe and equalTo. ## Brief change lo

[jira] [Updated] (FLINK-11724) Improve MemorySegment

[ https://issues.apache.org/jira/browse/FLINK-11724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11724: --- Labels: pull-request-available (was: ) > Improve MemorySegment > - > >

[GitHub] flinkbot commented on issue #7847: [FLINK-11724][core] Add util method to MemorySegment

flinkbot commented on issue #7847: [FLINK-11724][core] Add util method to MemorySegment URL: https://github.com/apache/flink/pull/7847#issuecomment-467831126 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull reque

[GitHub] zentol commented on a change in pull request #7687: [FLINK-11542][config][docs] Extend memory configuration descriptions

zentol commented on a change in pull request #7687: [FLINK-11542][config][docs] Extend memory configuration descriptions URL: https://github.com/apache/flink/pull/7687#discussion_r260715030 ## File path: docs/ops/config.md ## @@ -70,6 +70,12 @@ These parameters configure

[GitHub] zentol commented on a change in pull request #7687: [FLINK-11542][config][docs] Extend memory configuration descriptions

zentol commented on a change in pull request #7687: [FLINK-11542][config][docs] Extend memory configuration descriptions URL: https://github.com/apache/flink/pull/7687#discussion_r260718284 ## File path: docs/ops/config.md ## @@ -70,6 +70,12 @@ These parameters configure

[GitHub] Fokko commented on a change in pull request #7508: [hotfix][docs] Add example for the BulkFormat of the StreamingFileSink

Fokko commented on a change in pull request #7508: [hotfix][docs] Add example for the BulkFormat of the StreamingFileSink URL: https://github.com/apache/flink/pull/7508#discussion_r260719629 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -110,12 +110,45 @@ inte

[GitHub] flinkbot edited a comment on issue #7687: [FLINK-11542][config][docs] Extend memory configuration descriptions

flinkbot edited a comment on issue #7687: [FLINK-11542][config][docs] Extend memory configuration descriptions URL: https://github.com/apache/flink/pull/7687#issuecomment-462791945 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community t

[GitHub] Fokko commented on issue #7547: [FLINK-11401] Allow setting of compression on ParquetWriter

Fokko commented on issue #7547: [FLINK-11401] Allow setting of compression on ParquetWriter URL: https://github.com/apache/flink/pull/7547#issuecomment-467839816 Thanks @StephanEwen, I've updated the docs. This is an automate

[GitHub] Fokko commented on a change in pull request #7508: [hotfix][docs] Add example for the BulkFormat of the StreamingFileSink

Fokko commented on a change in pull request #7508: [hotfix][docs] Add example for the BulkFormat of the StreamingFileSink URL: https://github.com/apache/flink/pull/7508#discussion_r260720097 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -110,12 +110,45 @@ inte

[jira] [Created] (FLINK-11772) InternalTimerServiceSerializationProxy should not be serializing timers' key / namespace serializers anymore

Tzu-Li (Gordon) Tai created FLINK-11772: --- Summary: InternalTimerServiceSerializationProxy should not be serializing timers' key / namespace serializers anymore Key: FLINK-11772 URL: https://issues.apache.org

[GitHub] Fokko commented on a change in pull request #7508: [hotfix][docs] Add example for the BulkFormat of the StreamingFileSink

Fokko commented on a change in pull request #7508: [hotfix][docs] Add example for the BulkFormat of the StreamingFileSink URL: https://github.com/apache/flink/pull/7508#discussion_r260719292 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -110,12 +110,45 @@ inte

[GitHub] uce commented on issue #7843: [FLINK-11752] [dist] Move flink-python to opt

uce commented on issue #7843: [FLINK-11752] [dist] Move flink-python to opt URL: https://github.com/apache/flink/pull/7843#issuecomment-467843696 But this means that it's unnecessary for users to copy the JAR to `lib` in the first place. And from a user's perspective, it's more convenient t

[GitHub] zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#discussion_r260722788 ## File path: flink-container/src/main/java/org/apache/flink/container/entrypoint/ClassP

[GitHub] zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#discussion_r260726736 ## File path: flink-container/pom.xml ## @@ -66,4 +66,64 @@ under the License.

[GitHub] zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#discussion_r260728729 ## File path: flink-container/src/test/java/org/apache/flink/container/entrypoint/ClassP

[GitHub] zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#discussion_r260721801 ## File path: flink-container/kubernetes/README.md ## @@ -42,6 +41,7 @@ At last

[GitHub] zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#discussion_r260730087 ## File path: flink-container/src/test/java/org/apache/flink/container/entrypoint/JarMan

[GitHub] zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#discussion_r260724860 ## File path: flink-container/src/main/java/org/apache/flink/container/entrypoint/Standa

[GitHub] zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#discussion_r260729937 ## File path: flink-container/src/test/java/org/apache/flink/container/entrypoint/JarMan

[GitHub] zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

zentol commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#discussion_r260723741 ## File path: flink-container/src/main/java/org/apache/flink/container/entrypoint/JarMan

[GitHub] zentol commented on issue #7843: [FLINK-11752] [dist] Move flink-python to opt

zentol commented on issue #7843: [FLINK-11752] [dist] Move flink-python to opt URL: https://github.com/apache/flink/pull/7843#issuecomment-467848662 I still think we shouldn't willy-nilly load classes from /opt; but if there's precedence go ahead and change the script as you suggested. ---

[GitHub] zentol commented on issue #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance"

zentol commented on issue #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance" URL: https://github.com/apache/flink/pull/7820#issuecomment-467851967 @flinkbot approve description If no instance label was provided Prometheus auto-generates one from the host&por

[GitHub] zentol edited a comment on issue #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance"

zentol edited a comment on issue #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance" URL: https://github.com/apache/flink/pull/7820#issuecomment-467851967 @flinkbot approve description If no instance label was provided Prometheus auto-generates one from the h

[GitHub] flinkbot edited a comment on issue #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance"

flinkbot edited a comment on issue #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance" URL: https://github.com/apache/flink/pull/7820#issuecomment-466942158 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-10755) Port external catalogs in Table API extension points to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10755: --- Labels: pull-request-available (was: ) > Port external catalogs in Table API extension poin

[GitHub] dianfu opened a new pull request #7848: [FLINK-10755][table] Port external catalogs in Table API extension points to flink-table-common

dianfu opened a new pull request #7848: [FLINK-10755][table] Port external catalogs in Table API extension points to flink-table-common URL: https://github.com/apache/flink/pull/7848 ## What is the purpose of the change *This pull request ported external catalog to flink-table-common

[GitHub] flinkbot commented on issue #7848: [FLINK-10755][table] Port external catalogs in Table API extension points to flink-table-common

flinkbot commented on issue #7848: [FLINK-10755][table] Port external catalogs in Table API extension points to flink-table-common URL: https://github.com/apache/flink/pull/7848#issuecomment-467855282 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] dianfu commented on issue #7848: [FLINK-10755][table] Port external catalogs in Table API extension points to flink-table-common

dianfu commented on issue #7848: [FLINK-10755][table] Port external catalogs in Table API extension points to flink-table-common URL: https://github.com/apache/flink/pull/7848#issuecomment-467855706 @twalthr Have created a PR to port external catalogs to flink-table-common. Could you help

[GitHub] tzulitai opened a new pull request #7849: [FLINK-11772] [DataStream] InternalTimerServiceSerializationProxy should not be using the new serialization compatibility abstractions

tzulitai opened a new pull request #7849: [FLINK-11772] [DataStream] InternalTimerServiceSerializationProxy should not be using the new serialization compatibility abstractions URL: https://github.com/apache/flink/pull/7849 ## What is the purpose of the change This PR is based on #7

[GitHub] flinkbot commented on issue #7849: [FLINK-11772] [DataStream] InternalTimerServiceSerializationProxy should not be using the new serialization compatibility abstractions

flinkbot commented on issue #7849: [FLINK-11772] [DataStream] InternalTimerServiceSerializationProxy should not be using the new serialization compatibility abstractions URL: https://github.com/apache/flink/pull/7849#issuecomment-467856427 Thanks a lot for your contribution to the Apache F

[jira] [Updated] (FLINK-11772) InternalTimerServiceSerializationProxy should not be serializing timers' key / namespace serializers anymore

[ https://issues.apache.org/jira/browse/FLINK-11772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11772: --- Labels: pull-request-available (was: ) > InternalTimerServiceSerializationProxy should not

[GitHub] zentol commented on a change in pull request #7797: [FLINK-11379] Fix OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD

zentol commented on a change in pull request #7797: [FLINK-11379] Fix OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD URL: https://github.com/apache/flink/pull/7797#discussion_r260740825 ## File path: flink-core/src/main/java/org/apache/flink/util/File

[GitHub] zentol commented on issue #7797: [FLINK-11379] Fix OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD

zentol commented on issue #7797: [FLINK-11379] Fix OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD URL: https://github.com/apache/flink/pull/7797#issuecomment-467856518 There are outstanding licensing issues that need to be resolved. @flinkbot disapprov

[GitHub] uce commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

uce commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#discussion_r260742710 ## File path: flink-container/kubernetes/README.md ## @@ -42,6 +41,7 @@ At last, y

[GitHub] uce commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

uce commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#discussion_r260743482 ## File path: flink-container/pom.xml ## @@ -66,4 +66,64 @@ under the License.

[GitHub] zentol commented on a change in pull request #7797: [FLINK-11379] Fix OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD

zentol commented on a change in pull request #7797: [FLINK-11379] Fix OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD URL: https://github.com/apache/flink/pull/7797#discussion_r260743854 ## File path: flink-core/src/main/java/org/apache/flink/util/File

[GitHub] uce commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

uce commented on a change in pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#discussion_r260744178 ## File path: flink-container/src/main/java/org/apache/flink/container/entrypoint/ClassPath

  1   2   3   4   >