[GitHub] [flink] flinkbot commented on pull request #13584: [hotfix][typo] Fix typo in MiniCluster

2020-10-10 Thread GitBox
flinkbot commented on pull request #13584: URL: https://github.com/apache/flink/pull/13584#issuecomment-706654791 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] Shawn-Hx opened a new pull request #13584: [hotfix][typo] Fix typo in MiniCluster

2020-10-10 Thread GitBox
Shawn-Hx opened a new pull request #13584: URL: https://github.com/apache/flink/pull/13584 ## What is the purpose of the change Fix typo in `org.apache.flink.runtime.minicluster.MiniCluster.java` ## Brief change log

[jira] [Closed] (FLINK-19409) The comment for getValue has wrong code in class ListView

2020-10-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19409. --- Fix Version/s: 1.12.0 Resolution: Fixed Fixed in master: adedf07967efb05445dd7cd5b228a07fd65a60f8 >

[GitHub] [flink] wuchong merged pull request #13487: [FLINK-19409][Documentation] remove unrelated comment for getValue in ListView

2020-10-10 Thread GitBox
wuchong merged pull request #13487: URL: https://github.com/apache/flink/pull/13487 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] [Closed] (FLINK-19291) Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

2020-10-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19291. --- Resolution: Fixed > Fix exception for AvroSchemaConverter#convertToSchema when RowType contains > multiple

[jira] [Comment Edited] (FLINK-19291) Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

2020-10-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211659#comment-17211659 ] Jark Wu edited comment on FLINK-19291 at 10/11/20, 5:14 AM: Fixed in -

[GitHub] [flink] wuchong merged pull request #13582: [BP-1.11][FLINK-19291][avro] Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

2020-10-10 Thread GitBox
wuchong merged pull request #13582: URL: https://github.com/apache/flink/pull/13582 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-19566) TableITCase.testCollectWithClose failed with "IllegalStateException: MiniCluster is not yet running or has already been shut down"

2020-10-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19566: Labels: test-stability (was: ) > TableITCase.testCollectWithClose failed with "IllegalStateException: >

[jira] [Created] (FLINK-19566) TableITCase.testCollectWithClose failed with "IllegalStateException: MiniCluster is not yet running or has already been shut down"

2020-10-10 Thread Dian Fu (Jira)
Dian Fu created FLINK-19566: --- Summary: TableITCase.testCollectWithClose failed with "IllegalStateException: MiniCluster is not yet running or has already been shut down" Key: FLINK-19566 URL:

[jira] [Commented] (FLINK-18117) "Kerberized YARN per-job on Docker test" fails with "Could not start hadoop cluster."

2020-10-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211826#comment-17211826 ] Dian Fu commented on FLINK-18117: -

[jira] [Commented] (FLINK-19539) JMXReporterFactoryTest fails on Azure

2020-10-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211825#comment-17211825 ] Dian Fu commented on FLINK-19539: -

