[GitHub] [flink] flinkbot commented on pull request #13518: [FLINK-19386][Connector-hive] Using blink planner util class in HiveCatalogUseBlinkITCase

2020-09-29 Thread GitBox
flinkbot commented on pull request #13518: URL: https://github.com/apache/flink/pull/13518#issuecomment-701197757 ## CI report: * 1c26d97a7561edd3413ab3ca546fe3bf38c6b636 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13495: [Test]Fix case demo is more obvious to understand for ReinterpretAsKeyedStream

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13495: URL: https://github.com/apache/flink/pull/13495#issuecomment-699753576 ## CI report: * b64812a0cb08a25ee0853c57230ffe12ccc9ceb3 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900 ## CI report: * c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN * ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN * Unknown: [CANCELED](TBD) * 6e20

[jira] [Comment Edited] (FLINK-19452) statistics of group by CDC data is always 1

2020-09-29 Thread Zhengchao Shi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204488#comment-17204488 ] Zhengchao Shi edited comment on FLINK-19452 at 9/30/20, 6:43 AM: -

[jira] [Updated] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

2020-09-29 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19461: -- Component/s: Command Line Client > yarn-sesson.sh -jm -tm arguments have no effect > -

[jira] [Updated] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

2020-09-29 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19461: -- Fix Version/s: 1.12.0 > yarn-sesson.sh -jm -tm arguments have no effect >

[GitHub] [flink] flinkbot commented on pull request #13518: [FLINK-19386][Connector-hive] Using blink planner util class in HiveCatalogUseBlinkITCase

2020-09-29 Thread GitBox
flinkbot commented on pull request #13518: URL: https://github.com/apache/flink/pull/13518#issuecomment-701191269 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] [Comment Edited] (FLINK-19452) statistics of group by CDC data is always 1

2020-09-29 Thread Zhengchao Shi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204488#comment-17204488 ] Zhengchao Shi edited comment on FLINK-19452 at 9/30/20, 6:40 AM: -

[jira] [Updated] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

2020-09-29 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19461: -- Labels: usability (was: ) > yarn-sesson.sh -jm -tm arguments have no effect > ---

[GitHub] [flink] wangxlong opened a new pull request #13518: [FLINK-19386][Connector-hive] Using blink planner util class in HiveCatalogUseBlinkITCase

2020-09-29 Thread GitBox
wangxlong opened a new pull request #13518: URL: https://github.com/apache/flink/pull/13518 ## What is the purpose of the change Using blink planner util class in HiveCatalogUseBlinkITCase ## Brief change log Using blink planner util class in HiveCatalogUseBlinkITCas

[jira] [Commented] (FLINK-19452) statistics of group by CDC data is always 1

2020-09-29 Thread Zhengchao Shi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204488#comment-17204488 ] Zhengchao Shi commented on FLINK-19452: --- [~jark] Because I started the job from th

[GitHub] [flink] flinkbot commented on pull request #13517: [FLINK-19386][Connector-hive] Using blink planner util class in HiveCatalogUseBlinkITCase

2020-09-29 Thread GitBox
flinkbot commented on pull request #13517: URL: https://github.com/apache/flink/pull/13517#issuecomment-701188742 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-19386) Using blink planner util class in HiveCatalogUseBlinkITCase

2020-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19386: --- Labels: pull-request-available (was: ) > Using blink planner util class in HiveCatalogUseB

[GitHub] [flink] wangxlong closed pull request #13517: [FLINK-19386][Connector-hive] Using blink planner util class in HiveCatalogUseBlinkITCase

2020-09-29 Thread GitBox
wangxlong closed pull request #13517: URL: https://github.com/apache/flink/pull/13517 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 t

[GitHub] [flink] wangxlong opened a new pull request #13517: [FLINK-19386][Connector-hive] Using blink planner util class in HiveCatalogUseBlinkITCase

