[jira] [Updated] (FLINK-9) [GitHub] Add flag for visualization of pact plan with the nephele SWT visualization

2021-10-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9: --- Labels: github-import pull-request-available (was: github-import) > [GitHub] Add flag for visualization

[GitHub] [flink-ml] gaoyunhaii opened a new pull request #16: [FLINK-9][iteration] Support per-round iteration

2021-10-02 Thread GitBox
gaoyunhaii opened a new pull request #16: URL: https://github.com/apache/flink-ml/pull/16 Add support for the per-round iteration. This is done by 1. Allow specify which input datastreams require replaying. A new `ReplayOperator` is inserted for these inputs. 2. Use per-round oper

[jira] [Commented] (FLINK-23458) Document required number of buffers in the network stack

2021-10-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423620#comment-17423620 ] Xintong Song commented on FLINK-23458: -- [~akalashnikov][~pnowojski], The Chinese ve

[jira] [Commented] (FLINK-20454) Allow to read metadata for debezium-avro-confluent format

2021-10-02 Thread CaoZhen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423616#comment-17423616 ] CaoZhen commented on FLINK-20454: - [~MartijnVisser] Sure. I'll jump in as soon as I can.

[GitHub] [flink] RocMarshal edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

2021-10-02 Thread GitBox
RocMarshal edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-932250048 Thanks @Airblader @MartijnVisser for the review. Hi, @wuchong , @xintongsong @twalthr @tisonkun . Could you help me to merge it if there are nothing inappropriate ?

[GitHub] [flink] RocMarshal edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-02 Thread GitBox
RocMarshal edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-932249100 Thanks @Airblader for the review. Hi, @wuchong , @xintongsong @twalthr @tisonkun . Could you help me to merge it if there are nothing inappropriate ? Thank you.

[jira] [Commented] (FLINK-24433) "No space left on device" in Azure e2e tests

2021-10-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423572#comment-17423572 ] Robert Metzger commented on FLINK-24433: After each test run, we are logging "En

[GitHub] [flink-ml] becketqin commented on a change in pull request #7: [FLINK-3][iteration] Implements the feedback mechanism and the controller operators.

2021-10-02 Thread GitBox
becketqin commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r720580629 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/IterationRecord.java ## @@ -0,0 +1,163 @@ +/* + * Licensed to the Apache Softwa

[jira] [Commented] (FLINK-9465) Specify a separate savepoint timeout option via CLI

2021-10-02 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423539#comment-17423539 ] Feifan Wang commented on FLINK-9465: Hi [~trohrmann], thanks for reply, I think we ca

[GitHub] [flink] Airblader commented on a change in pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

2021-10-02 Thread GitBox
Airblader commented on a change in pull request #17332: URL: https://github.com/apache/flink/pull/17332#discussion_r720673107 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java ## @@ -142,4 +143,16 @@

[jira] [Commented] (FLINK-23139) State ownership: track and discard private state (registry+changelog)

2021-10-02 Thread Congxian Qiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423520#comment-17423520 ] Congxian Qiu commented on FLINK-23139: -- hi [~roman] seems the doc is not public, is

[jira] [Updated] (FLINK-24391) flink-json formats should support an option to extract the raw message into a column

2021-10-02 Thread Shengnan YU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengnan YU updated FLINK-24391: Description: Sometimes we only need to extract some columns of the json message for indexing but t

[GitHub] [flink] klion26 commented on a change in pull request #15903: [FLINK-22644][docs] Translate "Native Kubernetes" page into Chinese

2021-10-02 Thread GitBox
klion26 commented on a change in pull request #15903: URL: https://github.com/apache/flink/pull/15903#discussion_r720673586 ## File path: docs/content/docs/deployment/resource-providers/native_kubernetes.md ## @@ -79,7 +79,7 @@ Congratulations! You have successfully run a Flink

[GitHub] [flink] Airblader commented on a change in pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

2021-10-02 Thread GitBox
Airblader commented on a change in pull request #17332: URL: https://github.com/apache/flink/pull/17332#discussion_r720673107 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java ## @@ -142,4 +143,16 @@

[GitHub] [flink] cuibo01 commented on a change in pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

2021-10-02 Thread GitBox
cuibo01 commented on a change in pull request #17332: URL: https://github.com/apache/flink/pull/17332#discussion_r720671425 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java ## @@ -142,4 +143,16 @@

[GitHub] [flink] cuibo01 commented on a change in pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

2021-10-02 Thread GitBox
cuibo01 commented on a change in pull request #17332: URL: https://github.com/apache/flink/pull/17332#discussion_r720671425 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java ## @@ -142,4 +143,16 @@

[GitHub] [flink] JingGe edited a comment on pull request #17196: [HOTFIX][docs] fix sentence to make the description more clear.

2021-10-02 Thread GitBox
JingGe edited a comment on pull request #17196: URL: https://github.com/apache/flink/pull/17196#issuecomment-932735416 > I don't think this _really_ improves the javadocs. By virtue of what a seek does isn't the "position" bit unnecessary? Thanks for the feedback. IMHO, javadocs is w

[GitHub] [flink] JingGe edited a comment on pull request #17196: [HOTFIX][docs] fix sentence to make the description more clear.

2021-10-02 Thread GitBox
JingGe edited a comment on pull request #17196: URL: https://github.com/apache/flink/pull/17196#issuecomment-932735416 > I don't think this _really_ improves the javadocs. By virtue of what a seek does isn't the "position" bit unnecessary? Thanks for the feedback. IMHO, javadocs is w

[GitHub] [flink] Airblader commented on a change in pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

2021-10-02 Thread GitBox
Airblader commented on a change in pull request #17332: URL: https://github.com/apache/flink/pull/17332#discussion_r720667956 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java ## @@ -142,4 +143,16 @@

[GitHub] [flink] cuibo01 commented on pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

2021-10-02 Thread GitBox
cuibo01 commented on pull request #17332: URL: https://github.com/apache/flink/pull/17332#issuecomment-932735481 WDYT? @bowenli86 @JingsongLi -- 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

[GitHub] [flink] JingGe edited a comment on pull request #17196: [HOTFIX][docs] fix sentence to make the description more clear.

2021-10-02 Thread GitBox
JingGe edited a comment on pull request #17196: URL: https://github.com/apache/flink/pull/17196#issuecomment-932735416 > I don't think this _really_ improves the javadocs. By virtue of what a seek does isn't the "position" bit unnecessary? Thanks for the feedback. IMHO, javadocs is w

[GitHub] [flink] JingGe commented on pull request #17196: [HOTFIX][docs] fix sentence to make the description more clear.

2021-10-02 Thread GitBox
JingGe commented on pull request #17196: URL: https://github.com/apache/flink/pull/17196#issuecomment-932735416 > I don't think this _really_ improves the javadocs. By virtue of what a seek does isn't the "position" bit unnecessary? Thanks for the feedback. IMHO, javadocs is written