[jira] [Commented] (FLINK-18371) NPE of "org.apache.flink.table.data.util.DataFormatConverters$BigDecimalConverter.toExternalImpl(DataFormatConverters.java:680)"

[ https://issues.apache.org/jira/browse/FLINK-18371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142672#comment-17142672 ] Leonard Xu commented on FLINK-18371: I test this case use filesystem connector in la

[jira] [Created] (FLINK-18415) Support TableResult#collect in the Python Table API to align with the Java Table API

Dian Fu created FLINK-18415: --- Summary: Support TableResult#collect in the Python Table API to align with the Java Table API Key: FLINK-18415 URL: https://issues.apache.org/jira/browse/FLINK-18415 Project: F

[GitHub] [flink] flinkbot edited a comment on pull request #12742: [FLINK-18407][runtime] Harden SlotPoolImpl#maybeRemapOrphanedAllocation

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

[GitHub] [flink] flinkbot edited a comment on pull request #12747: [FLINK-17327] Fix Kafka Producer Resource Leaks (backport to Flink 1.10)

flinkbot edited a comment on pull request #12747: URL: https://github.com/apache/flink/pull/12747#issuecomment-647739041 ## CI report: * b2916ff151653f8d2a952ab8acd52e8fce031055 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/172554306) Bot comman

[jira] [Closed] (FLINK-18411) CollectionExecutorTest failed to compiled in release-1.11

[ https://issues.apache.org/jira/browse/FLINK-18411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18411. --- Resolution: Fixed Fixed in 1.11.0: 83d78134d2497266f8d864b2667c10a955384b94 This problem not exists in mast

[GitHub] [flink] wuchong merged pull request #12749: [FLINK-18411][tests] Fix CollectionExecutorTest failed to compiled in release-1.11

wuchong merged pull request #12749: URL: https://github.com/apache/flink/pull/12749 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] wuchong commented on pull request #12749: [FLINK-18411][tests] Fix CollectionExecutorTest failed to compiled in release-1.11

wuchong commented on pull request #12749: URL: https://github.com/apache/flink/pull/12749#issuecomment-647943193 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] aljoscha commented on pull request #12747: [FLINK-17327] Fix Kafka Producer Resource Leaks (backport to Flink 1.10)

aljoscha commented on pull request #12747: URL: https://github.com/apache/flink/pull/12747#issuecomment-647939692 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Commented] (FLINK-18352) org.apache.flink.core.execution.DefaultExecutorServiceLoader not thread safe

[ https://issues.apache.org/jira/browse/FLINK-18352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142656#comment-17142656 ] Piotr Nowojski commented on FLINK-18352: This caused https://issues.apache.org/j

[GitHub] [flink] flinkbot edited a comment on pull request #12728: [FLINK-18399] [table-api-java] fix TableResult#print can not print the result of unbounded stream query

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

[jira] [Updated] (FLINK-18187) CheckPubSubEmulatorTest failed on azure

[ https://issues.apache.org/jira/browse/FLINK-18187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18187: --- Priority: Critical (was: Major) > CheckPubSubEmulatorTest failed on azure > ---

[jira] [Commented] (FLINK-18187) CheckPubSubEmulatorTest failed on azure

[ https://issues.apache.org/jira/browse/FLINK-18187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142650#comment-17142650 ] Piotr Nowojski commented on FLINK-18187: another instance on 1.11 branch: https:

[jira] [Commented] (FLINK-18406) Annotate DualKeyLinkedMap with @Nullable annotation

[ https://issues.apache.org/jira/browse/FLINK-18406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142651#comment-17142651 ] Zhu Zhu commented on FLINK-18406: - Well I see that @Nullable annotations are still good

[jira] [Updated] (FLINK-18371) NPE of "org.apache.flink.table.data.util.DataFormatConverters$BigDecimalConverter.toExternalImpl(DataFormatConverters.java:680)"

[ https://issues.apache.org/jira/browse/FLINK-18371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-18371: --- Environment: I use the sql-gateway to run this sql. The environment is streaming. *The sql is:* CRE

[jira] [Commented] (FLINK-18406) Annotate DualKeyLinkedMap with @Nullable annotation

[ https://issues.apache.org/jira/browse/FLINK-18406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142644#comment-17142644 ] Zhu Zhu commented on FLINK-18406: - Would it make sense to forbid null keys in DualKeyLin

[GitHub] [flink] tillrohrmann closed pull request #12745: [FLINK-18353] Make enabling of the JVM Direct Memory limit configurable for JM

tillrohrmann closed pull request #12745: URL: https://github.com/apache/flink/pull/12745 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 g

[GitHub] [flink] klion26 commented on a change in pull request #12727: [FLINK-17292][docs] Translate Fault Tolerance training lesson to Chinese

klion26 commented on a change in pull request #12727: URL: https://github.com/apache/flink/pull/12727#discussion_r443971994 ## File path: docs/learn-flink/fault_tolerance.zh.md ## @@ -29,180 +29,156 @@ under the License. ## State Backends -The keyed state managed by Flink

[GitHub] [flink] flinkbot edited a comment on pull request #12750: [FLINK-18413][streaming] CollectResultIterator should throw exception if user does not enable checkpointing in streaming mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #12054: [FLINK-17579] Allow user to set the prefix of TaskManager's ResourceID in standalone mode

flinkbot edited a comment on pull request #12054: URL: https://github.com/apache/flink/pull/12054#issuecomment-626143079 ## CI report: * 311c21707305392d6bde18038bb1d8413867419b UNKNOWN * e85a3c626720f035ff0379e849e36ea6e8db7249 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-17800: -- Priority: Blocker (was: Critical) Escalating the priority to Blocker since the previous observed coredump iss

[jira] [Commented] (FLINK-18414) Kafka Json connector in Table API support more option

[ https://issues.apache.org/jira/browse/FLINK-18414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142639#comment-17142639 ] DuBin commented on FLINK-18414: --- [~jark] exactly, thanks for help! > Kafka Json connector

[jira] [Closed] (FLINK-18414) Kafka Json connector in Table API support more option

[ https://issues.apache.org/jira/browse/FLINK-18414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] DuBin closed FLINK-18414. - Fix Version/s: 1.11.1 Resolution: Fixed > Kafka Json connector in Table API support more option > ---

[jira] [Commented] (FLINK-18414) Kafka Json connector in Table API support more option

[ https://issues.apache.org/jira/browse/FLINK-18414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142638#comment-17142638 ] Jark Wu commented on FLINK-18414: - We added a new option {{json.ignore-parse-error}} in

[GitHub] [flink] flinkbot commented on pull request #12750: [FLINK-18413][streaming] CollectResultIterator should throw exception if user does not enable checkpointing in streaming mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #12737: [FLINK-17639][docs] Document which FileSystems are supported by the Streami…

flinkbot edited a comment on pull request #12737: URL: https://github.com/apache/flink/pull/12737#issuecomment-647407770 ## CI report: * cccbc2294423fce32765002c73acbb06b5ed40a4 UNKNOWN * ec2483d7dd2f9b5e20cdde4673c77eeaf377491b Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-18414) Kafka Json connector in Table API support more option

DuBin created FLINK-18414: - Summary: Kafka Json connector in Table API support more option Key: FLINK-18414 URL: https://issues.apache.org/jira/browse/FLINK-18414 Project: Flink Issue Type: Improveme

[GitHub] [flink] leonardBang commented on pull request #12719: [FLINK-18352] Make the default ClusterClientServiceLoader and ExecutorServiceLoader thread-safe.

leonardBang commented on pull request #12719: URL: https://github.com/apache/flink/pull/12719#issuecomment-647918747 ignore my comment, @wuchong have hot-fixed this one This is an automated message from the Apache Git Service

[GitHub] [flink-web] klion26 commented on a change in pull request #345: [FLINK-17491] Translate Training page on project website

klion26 commented on a change in pull request #345: URL: https://github.com/apache/flink-web/pull/345#discussion_r443967697 ## File path: training.zh.md ## @@ -58,49 +57,49 @@ This training covers the fundamentals of Flink, including: -

[GitHub] [flink] aljoscha commented on pull request #12749: [FLINK-18411][tests] Fix CollectionExecutorTest failed to compiled in release-1.11

aljoscha commented on pull request #12749: URL: https://github.com/apache/flink/pull/12749#issuecomment-647909183 LGTM once azure is green! Thanks for fixing it! This is an automated message from the Apache Git Service. To re

[GitHub] [flink] flinkbot edited a comment on pull request #12728: [FLINK-18399] [table-api-java] fix TableResult#print can not print the result of unbounded stream query

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

[GitHub] [flink] flinkbot edited a comment on pull request #12054: [FLINK-17579] Allow user to set the prefix of TaskManager's ResourceID in standalone mode

flinkbot edited a comment on pull request #12054: URL: https://github.com/apache/flink/pull/12054#issuecomment-626143079 ## CI report: * 311c21707305392d6bde18038bb1d8413867419b UNKNOWN * e0c34c807adf768d904b5850c9ce4c8b4be4b70a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #12750: [FLINK-18413][streaming] CollectResultIterator should throw exception if user does not enable checkpointing in streaming mode

flinkbot commented on pull request #12750: URL: https://github.com/apache/flink/pull/12750#issuecomment-647907034 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] leonardBang edited a comment on pull request #12719: [FLINK-18352] Make the default ClusterClientServiceLoader and ExecutorServiceLoader thread-safe.

leonardBang edited a comment on pull request #12719: URL: https://github.com/apache/flink/pull/12719#issuecomment-647906823 Hello, @kl0u I got a compile error, seems this PR direct go into release-1.11, the line[1] should update too. I'd like to open a hotfix if you can help confirm

[GitHub] [flink] leonardBang commented on pull request #12719: [FLINK-18352] Make the default ClusterClientServiceLoader and ExecutorServiceLoader thread-safe.

leonardBang commented on pull request #12719: URL: https://github.com/apache/flink/pull/12719#issuecomment-647906823 Hello, @kl0u I got a compile error, seems this PR direct go into release-1.11, the line should update too. https://github.com/apache/flink/blob/release-1.11/flink-ja

[GitHub] [flink] TsReaper opened a new pull request #12750: [FLINK-18413][streaming] CollectResultIterator should throw exception if user does not enable checkpointing in streaming mode

TsReaper opened a new pull request #12750: URL: https://github.com/apache/flink/pull/12750 ## What is the purpose of the change Currently CollectResultIterator will only output results after a checkpoint in streaming mode. It will be strange for users who does not enable checkpointi

[jira] [Updated] (FLINK-18413) CollectResultIterator should throw exception if user does not enable checkpointing in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-18413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18413: --- Labels: pull-request-available (was: ) > CollectResultIterator should throw exception if us

[jira] [Updated] (FLINK-18413) CollectResultIterator should throw exception if user does not enable checkpointing in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-18413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-18413: Description: Currently {{CollectResultIterator}} will only output results after a checkpoint in s

[jira] [Updated] (FLINK-18413) CollectResultIterator should throw exception if user does not enable checkpointing in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-18413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-18413: Component/s: (was: Table SQL / API) API / DataStream > CollectResultIterator

[jira] [Updated] (FLINK-18413) CollectResultIterator should throw exception if user does not enable checkpointing in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-18413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-18413: Summary: CollectResultIterator should throw exception if user does not enable checkpointing in str

[jira] [Created] (FLINK-18413) TableResult.collect should throw exception if user does not enable checkpointing in streaming mode

Caizhi Weng created FLINK-18413: --- Summary: TableResult.collect should throw exception if user does not enable checkpointing in streaming mode Key: FLINK-18413 URL: https://issues.apache.org/jira/browse/FLINK-18413

[GitHub] [flink] flinkbot edited a comment on pull request #12054: [FLINK-17579] Allow user to set the prefix of TaskManager's ResourceID in standalone mode

flinkbot edited a comment on pull request #12054: URL: https://github.com/apache/flink/pull/12054#issuecomment-626143079 ## CI report: * 311c21707305392d6bde18038bb1d8413867419b UNKNOWN * e0c34c807adf768d904b5850c9ce4c8b4be4b70a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12728: [FLINK-18399] [table-api-java] fix TableResult#print can not print the result of unbounded stream query

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

[GitHub] [flink] wuchong commented on a change in pull request #12666: [FLINK-18313][doc] Update Hive dialect doc about VIEW

wuchong commented on a change in pull request #12666: URL: https://github.com/apache/flink/pull/12666#discussion_r443954497 ## File path: docs/dev/table/hive/hive_dialect.md ## @@ -272,6 +272,8 @@ CREATE VIEW [IF NOT EXISTS] view_name [(column_name, ...) ] Alter +**NO

[GitHub] [flink] flinkbot edited a comment on pull request #9648: [FLINK-13872] [docs-zh] Translate Operations Playground to Chinese

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

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142610#comment-17142610 ] Anshul Bansal commented on FLINK-16048: --- [~danny0405], Any update on this , when i

[jira] [Commented] (FLINK-18364) A streaming sql cause "org.apache.flink.table.api.ValidationException: Type TIMESTAMP(6) of table field 'rowtime' does not match with the physical type TIMESTAMP(3) of

[ https://issues.apache.org/jira/browse/FLINK-18364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142609#comment-17142609 ] Jark Wu commented on FLINK-18364: - cc [~lirui] > A streaming sql cause "org.apache.flin

[jira] [Commented] (FLINK-18371) NPE of "org.apache.flink.table.data.util.DataFormatConverters$BigDecimalConverter.toExternalImpl(DataFormatConverters.java:680)"

[ https://issues.apache.org/jira/browse/FLINK-18371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142607#comment-17142607 ] Jark Wu commented on FLINK-18371: - cc [~Leonard Xu] > NPE of > "org.apache.flink.table

[GitHub] [flink] lirui-apache commented on pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

lirui-apache commented on pull request #12682: URL: https://github.com/apache/flink/pull/12682#issuecomment-647895172 Jingsong is on annual leave. @zentol could you please help merge this PR? This is an automated message from

[jira] [Commented] (FLINK-18400) A streaming sql has "java.lang.NegativeArraySizeException"

[ https://issues.apache.org/jira/browse/FLINK-18400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142606#comment-17142606 ] Jark Wu commented on FLINK-18400: - cc [~TsReaper] > A streaming sql has "java.lang.Nega

[jira] [Commented] (FLINK-18365) The same sql in a batch env and a streaming env has different value.

[ https://issues.apache.org/jira/browse/FLINK-18365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142604#comment-17142604 ] Jark Wu commented on FLINK-18365: - [~zjwang], I postponed this issue to 1.11.1. The root

[GitHub] [flink] flinkbot edited a comment on pull request #12748: [FLINK-18324][docs-zh] Translate updated data type into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #12737: [FLINK-17639][docs] Document which FileSystems are supported by the Streami…

flinkbot edited a comment on pull request #12737: URL: https://github.com/apache/flink/pull/12737#issuecomment-647407770 ## CI report: * cccbc2294423fce32765002c73acbb06b5ed40a4 UNKNOWN * ec2483d7dd2f9b5e20cdde4673c77eeaf377491b Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12749: [FLINK-18411][tests] Fix CollectionExecutorTest failed to compiled in release-1.11

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

[jira] [Updated] (FLINK-18365) The same sql in a batch env and a streaming env has different value.

[ https://issues.apache.org/jira/browse/FLINK-18365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18365: Fix Version/s: (was: 1.11.0) 1.11.1 > The same sql in a batch env and a streaming e

[GitHub] [flink] godfreyhe commented on pull request #12577: [FLINK-17599][docs] Update documents due to FLIP-84

godfreyhe commented on pull request #12577: URL: https://github.com/apache/flink/pull/12577#issuecomment-647893295 cc @twalthr This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [flink] flinkbot edited a comment on pull request #9648: [FLINK-13872] [docs-zh] Translate Operations Playground to Chinese

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

[GitHub] [flink] godfreyhe commented on pull request #12728: [FLINK-18399] [table-api-java] fix TableResult#print can not print the result of unbounded stream query

godfreyhe commented on pull request #12728: URL: https://github.com/apache/flink/pull/12728#issuecomment-647892983 cc @twalthr @wuchong This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Commented] (FLINK-18376) java.lang.ArrayIndexOutOfBoundsException in RetractableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-18376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142602#comment-17142602 ] Jark Wu commented on FLINK-18376: - I think FLINK-17625 didn't fix this issue. > java.

[GitHub] [flink] guoweiM commented on a change in pull request #12737: [FLINK-17639][docs] Document which FileSystems are supported by the Streami…

guoweiM commented on a change in pull request #12737: URL: https://github.com/apache/flink/pull/12737#discussion_r443945110 ## File path: docs/dev/connectors/streamfile_sink.zh.md ## @@ -705,6 +705,9 @@ Hadoop 2.7 之前的版本不支持这个方法，因此 Flink 会报异常。 重要提示 3: Flink 以及 `StreamingFileSink

[jira] [Assigned] (FLINK-18399) TableResult#print can not print the result of unbounded stream query

[ https://issues.apache.org/jira/browse/FLINK-18399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18399: Assignee: Zhijiang > TableResult#print can not print the result of unbounded stream query > -

[jira] [Assigned] (FLINK-18399) TableResult#print can not print the result of unbounded stream query

[ https://issues.apache.org/jira/browse/FLINK-18399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18399: Assignee: godfrey he (was: Zhijiang) > TableResult#print can not print the result of unbounded s

[jira] [Commented] (FLINK-18351) ModuleManager creates a lot of duplicate/similar log messages

[ https://issues.apache.org/jira/browse/FLINK-18351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142601#comment-17142601 ] Jark Wu commented on FLINK-18351: - +1 to downgrade the log level. > ModuleManager crea

[jira] [Commented] (FLINK-18376) java.lang.ArrayIndexOutOfBoundsException in RetractableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-18376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142600#comment-17142600 ] LakeShen commented on FLINK-18376: -- The FLINK-17625 fix the ArrayIndexOutOfBoundsExcept

[jira] [Commented] (FLINK-18365) The same sql in a batch env and a streaming env has different value.

[ https://issues.apache.org/jira/browse/FLINK-18365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142599#comment-17142599 ] Zhijiang commented on FLINK-18365: -- [~jark] Do you think it would be a blocker issue fo

[GitHub] [flink] flinkbot commented on pull request #12748: [FLINK-18324][docs-zh] Translate updated data type into Chinese

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

[GitHub] [flink] flinkbot commented on pull request #12749: [FLINK-18411][tests] Fix CollectionExecutorTest failed to compiled in release-1.11

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

[jira] [Updated] (FLINK-18385) Translate "DataGen SQL Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18385: Fix Version/s: 1.11.0 > Translate "DataGen SQL Connector" page into Chinese >

[jira] [Closed] (FLINK-18385) Translate "DataGen SQL Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18385. --- Resolution: Fixed - master (1.12.0): 0c20f25fd5a435143fd607dfbf3b18671d574fc2 - 1.11.0: cba18bde4a17832e01c3

[jira] [Commented] (FLINK-18376) java.lang.ArrayIndexOutOfBoundsException in RetractableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-18376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142597#comment-17142597 ] LakeShen commented on FLINK-18376: -- Hi ,[~libenchao],the flink version is flink 1.10 ,

[GitHub] [flink] wuchong closed pull request #12730: [FLINK-18385][docs-zh] Translate "DataGen SQL Connector" page into Chinese

wuchong closed pull request #12730: URL: https://github.com/apache/flink/pull/12730 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] [Comment Edited] (FLINK-18351) ModuleManager creates a lot of duplicate/similar log messages

[ https://issues.apache.org/jira/browse/FLINK-18351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142594#comment-17142594 ] Shengkai Fang edited comment on FLINK-18351 at 6/23/20, 3:36 AM: -

[jira] [Commented] (FLINK-18364) A streaming sql cause "org.apache.flink.table.api.ValidationException: Type TIMESTAMP(6) of table field 'rowtime' does not match with the physical type TIMESTAMP(3) of

[ https://issues.apache.org/jira/browse/FLINK-18364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142595#comment-17142595 ] Zhijiang commented on FLINK-18364: --  [~lzljs3620320] is in vacation these days. [~ykt83

[jira] [Comment Edited] (FLINK-18278) Translate new documenation homepage

[ https://issues.apache.org/jira/browse/FLINK-18278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142593#comment-17142593 ] zhangzhanhua edited comment on FLINK-18278 at 6/23/20, 3:36 AM: --

[jira] [Commented] (FLINK-18351) ModuleManager creates a lot of duplicate/similar log messages

[ https://issues.apache.org/jira/browse/FLINK-18351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142594#comment-17142594 ] Shengkai Fang commented on FLINK-18351: --- The reason why we have repeated logs is t

[jira] [Commented] (FLINK-18278) Translate new documenation homepage

[ https://issues.apache.org/jira/browse/FLINK-18278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142593#comment-17142593 ] zhangzhanhua commented on FLINK-18278: -- [~libenchao] [~sjwiesman] In the doc: [

[jira] [Updated] (FLINK-15397) Streaming and batch has different value in the case of count function

[ https://issues.apache.org/jira/browse/FLINK-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-15397: --- Fix Version/s: 1.11.0 Affects Version/s: 1.11.0 > Streaming and batch has different value in

[jira] [Commented] (FLINK-18371) NPE of "org.apache.flink.table.data.util.DataFormatConverters$BigDecimalConverter.toExternalImpl(DataFormatConverters.java:680)"

[ https://issues.apache.org/jira/browse/FLINK-18371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142588#comment-17142588 ] Zhijiang commented on FLINK-18371: -- [~caoshaokan] [~libenchao], If this is really a bug

[jira] [Commented] (FLINK-18400) A streaming sql has "java.lang.NegativeArraySizeException"

[ https://issues.apache.org/jira/browse/FLINK-18400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142584#comment-17142584 ] Zhijiang commented on FLINK-18400: -- [~jark] [~ykt836], could you check whether it is in

[GitHub] [flink] flinkbot commented on pull request #12749: [FLINK-18411][tests] Fix CollectionExecutorTest failed to compiled in release-1.11

flinkbot commented on pull request #12749: URL: https://github.com/apache/flink/pull/12749#issuecomment-647881473 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] [Commented] (FLINK-18411) CollectionExecutorTest failed to compiled in release-1.11

[ https://issues.apache.org/jira/browse/FLINK-18411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142582#comment-17142582 ] Jark Wu commented on FLINK-18411: - I will help to fix this. > CollectionExecutorTest f

[jira] [Updated] (FLINK-18411) CollectionExecutorTest failed to compiled in release-1.11

[ https://issues.apache.org/jira/browse/FLINK-18411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18411: --- Labels: pull-request-available (was: ) > CollectionExecutorTest failed to compiled in relea

[GitHub] [flink] wuchong commented on pull request #12749: [FLINK-18411][tests] Fix CollectionExecutorTest failed to compiled in release-1.11

wuchong commented on pull request #12749: URL: https://github.com/apache/flink/pull/12749#issuecomment-647881233 Could you help to review this @kl0u @aljoscha ? This is an automated message from the Apache Git Service. To res

[GitHub] [flink] wuchong opened a new pull request #12749: [FLINK-18411][tests] Fix CollectionExecutorTest failed to compiled in release-1.11

wuchong opened a new pull request #12749: URL: https://github.com/apache/flink/pull/12749 ## What is the purpose of the change I think this is caused by "[FLINK-18352] Make DefaultClusterClientServiceLoader/DefaultExecutorServiceLoader thread-safe", commit id: eeeff7

[jira] [Commented] (FLINK-18411) CollectionExecutorTest failed to compiled in release-1.11

[ https://issues.apache.org/jira/browse/FLINK-18411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142581#comment-17142581 ] Jark Wu commented on FLINK-18411: - I think this is caused by [FLINK-18352] which doesn't

[jira] [Updated] (FLINK-18411) CollectionExecutorTest failed to compiled in release-1.11

[ https://issues.apache.org/jira/browse/FLINK-18411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18411: - Issue Type: Task (was: Bug) > CollectionExecutorTest failed to compiled in release-1.11 > -

[jira] [Updated] (FLINK-18411) CollectionExecutorTest failed to compiled in release-1.11

[ https://issues.apache.org/jira/browse/FLINK-18411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18411: Summary: CollectionExecutorTest failed to compiled in release-1.11 (was: release-1.11 compile failed) >

[jira] [Assigned] (FLINK-18411) CollectionExecutorTest failed to compiled in release-1.11

[ https://issues.apache.org/jira/browse/FLINK-18411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18411: --- Assignee: Jark Wu > CollectionExecutorTest failed to compiled in release-1.11 > ---

[jira] [Updated] (FLINK-18411) CollectionExecutorTest failed to compiled in release-1.11

[ https://issues.apache.org/jira/browse/FLINK-18411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18411: Priority: Blocker (was: Major) > CollectionExecutorTest failed to compiled in release-1.11 >

[GitHub] [flink] flinkbot edited a comment on pull request #12726: [FLINK-14938][Connectors / ElasticSearch] Fix ConcurrentModificationException when Flink elasticsearch failure handler re-add indexre

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

[jira] [Commented] (FLINK-17845) Can't remove a table connector property with ALTER TABLE

[ https://issues.apache.org/jira/browse/FLINK-17845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142575#comment-17142575 ] Jark Wu commented on FLINK-17845: - > I thought users can add arbitrary properties for a

[jira] [Comment Edited] (FLINK-17845) Can't remove a table connector property with ALTER TABLE

[ https://issues.apache.org/jira/browse/FLINK-17845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142575#comment-17142575 ] Jark Wu edited comment on FLINK-17845 at 6/23/20, 2:59 AM: --- >

[jira] [Assigned] (FLINK-18412) JdbcFullTest failed to compile on JDK11

[ https://issues.apache.org/jira/browse/FLINK-18412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18412: --- Assignee: Jark Wu > JdbcFullTest failed to compile on JDK11 > -

[jira] [Closed] (FLINK-18412) JdbcFullTest failed to compile on JDK11

[ https://issues.apache.org/jira/browse/FLINK-18412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18412. --- Resolution: Fixed - master (1.12.0): de8a25ae597845f688376bde51dda5e419bf2085 - 1.11.0: 515aff8195beeb88ba9c

[jira] [Commented] (FLINK-18412) JdbcFullTest failed to compile on JDK11

[ https://issues.apache.org/jira/browse/FLINK-18412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142572#comment-17142572 ] Jark Wu commented on FLINK-18412: - Thanks for reporting this [~dian.fu]. > JdbcFullTest

[jira] [Closed] (FLINK-17678) Create flink-sql-connector-hbase module to shade HBase

[ https://issues.apache.org/jira/browse/FLINK-17678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17678. --- Resolution: Fixed Fixed in master (1.12.0): 6c7416a733505ca2dc16e68208ac718953a7eb0e > Create flink-sql-con

[GitHub] [flink] flinkbot commented on pull request #12748: [FLINK-18324][docs-zh] Translate updated data type into Chinese

flinkbot commented on pull request #12748: URL: https://github.com/apache/flink/pull/12748#issuecomment-647876138 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-18324) Translate updated data type and function page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18324: --- Labels: pull-request-available (was: ) > Translate updated data type and function page into

[jira] [Assigned] (FLINK-18116) Manually test E2E performance on Flink 1.11

[ https://issues.apache.org/jira/browse/FLINK-18116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18116: Assignee: Aihua Li (was: Zhijiang) > Manually test E2E performance on Flink 1.11 > -

[jira] [Assigned] (FLINK-18116) Manually test E2E performance on Flink 1.11

[ https://issues.apache.org/jira/browse/FLINK-18116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18116: Assignee: Zhijiang (was: Aihua Li) > Manually test E2E performance on Flink 1.11 > -

[GitHub] [flink] liyubin117 opened a new pull request #12748: [FLINK-18324][docs-zh] Translate updated data type into Chinese

liyubin117 opened a new pull request #12748: URL: https://github.com/apache/flink/pull/12748 ## What is the purpose of the change Translate updated data type into Chinese file locate flink/docs/dev/table/types.zh.md https://ci.apache.org/projects/flink/flink-docs-master/dev/tab

  1   2   3   4   5   >