2020-09-29 Thread GitBox
wangxlong opened a new pull request #13517: URL: https://github.com/apache/flink/pull/13517 ## What is the purpose of the change Using blink planner util class in HiveCatalogUseBlinkITCase ## Brief change log Using blink planner util class in HiveCatalogUseBlinkITCase

[GitHub] [flink] dawidwys commented on pull request #13509: [FLINK-19317] Make EventTime the default TimeCharacteristic

2020-09-29 Thread GitBox
dawidwys commented on pull request #13509: URL: https://github.com/apache/flink/pull/13509#issuecomment-701187583 BTW, I forgot to mention I really liked commit messages! This is an automated message from the Apache Git Servi

[GitHub] [flink] flinkbot edited a comment on pull request #13495: [Test]Fix case demo is more obvious to understand for ReinterpretAsKeyedStream

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13495: URL: https://github.com/apache/flink/pull/13495#issuecomment-699753576 ## CI report: * b64812a0cb08a25ee0853c57230ffe12ccc9ceb3 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13496: [FLINK-18818][filesystem][tests] Ignores exceptions after files written successfully in HadoopRenameCommitter test

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13496: URL: https://github.com/apache/flink/pull/13496#issuecomment-699831973 ## CI report: * fb621d653a6765dca63ad6c057fbcd7a2b549a90 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-19475) Implement a timer service that holds a single key at a time

2020-09-29 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-19475: Assignee: Dawid Wysakowicz > Implement a timer service that holds a single key at

[GitHub] [flink] flinkbot edited a comment on pull request #13494: [kafka connector]Fix cast question for properies() method in kafka ConnectorDescriptor

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13494: URL: https://github.com/apache/flink/pull/13494#issuecomment-699748753 ## CI report: * b139f0662c5c86ae97742c6dc6742aaef4f97a97 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-19475) Implement a timer service that holds a single key at a time

2020-09-29 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-19475: Summary: Implement a timer service that holds a single key at a time Key: FLINK-19475 URL: https://issues.apache.org/jira/browse/FLINK-19475 Project: Flink

[jira] [Created] (FLINK-19474) Implement a state backends that holds a single key at a time

2020-09-29 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-19474: Summary: Implement a state backends that holds a single key at a time Key: FLINK-19474 URL: https://issues.apache.org/jira/browse/FLINK-19474 Project: Flink

[jira] [Created] (FLINK-19472) Implement a one input sorting DataInput

2020-09-29 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-19472: Summary: Implement a one input sorting DataInput Key: FLINK-19472 URL: https://issues.apache.org/jira/browse/FLINK-19472 Project: Flink Issue Type: S

[jira] [Created] (FLINK-19473) Implement multi inputs sorting DataInput

2020-09-29 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-19473: Summary: Implement multi inputs sorting DataInput Key: FLINK-19473 URL: https://issues.apache.org/jira/browse/FLINK-19473 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900 ## CI report: * c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN * ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN * Unknown: [CANCELED](TBD) * 6e20

[GitHub] [flink] dawidwys commented on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

2020-09-29 Thread GitBox
dawidwys commented on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-701184135 Hey @senegalo I've seen you merged the master into your branch. That will not work. We need a linear history in the master branch. Could you please rebase the changes? ---

[GitHub] [flink] senegalo commented on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

2020-09-29 Thread GitBox
senegalo commented on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-701181655 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] senegalo edited a comment on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

2020-09-29 Thread GitBox
senegalo edited a comment on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-700850674 Sure will do that right away :) This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #13496: [FLINK-18818][filesystem][tests] Ignores exceptions after files written successfully in HadoopRenameCommitter test

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13496: URL: https://github.com/apache/flink/pull/13496#issuecomment-699831973 ## CI report: * fb621d653a6765dca63ad6c057fbcd7a2b549a90 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13494: [kafka connector]Fix cast question for properies() method in kafka ConnectorDescriptor

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13494: URL: https://github.com/apache/flink/pull/13494#issuecomment-699748753 ## CI report: * b139f0662c5c86ae97742c6dc6742aaef4f97a97 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] hehuiyuan commented on pull request #13495: [Test]Fix case demo is more obvious to understand for ReinterpretAsKeyedStream

