[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:

[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

[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

[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 

[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=17204455#comment-17204455 ] hailong wang commented on FLINK-19386: -- Thank you [~jark]. I understand now~ Yes, My first thought

[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

[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

[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:

[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=17204453#comment-17204453 ] Zhijiang commented on FLINK-19249: -- Thanks for reporting this [~klion26] and all the above discussions.

[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

[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 ## @@

[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

[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

[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:

[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=17204445#comment-17204445 ] Zhijiang commented on FLINK-17331: -- After offline discussing with [~karmagyz], i am aware of this

[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=17204441#comment-17204441 ] chouxu commented on FLINK-16408: [~Echo Lee]  do you  using  flink rest api ? I  meet up the same 

[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

[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

[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=17204440#comment-17204440 ] Jark Wu commented on FLINK-19456: - +1 for this. > 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: 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=17204437#comment-17204437 ] Jark Wu commented on FLINK-19452: - [~tinny], could you share the reason here? I think it's helpful for

[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=17204438#comment-17204438 ] Jark Wu commented on FLINK-19386: - Hi [~hailong wang], thank you for sharing the thoughts. However,

[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

[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

[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=17204433#comment-17204433 ] Jark Wu commented on FLINK-19446: - That's true. I think we need to know whether this is a "changed"

[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=17204433#comment-17204433 ] Jark Wu edited comment on FLINK-19446 at 9/30/20, 4:03 AM: --- That's true. I

[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

[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

[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:

[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

[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:

[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

[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

[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

[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

[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 @@

[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 @@

[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 @@

[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

[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:

[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

[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:

[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:

[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

[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:

[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

[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~) >

[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=17204412#comment-17204412 ] Roc Marshal commented on FLINK-19394: - [~jark] Could you assign this ticket to me ? Thank you~ >

[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

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

2020-09-29 Thread GitBox
godfreyhe commented on pull request #13434: URL: https://github.com/apache/flink/pull/13434#issuecomment-701120479 LGTM, +1 to merge This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Closed] (FLINK-19429) Translate page 'Data Types' into Chinese

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19429. --- Resolution: Fixed master: 3d6d6570177ff57945ae719acb8ad17d92603c9c > Translate page 'Data Types' into

[GitHub] [flink] dianfu merged pull request #13497: [FLINK-19429][docs-zh] Translate page `Data Types` into Chinese

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

[jira] [Updated] (FLINK-19429) Translate page 'Data Types' into Chinese

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

[GitHub] [flink] dianfu commented on pull request #13497: [FLINK-19429][docs-zh] Translate page `Data Types` into Chinese

2020-09-29 Thread GitBox
dianfu commented on pull request #13497: URL: https://github.com/apache/flink/pull/13497#issuecomment-701118190 @wangxlong Thanks for the PR. LGTM. Merging... This is an automated message from the Apache Git Service. To

[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-701117242 Hi @dianfu, Could you help have a review in your free time, Thank you~ This is an automated message from the

[GitHub] [flink] wangxlong commented on pull request #13497: [FLINK-19429][docs-zh] Translate page `Data Types` into Chinese

2020-09-29 Thread GitBox
wangxlong commented on pull request #13497: URL: https://github.com/apache/flink/pull/13497#issuecomment-701117042 Hi @dianfu, Could you help have a review in your free time, Thank you. This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #13510: [FLINK-13095][state-processor-api] Introduce window bootstrap writer for writing window operator state

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13510: URL: https://github.com/apache/flink/pull/13510#issuecomment-700881897 ## CI report: * e6ccb2f3e1b474cee6b31d0f0d894d1fe94ce22d Azure:

[jira] [Comment Edited] (FLINK-19443) runtime function 'splitIndex'

2020-09-29 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204401#comment-17204401 ] Nicholas Jiang edited comment on FLINK-19443 at 9/30/20, 1:55 AM: --

[jira] [Commented] (FLINK-19443) runtime function 'splitIndex'

2020-09-29 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204401#comment-17204401 ] Nicholas Jiang commented on FLINK-19443: [~libenchao], if [~mytang0] wouldn't be available to

[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: * 7ed9da178f78a54bbca8de66984a802c1875e3cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13513: [FLINK-19434][DataStream API] Add source input chaining to StreamingJobGraphGenerator

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13513: URL: https://github.com/apache/flink/pull/13513#issuecomment-701011500 ## CI report: * 73ff86c5d941fdf7ed5fd22c8c6d5b982a0089d5 Azure:

[jira] [Updated] (FLINK-17480) Support running PyFlink on Kubernetes

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17480: Component/s: API / Python > Support running PyFlink on Kubernetes > -

[jira] [Closed] (FLINK-17480) Support running PyFlink on Kubernetes

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17480. --- Fix Version/s: 1.12.0 Resolution: Fixed Merged to master(1.12) via

[GitHub] [flink] dianfu closed pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

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

[jira] [Commented] (FLINK-18044) Add the subtask index information to the SourceReaderContext.

2020-09-29 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204396#comment-17204396 ] Jiangjie Qin commented on FLINK-18044: -- [~sewen] Thanks for the comment. I agree that we should

[GitHub] [flink] dianfu commented on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

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

[jira] [Comment Edited] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204394#comment-17204394 ] Dian Fu edited comment on FLINK-19447 at 9/30/20, 1:37 AM: --- Another instance:

[jira] [Commented] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204395#comment-17204395 ] Dian Fu commented on FLINK-19447: - Upgrade it to "Blocker" as it seems that this test is continuously

[jira] [Updated] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19447: Priority: Blocker (was: Major) > HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master

[jira] [Updated] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19447: Fix Version/s: 1.12.0 > HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not >

[jira] [Commented] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204394#comment-17204394 ] Dian Fu commented on FLINK-19447: - Another instance:

[jira] [Updated] (FLINK-19469) HBase connector 2.2 failed to download dependencies "org.glassfish:javax.el:jar:3.0.1-b06-SNAPSHOT"

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19469: Labels: test-stability (was: ) > HBase connector 2.2 failed to download dependencies >

[jira] [Created] (FLINK-19469) HBase connector 2.2 failed to download dependencies "org.glassfish:javax.el:jar:3.0.1-b06-SNAPSHOT"

2020-09-29 Thread Dian Fu (Jira)
Dian Fu created FLINK-19469: --- Summary: HBase connector 2.2 failed to download dependencies "org.glassfish:javax.el:jar:3.0.1-b06-SNAPSHOT" Key: FLINK-19469 URL: https://issues.apache.org/jira/browse/FLINK-19469

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

2020-09-29 Thread wulei0302 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204391#comment-17204391 ] wulei0302 commented on FLINK-19454: --- [~jark] hello Jark,  could you assignee this issue to me ? >

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

2020-09-29 Thread wulei0302 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wulei0302 updated FLINK-19454: -- Comment: was deleted (was: [~libenchao] hello benchao,  could you assignee this issue to me ?) >

[jira] [Comment Edited] (FLINK-18648) KafkaITCase.testStartFromGroupOffsets times out on azure

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204387#comment-17204387 ] Dian Fu edited comment on FLINK-18648 at 9/30/20, 1:13 AM: ---

[jira] [Updated] (FLINK-18648) KafkaITCase.testStartFromGroupOffsets times out on azure

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18648: Labels: test-stability (was: ) > KafkaITCase.testStartFromGroupOffsets times out on azure >

[jira] [Updated] (FLINK-18648) KafkaITCase.testStartFromGroupOffsets times out on azure

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18648: Affects Version/s: 1.11.0 > KafkaITCase.testStartFromGroupOffsets times out on azure >

[jira] [Commented] (FLINK-18648) KafkaITCase.testStartFromGroupOffsets times out on azure

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204387#comment-17204387 ] Dian Fu commented on FLINK-18648: - KafkaITCase.testAutoOffsetRetrievalAndCommitToKafka failed with the

[jira] [Updated] (FLINK-19437) FileSourceTextLinesITCase.testContinuousTextFileSource failed with "SimpleStreamFormat is not splittable, but found split end (0) different from file length (198)"

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19437: Fix Version/s: 1.12.0 > FileSourceTextLinesITCase.testContinuousTextFileSource failed with >

[jira] [Commented] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

2020-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204383#comment-17204383 ] Dian Fu commented on FLINK-19447: - All the logs could be found here:

[GitHub] [flink] flinkbot edited a comment on pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13499: URL: https://github.com/apache/flink/pull/13499#issuecomment-699852497 ## CI report: * f298e8b85569242501d871e326cce21695582caa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13514: [FLINK-19468][DataStream API] Metrics return empty when data stream / operator name contains "+"

2020-09-29 Thread GitBox
flinkbot edited a comment on pull request #13514: URL: https://github.com/apache/flink/pull/13514#issuecomment-701038173 ## CI report: * 8a72f73417ceb18536d282679e8ce5c60f634acb Azure:

[GitHub] [flink] flinkbot commented on pull request #13514: [FLINK-19468][DataStream API] Metrics return empty when data stream / operator name contains "+"

2020-09-29 Thread GitBox
flinkbot commented on pull request #13514: URL: https://github.com/apache/flink/pull/13514#issuecomment-701038173 ## CI report: * 8a72f73417ceb18536d282679e8ce5c60f634acb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13514: [FLINK-19468][DataStream API] Metrics return empty when data stream / operator name contains "+"

2020-09-29 Thread GitBox
flinkbot commented on pull request #13514: URL: https://github.com/apache/flink/pull/13514#issuecomment-701034946 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

[GitHub] [flink] jerrypeng opened a new pull request #13514: [FLINK-19468][DataStream API] Metrics return empty when data stream / operator name contains "+"

2020-09-29 Thread GitBox
jerrypeng opened a new pull request #13514: URL: https://github.com/apache/flink/pull/13514 There is an issue in which the special character "+" is not removed from the data stream / operator name which causes metrics for the operator to not be properly returned. Code Reference:

  1   2   3   4   5   >