[jira] [Updated] (FLINK-16847) Support timestamp types in vectorized Python UDF

2020-03-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16847: --- Labels: pull-request-available (was: ) > Support timestamp types in vectorized Python UDF

[GitHub] [flink] dianfu opened a new pull request #11556: [FLINK-16847][python] Support timestamp types in vectorized Python UDF

2020-03-28 Thread GitBox
dianfu opened a new pull request #11556: [FLINK-16847][python] Support timestamp types in vectorized Python UDF URL: https://github.com/apache/flink/pull/11556 ## What is the purpose of the change *This pull request adds support of LocalZonedTimestampType and TimestampType in

[GitHub] [flink] flinkbot edited a comment on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix URL: https://github.com/apache/flink/pull/11482#issuecomment-60726 ## CI report: * 54a34b1dcbcaff049bed0cd11033711e44c38ccf Travis:

[jira] [Created] (FLINK-16847) Support timestamp types in vectorized Python UDF

2020-03-28 Thread Dian Fu (Jira)
Dian Fu created FLINK-16847: --- Summary: Support timestamp types in vectorized Python UDF Key: FLINK-16847 URL: https://issues.apache.org/jira/browse/FLINK-16847 Project: Flink Issue Type: Task

[GitHub] [flink-statefun] tzulitai closed pull request #79: [FLINK-16730][docs] Add walkthrough distribution as build step

2020-03-28 Thread GitBox
tzulitai closed pull request #79: [FLINK-16730][docs] Add walkthrough distribution as build step URL: https://github.com/apache/flink-statefun/pull/79 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink-statefun] tzulitai edited a comment on issue #79: [FLINK-16730][docs] Add walkthrough distribution as build step

2020-03-28 Thread GitBox
tzulitai edited a comment on issue #79: [FLINK-16730][docs] Add walkthrough distribution as build step URL: https://github.com/apache/flink-statefun/pull/79#issuecomment-605554070 After some time thinking about this, I think we probably shouldn’t rush adding the zip dist building as a

[GitHub] [flink-statefun] tzulitai edited a comment on issue #79: [FLINK-16730][docs] Add walkthrough distribution as build step

2020-03-28 Thread GitBox
tzulitai edited a comment on issue #79: [FLINK-16730][docs] Add walkthrough distribution as build step URL: https://github.com/apache/flink-statefun/pull/79#issuecomment-605554070 After some time thinking about this, I think we probably shouldn’t rush adding the zip dist building as a

[GitHub] [flink-statefun] tzulitai edited a comment on issue #79: [FLINK-16730][docs] Add walkthrough distribution as build step

2020-03-28 Thread GitBox
tzulitai edited a comment on issue #79: [FLINK-16730][docs] Add walkthrough distribution as build step URL: https://github.com/apache/flink-statefun/pull/79#issuecomment-605554070 After some time thinking about this, I think we probably shouldn’t rush adding the zip dist building as a

[GitHub] [flink-statefun] tzulitai commented on issue #79: [FLINK-16730][docs] Add walkthrough distribution as build step

2020-03-28 Thread GitBox
tzulitai commented on issue #79: [FLINK-16730][docs] Add walkthrough distribution as build step URL: https://github.com/apache/flink-statefun/pull/79#issuecomment-605554070 After some time thinking about this, I think we probably shouldn’t rush adding the zip dist building as a Maven

[jira] [Closed] (FLINK-16489) Use flink on yarn,RM restart AM,but the flink job is not restart from the saved checkpoint.