[jira] [Commented] (FLINK-19484) Kubernetes pyflink application test failed with "error executing jsonpath "{range .items[*]}{.metadata.name}{\"\\n\"}{end}": Error executing template: not in rang"

2020-10-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211823#comment-17211823 ] Dian Fu commented on FLINK-19484: -

[jira] [Commented] (FLINK-18444) KafkaITCase failing with "Failed to send data to Kafka: This server does not host this topic-partition"

2020-10-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211822#comment-17211822 ] Dian Fu commented on FLINK-18444: - Another instance(Kafka011TableITCase.testKafkaSourceSink failed with

[jira] [Assigned] (FLINK-19561) Corrected spelling errors in "Monitoring REST API" page of "Debugging & Monitoring"

2020-10-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19561: --- Assignee: weizheng > Corrected spelling errors in "Monitoring REST API" page of "Debugging & >

[jira] [Closed] (FLINK-19561) Corrected spelling errors in "Monitoring REST API" page of "Debugging & Monitoring"

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

[GitHub] [flink] dianfu merged pull request #13578: [FLINK-19561][docs]Corrected spelling errors in "Monitoring REST API" page of "Debugging & Monitoring"

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

[GitHub] [flink] dianfu commented on pull request #13578: [FLINK-19561][docs]Corrected spelling errors in "Monitoring REST API" page of "Debugging & Monitoring"

2020-10-10 Thread GitBox
dianfu commented on pull request #13578: URL: https://github.com/apache/flink/pull/13578#issuecomment-706643246 @weizheng92 Good catch! LGTM. This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #13583: [FLINK-19154] ApplicationDispatcherBootstrap clean up HA data only when necessary.

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13583: URL: https://github.com/apache/flink/pull/13583#issuecomment-706604937 ## CI report: * 5fe1d5b4deb0c6b94ce8a7c564e98caec5217339 Azure:

[GitHub] [flink] stevenzwu commented on a change in pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

2020-10-10 Thread GitBox
stevenzwu commented on a change in pull request #13574: URL: https://github.com/apache/flink/pull/13574#discussion_r502835270 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java ## @@

[GitHub] [flink] stevenzwu commented on a change in pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

2020-10-10 Thread GitBox
stevenzwu commented on a change in pull request #13574: URL: https://github.com/apache/flink/pull/13574#discussion_r502835270 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java ## @@

[GitHub] [flink] stevenzwu commented on a change in pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

2020-10-10 Thread GitBox
stevenzwu commented on a change in pull request #13574: URL: https://github.com/apache/flink/pull/13574#discussion_r502835270 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java ## @@

[GitHub] [flink] stevenzwu commented on a change in pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

2020-10-10 Thread GitBox
stevenzwu commented on a change in pull request #13574: URL: https://github.com/apache/flink/pull/13574#discussion_r502831204 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #13583: [FLINK-19154] ApplicationDispatcherBootstrap clean up HA data only when necessary.

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13583: URL: https://github.com/apache/flink/pull/13583#issuecomment-706604937 ## CI report: * 5fe1d5b4deb0c6b94ce8a7c564e98caec5217339 Azure:

[GitHub] [flink] flinkbot commented on pull request #13583: [FLINK-19154] ApplicationDispatcherBootstrap clean up HA data only when necessary.

2020-10-10 Thread GitBox
flinkbot commented on pull request #13583: URL: https://github.com/apache/flink/pull/13583#issuecomment-706604937 ## CI report: * 5fe1d5b4deb0c6b94ce8a7c564e98caec5217339 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13583: [FLINK-19154] ApplicationDispatcherBootstrap clean up HA data only when necessary.

2020-10-10 Thread GitBox
flinkbot commented on pull request #13583: URL: https://github.com/apache/flink/pull/13583#issuecomment-706604088 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-19154) Application mode deletes HA data in case of suspended ZooKeeper connection

2020-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19154: --- Labels: pull-request-available (was: ) > Application mode deletes HA data in case of

[GitHub] [flink] kl0u opened a new pull request #13583: [FLINK-19154] ApplicationDispatcherBootstrap clean up HA data only when necessary.

2020-10-10 Thread GitBox
kl0u opened a new pull request #13583: URL: https://github.com/apache/flink/pull/13583 ## What is the purpose of the change Currently in Application Mode when we shutdown the cluster we always clean up the HA data of a job. This also includes the cases when the job fails due to a

[GitHub] [flink] stevenzwu commented on a change in pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

2020-10-10 Thread GitBox
stevenzwu commented on a change in pull request #13574: URL: https://github.com/apache/flink/pull/13574#discussion_r502815083 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java ## @@

[jira] [Commented] (FLINK-19491) AvroSerializerSnapshot cannot handle large schema

2020-10-10 Thread Lian Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211732#comment-17211732 ] Lian Jiang commented on FLINK-19491: Thanks [~nicholasjiang] and [~AHeise] for taking a look. Could

[GitHub] [flink] flinkbot edited a comment on pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397 ## CI report: * 1e187203b15559b08d15a0cca949ca15a8a3bafe Azure:

[GitHub] [flink] dforciea commented on a change in pull request #13570: [FLINK-19522][Table SQL / Ecosystem] Add auto-commit option for Table/SQL API

2020-10-10 Thread GitBox
dforciea commented on a change in pull request #13570: URL: https://github.com/apache/flink/pull/13570#discussion_r502798851 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactory.java ## @@ -109,6

[GitHub] [flink] flinkbot edited a comment on pull request #13582: [BP-1.11][FLINK-19291][avro] Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13582: URL: https://github.com/apache/flink/pull/13582#issuecomment-706531763 ## CI report: * 9f79dca8c82e474548cb6743fd6e20881b96d347 Azure:

[GitHub] [flink] dforciea commented on a change in pull request #13570: [FLINK-19522][Table SQL / Ecosystem] Add auto-commit option for Table/SQL API

2020-10-10 Thread GitBox
dforciea commented on a change in pull request #13570: URL: https://github.com/apache/flink/pull/13570#discussion_r502797174 ## File path: docs/dev/table/connectors/jdbc.md ## @@ -183,7 +183,14 @@ Connector Options 0 Integer The number of rows that should

[GitHub] [flink] flinkbot edited a comment on pull request #13487: [FLINK-19409][Documentation] remove unrelated comment for getValue in ListView

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13487: URL: https://github.com/apache/flink/pull/13487#issuecomment-699575614 ## CI report: * 86351d896dfe576264025b6db7ca9ba46e27881a Azure:

[jira] [Comment Edited] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000

2020-10-10 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211710#comment-17211710 ] Kostas Kloudas edited comment on FLINK-19358 at 10/10/20, 2:09 PM: ---

[jira] [Comment Edited] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000

2020-10-10 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211710#comment-17211710 ] Kostas Kloudas edited comment on FLINK-19358 at 10/10/20, 2:08 PM: ---

[jira] [Commented] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000

2020-10-10 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211710#comment-17211710 ] Kostas Kloudas commented on FLINK-19358: [~fly_in_gis] I agree with you that for single-execute

[GitHub] [flink] flinkbot edited a comment on pull request #13482: test

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * 3777e154a7c1175f78937702a3d3d857f017e9c3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397 ## CI report: * ef1039af70b46068bbbcd9ef4ea0c5cfd0583d5c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13577: URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705 ## CI report: * 1fe9b6df03a206823ad28df58cf87ad7078eeb26 Azure:

[GitHub] [flink] wangxlong commented on pull request #13559: [Hotfix][Docs] Fix broken link of flink-architecture.md

2020-10-10 Thread GitBox
wangxlong commented on pull request #13559: URL: https://github.com/apache/flink/pull/13559#issuecomment-706545475 cc @zentol @klion26 in your free time ~ This is an automated message from the Apache Git Service. To respond

[GitHub] [flink-web] loniecc opened a new pull request #386: [FLINK-13679] Translate Training page on project website

2020-10-10 Thread GitBox
loniecc opened a new pull request #386: URL: https://github.com/apache/flink-web/pull/386 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

[GitHub] [flink] flinkbot edited a comment on pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13577: URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705 ## CI report: * 039b08f4bdd8a60a89fa324cc0213f4fb99a9e8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397 ## CI report: * ef1039af70b46068bbbcd9ef4ea0c5cfd0583d5c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13216: [FLINK-18999][table-planner-blink][hive] Temporary generic table does…

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13216: URL: https://github.com/apache/flink/pull/13216#issuecomment-678268420 ## CI report: * 8d6ca96817da4640dee68e9c81b7e612e63dfcd9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397 ## CI report: * ef1039af70b46068bbbcd9ef4ea0c5cfd0583d5c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13582: [BP-1.11][FLINK-19291][avro] Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13582: URL: https://github.com/apache/flink/pull/13582#issuecomment-706531763 ## CI report: * 9f79dca8c82e474548cb6743fd6e20881b96d347 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13216: [FLINK-18999][table-planner-blink][hive] Temporary generic table does…

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13216: URL: https://github.com/apache/flink/pull/13216#issuecomment-678268420 ## CI report: * 528277a79d67bb9309ec3d6121d40dfca9e83553 Azure:

[jira] [Comment Edited] (FLINK-19517) Support for Confluent Kafka of Table Creation in Flink SQL Client

2020-10-10 Thread Kevin Kwon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211673#comment-17211673 ] Kevin Kwon edited comment on FLINK-19517 at 10/10/20, 11:27 AM: Seems

[jira] [Closed] (FLINK-19517) Support for Confluent Kafka of Table Creation in Flink SQL Client

2020-10-10 Thread Kevin Kwon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Kwon closed FLINK-19517. -- Resolution: Duplicate Seems most of the concerns are already in the issue tracker as well as the

[jira] [Commented] (FLINK-19517) Support for Confluent Kafka of Table Creation in Flink SQL Client

2020-10-10 Thread Kevin Kwon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211672#comment-17211672 ] Kevin Kwon commented on FLINK-19517: [~jark] thanks :) > Support for Confluent Kafka of Table

[jira] [Commented] (FLINK-19292) HiveCatalog should support specifying Hadoop conf dir with configuration

2020-10-10 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211670#comment-17211670 ] Rui Li commented on FLINK-19292: I think the feature doesn't need to go to 1.11 and we can close this

[GitHub] [flink] flinkbot commented on pull request #13582: [BP-1.11][FLINK-19291][avro] Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

2020-10-10 Thread GitBox
flinkbot commented on pull request #13582: URL: https://github.com/apache/flink/pull/13582#issuecomment-706531763 ## CI report: * 9f79dca8c82e474548cb6743fd6e20881b96d347 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13479: [FLINK-19414][parquet] Introduce ParquetColumnarRowInputFormat

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13479: URL: https://github.com/apache/flink/pull/13479#issuecomment-698831350 ## CI report: * 6fc43dcfa07a2f1488f33d54d26ed8c4bdeff2ef Azure:

[GitHub] [flink] flinkbot commented on pull request #13582: [BP-1.11][FLINK-19291][avro] Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

2020-10-10 Thread GitBox
flinkbot commented on pull request #13582: URL: https://github.com/apache/flink/pull/13582#issuecomment-706530967 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] wuchong opened a new pull request #13582: [BP-1.11][FLINK-19291][avro] Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

2020-10-10 Thread GitBox
wuchong opened a new pull request #13582: URL: https://github.com/apache/flink/pull/13582 This is a cherry pick to release-1.11 branch. This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-19291) Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

2020-10-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19291: Fix Version/s: 1.11.3 > Fix exception for AvroSchemaConverter#convertToSchema when RowType contains >

[jira] [Reopened] (FLINK-19291) Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

2020-10-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reopened FLINK-19291: - > Fix exception for AvroSchemaConverter#convertToSchema when RowType contains > multiple row fields >

[jira] [Comment Edited] (FLINK-19291) Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

2020-10-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211659#comment-17211659 ] Jark Wu edited comment on FLINK-19291 at 10/10/20, 10:59 AM: - Fixed in -

[jira] [Closed] (FLINK-19291) Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

2020-10-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19291. --- Fix Version/s: 1.12.0 Resolution: Fixed Fixed in master: de87a2debde8546e6741390a81f43c032521c3c0 >

[GitHub] [flink] wuchong merged pull request #13472: [FLINK-19291][Formats] Fix `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-10-10 Thread GitBox
wuchong merged pull request #13472: URL: https://github.com/apache/flink/pull/13472 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-19291) Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

2020-10-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19291: Summary: Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields

[GitHub] [flink] flinkbot edited a comment on pull request #13487: [FLINK-19409][Documentation] remove unrelated comment for getValue in ListView

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13487: URL: https://github.com/apache/flink/pull/13487#issuecomment-699575614 ## CI report: * f756ebd3f2f727c01f63e63e27f5fb7be2c8120f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13577: URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705 ## CI report: * 66f4d1a8a98fd2a0736b0f8e14dbe765cedf33f6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13472: [FLINK-19291][Formats] Fix `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13472: URL: https://github.com/apache/flink/pull/13472#issuecomment-698171211 ## CI report: * a8b88bc4d52ac3d0aa6fe7a5681bd80a18501934 Azure:

[jira] [Commented] (FLINK-19525) Update Table API Overview page

2020-10-10 Thread M Haseeb Asif (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211658#comment-17211658 ] M Haseeb Asif commented on FLINK-19525: --- I will start working on this. > Update Table API

[GitHub] [flink] lirui-apache commented on a change in pull request #13479: [FLINK-19414][parquet] Introduce ParquetColumnarRowInputFormat

2020-10-10 Thread GitBox
lirui-apache commented on a change in pull request #13479: URL: https://github.com/apache/flink/pull/13479#discussion_r502767584 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetVectorizedInputFormat.java ## @@ -0,0 +1,471 @@ +/*

[jira] [Updated] (FLINK-19565) java.util.Collections$UnmodifiableList to field org.apache.flink.runtime.jobgraph.JobVertex.operatorIDs of type java.util.ArrayList in instance of org.apache.flink.runti

2020-10-10 Thread yardstrong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yardstrong updated FLINK-19565: --- Environment: I add {color:#4c9aff}flink-csv-1.10.2.jar{color} &

[jira] [Updated] (FLINK-19565) java.util.Collections$UnmodifiableList to field org.apache.flink.runtime.jobgraph.JobVertex.operatorIDs of type java.util.ArrayList in instance of org.apache.flink.runti

2020-10-10 Thread yardstrong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yardstrong updated FLINK-19565: --- Priority: Trivial (was: Major) > java.util.Collections$UnmodifiableList to field >

[jira] [Updated] (FLINK-19565) java.util.Collections$UnmodifiableList to field org.apache.flink.runtime.jobgraph.JobVertex.operatorIDs of type java.util.ArrayList in instance of org.apache.flink.runti

2020-10-10 Thread yardstrong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yardstrong updated FLINK-19565: --- Environment: I add {color:#4c9aff}flink-csv-1.10.2.jar{color} &

[jira] [Created] (FLINK-19565) java.util.Collections$UnmodifiableList to field org.apache.flink.runtime.jobgraph.JobVertex.operatorIDs of type java.util.ArrayList in instance of org.apache.flink.runti

2020-10-10 Thread yardstrong (Jira)
yardstrong created FLINK-19565: -- Summary: java.util.Collections$UnmodifiableList to field org.apache.flink.runtime.jobgraph.JobVertex.operatorIDs of type java.util.ArrayList in instance of org.apache.flink.runtime.jobgraph.JobVertex

[GitHub] [flink] flinkbot edited a comment on pull request #13571: [FLINK-18068] Use FatalErrorHandler to handle the error thrown from r…

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13571: URL: https://github.com/apache/flink/pull/13571#issuecomment-706172803 ## CI report: * 44ac0337baeedbe012e2762f73146b2ede74375b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13487: [FLINK-19409][Documentation] remove unrelated comment for getValue in ListView

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13487: URL: https://github.com/apache/flink/pull/13487#issuecomment-699575614 ## CI report: * f756ebd3f2f727c01f63e63e27f5fb7be2c8120f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13482: test

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * ed1e28ba08b65e2de0444a1e6b2da94b5197ba07 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13577: URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705 ## CI report: * cde6b367bcfc5c76ee9004a6399c734ec890c6d1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13482: test

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * ed1e28ba08b65e2de0444a1e6b2da94b5197ba07 Azure:

[jira] [Closed] (FLINK-15324) Make MesosResourceManager inherit from ActiveResourceManager

2020-10-10 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-15324. -- Resolution: Won't Fix > Make MesosResourceManager inherit from ActiveResourceManager >

[jira] [Commented] (FLINK-15324) Make MesosResourceManager inherit from ActiveResourceManager

2020-10-10 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211642#comment-17211642 ] Yangze Guo commented on FLINK-15324: I believe this issue will be fixed by FLINK-18722. Close it

[GitHub] [flink] flinkbot edited a comment on pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397 ## CI report: * ef1039af70b46068bbbcd9ef4ea0c5cfd0583d5c Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #13529: [FLINK-19473] Implement multi inputs sorting DataInput

2020-10-10 Thread GitBox
pnowojski commented on a change in pull request #13529: URL: https://github.com/apache/flink/pull/13529#discussion_r502771468 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/MultiInputSortingDataInput.java ## @@ -0,0 +1,429 @@

[GitHub] [flink] danny0405 commented on a change in pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-10 Thread GitBox
danny0405 commented on a change in pull request #13577: URL: https://github.com/apache/flink/pull/13577#discussion_r502771369 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/calcite/schema/Statistic.java ## @@ -0,0 +1,73 @@ +/* + * Licensed to the

[GitHub] [flink] danny0405 commented on a change in pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-10 Thread GitBox
danny0405 commented on a change in pull request #13577: URL: https://github.com/apache/flink/pull/13577#discussion_r502771175 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/schema/TableSourceTable.scala ## @@ -65,15

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

2020-10-10 Thread CloseRiver (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211635#comment-17211635 ] CloseRiver commented on FLINK-19456: [~jark],could you assign to me ? > sql client execute insert

[GitHub] [flink] scottxusayhi commented on pull request #13555: [FLINK-17613][e2e][k8s] Test against multiple k8s versions

2020-10-10 Thread GitBox
scottxusayhi commented on pull request #13555: URL: https://github.com/apache/flink/pull/13555#issuecomment-706520260 This has been done as @rmetzger suggested. @wangyang0918 would you mind to review again? This is an

[GitHub] [flink] danny0405 commented on a change in pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-10 Thread GitBox
danny0405 commented on a change in pull request #13577: URL: https://github.com/apache/flink/pull/13577#discussion_r502770161 ## File path: flink-table/flink-table-planner-blink/pom.xml ## @@ -189,10 +194,6 @@ under the License.

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

2020-10-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211631#comment-17211631 ] Yun Tang commented on FLINK-19481: -- [~jgrier] Sounds reasonable to me. [~rmetzger] what do you think

[GitHub] [flink] xintongsong commented on pull request #13500: [FLINK-19180][state backends] Make RocksDB respect managed memory fraction

2020-10-10 Thread GitBox
xintongsong commented on pull request #13500: URL: https://github.com/apache/flink/pull/13500#issuecomment-706519417 @Myasuka Thanks for the review. Comments addressed. Please take another look. This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13577: URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705 ## CI report: * cde6b367bcfc5c76ee9004a6399c734ec890c6d1 Azure:

[GitHub] [flink] flinkbot commented on pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

2020-10-10 Thread GitBox
flinkbot commented on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397 ## CI report: * ef1039af70b46068bbbcd9ef4ea0c5cfd0583d5c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13500: [FLINK-19180][state backends] Make RocksDB respect managed memory fraction

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13500: URL: https://github.com/apache/flink/pull/13500#issuecomment-699908639 ## CI report: * f8c0014b7d02402a3b0b251d6295a3a75504b0f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13482: test

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * ed1e28ba08b65e2de0444a1e6b2da94b5197ba07 Azure:

[jira] [Closed] (FLINK-5815) Add resource files configuration for Yarn Mode

2020-10-10 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu closed FLINK-5815. -- Resolution: Abandoned > Add resource files configuration for Yarn Mode >

[GitHub] [flink] flinkbot commented on pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

2020-10-10 Thread GitBox
flinkbot commented on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706518502 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] gaoyunhaii commented on pull request #11326: [FLINK-11427][formats] Add protobuf parquet support for StreamingFileSink

2020-10-10 Thread GitBox
gaoyunhaii commented on pull request #11326: URL: https://github.com/apache/flink/pull/11326#issuecomment-706518299 Hi @aljoscha the failed test should be fixed. I also updated the corresponding docs. This is an automated

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

2020-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17331: --- Labels: pull-request-available (was: ) > Add NettyMessageContent interface for all the

[GitHub] [flink] KarmaGYZ opened a new pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

2020-10-10 Thread GitBox
KarmaGYZ opened a new pull request #13581: URL: https://github.com/apache/flink/pull/13581 …is written to NettyMessage ## What is the purpose of the change Explicitly get the ByteBuf length of all classes which is written to NettyMessage

[jira] [Commented] (FLINK-13678) Translate "Code Style - Preamble" page into Chinese

2020-10-10 Thread huzeming (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211629#comment-17211629 ] huzeming commented on FLINK-13678: -- I want to work on this. would you please assign it to me? I think I

[jira] [Commented] (FLINK-19553) The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to yyyy-MM-dd HH:mm:ss

2020-10-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211627#comment-17211627 ] Yun Tang commented on FLINK-19553: -- I think this deserves to fix, [~liufangliang] would you like to fix

[GitHub] [flink] flinkbot edited a comment on pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13577: URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705 ## CI report: * cde6b367bcfc5c76ee9004a6399c734ec890c6d1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13555: [FLINK-17613][e2e][k8s] Test against multiple k8s versions

2020-10-10 Thread GitBox
flinkbot edited a comment on pull request #13555: URL: https://github.com/apache/flink/pull/13555#issuecomment-704987370 ## CI report: * 53c344d97f8d63db14ccb2fcd2ff923f2e5e08a2 Azure:

  1   2   >