2020-09-29 Thread GitBox
hehuiyuan commented on pull request #13495: URL: https://github.com/apache/flink/pull/13495#issuecomment-701178023 @flinkbot re-run This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [flink] hehuiyuan edited a comment on pull request #13494: [kafka connector]Fix cast question for properies() method in kafka ConnectorDescriptor

2020-09-29 Thread GitBox
hehuiyuan edited a comment on pull request #13494: URL: https://github.com/apache/flink/pull/13494#issuecomment-701176092 @flinkbot run azure re-run the last Azure build @flinkbot run travis re-run the last Travis build ---

[GitHub] [flink] hehuiyuan removed a comment on pull request #13494: [kafka connector]Fix cast question for properies() method in kafka ConnectorDescriptor

2020-09-29 Thread GitBox
hehuiyuan removed a comment on pull request #13494: URL: https://github.com/apache/flink/pull/13494#issuecomment-701166109 @flinkbot This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] hehuiyuan commented on pull request #13494: [kafka connector]Fix cast question for properies() method in kafka ConnectorDescriptor

2020-09-29 Thread GitBox
hehuiyuan commented on pull request #13494: URL: https://github.com/apache/flink/pull/13494#issuecomment-701176092 @flinkbot run azure re-run the last Azure build This is an automated message from the Apache Git Service. To r

[GitHub] [flink] dianfu merged pull request #13498: [FLINK-19430][docs-zh] Translate page datastream_tutorial into Chinese

2020-09-29 Thread GitBox
dianfu merged pull request #13498: URL: https://github.com/apache/flink/pull/13498 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 t

[jira] [Updated] (FLINK-19430) Translate page 'datastream_tutorial' into Chinese

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19430: Component/s: API / Python > Translate page 'datastream_tutorial' into Chinese > --

[jira] [Closed] (FLINK-19430) Translate page 'datastream_tutorial' into Chinese

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19430. --- Resolution: Fixed master: cacfd98e0dd4896c8e86a6e5f5fa418045719b76 > Translate page 'datastream_tutorial' i

[GitHub] [flink] flinkbot edited a comment on pull request #13498: [FLINK-19430][docs-zh] Translate page datastream_tutorial into Chinese

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13498: URL: https://github.com/apache/flink/pull/13498#issuecomment-699842299 ## CI report: * 84117cb7218b909348d276f2803bdb11c8a81ba9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-19471) CVE-2020-7712 is reported for flink-streaming-java_2.11:jar:1.11.1

2020-09-29 Thread Jeff Hu (Jira)
Jeff Hu created FLINK-19471: --- Summary: CVE-2020-7712 is reported for flink-streaming-java_2.11:jar:1.11.1 Key: FLINK-19471 URL: https://issues.apache.org/jira/browse/FLINK-19471 Project: Flink Iss

[GitHub] [flink] wangxlong commented on pull request #13498: [FLINK-19430][docs-zh] Translate page datastream_tutorial into Chinese

2020-09-29 Thread GitBox
wangxlong commented on pull request #13498: URL: https://github.com/apache/flink/pull/13498#issuecomment-701166463 @dianfu Thank you for reminder and patient review. Updated~ This is an automated message from the Apache Git

[GitHub] [flink] hehuiyuan commented on pull request #13494: [kafka connector]Fix cast question for properies() method in kafka ConnectorDescriptor

2020-09-29 Thread GitBox
hehuiyuan commented on pull request #13494: URL: https://github.com/apache/flink/pull/13494#issuecomment-701166109 @flinkbot This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] hehuiyuan commented on pull request #13495: [Test]Fix case demo is more obvious to understand for ReinterpretAsKeyedStream