2020-03-28 Thread liangji (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liangji closed FLINK-16489. --- Resolution: Not A Problem > Use flink on yarn,RM restart AM,but the flink job is not restart from the >

[jira] [Issue Comment Deleted] (FLINK-16489) Use flink on yarn,RM restart AM,but the flink job is not restart from the saved checkpoint.

2020-03-28 Thread liangji (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liangji updated FLINK-16489: Comment: was deleted (was: reopen because of the AM attempt exceeds the num of 

[jira] [Issue Comment Deleted] (FLINK-16489) Use flink on yarn,RM restart AM,but the flink job is not restart from the saved checkpoint.

2020-03-28 Thread liangji (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liangji updated FLINK-16489: Comment: was deleted (was: Additional,I have another question. When I killed JM progress of 5 times, AM

[GitHub] [flink] godfreyhe commented on issue #11544: [FLINK-16822] [sql-client] `table.xx` property set from CLI should also be set into SessionState's TableConfig

2020-03-28 Thread GitBox
godfreyhe commented on issue #11544: [FLINK-16822] [sql-client] `table.xx` property set from CLI should also be set into SessionState's TableConfig URL: https://github.com/apache/flink/pull/11544#issuecomment-605552309 > Can this also fix runtime environment configurations? Currently, SET

[GitHub] [flink] godfreyhe commented on a change in pull request #11544: [FLINK-16822] [sql-client] `table.xx` property set from CLI should also be set into SessionState's TableConfig

2020-03-28 Thread GitBox
godfreyhe commented on a change in pull request #11544: [FLINK-16822] [sql-client] `table.xx` property set from CLI should also be set into SessionState's TableConfig URL: https://github.com/apache/flink/pull/11544#discussion_r399738426 ## File path:

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #79: [FLINK-16730][docs] Add walkthrough distribution as build step

2020-03-28 Thread GitBox
tzulitai commented on a change in pull request #79: [FLINK-16730][docs] Add walkthrough distribution as build step URL: https://github.com/apache/flink-statefun/pull/79#discussion_r399734879 ## File path: statefun-examples/statefun-python-greeter/pom.xml ## @@ -0,0 +1,55

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #79: [FLINK-16730][docs] Add walkthrough distribution as build step

2020-03-28 Thread GitBox
tzulitai commented on a change in pull request #79: [FLINK-16730][docs] Add walkthrough distribution as build step URL: https://github.com/apache/flink-statefun/pull/79#discussion_r399735561 ## File path: tools/releasing/update_branch_version.sh ## @@ -77,6 +77,9 @@ perl

[GitHub] [flink] flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism URL: https://github.com/apache/flink/pull/11356#issuecomment-596856858 ## CI report: * ce87022bb654cbee5e5ac8f31c6e72dc03b89c9f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism URL: https://github.com/apache/flink/pull/11356#issuecomment-596856858 ## CI report: * ce87022bb654cbee5e5ac8f31c6e72dc03b89c9f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism URL: https://github.com/apache/flink/pull/11356#issuecomment-596856858 ## CI report: * 545fd6194256f5daefac1e0a6fc2d7fb349c7aa6 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism URL: https://github.com/apache/flink/pull/11356#issuecomment-596856858 ## CI report: * 545fd6194256f5daefac1e0a6fc2d7fb349c7aa6 Travis:

[GitHub] [flink] faaronzheng commented on a change in pull request #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism

2020-03-28 Thread GitBox
faaronzheng commented on a change in pull request #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism URL: https://github.com/apache/flink/pull/11356#discussion_r399729007 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism URL: https://github.com/apache/flink/pull/11356#issuecomment-596856858 ## CI report: * 8917c0690a4d84ac1ca15a4ca4f68af921f8bdc1 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism URL: https://github.com/apache/flink/pull/11356#issuecomment-596856858 ## CI report: * 8917c0690a4d84ac1ca15a4ca4f68af921f8bdc1 Travis:

[jira] [Comment Edited] (FLINK-16846) Add python docker images

2020-03-28 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-16846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070016#comment-17070016 ] Ismaël Mejía edited comment on FLINK-16846 at 3/28/20, 9:16 PM:

[jira] [Updated] (FLINK-16846) Add python docker images

2020-03-28 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-16846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated FLINK-16846: - Summary: Add python docker images (was: Add docker images with python) > Add python docker

[jira] [Commented] (FLINK-16773) Flink 1.10 test execution is broken due to premature test cluster shutdown

2020-03-28 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-16773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070020#comment-17070020 ] Ismaël Mejía commented on FLINK-16773: -- Was this bug intended to be created on the Beam issue

[jira] [Commented] (FLINK-16846) Add docker images with python

2020-03-28 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-16846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070016#comment-17070016 ] Ismaël Mejía commented on FLINK-16846: -- [~plucas] WDYT? I will write a message to the ML to see

[jira] [Created] (FLINK-16846) Add docker images with python

2020-03-28 Thread Jira
Ismaël Mejía created FLINK-16846: Summary: Add docker images with python Key: FLINK-16846 URL: https://issues.apache.org/jira/browse/FLINK-16846 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-605488014 ## CI report: * c5b4e3f0e6267ce5f6bbcd1c920516a2f0f420f9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-605488014 ## CI report: * c5b4e3f0e6267ce5f6bbcd1c920516a2f0f420f9 Travis:

[jira] [Updated] (FLINK-16260) Add docker images based on Java 11

2020-03-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16260: --- Labels: pull-request-available (was: ) > Add docker images based on Java 11 >

[GitHub] [flink-docker] iemejia opened a new pull request #9: [FLINK-16260][docker] Add docker images based on Java 11

2020-03-28 Thread GitBox
iemejia opened a new pull request #9: [FLINK-16260][docker] Add docker images based on Java 11 URL: https://github.com/apache/flink-docker/pull/9 I have some doubts now that we are back to the Apache Flink repo. - Do we need an additional Flink committer in place to merge/publish this

[GitHub] [flink-statefun] sjwiesman opened a new pull request #79: [FLINK-16730][docs] Add walkthrough distribution as build step

2020-03-28 Thread GitBox
sjwiesman opened a new pull request #79: [FLINK-16730][docs] Add walkthrough distribution as build step URL: https://github.com/apache/flink-statefun/pull/79 The python walkthrough is based on the python greeter example and includes skeleton code to quickly get started. Python does not

[jira] [Closed] (FLINK-16838) Stateful Functions Quickstart archetype Dockerfile should reference a specific version tag

2020-03-28 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16838. --- Fix Version/s: statefun-2.0 Resolution: Fixed Fixed. master via

[jira] [Closed] (FLINK-16842) Ridesharing example simulator built artifact is missing NOTICE / LICENSE for bundled dependencies

2020-03-28 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16842. --- Resolution: Fixed Fixed. master - 6f6476cb99f9e70925c2b483c69eaca18fb52cc0

[jira] [Closed] (FLINK-16841) Stateful Function artifacts jars should not bundle proto sources

2020-03-28 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16841. --- Resolution: Fixed Fixed - master: e72eb732ba6403ab915ab73570a9d96431254fa9

[jira] [Closed] (FLINK-16843) Python SDK distribution is missing LICENSE and NOTICE files

2020-03-28 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16843. --- Resolution: Fixed Fixed. master - a06db812d3f4c153886df97e31d96d9534b1ca67

[jira] [Commented] (FLINK-16730) Python SDK Getting Started

2020-03-28 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17069961#comment-17069961 ] Tzu-Li (Gordon) Tai commented on FLINK-16730: - Resolved in release-2.0 with

[GitHub] [flink] flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-605488014 ## CI report: * c5b4e3f0e6267ce5f6bbcd1c920516a2f0f420f9 Travis:

[GitHub] [flink] zentol commented on issue #11551: [FLINK-16834] Add flink-clients dependency to all example modules

2020-03-28 Thread GitBox
zentol commented on issue #11551: [FLINK-16834] Add flink-clients dependency to all example modules URL: https://github.com/apache/flink/pull/11551#issuecomment-605488892 we must add this dependency directly to the example; the scala dependency must not be in a parent pom module.

[GitHub] [flink] flinkbot commented on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

2020-03-28 Thread GitBox
flinkbot commented on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-605488014 ## CI report: * c5b4e3f0e6267ce5f6bbcd1c920516a2f0f420f9 UNKNOWN Bot

[GitHub] [flink] flinkbot commented on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

2020-03-28 Thread GitBox
flinkbot commented on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-605485414 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-16576) State inconsistency on restore with memory state backends

2020-03-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16576: --- Labels: pull-request-available (was: ) > State inconsistency on restore with memory state

[GitHub] [flink] klion26 opened a new pull request #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

2020-03-28 Thread GitBox
klion26 opened a new pull request #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555 ## What is the purpose of the change This pr will return null if the handler's key-group does not

[jira] [Updated] (FLINK-15981) Control the direct memory in FileChannelBoundedData.FileBufferReader

2020-03-28 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-15981: - Fix Version/s: (was: 1.10.1) (was: 1.11.0) > Control the direct memory in

[GitHub] [flink] flinkbot edited a comment on issue #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#issuecomment-605459909 ## CI report: * 7f2e408128e5d7929dd4301362a20d8d90c69597 Travis:

[jira] [Commented] (FLINK-16787) Provide an assigner strategy of average splits allocation

2020-03-28 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17069927#comment-17069927 ] Zhijiang commented on FLINK-16787: -- I guess this feature would be involved in more components, from API

[jira] [Updated] (FLINK-16787) Provide an assigner strategy of average splits allocation

2020-03-28 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16787: - Component/s: Runtime / Coordination API / Core > Provide an assigner strategy of

[GitHub] [flink-statefun] tzulitai commented on issue #77: [FLINK-16730][docs] Python SDK Getting Started

2020-03-28 Thread GitBox
tzulitai commented on issue #77: [FLINK-16730][docs] Python SDK Getting Started URL: https://github.com/apache/flink-statefun/pull/77#issuecomment-605461026 Backporting to `release-2.0` to be included in RC3 This is an

[GitHub] [flink-statefun] tzulitai closed pull request #78: [FLINK-16838] Change base image name and apply versioning

2020-03-28 Thread GitBox
tzulitai closed pull request #78: [FLINK-16838] Change base image name and apply versioning URL: https://github.com/apache/flink-statefun/pull/78 This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-16787) Provide an assigner strategy of average splits allocation

2020-03-28 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16787: - Fix Version/s: (was: 1.11.0) > Provide an assigner strategy of average splits allocation >

[GitHub] [flink] flinkbot commented on issue #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-03-28 Thread GitBox
flinkbot commented on issue #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#issuecomment-605459909 ## CI report: * 7f2e408128e5d7929dd4301362a20d8d90c69597 UNKNOWN Bot commands The

[jira] [Assigned] (FLINK-16845) Implement SourceReaderOperator which runs the SourceReader.

2020-03-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-16845: Assignee: Jiangjie Qin > Implement SourceReaderOperator which runs the SourceReader. >

[jira] [Created] (FLINK-16845) Implement SourceReaderOperator which runs the SourceReader.

2020-03-28 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-16845: Summary: Implement SourceReaderOperator which runs the SourceReader. Key: FLINK-16845 URL: https://issues.apache.org/jira/browse/FLINK-16845 Project: Flink

[GitHub] [flink-statefun] tzulitai commented on issue #78: [FLINK-16838] Change base image name and apply versioning

2020-03-28 Thread GitBox
tzulitai commented on issue #78: [FLINK-16838] Change base image name and apply versioning URL: https://github.com/apache/flink-statefun/pull/78#issuecomment-605458402 Thanks for the fast review Igal. Merging ... This

[jira] [Commented] (FLINK-15101) Add implementation for SourceCoordinator

2020-03-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17069478#comment-17069478 ] Jiangjie Qin commented on FLINK-15101: -- [~trohrmann] Sorry for the belated reply. Yes, that makes a

[jira] [Updated] (FLINK-15101) Add implementation for SourceCoordinator

2020-03-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-15101: - Summary: Add implementation for SourceCoordinator (was: Add implementation for

[jira] [Updated] (FLINK-15101) Add implementation for SourceCoordinator

2020-03-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-15101: - Description: This ticket should implement the SourceCoordinator which runs the SplitEnumerator.

[jira] [Closed] (FLINK-15100) Add the interface and base implementation for SourceReader.

2020-03-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-15100. Resolution: Implemented merged to master:  4f6efedd31d0e7705a094725824ddec8940efb3b > Add the

[GitHub] [flink] flinkbot commented on issue #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-03-28 Thread GitBox
flinkbot commented on issue #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#issuecomment-605457410 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] becketqin commented on issue #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-03-28 Thread GitBox
becketqin commented on issue #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#issuecomment-605457279 @StephanEwen This is the patch for SourceCoordinator implementation. Do you have time to take a look? Thanks.

[jira] [Updated] (FLINK-15101) Add implementation for SourceCoordinator and integration with JobMaster

2020-03-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15101: --- Labels: pull-request-available (was: ) > Add implementation for SourceCoordinator and

[GitHub] [flink] becketqin opened a new pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-03-28 Thread GitBox
becketqin opened a new pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554 ## What is the purpose of the change This patch is a part of

[jira] [Resolved] (FLINK-16262) Class loader problem with FlinkKafkaProducer.Semantic.EXACTLY_ONCE and usrlib directory

2020-03-28 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang resolved FLINK-16262. -- Resolution: Fixed Merged in release-1.10: e39cfe7660daaeed4213f04ccbce6de1e8d90fe5 Merged in master: 

[jira] [Commented] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

2020-03-28 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17069458#comment-17069458 ] Zhijiang commented on FLINK-16821: -- Thanks for solving it [~rmetzger]! I guess it is already needed

[GitHub] [flink] zhijiangW merged pull request #11497: [FLINK-16262][Connectors] Set the context classloader for parallel stream in FlinkKafkaProducer

2020-03-28 Thread GitBox
zhijiangW merged pull request #11497: [FLINK-16262][Connectors] Set the context classloader for parallel stream in FlinkKafkaProducer URL: https://github.com/apache/flink/pull/11497 This is an automated message from the

[GitHub] [flink] zhijiangW merged pull request #11247: [FLINK-16262][Connectors] Set the context classloader for parallel stream in FlinkKafkaProducer

2020-03-28 Thread GitBox
zhijiangW merged pull request #11247: [FLINK-16262][Connectors] Set the context classloader for parallel stream in FlinkKafkaProducer URL: https://github.com/apache/flink/pull/11247 This is an automated message from the

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

2020-03-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17069437#comment-17069437 ] Yun Gao commented on FLINK-10114: - [~zenfenan] Very thanks for the doc and PR, I will also take a look

[GitHub] [flink] flinkbot edited a comment on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix URL: https://github.com/apache/flink/pull/11482#issuecomment-60726 ## CI report: * 54a34b1dcbcaff049bed0cd11033711e44c38ccf Travis:

[jira] [Commented] (FLINK-16576) State inconsistency on restore with memory state backends

2020-03-28 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17069428#comment-17069428 ] Congxian Qiu(klion26) commented on FLINK-16576: --- The reason why the restore failed here

[GitHub] [flink] flinkbot edited a comment on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix URL: https://github.com/apache/flink/pull/11482#issuecomment-60726 ## CI report: * 95c74ce398cdc779ac895edb7cf3433579f1 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix URL: https://github.com/apache/flink/pull/11482#issuecomment-60726 ## CI report: * 95c74ce398cdc779ac895edb7cf3433579f1 Travis:

[GitHub] [flink] mxm commented on issue #11473: [FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval

2020-03-28 Thread GitBox
mxm commented on issue #11473: [FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval URL: https://github.com/apache/flink/pull/11473#issuecomment-605432413 @flinkbot run azure This is an

[GitHub] [flink] mxm commented on issue #11473: [FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval

2020-03-28 Thread GitBox
mxm commented on issue #11473: [FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval URL: https://github.com/apache/flink/pull/11473#issuecomment-605432479 Travis passes, though the Flink bot doesn't seem to recognize that:

[GitHub] [flink] lsyldliu commented on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix

2020-03-28 Thread GitBox
lsyldliu commented on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix URL: https://github.com/apache/flink/pull/11482#issuecomment-605432227 @wuchong CC This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * f2415e335c546fff15d8f432e673da8ef0eb72ae Travis:

[jira] [Created] (FLINK-16844) Support retract message for StreamExecGroupWindowAggregate in blink planner

2020-03-28 Thread Benchao Li (Jira)
Benchao Li created FLINK-16844: -- Summary: Support retract message for StreamExecGroupWindowAggregate in blink planner Key: FLINK-16844 URL: https://issues.apache.org/jira/browse/FLINK-16844 Project:

[jira] [Commented] (FLINK-16411) Maven central connection timeouts on Azure Pipelines

2020-03-28 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17069378#comment-17069378 ] Piotr Nowojski commented on FLINK-16411: Can we run our own mvn cache on the AliCloud or sth

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * f2415e335c546fff15d8f432e673da8ef0eb72ae Travis:

[jira] [Created] (FLINK-16843) Python SDK distribution is missing LICENSE and NOTICE files

2020-03-28 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-16843: --- Summary: Python SDK distribution is missing LICENSE and NOTICE files Key: FLINK-16843 URL: https://issues.apache.org/jira/browse/FLINK-16843 Project:

[jira] [Commented] (FLINK-16835) Replace TableConfig with Configuration

2020-03-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17069370#comment-17069370 ] Jingsong Lee commented on FLINK-16835: -- +1 to the replacement. [~jark] I think it is time to

[jira] [Commented] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-28 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17069357#comment-17069357 ] tartarus commented on FLINK-16626: -- This is JM logs,but It's a surface phenomenon. {code:java}

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * 2c3fb6f86e182998f2207926cddb7b1b3e9dd44d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test

2020-03-28 Thread GitBox
flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * 2c3fb6f86e182998f2207926cddb7b1b3e9dd44d Travis:

[jira] [Created] (FLINK-16842) Ridesharing example simulator built artifact is missing NOTICE / LICENSE for bundled dependencies

2020-03-28 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-16842: --- Summary: Ridesharing example simulator built artifact is missing NOTICE / LICENSE for bundled dependencies Key: FLINK-16842 URL:

[jira] [Created] (FLINK-16841) Stateful Function artifacts jars should not bundle proto sources

2020-03-28 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-16841: --- Summary: Stateful Function artifacts jars should not bundle proto sources Key: FLINK-16841 URL: https://issues.apache.org/jira/browse/FLINK-16841

[jira] [Commented] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policies

2020-03-28 Thread Sivaprasanna Sethuraman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17069306#comment-17069306 ] Sivaprasanna Sethuraman commented on FLINK-11499: - [~pnowojski] Regarding point #1 in

[GitHub] [flink-statefun] igalshilman removed a comment on issue #78: [FLINK-16838] Change base image name and apply versioning

2020-03-28 Thread GitBox
igalshilman removed a comment on issue #78: [FLINK-16838] Change base image name and apply versioning URL: https://github.com/apache/flink-statefun/pull/78#issuecomment-605412130 Thanks! This looks good to me. This is an

[GitHub] [flink-statefun] igalshilman commented on issue #78: [FLINK-16838] Change base image name and apply versioning

2020-03-28 Thread GitBox
igalshilman commented on issue #78: [FLINK-16838] Change base image name and apply versioning URL: https://github.com/apache/flink-statefun/pull/78#issuecomment-605412130 Thanks! This looks good to me. This is an

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #78: [FLINK-16838] Change base image name and apply versioning

2020-03-28 Thread GitBox
tzulitai commented on a change in pull request #78: [FLINK-16838] Change base image name and apply versioning URL: https://github.com/apache/flink-statefun/pull/78#discussion_r399633529 ## File path: statefun-e2e-tests/statefun-routable-kafka-e2e/src/test/resources/Dockerfile

[jira] [Updated] (FLINK-16840) PostgresCatalogTest fails waiting for server

2020-03-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-16840: --- Labels: test-stability (was: ) > PostgresCatalogTest fails waiting for server >

[jira] [Created] (FLINK-16840) PostgresCatalogTest fails waiting for server

2020-03-28 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-16840: -- Summary: PostgresCatalogTest fails waiting for server Key: FLINK-16840 URL: https://issues.apache.org/jira/browse/FLINK-16840 Project: Flink Issue Type:

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #78: [FLINK-16838] Change base image name and apply versioning

2020-03-28 Thread GitBox
tzulitai commented on a change in pull request #78: [FLINK-16838] Change base image name and apply versioning URL: https://github.com/apache/flink-statefun/pull/78#discussion_r399633194 ## File path: statefun-e2e-tests/statefun-routable-kafka-e2e/src/test/resources/Dockerfile

[GitHub] [flink-statefun] tzulitai opened a new pull request #78: [FLINK-16838] Change base image name and apply versioning

2020-03-28 Thread GitBox
tzulitai opened a new pull request #78: [FLINK-16838] Change base image name and apply versioning URL: https://github.com/apache/flink-statefun/pull/78 This PR has the following end-goal in mind: - Examples / E2E tests / quickstart archetype built or run from snapshot versions (i.e.

[jira] [Updated] (FLINK-16838) Stateful Functions Quickstart archetype Dockerfile should reference a specific version tag

2020-03-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16838: --- Labels: pull-request-available (was: ) > Stateful Functions Quickstart archetype

[GitHub] [flink] carp84 commented on issue #11491: [FLINK-16513][checkpointing] Unaligned checkpoints: checkpoint metadata

2020-03-28 Thread GitBox
carp84 commented on issue #11491: [FLINK-16513][checkpointing] Unaligned checkpoints: checkpoint metadata URL: https://github.com/apache/flink/pull/11491#issuecomment-605403180 Thanks for the ping @pnowojski @rkhachatryan , and sorry for the late response. I've noticed this one and asked