[GitHub] tzulitai commented on issue #7823: [hotfix][tests]Fix typo in RollingSinkSecuredITCase.java.

tzulitai commented on issue #7823: [hotfix][tests]Fix typo in RollingSinkSecuredITCase.java. URL: https://github.com/apache/flink/pull/7823#issuecomment-468174898 @flinkbot approve all Thanks, merging .. This is an aut

[jira] [Closed] (FLINK-11777) fix hadoop_compatibility.md link bug

[ https://issues.apache.org/jira/browse/FLINK-11777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11777. --- Resolution: Fixed Fix Version/s: 1.9.0 1.8.0 Fixed in master: 626cbc6ef3ff

[jira] [Updated] (FLINK-11777) fix hadoop_compatibility.md link bug

[ https://issues.apache.org/jira/browse/FLINK-11777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11777: --- Labels: pull-request-available (was: ) > fix hadoop_compatibility.md link bug > ---

[GitHub] asfgit closed pull request #7802: [FLINK-11777] [docs] Remove and update useless html anchor in hadoop_compatibility.md

asfgit closed pull request #7802: [FLINK-11777] [docs] Remove and update useless html anchor in hadoop_compatibility.md URL: https://github.com/apache/flink/pull/7802 This is an automated message from the Apache Git Service.

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

KurtYoung 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_r261076888 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

[GitHub] flinkbot commented on issue #7856: [FLINK-11776][coordination] Refactor to simplify the process of scheduleOrUpdateConsumers

flinkbot commented on issue #7856: [FLINK-11776][coordination] Refactor to simplify the process of scheduleOrUpdateConsumers URL: https://github.com/apache/flink/pull/7856#issuecomment-468170966 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the c

[jira] [Updated] (FLINK-11776) Refactor to simplify the process of scheduleOrUpdateConsumers

[ https://issues.apache.org/jira/browse/FLINK-11776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11776: --- Labels: pull-request-available (was: ) > Refactor to simplify the process of scheduleOrUpda

[GitHub] zhijiangW opened a new pull request #7856: [FLINK-11776][coordination] Refactor to simplify the process of scheduleOrUpdateConsumers

zhijiangW opened a new pull request #7856: [FLINK-11776][coordination] Refactor to simplify the process of scheduleOrUpdateConsumers URL: https://github.com/apache/flink/pull/7856 ## What is the purpose of the change *Based on the work of FLINK-11417, the process of `Execution#sched

[GitHub] sunjincheng121 commented on issue #7802: [FLINK-11777] [docs] Remove and update useless html anchor in hadoop_compatibility.md

sunjincheng121 commented on issue #7802: [FLINK-11777] [docs] Remove and update useless html anchor in hadoop_compatibility.md URL: https://github.com/apache/flink/pull/7802#issuecomment-468169132 Merging... This is an automa

[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_r261073648 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apa

[GitHub] yanghua commented on issue #7375: [FLINK-11175][docs][table] Fix the sample code describing the Processing tim…

yanghua commented on issue #7375: [FLINK-11175][docs][table] Fix the sample code describing the Processing tim… URL: https://github.com/apache/flink/pull/7375#issuecomment-468168395 @sunjincheng121 if you have time, can you review this PR? thanks. --

[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_r261072851 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apa

[GitHub] flinkbot edited a comment on issue #7802: [hotfix][docs] Remove and update useless html anchor in hadoop_compatibility.md

flinkbot edited a comment on issue #7802: [hotfix][docs] Remove and update useless html anchor in hadoop_compatibility.md URL: https://github.com/apache/flink/pull/7802#issuecomment-466305120 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the comm

[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_r261072763 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apa

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

KurtYoung 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_r261072531 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

[GitHub] sunjincheng121 commented on issue #7802: [hotfix][docs] Remove and update useless html anchor in hadoop_compatibility.md

sunjincheng121 commented on issue #7802: [hotfix][docs] Remove and update useless html anchor in hadoop_compatibility.md URL: https://github.com/apache/flink/pull/7802#issuecomment-468167356 LGTM. +1 to merged. @flinkbot approve all --

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

KurtYoung 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_r261071464 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

[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] 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] wuchong commented on a change in pull request #7817: [FLINK-11702][table-planner-blink] Introduce a new table type system: InternalType

wuchong 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_r261071015 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache

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

KurtYoung 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_r261070774 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

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

KurtYoung 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_r261070322 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

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

KurtYoung 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_r261070021 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

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

KurtYoung 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_r261070152 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

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

KurtYoung 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_r261069766 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

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

KurtYoung 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_r261069514 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

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

KurtYoung 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_r261069060 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

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

KurtYoung 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_r261068921 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

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

KurtYoung 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_r261068676 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

[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

[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

[jira] [Created] (FLINK-11777) fix hadoop_compatibility.md link bug

sunjincheng created FLINK-11777: --- Summary: fix hadoop_compatibility.md link bug Key: FLINK-11777 URL: https://issues.apache.org/jira/browse/FLINK-11777 Project: Flink Issue Type: Improvement

[GitHub] sunjincheng121 commented on issue #7802: [hotfix][docs] Remove and update useless html anchor in hadoop_compatibility.md

sunjincheng121 commented on issue #7802: [hotfix][docs] Remove and update useless html anchor in hadoop_compatibility.md URL: https://github.com/apache/flink/pull/7802#issuecomment-468158248 I have created the JIRA. FLINK-11777 and link the PR to it. @wenhuitang --

[GitHub] Clarkkkkk commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base

Clark commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base URL: https://github.com/apache/flink/pull/7780#discussion_r261064038 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecuto

[GitHub] Clarkkkkk commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base

Clark commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base URL: https://github.com/apache/flink/pull/7780#discussion_r261063760 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/TestingAbstrac

[GitHub] TisonKun commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base

TisonKun commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base URL: https://github.com/apache/flink/pull/7780#discussion_r261063534 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor

[jira] [Created] (FLINK-11776) Refactor to simplify the process of scheduleOrUpdateConsumers

zhijiang created FLINK-11776: Summary: Refactor to simplify the process of scheduleOrUpdateConsumers Key: FLINK-11776 URL: https://issues.apache.org/jira/browse/FLINK-11776 Project: Flink Issue

[GitHub] Clarkkkkk commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base

Clark commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base URL: https://github.com/apache/flink/pull/7780#discussion_r261062837 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecuto

[GitHub] Clarkkkkk commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base

Clark commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base URL: https://github.com/apache/flink/pull/7780#discussion_r261062947 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/TestingAbstrac

[GitHub] flinkbot edited a comment on issue #7838: [FLINK-11711][table-planner-blink] Add table and column stats

flinkbot edited a comment on issue #7838: [FLINK-11711][table-planner-blink] Add table and column stats URL: https://github.com/apache/flink/pull/7838#issuecomment-467405536 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] KurtYoung commented on issue #7838: [FLINK-11711][table-planner-blink] Add table and column stats

KurtYoung commented on issue #7838: [FLINK-11711][table-planner-blink] Add table and column stats URL: https://github.com/apache/flink/pull/7838#issuecomment-468156451 @flinkbot approve all This is an automated message from t

[GitHub] sunjincheng121 commented on issue #7737: [hotfix][docs] Add that LIMIT requires ORDER BY.

sunjincheng121 commented on issue #7737: [hotfix][docs] Add that LIMIT requires ORDER BY. URL: https://github.com/apache/flink/pull/7737#issuecomment-468152907 Fixed in master: be9f0307d678adfe2040ac82cc71954a3de15ad4 Fixed in release-1.8: 77dc5debfc2aa793bc82ea00e460be15579a0fbe --

[GitHub] asfgit closed pull request #7737: [hotfix][docs] Add that LIMIT requires ORDER BY.

asfgit closed pull request #7737: [hotfix][docs] Add that LIMIT requires ORDER BY. URL: https://github.com/apache/flink/pull/7737 This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] flinkbot edited a comment on issue #7737: [hotfix][docs] Add that LIMIT requires ORDER BY.

flinkbot edited a comment on issue #7737: [hotfix][docs] Add that LIMIT requires ORDER BY. URL: https://github.com/apache/flink/pull/7737#issuecomment-464722427 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull re

[GitHub] sunjincheng121 commented on issue #7737: [hotfix][docs] Add that LIMIT requires ORDER BY.

sunjincheng121 commented on issue #7737: [hotfix][docs] Add that LIMIT requires ORDER BY. URL: https://github.com/apache/flink/pull/7737#issuecomment-468150259 Thanks for the fix @fhueske! LGTM. Merging. @flinkbot approve all --

[jira] [Resolved] (FLINK-11738) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Sen

[ https://issues.apache.org/jira/browse/FLINK-11738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinktothings resolved FLINK-11738. --- Resolution: Fixed master is ok > Caused by: akka.pattern.AskTimeoutException: Ask timed out

[jira] [Commented] (FLINK-11738) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Se

[ https://issues.apache.org/jira/browse/FLINK-11738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16780143#comment-16780143 ] thinktothings commented on FLINK-11738: --- ok,master is ok, !image-2019-02-28-14-05

[jira] [Updated] (FLINK-11738) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Send

[ https://issues.apache.org/jira/browse/FLINK-11738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinktothings updated FLINK-11738: -- Attachment: image-2019-02-28-14-05-51-875.png > Caused by: akka.pattern.AskTimeoutException: A

[jira] [Commented] (FLINK-1728) Add random forest ensemble method to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16780139#comment-16780139 ] Seungchul Lee commented on FLINK-1728: -- [~till.rohrmann] Hi, I would like to know

[GitHub] flinkbot edited a comment on issue #7854: [hotfix][datastream] Fix typo in StreamExecutionEnvironment

flinkbot edited a comment on issue #7854: [hotfix][datastream] Fix typo in StreamExecutionEnvironment URL: https://github.com/apache/flink/pull/7854#issuecomment-468115336 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review y

[GitHub] KurtYoung merged pull request #7854: [hotfix][datastream] Fix typo in StreamExecutionEnvironment

KurtYoung merged pull request #7854: [hotfix][datastream] Fix typo in StreamExecutionEnvironment URL: https://github.com/apache/flink/pull/7854 This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] KurtYoung commented on issue #7854: [hotfix][datastream] Fix typo in StreamExecutionEnvironment

KurtYoung commented on issue #7854: [hotfix][datastream] Fix typo in StreamExecutionEnvironment URL: https://github.com/apache/flink/pull/7854#issuecomment-468147373 @flinkbot approve all This is an automated message from the

[jira] [Updated] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes

[ https://issues.apache.org/jira/browse/FLINK-11775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11775: - Description: Blink new binary format is based on MemorySegment. Introduce MemorySegmentWritable

[GitHub] KurtYoung merged pull request #7855: [hotfix][core] Fix typo in TypeInformation

KurtYoung merged pull request #7855: [hotfix][core] Fix typo in TypeInformation URL: https://github.com/apache/flink/pull/7855 This is an automated message from the Apache Git Service. To respond to the message, please log on

[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-468145920 @bowenli86 Thanks a lot for the suggestions. I'm fine to remove the annotation of Exter

[GitHub] KurtYoung commented on issue #7855: [hotfix][core] Fix typo in TypeInformation

KurtYoung commented on issue #7855: [hotfix][core] Fix typo in TypeInformation URL: https://github.com/apache/flink/pull/7855#issuecomment-468145525 Hi @libenchao , thanks for fixing this, will merge This is an automated messa

[GitHub] flinkbot edited a comment on issue #7855: [hotfix][core] Fix typo in TypeInformation

flinkbot edited a comment on issue #7855: [hotfix][core] Fix typo in TypeInformation URL: https://github.com/apache/flink/pull/7855#issuecomment-468116352 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request.

[jira] [Updated] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes

[ https://issues.apache.org/jira/browse/FLINK-11775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11775: - Description: Blink new binary format is based on MemorySegment. Introduce MemorySegmentWritable

[GitHub] KurtYoung commented on issue #7855: [hotfix][core] Fix typo in TypeInformation

KurtYoung commented on issue #7855: [hotfix][core] Fix typo in TypeInformation URL: https://github.com/apache/flink/pull/7855#issuecomment-468145462 @flinkbot approve all This is an automated message from the Apache Git Se

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

flinkbot edited a comment 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 pul

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

KurtYoung commented on issue #7847: [FLINK-11724][core] Add util method to MemorySegment URL: https://github.com/apache/flink/pull/7847#issuecomment-468144249 @flinkbot approve all @flinkbot attention @StephanEwen This is

[jira] [Commented] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes

[ https://issues.apache.org/jira/browse/FLINK-11775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16780123#comment-16780123 ] Kurt Young commented on FLINK-11775: cc [~StephanEwen], [~pnowojski] > Introduce Me

[GitHub] tzulitai commented on issue #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot

tzulitai commented on issue #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot URL: https://github.com/apache/flink/pull/7852#issuecomment-468143776 @flinkbot approve quality This is an automated message from the Apache

[GitHub] flinkbot edited a comment on issue #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot

flinkbot edited a comment on issue #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot URL: https://github.com/apache/flink/pull/7852#issuecomment-468019919 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull r

[jira] [Commented] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes

[ https://issues.apache.org/jira/browse/FLINK-11775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16780122#comment-16780122 ] Kurt Young commented on FLINK-11775: Hi [~lzljs3620320], could you add some more exp

[GitHub] tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot

tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot URL: https://github.com/apache/flink/pull/7852#discussion_r261048676 ## File path: flink-core/src/main/java/org/apache/flink/util/LinkedOptionalMapSerializer.java ## @@

[GitHub] tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot

tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot URL: https://github.com/apache/flink/pull/7852#discussion_r261050792 ## File path: flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializerSnapsho

[GitHub] tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot

tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot URL: https://github.com/apache/flink/pull/7852#discussion_r261049034 ## File path: flink-core/src/main/java/org/apache/flink/util/LinkedOptionalMapSerializer.java ## @@

[GitHub] tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot

tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot URL: https://github.com/apache/flink/pull/7852#discussion_r261050414 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializerSnapsho

[GitHub] tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot

tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot URL: https://github.com/apache/flink/pull/7852#discussion_r261048428 ## File path: flink-core/src/main/java/org/apache/flink/util/LinkedOptionalMapSerializer.java ## @@

[GitHub] tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot

tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot URL: https://github.com/apache/flink/pull/7852#discussion_r261047891 ## File path: flink-core/src/main/java/org/apache/flink/util/LinkedOptionalMapSerializer.java ## @@

[GitHub] tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot

tzulitai commented on a change in pull request #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot URL: https://github.com/apache/flink/pull/7852#discussion_r26104 ## File path: flink-core/src/main/java/org/apache/flink/util/LinkedOptionalMapSerializer.java ## @@

[jira] [Comment Edited] (FLINK-11335) Kafka consumer can not commit offset at checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16780105#comment-16780105 ] andy hoang edited comment on FLINK-11335 at 2/28/19 5:15 AM: -

[jira] [Comment Edited] (FLINK-11335) Kafka consumer can not commit offset at checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16780105#comment-16780105 ] andy hoang edited comment on FLINK-11335 at 2/28/19 5:14 AM: -

[jira] [Comment Edited] (FLINK-11335) Kafka consumer can not commit offset at checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16780105#comment-16780105 ] andy hoang edited comment on FLINK-11335 at 2/28/19 4:55 AM: -

[jira] [Comment Edited] (FLINK-11335) Kafka consumer can not commit offset at checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16780105#comment-16780105 ] andy hoang edited comment on FLINK-11335 at 2/28/19 4:56 AM: -

[jira] [Commented] (FLINK-11335) Kafka consumer can not commit offset at checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16780105#comment-16780105 ] andy hoang commented on FLINK-11335: [~dawidwys]Thanks for reply, I dont see any asy

[GitHub] KurtYoung commented on a change in pull request #7838: [FLINK-11711][table-planner-blink] Add table and column stats

KurtYoung commented on a change in pull request #7838: [FLINK-11711][table-planner-blink] Add table and column stats URL: https://github.com/apache/flink/pull/7838#discussion_r261039347 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/plan/s

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

JingsongLi commented on issue #7847: [FLINK-11724][core] Add util method to MemorySegment URL: https://github.com/apache/flink/pull/7847#issuecomment-468125223 Jira splited This is an automated message from the Apache Git Ser

[jira] [Created] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes

Jingsong Lee created FLINK-11775: Summary: Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes Key: FLINK-11775 URL: https://issues.apache.org/jira/browse/FLINK-11775 P

[jira] [Updated] (FLINK-11724) Add util method to MemorySegment

[ https://issues.apache.org/jira/browse/FLINK-11724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11724: - Summary: Add util method to MemorySegment (was: Improve MemorySegment) > Add util method to Mem

[jira] [Updated] (FLINK-11724) Add util method to MemorySegment

[ https://issues.apache.org/jira/browse/FLINK-11724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11724: - Description: Blink new binary format is based on MemorySegment. Improve MemorySegment to provid

[GitHub] KurtYoung commented on a change in pull request #7847: [FLINK-11724][core] Add util method to MemorySegment

KurtYoung commented on a change in pull request #7847: [FLINK-11724][core] Add util method to MemorySegment URL: https://github.com/apache/flink/pull/7847#discussion_r261034464 ## File path: flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java ## @@ -1

[GitHub] KurtYoung commented on a change in pull request #7847: [FLINK-11724][core] Add util method to MemorySegment

KurtYoung commented on a change in pull request #7847: [FLINK-11724][core] Add util method to MemorySegment URL: https://github.com/apache/flink/pull/7847#discussion_r261034464 ## File path: flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java ## @@ -1

[GitHub] KurtYoung commented on a change in pull request #7847: [FLINK-11724][core] Add util method to MemorySegment

KurtYoung commented on a change in pull request #7847: [FLINK-11724][core] Add util method to MemorySegment URL: https://github.com/apache/flink/pull/7847#discussion_r261034366 ## File path: flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java ## @@ -1

[GitHub] KurtYoung commented on a change in pull request #7847: [FLINK-11724][core] Add util method to MemorySegment

KurtYoung commented on a change in pull request #7847: [FLINK-11724][core] Add util method to MemorySegment URL: https://github.com/apache/flink/pull/7847#discussion_r261034316 ## File path: flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java ## @@ -1

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

sunhaibotb 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_r261027583 ## File path: flink-core/src/main/java/org/apache/flink/util/

[GitHub] flinkbot edited a comment on issue #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot

flinkbot edited a comment on issue #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot URL: https://github.com/apache/flink/pull/7852#issuecomment-468019919 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull r

[GitHub] tzulitai commented on issue #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot

tzulitai commented on issue #7852: [FLINK-11773][core] Harden KryoSerializerSnapshot URL: https://github.com/apache/flink/pull/7852#issuecomment-468117321 @flinkbot approve description @flinkbot approve architecture @flinkbot approve consensus

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

Tom-Goong commented on issue #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance" URL: https://github.com/apache/flink/pull/7820#issuecomment-468116677 @zentol I am sorry for the reckless submission of PR. As a newcomer, I am still not familiar with the norms of t

[GitHub] flinkbot commented on issue #7855: [hotfix][core] Fix typo in TypeInformation

flinkbot commented on issue #7855: [hotfix][core] Fix typo in TypeInformation URL: https://github.com/apache/flink/pull/7855#issuecomment-468116352 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will

[GitHub] libenchao opened a new pull request #7855: [hotfix][core] Fix typo in TypeInformation

libenchao opened a new pull request #7855: [hotfix][core] Fix typo in TypeInformation URL: https://github.com/apache/flink/pull/7855 ## What is the purpose of the change *Fix typo* ## Brief change log - *Fix typo in TypeInformation* ## Verifying

[GitHub] flinkbot commented on issue #7854: [hotfix][datastream] Fix typo in StreamExecutionEnvironment

flinkbot commented on issue #7854: [hotfix][datastream] Fix typo in StreamExecutionEnvironment URL: https://github.com/apache/flink/pull/7854#issuecomment-468115336 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pul

[GitHub] libenchao opened a new pull request #7854: [hotfix][datastream] Fix typo in StreamExecutionEnvironment

libenchao opened a new pull request #7854: [hotfix][datastream] Fix typo in StreamExecutionEnvironment URL: https://github.com/apache/flink/pull/7854 ## What is the purpose of the change *Fix typo* ## Brief change log - *Fix typo in StreamExecutionEnvironm

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

sunhaibotb 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_r261027583 ## File path: flink-core/src/main/java/org/apache/flink/util/

[jira] [Assigned] (FLINK-7605) JDBCOutputFormat autoCommit

[ https://issues.apache.org/jira/browse/FLINK-7605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-7605: --- Assignee: vinoyang > JDBCOutputFormat autoCommit > --- > > K

[jira] [Commented] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16779985#comment-16779985 ] vinoyang commented on FLINK-6573: - [~Zentol] and [~till.rohrmann] Do you think this is a

[GitHub] wyx5921921 closed pull request #7853: blink first commit

wyx5921921 closed pull request #7853: blink first commit URL: https://github.com/apache/flink/pull/7853 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL

[GitHub] klion26 commented on issue #7853: blink first commit

klion26 commented on issue #7853: blink first commit URL: https://github.com/apache/flink/pull/7853#issuecomment-468100602 @wyx5921921 I think this pr is not needed, could you please close it? This is an automated message from

[jira] [Assigned] (FLINK-11141) Key generation for RocksDBMapState can theoretically be ambiguous

[ https://issues.apache.org/jira/browse/FLINK-11141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-11141: - Assignee: (was: Congxian Qiu(klion26)) > Key generation for RocksDB

  1   2   3   4   >