[jira] [Commented] (FLINK-19423) Primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-19423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211841#comment-17211841 ] limbo commented on FLINK-19423: --- I'm trying to fix the code, and do some test, but find th

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

flinkbot edited a comment on pull request #13584: URL: https://github.com/apache/flink/pull/13584#issuecomment-706656585 ## CI report: * ab9911fee445c24dba308c6bae19ef51db8abec8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot commented on pull request #13584: URL: https://github.com/apache/flink/pull/13584#issuecomment-706656585 ## CI report: * ab9911fee445c24dba308c6bae19ef51db8abec8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

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 pro

[GitHub] [flink] Shawn-Hx opened a new pull request #13584: [hotfix][typo] Fix typo in MiniCluster

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 `dispatcherResourceManagreComponentRpcServiceFa

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

[ 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

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

[ 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

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

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

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"

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

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: https://issues.apache.org/

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

[ https://issues.apache.org/jira/browse/FLINK-18117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211826#comment-17211826 ] Dian Fu commented on FLINK-18117: - https://dev.azure.com/apache-flink/apache-flink/_buil

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

[ https://issues.apache.org/jira/browse/FLINK-19539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211825#comment-17211825 ] Dian Fu commented on FLINK-19539: - https://dev.azure.com/apache-flink/apache-flink/_buil

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

[ https://issues.apache.org/jira/browse/FLINK-19484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211823#comment-17211823 ] Dian Fu commented on FLINK-19484: - https://dev.azure.com/apache-flink/apache-flink/_buil

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

[ https://issues.apache.org/jira/browse/FLINK-18444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211822#comment-17211822 ] Dian Fu commented on FLINK-18444: - Another instance(Kafka011TableITCase.testKafkaSourceS

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

[ 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 & > Mon

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

[ 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 2126397101877d31978a15cdb311550f

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

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 t

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

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 messag

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

flinkbot edited a comment on pull request #13583: URL: https://github.com/apache/flink/pull/13583#issuecomment-706604937 ## CI report: * 5fe1d5b4deb0c6b94ce8a7c564e98caec5217339 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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.

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.

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.

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.

flinkbot edited a comment on pull request #13583: URL: https://github.com/apache/flink/pull/13583#issuecomment-706604937 ## CI report: * 5fe1d5b4deb0c6b94ce8a7c564e98caec5217339 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 r

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

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 pro

[jira] [Updated] (FLINK-19154) Application mode deletes HA data in case of suspended ZooKeeper connection

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

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

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 tr

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

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

[ https://issues.apache.org/jira/browse/FLINK-19491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211732#comment-17211732 ] Lian Jiang commented on FLINK-19491: Thanks [~nicholasjiang] and [~AHeise] for takin

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

flinkbot edited a comment on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397 ## CI report: * 1e187203b15559b08d15a0cca949ca15a8a3bafe Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 +109,1

[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

flinkbot edited a comment on pull request #13582: URL: https://github.com/apache/flink/pull/13582#issuecomment-706531763 ## CI report: * 9f79dca8c82e474548cb6743fd6e20881b96d347 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 b

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

flinkbot edited a comment on pull request #13487: URL: https://github.com/apache/flink/pull/13487#issuecomment-699575614 ## CI report: * 86351d896dfe576264025b6db7ca9ba46e27881a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211710#comment-17211710 ] Kostas Kloudas commented on FLINK-19358: [~fly_in_gis] I agree with you that for

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

flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * 3777e154a7c1175f78937702a3d3d857f017e9c3 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397 ## CI report: * ef1039af70b46068bbbcd9ef4ea0c5cfd0583d5c Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #13577: URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705 ## CI report: * 1fe9b6df03a206823ad28df58cf87ad7078eeb26 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 t

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

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

flinkbot edited a comment on pull request #13577: URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705 ## CI report: * 039b08f4bdd8a60a89fa324cc0213f4fb99a9e8f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397 ## CI report: * ef1039af70b46068bbbcd9ef4ea0c5cfd0583d5c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13216: URL: https://github.com/apache/flink/pull/13216#issuecomment-678268420 ## CI report: * 8d6ca96817da4640dee68e9c81b7e612e63dfcd9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397 ## CI report: * ef1039af70b46068bbbcd9ef4ea0c5cfd0583d5c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

flinkbot edited a comment on pull request #13582: URL: https://github.com/apache/flink/pull/13582#issuecomment-706531763 ## CI report: * 9f79dca8c82e474548cb6743fd6e20881b96d347 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13216: URL: https://github.com/apache/flink/pull/13216#issuecomment-678268420 ## CI report: * 528277a79d67bb9309ec3d6121d40dfca9e83553 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-19517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211672#comment-17211672 ] Kevin Kwon commented on FLINK-19517: [~jark] thanks :) > Support for Confluent Kafk

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

[ https://issues.apache.org/jira/browse/FLINK-19292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211670#comment-17211670 ] Rui Li commented on FLINK-19292: I think the feature doesn't need to go to 1.11 and we c

[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

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 r

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

flinkbot edited a comment on pull request #13479: URL: https://github.com/apache/flink/pull/13479#issuecomment-698831350 ## CI report: * 6fc43dcfa07a2f1488f33d54d26ed8c4bdeff2ef Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

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 pro

[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

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, ple

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

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

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

[ 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

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

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

[ 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

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

[ 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

flinkbot edited a comment on pull request #13487: URL: https://github.com/apache/flink/pull/13487#issuecomment-699575614 ## CI report: * f756ebd3f2f727c01f63e63e27f5fb7be2c8120f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13577: URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705 ## CI report: * 66f4d1a8a98fd2a0736b0f8e14dbe765cedf33f6 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #13472: URL: https://github.com/apache/flink/pull/13472#issuecomment-698171211 ## CI report: * a8b88bc4d52ac3d0aa6fe7a5681bd80a18501934 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[ https://issues.apache.org/jira/browse/FLINK-19525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211658#comment-17211658 ] M Haseeb Asif commented on FLINK-19525: --- I will start working on this. > Update T

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

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

[ 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} & {color:#4c9aff}flink-sql-connector-

[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

[ 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 > org.apache.flin

[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

[ 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} & {color:#4c9aff}flink-sql-connector-

[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

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…

flinkbot edited a comment on pull request #13571: URL: https://github.com/apache/flink/pull/13571#issuecomment-706172803 ## CI report: * 44ac0337baeedbe012e2762f73146b2ede74375b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13487: URL: https://github.com/apache/flink/pull/13487#issuecomment-699575614 ## CI report: * f756ebd3f2f727c01f63e63e27f5fb7be2c8120f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * ed1e28ba08b65e2de0444a1e6b2da94b5197ba07 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13577: URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705 ## CI report: * cde6b367bcfc5c76ee9004a6399c734ec890c6d1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * ed1e28ba08b65e2de0444a1e6b2da94b5197ba07 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-15324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211642#comment-17211642 ] Yangze Guo commented on FLINK-15324: I believe this issue will be fixed by FLINK-187

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

flinkbot edited a comment on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397 ## CI report: * ef1039af70b46068bbbcd9ef4ea0c5cfd0583d5c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

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 Apache

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

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 +65,8

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

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

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

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 automa

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

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. org.apach

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

[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211631#comment-17211631 ] Yun Tang commented on FLINK-19481: -- [~jgrier] Sounds reasonable to me. [~rmetzger] wha

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

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 f

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

flinkbot edited a comment on pull request #13577: URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705 ## CI report: * cde6b367bcfc5c76ee9004a6399c734ec890c6d1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 r

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

flinkbot edited a comment on pull request #13500: URL: https://github.com/apache/flink/pull/13500#issuecomment-699908639 ## CI report: * f8c0014b7d02402a3b0b251d6295a3a75504b0f7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * ed1e28ba08b65e2de0444a1e6b2da94b5197ba07 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

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 pro

[GitHub] [flink] gaoyunhaii commented on pull request #11326: [FLINK-11427][formats] Add protobuf parquet support for StreamingFileSink

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 m

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211629#comment-17211629 ] huzeming commented on FLINK-13678: -- I want to work on this. would you please assign it

  1   2   >