2020-09-29 Thread GitBox
hehuiyuan commented on pull request #13495: URL: https://github.com/apache/flink/pull/13495#issuecomment-701164789 @flinkbot test This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Updated] (FLINK-19386) Remove legacy table planner dependecy from connectors and formats

2020-09-29 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19386: - Description: Replacing {code:java} org.apache.flink.table.utils.JavaScalaConversionUtil  {code}

[jira] [Updated] (FLINK-19386) Remove legacy table planner dependecy from connectors and formats

2020-09-29 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19386: - Description: Replacing   {code:java} org.apache.flink.table.utils.JavaScalaConversionUtil  {cod

[jira] [Commented] (FLINK-19386) Remove legacy table planner dependecy from connectors and formats

2020-09-29 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204455#comment-17204455 ] hailong wang commented on FLINK-19386: -- Thank you [~jark]. I understand now~ Yes,

[jira] [Updated] (FLINK-19386) Using blink planner util class in

2020-09-29 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19386: - Summary: Using blink planner util class in (was: Remove legacy table planner dependecy from co

[jira] [Updated] (FLINK-19386) Using blink planner util class in HiveCatalogUseBlinkITCase

2020-09-29 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19386: - Summary: Using blink planner util class in HiveCatalogUseBlinkITCase (was: Using blink planner

[GitHub] [flink] flinkbot edited a comment on pull request #13516: [FLINK-19453][table-common] Deprecate old source and sink interfaces

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13516: URL: https://github.com/apache/flink/pull/13516#issuecomment-701152610 ## CI report: * 71ea6811ae9194c35241a225d105c636e515d653 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

2020-09-29 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204453#comment-17204453 ] Zhijiang commented on FLINK-19249: -- Thanks for reporting this [~klion26] and all the ab

[GitHub] [flink] flinkbot commented on pull request #13516: [FLINK-19453][table-common] Deprecate old source and sink interfaces

2020-09-29 Thread GitBox
flinkbot commented on pull request #13516: URL: https://github.com/apache/flink/pull/13516#issuecomment-701152610 ## CI report: * 71ea6811ae9194c35241a225d105c636e515d653 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] twalthr commented on a change in pull request #13507: [FLINK-19231][python] Support ListState and ListView for Python UDAF.

2020-09-29 Thread GitBox
twalthr commented on a change in pull request #13507: URL: https://github.com/apache/flink/pull/13507#discussion_r497238937 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPythonAggregate.scala ## @@ -65

[GitHub] [flink] flinkbot commented on pull request #13516: [FLINK-19453][table-common] Deprecate old source and sink interfaces

2020-09-29 Thread GitBox
flinkbot commented on pull request #13516: URL: https://github.com/apache/flink/pull/13516#issuecomment-701149527 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] twalthr opened a new pull request #13516: [FLINK-19453][table-common] Deprecate old source and sink interfaces

2020-09-29 Thread GitBox
twalthr opened a new pull request #13516: URL: https://github.com/apache/flink/pull/13516 ## What is the purpose of the change Deprecates all old source and sink interfaces and their helper interfaces that are not required in FLIP-95. ## Brief change log Deprecation ann

[jira] [Updated] (FLINK-19453) Deprecate old source and sink interfaces

2020-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19453: --- Labels: pull-request-available (was: ) > Deprecate old source and sink interfaces > ---

[GitHub] [flink] twalthr commented on pull request #13516: [FLINK-19453][table-common] Deprecate old source and sink interfaces

2020-09-29 Thread GitBox
twalthr commented on pull request #13516: URL: https://github.com/apache/flink/pull/13516#issuecomment-701149021 CC @wuchong This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on pull request #13515: [FLINK-19470][orc][parquet] Parquet and ORC reader reachEnd returns f…

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13515: URL: https://github.com/apache/flink/pull/13515#issuecomment-701143749 ## CI report: * 5f8c701af43074f17ce503aa2497d2f91ed56c50 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-17331) Add NettyMessageContent interface for all the class which could be write to NettyMessage

2020-09-29 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204445#comment-17204445 ] Zhijiang commented on FLINK-17331: -- After offline discussing with [~karmagyz], i am awa

[jira] [Commented] (FLINK-16408) Bind user code class loader to lifetime of a slot

2020-09-29 Thread chouxu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204441#comment-17204441 ] chouxu commented on FLINK-16408: [~Echo Lee]  do you  using  flink rest api ? I  meet up

[jira] [Assigned] (FLINK-17331) Add NettyMessageContent interface for all the class which could be write to NettyMessage

2020-09-29 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17331: Assignee: Yangze Guo > Add NettyMessageContent interface for all the class which could be write t

[jira] [Updated] (FLINK-17331) Add NettyMessageContent interface for all the class which could be write to NettyMessage

2020-09-29 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17331: - Fix Version/s: (was: 1.12.0) > Add NettyMessageContent interface for all the class which could be wr

[jira] [Assigned] (FLINK-19454) Translate page 'Importing Flink into an IDE' into Chinese

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19454: --- Assignee: wulei0302 (was: wulei) > Translate page 'Importing Flink into an IDE' into Chinese > ---

[jira] [Assigned] (FLINK-19454) Translate page 'Importing Flink into an IDE' into Chinese

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19454: --- Assignee: wulei > Translate page 'Importing Flink into an IDE' into Chinese > -

[jira] [Commented] (FLINK-19456) sql client execute insert sql with comment ahead

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204440#comment-17204440 ] Jark Wu commented on FLINK-19456: - +1 for this. > sql client execute insert sql with co

[jira] [Updated] (FLINK-19456) sql client execute insert sql with comment ahead

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19456: Priority: Major (was: Minor) > sql client execute insert sql with comment ahead > ---

[jira] [Updated] (FLINK-19456) sql client execute insert sql with comment ahead

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19456: Issue Type: Improvement (was: Bug) > sql client execute insert sql with comment ahead > -

[jira] [Updated] (FLINK-19456) sql client execute insert sql with comment ahead

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19456: Labels: (was: Bug) > sql client execute insert sql with comment ahead >

[jira] [Commented] (FLINK-19452) statistics of group by CDC data is always 1

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204437#comment-17204437 ] Jark Wu commented on FLINK-19452: - [~tinny], could you share the reason here? I think it

[jira] [Commented] (FLINK-19386) Remove legacy table planner dependecy from connectors and formats

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204438#comment-17204438 ] Jark Wu commented on FLINK-19386: - Hi [~hailong wang], thank you for sharing the thought

[GitHub] [flink] dianfu commented on a change in pull request #13498: [FLINK-19430][docs-zh] Translate page datastream_tutorial into Chinese

2020-09-29 Thread GitBox
dianfu commented on a change in pull request #13498: URL: https://github.com/apache/flink/pull/13498#discussion_r497227841 ## File path: docs/dev/python/datastream_tutorial.zh.md ## @@ -22,76 +22,77 @@ specific language governing permissions and limitations under the License.

[jira] [Closed] (FLINK-19444) flink 1.11 sql group by tumble Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19444. --- Resolution: Not A Problem The exception is as expected. See https://ci.apache.org/projects/flink/flink-docs

[jira] [Reopened] (FLINK-19386) Remove legacy table planner dependecy from connectors and formats

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reopened FLINK-19386: - Sorry. Close by mistake. > Remove legacy table planner dependecy from connectors and formats > ---

[jira] [Issue Comment Deleted] (FLINK-19386) Remove legacy table planner dependecy from connectors and formats

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19386: Comment: was deleted (was: See https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming

[jira] [Commented] (FLINK-19446) canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204433#comment-17204433 ] Jark Wu commented on FLINK-19446: - That's true. I think we need to know whether this is

[GitHub] [flink] flinkbot commented on pull request #13515: [FLINK-19470][orc][parquet] Parquet and ORC reader reachEnd returns f…

2020-09-29 Thread GitBox
flinkbot commented on pull request #13515: URL: https://github.com/apache/flink/pull/13515#issuecomment-701143749 ## CI report: * 5f8c701af43074f17ce503aa2497d2f91ed56c50 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Comment Edited] (FLINK-19446) canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204433#comment-17204433 ] Jark Wu edited comment on FLINK-19446 at 9/30/20, 4:03 AM: --- Th

[jira] [Closed] (FLINK-19386) Remove legacy table planner dependecy from connectors and formats

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19386. --- Fix Version/s: (was: 1.12.0) Resolution: Not A Problem See https://ci.apache.org/projects/flink/

[jira] [Assigned] (FLINK-19394) Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring' into Chinese

2020-09-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19394: --- Assignee: Roc Marshal > Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring'

[GitHub] [flink] leonardBang commented on a change in pull request #13299: [FLINK-19072][table-planner] Import Temporal Table join rule for Stream

2020-09-29 Thread GitBox
leonardBang commented on a change in pull request #13299: URL: https://github.com/apache/flink/pull/13299#discussion_r497228266 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/LogicalCorrelateToJoinFromTemporalTableR

[jira] [Updated] (FLINK-19365) Migrate Hive source to FLIP-27 source interface for batch

2020-09-29 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-19365: --- Description: I'll limit the scope here to batch reading, to make the PR easier to review. > Migrate Hive so

[GitHub] [flink] leonardBang commented on a change in pull request #13299: [FLINK-19072][table-planner] Import Temporal Table join rule for Stream

2020-09-29 Thread GitBox
leonardBang commented on a change in pull request #13299: URL: https://github.com/apache/flink/pull/13299#discussion_r497227009 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/LogicalCorrelateToJoinFromTemporalTableR

[GitHub] [flink] flinkbot commented on pull request #13515: [FLINK-19470][orc][parquet] Parquet and ORC reader reachEnd returns f…

2020-09-29 Thread GitBox
flinkbot commented on pull request #13515: URL: https://github.com/apache/flink/pull/13515#issuecomment-701140042 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-19365) Migrate Hive source to FLIP-27 source interface for batch

2020-09-29 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-19365: --- Summary: Migrate Hive source to FLIP-27 source interface for batch (was: Migrate Hive source to FLIP-27 sou

[jira] [Updated] (FLINK-19470) Parquet and ORC reader reachEnd returns false after it has reached end

2020-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19470: --- Labels: pull-request-available (was: ) > Parquet and ORC reader reachEnd returns false afte

[GitHub] [flink] lirui-apache opened a new pull request #13515: [FLINK-19470][orc][parquet] Parquet and ORC reader reachEnd returns f…

2020-09-29 Thread GitBox
lirui-apache opened a new pull request #13515: URL: https://github.com/apache/flink/pull/13515 …alse after it has reached end ## What is the purpose of the change Fix the issue that ORC and parquet reader `reachEnd` methods return false after it has reached end.

[GitHub] [flink] dianfu commented on a change in pull request #13507: [FLINK-19231][python] Support ListState and ListView for Python UDAF.

2020-09-29 Thread GitBox
dianfu commented on a change in pull request #13507: URL: https://github.com/apache/flink/pull/13507#discussion_r497198985 ## File path: flink-python/pyflink/common/types.py ## @@ -37,7 +37,7 @@ def _create_row(fields, values, row_kind: RowKind = None): return row -cla

[GitHub] [flink] curcur commented on a change in pull request #13501: Single task result partition type

2020-09-29 Thread GitBox
curcur commented on a change in pull request #13501: URL: https://github.com/apache/flink/pull/13501#discussion_r497225677 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedApproximateSubpartition.java ## @@ -0,0 +1,138 @@ +packag

[GitHub] [flink] curcur commented on a change in pull request #13501: Single task result partition type

2020-09-29 Thread GitBox
curcur commented on a change in pull request #13501: URL: https://github.com/apache/flink/pull/13501#discussion_r497225677 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedApproximateSubpartition.java ## @@ -0,0 +1,138 @@ +packag

[GitHub] [flink] curcur commented on a change in pull request #13501: Single task result partition type

2020-09-29 Thread GitBox
curcur commented on a change in pull request #13501: URL: https://github.com/apache/flink/pull/13501#discussion_r497225512 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedApproximateSubpartitionView.java ## @@ -0,0 +1,27 @@ +pac

[GitHub] [flink] curcur commented on pull request #13501: Single task result partition type

2020-09-29 Thread GitBox
curcur commented on pull request #13501: URL: https://github.com/apache/flink/pull/13501#issuecomment-701136832 Thank you very much @AHeise for reviewing! This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink] flinkbot edited a comment on pull request #11509: [FLINK-16753] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRunnable

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #11509: URL: https://github.com/apache/flink/pull/11509#issuecomment-603811265 ## CI report: * 0a96025249d753072b8eaab23b404ded9b6ddf47 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-19470) Parquet and ORC reader reachEnd returns false after it has reached end

2020-09-29 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-19470: --- Description: After a {{ParquetColumnarRowSplitReader}} or {{OrcColumnarRowSplitReader}} has reached its end,

[jira] [Updated] (FLINK-19470) Parquet and ORC reader reachEnd returns false after it has reached end

2020-09-29 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-19470: --- Summary: Parquet and ORC reader reachEnd returns false after it has reached end (was: ParquetColumnarRowSpl

[GitHub] [flink] flinkbot edited a comment on pull request #13512: [FLINK-19457][core] Add a number sequence generating source for the New Source API.

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13512: URL: https://github.com/apache/flink/pull/13512#issuecomment-700995407 ## CI report: * 45a5a5dd40652d6d9212a0cdba6cd47a293ac819 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] pyscala commented on pull request #13214: [FLINK-18938][tableSQL/API] Throw better exception message for quering sink-only connector

2020-09-29 Thread GitBox
pyscala commented on pull request #13214: URL: https://github.com/apache/flink/pull/13214#issuecomment-701128918 @wuchong The following changes have been made. 1.Keep FactoryUtil#discoverFactory is still a generic method for all kinds of factories. 2.Adding a new method OptionalFai

[jira] [Created] (FLINK-19470) ParquetColumnarRowSplitReader::reachEnd returns false after it has reached end

2020-09-29 Thread Rui Li (Jira)
Rui Li created FLINK-19470: -- Summary: ParquetColumnarRowSplitReader::reachEnd returns false after it has reached end Key: FLINK-19470 URL: https://issues.apache.org/jira/browse/FLINK-19470 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #11509: [FLINK-16753] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRunnable

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #11509: URL: https://github.com/apache/flink/pull/11509#issuecomment-603811265 ## CI report: * 0a96025249d753072b8eaab23b404ded9b6ddf47 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Jiayi-Liao commented on pull request #11509: [FLINK-16753] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRunnable

2020-09-29 Thread GitBox
Jiayi-Liao commented on pull request #11509: URL: https://github.com/apache/flink/pull/11509#issuecomment-701125599 @zhijiangW The PR should be good now. Could you take another look? This is an automated message from the Apa

[jira] [Issue Comment Deleted] (FLINK-19394) Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring' into Chinese

2020-09-29 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-19394: Comment: was deleted (was: [~lzljs3620320] Could you assign this ticket to me ? Thank you~) > Tra

[jira] [Commented] (FLINK-19394) Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring' into Chinese

2020-09-29 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204412#comment-17204412 ] Roc Marshal commented on FLINK-19394: - [~jark] Could you assign this ticket to me ?

[GitHub] [flink] godfreyhe merged pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

2020-09-29 Thread GitBox
godfreyhe merged pull request #13434: URL: https://github.com/apache/flink/pull/13434 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 t

  1   2   3   4   5   >