[jira] [Assigned] (FLINK-22670) Initial HybridSource DataStream Implementation

2021-05-15 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-22670: Assignee: Thomas Weise > Initial HybridSource DataStream Implementation > ---

[jira] [Updated] (FLINK-22670) Initial HybridSource DataStream Implementation

2021-05-15 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-22670: - Description: Implementation based on FLIP-27 interfaces that supports fixed start position and

[jira] [Created] (FLINK-22670) Initial HybridSource DataStream Implementation

2021-05-15 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-22670: Summary: Initial HybridSource DataStream Implementation Key: FLINK-22670 URL: https://issues.apache.org/jira/browse/FLINK-22670 Project: Flink Issue Type: Su

[GitHub] [flink] flinkbot edited a comment on pull request #15923: [hotfix][docs] Changed argument for toDataStream to Table

2021-05-15 Thread GitBox
flinkbot edited a comment on pull request #15923: URL: https://github.com/apache/flink/pull/15923#issuecomment-841717558 ## CI report: * 3f6fb83078530163e28e2fc9c171428e6c784d2e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22483) Recover checkpoints when JobMaster gains leadership

2021-05-15 Thread Eduardo Winpenny Tejedor (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345584#comment-17345584 ] Eduardo Winpenny Tejedor commented on FLINK-22483: -- Hi I'm willing to t

[GitHub] [flink] flinkbot edited a comment on pull request #15923: [hotfix][docs] Changed argument for toDataStream to Table

2021-05-15 Thread GitBox
flinkbot edited a comment on pull request #15923: URL: https://github.com/apache/flink/pull/15923#issuecomment-841717558 ## CI report: * 3f6fb83078530163e28e2fc9c171428e6c784d2e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #15923: [hotfix][docs] Changed argument for toDataStream to Table

2021-05-15 Thread GitBox
flinkbot commented on pull request #15923: URL: https://github.com/apache/flink/pull/15923#issuecomment-841717558 ## CI report: * 3f6fb83078530163e28e2fc9c171428e6c784d2e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15923: [hotfix][docs] Changed argument for toDataStream to Table

2021-05-15 Thread GitBox
flinkbot commented on pull request #15923: URL: https://github.com/apache/flink/pull/15923#issuecomment-841714500 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 use this comment to track the pro

[GitHub] [flink] mans2singh opened a new pull request #15923: [hotfix][docs] Changed argument for toDataStream to Table

2021-05-15 Thread GitBox
mans2singh opened a new pull request #15923: URL: https://github.com/apache/flink/pull/15923 ## What is the purpose of the change * Changed argument for toDataStream to Table ## Brief change log * Corrected argument for toDataStream ## Verifying this chang

[GitHub] [flink] flinkbot edited a comment on pull request #15922: [FLINK-22650][python][table-planner-blink] Support StreamExecPythonCorrelate json serialization/deserialization

2021-05-15 Thread GitBox
flinkbot edited a comment on pull request #15922: URL: https://github.com/apache/flink/pull/15922#issuecomment-841617014 ## CI report: * 01cc8a69d63b42251c294c2460b8152cd0d06a11 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-19481) Add support for a flink native GCS FileSystem

2021-05-15 Thread Jamie Grier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345032#comment-17345032 ] Jamie Grier edited comment on FLINK-19481 at 5/15/21, 1:25 PM: ---

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

2021-05-15 Thread Jamie Grier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345032#comment-17345032 ] Jamie Grier commented on FLINK-19481: - The primary benefits of a native implementati

[jira] [Comment Edited] (FLINK-19481) Add support for a flink native GCS FileSystem

2021-05-15 Thread Jamie Grier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345032#comment-17345032 ] Jamie Grier edited comment on FLINK-19481 at 5/15/21, 1:25 PM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #15922: [FLINK-22650][python][table-planner-blink] Support StreamExecPythonCorrelate json serialization/deserialization

2021-05-15 Thread GitBox
flinkbot edited a comment on pull request #15922: URL: https://github.com/apache/flink/pull/15922#issuecomment-841617014 ## CI report: * ca64129d712be957c624a0f1e30453061f69f365 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15922: [FLINK-22650][python][table-planner-blink] Support StreamExecPythonCorrelate json serialization/deserialization

2021-05-15 Thread GitBox
flinkbot edited a comment on pull request #15922: URL: https://github.com/apache/flink/pull/15922#issuecomment-841617014 ## CI report: * ca64129d712be957c624a0f1e30453061f69f365 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-17845) Can't remove a table connector property with ALTER TABLE

2021-05-15 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345019#comment-17345019 ] Jane Chan commented on FLINK-17845: --- Hi [~jark], sorry to joining this discussion late

[jira] [Closed] (FLINK-13679) Translate "Code Style - Pull Requests & Changes" page into Chinese

2021-05-15 Thread Congxian Qiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu closed FLINK-13679. Resolution: Fixed merged with commit 23ad02dcc845ca2d87fa893572d77b5ec58104a8 > Translate "Code S

[GitHub] [flink] flinkbot edited a comment on pull request #15922: [FLINK-22650][python][table-planner-blink] Support StreamExecPythonCorrelate json serialization/deserialization

2021-05-15 Thread GitBox
flinkbot edited a comment on pull request #15922: URL: https://github.com/apache/flink/pull/15922#issuecomment-841617014 ## CI report: * ca64129d712be957c624a0f1e30453061f69f365 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #15922: [FLINK-22650][python][table-planner-blink] Support StreamExecPythonCorrelate json serialization/deserialization

2021-05-15 Thread GitBox
flinkbot commented on pull request #15922: URL: https://github.com/apache/flink/pull/15922#issuecomment-841617014 ## CI report: * ca64129d712be957c624a0f1e30453061f69f365 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Resolved] (FLINK-22511) Fix the bug of non-composite result type in Python TableAggregateFunction

2021-05-15 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-22511. -- Resolution: Fixed Merged into master via b83e64ed1402713955a630d4f635ab7068450347 Merged into

[GitHub] [flink] HuangXingBo closed pull request #15796: [FLINK-22511][python] Fix the bug of non-composite result type in Python TableAggregateFunction

2021-05-15 Thread GitBox
HuangXingBo closed pull request #15796: URL: https://github.com/apache/flink/pull/15796 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, pl

[GitHub] [flink] flinkbot commented on pull request #15922: [FLINK-22650][python][table-planner-blink] Support StreamExecPythonCorrelate json serialization/deserialization

2021-05-15 Thread GitBox
flinkbot commented on pull request #15922: URL: https://github.com/apache/flink/pull/15922#issuecomment-841615983 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 use this comment to track the pro

[jira] [Updated] (FLINK-22650) Support StreamExecPythonCorrelate json serialization/deserialization

2021-05-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22650: --- Labels: pull-request-available (was: ) > Support StreamExecPythonCorrelate json serializati

[GitHub] [flink] HuangXingBo opened a new pull request #15922: [FLINK-22650][python][table-planner-blink] Support StreamExecPythonCorrelate json serialization/deserialization

2021-05-15 Thread GitBox
HuangXingBo opened a new pull request #15922: URL: https://github.com/apache/flink/pull/15922 ## What is the purpose of the change *This pull request will support StreamExecPythonCorrelate json serialization/deserialization* ## Brief change log - *Optimize `PythonCorre