[GitHub] [flink] Airblader commented on a change in pull request #16805: [FLINK-16501][table] Support IS JSON for Table API

Airblader commented on a change in pull request #16805: URL: https://github.com/apache/flink/pull/16805#discussion_r699866579 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java ## @@ -1488,6 +1489,20 @@

[jira] [Commented] (FLINK-24093) Supports setting the percentage of kubernetes Request resources

[ https://issues.apache.org/jira/browse/FLINK-24093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407841#comment-17407841 ] Yang Wang commented on FLINK-24093: --- [~spoon-lz] Really thanks for your contribution to the Flink

[jira] [Resolved] (FLINK-23351) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails due to "too few watermarks emitted" on azure

[ https://issues.apache.org/jira/browse/FLINK-23351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23351. - Resolution: Fixed > FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails due to

[jira] [Commented] (FLINK-23351) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails due to "too few watermarks emitted" on azure

[ https://issues.apache.org/jira/browse/FLINK-23351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407840#comment-17407840 ] Arvid Heise commented on FLINK-23351: - Merged into 1.14 as e66b92be2a5abaa6dc7b1510b21b00a9447754f1.

[GitHub] [flink] AHeise merged pull request #17086: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting watermarks after source operator finishes [1.14]

AHeise merged pull request #17086: URL: https://github.com/apache/flink/pull/17086 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

flinkbot edited a comment on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-908359102 ## CI report: * da1ab056d42b37d5e36a3121a4827fc7200a6164 UNKNOWN * 2a176d1b90dc2c547287471d40d89c3f4000c7cf Azure:

[jira] [Commented] (FLINK-24093) Supports setting the percentage of kubernetes Request resources

[ https://issues.apache.org/jira/browse/FLINK-24093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407839#comment-17407839 ] Yang Wang commented on FLINK-24093: --- It might be a duplicate ticket of FLINK-15648? BTW, I prefer the

[GitHub] [flink] Airblader commented on a change in pull request #16805: [FLINK-16501][table] Support IS JSON for Table API

Airblader commented on a change in pull request #16805: URL: https://github.com/apache/flink/pull/16805#discussion_r699863763 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/LogicalFunctionsITCase.java ## @@ -35,10 +35,104

[GitHub] [flink] Airblader commented on a change in pull request #16805: [FLINK-16501][table] Support IS JSON for Table API

Airblader commented on a change in pull request #16805: URL: https://github.com/apache/flink/pull/16805#discussion_r699863553 ## File path: docs/data/sql_functions.yml ## @@ -83,7 +83,7 @@ logical: table: BOOLEAN1 && BOOLEAN2 description: Returns TRUE if BOOLEAN1 and

[jira] [Updated] (FLINK-15648) Support to configure limit for CPU and memory requirement

[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15648: -- Fix Version/s: 1.15.0 > Support to configure limit for CPU and memory requirement >

[GitHub] [flink] Aitozi commented on pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

Aitozi commented on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-909905091 Thanks for your review @tillrohrmann . I have addressed most of your comments. Regarding to whether to remove the listener in `ZooKeeperLeaderElectionDriver` and

[GitHub] [flink] flinkbot edited a comment on pull request #17093: [FLINK-24088][streaming] Log FlinkJobNotFoundException in debug instead of warn level in CollectResultFetcher for a cleaner log

flinkbot edited a comment on pull request #17093: URL: https://github.com/apache/flink/pull/17093#issuecomment-909883551 ## CI report: * 85bfb8d5f4b38b06217c5e3450eaae0f43342e30 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * b90b6626006dabd8e7611f6e76c275ce4fe2691e Azure:

[GitHub] [flink] Aitozi commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699753195 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -226,9 +230,21 @@ public static CuratorFramework

[jira] [Updated] (FLINK-24024) Fix syntax mistake in session Window TVF

[ https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-24024: --- Description: There is a syntax mistake in session Window TVF in FLINK-23544 . For example, the

[GitHub] [flink] flinkbot commented on pull request #17093: [FLINK-24088][streaming] Log FlinkJobNotFoundException in debug instead of warn level in CollectResultFetcher for a cleaner log

flinkbot commented on pull request #17093: URL: https://github.com/apache/flink/pull/17093#issuecomment-909883551 ## CI report: * 85bfb8d5f4b38b06217c5e3450eaae0f43342e30 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17091: [FLINK-24083][python] Fix Python UDTF to handle properly when the result is str

flinkbot edited a comment on pull request #17091: URL: https://github.com/apache/flink/pull/17091#issuecomment-909872649 ## CI report: * 68a933f3b360e3e2df71ac33d0e248af294055bc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17092: [FLINK-24093] Supports setting the percentage of kubernetes Request resources

flinkbot edited a comment on pull request #17092: URL: https://github.com/apache/flink/pull/17092#issuecomment-909872724 ## CI report: * a4cfc14cb67890c2d66b5edb85a00b0b2702d24e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

flinkbot edited a comment on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537 ## CI report: * fcfa7e6f398fdcc73317c2cbf5f6124e87d2a89c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16983: [FLINK-23750][docs][table] Add documentation for Window Top-N after Windowing TVF.

flinkbot edited a comment on pull request #16983: URL: https://github.com/apache/flink/pull/16983#issuecomment-905482325 ## CI report: * 77edfcd73b251ff79006549f1b0857ccaa0959be Azure:

[GitHub] [flink] flinkbot commented on pull request #17093: [FLINK-24088][streaming] Log FlinkJobNotFoundException in debug instead of warn level in CollectResultFetcher for a cleaner log

flinkbot commented on pull request #17093: URL: https://github.com/apache/flink/pull/17093#issuecomment-909878144 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-24088) "Internal server error" when quitting a SELECT query in the SqlClient

[ https://issues.apache.org/jira/browse/FLINK-24088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24088: --- Labels: pull-request-available (was: ) > "Internal server error" when quitting a SELECT

[GitHub] [flink] tsreaper opened a new pull request #17093: [FLINK-24088][streaming] Log FlinkJobNotFoundException in debug instead of warn level in CollectResultFetcher for a cleaner log

tsreaper opened a new pull request #17093: URL: https://github.com/apache/flink/pull/17093 ## What is the purpose of the change Some user may encounter a warning message with `FlinkJobNotFoundException` when using `DataStream#collect` or `TableResult#collect`. This is because a

[GitHub] [flink] flinkbot commented on pull request #17092: [FLINK-24093] Supports setting the percentage of kubernetes Request resources

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

[GitHub] [flink] flinkbot commented on pull request #17091: [FLINK-24083][python] Fix Python UDTF to handle properly when the result is str

flinkbot commented on pull request #17091: URL: https://github.com/apache/flink/pull/17091#issuecomment-909872649 ## CI report: * 68a933f3b360e3e2df71ac33d0e248af294055bc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17075: [FLINK-24035][network][refactor] Move the blocking allocation of one floating buffer logic from the constructor of LocalBufferPool to

flinkbot edited a comment on pull request #17075: URL: https://github.com/apache/flink/pull/17075#issuecomment-909241018 ## CI report: * ccdf9bfaaa9e6d6eefb728b07ccf69df8233e93a Azure:

[jira] [Comment Edited] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407803#comment-17407803 ] JING ZHANG edited comment on FLINK-23886 at 9/1/21, 4:26 AM: - [~yunta] Sorry

[GitHub] [flink] flinkbot edited a comment on pull request #17025: [FLINK-24029][docs] Update doc example sql field in release-1.13.2 to dept_id

flinkbot edited a comment on pull request #17025: URL: https://github.com/apache/flink/pull/17025#issuecomment-907189639 ## CI report: * e39889a7f6b505ea5d8eb9b8c9b0af2581372f53 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16192: [FLINK-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate

flinkbot edited a comment on pull request #16192: URL: https://github.com/apache/flink/pull/16192#issuecomment-863860019 ## CI report: * 832a44171672a679bb17556b94afa3381d30157c Azure:

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407803#comment-17407803 ] JING ZHANG commented on FLINK-23886: [~yunta] Sorry for late response. We use Flink 1.10,  > 1.

[GitHub] [flink] wuchong commented on pull request #16037: [FLINK-22812][hive] Fix HiveConf, HiveMetaStoreClient and upgrade avr…

wuchong commented on pull request #16037: URL: https://github.com/apache/flink/pull/16037#issuecomment-909857474 The pull request also looks good to me. I can help to address @twalthr 's comment and merge it if @lirui-apache doesn't have time. -- This is an automated message from the

[jira] [Commented] (FLINK-24094) Could not execute ALTER TABLE check_rule_base_hive_catalog.test_flink.test_partition DROP PARTITION (dt=2021-08-31)

[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407798#comment-17407798 ] Jark Wu commented on FLINK-24094: - [~leexu], you should specify the full partition key values in your

[GitHub] [flink] flinkbot edited a comment on pull request #17089: [FLINK-22601][table-planner] PushWatermarkIntoScan should produce digest created by Expression.

flinkbot edited a comment on pull request #17089: URL: https://github.com/apache/flink/pull/17089#issuecomment-909842605 ## CI report: * 485a949b351a4df7a691740bcdf9f8e5e6e4a7f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17090: [FLINK-24082][python] Fix Python UDTF to handle properly when the result is a generator of Row

flinkbot edited a comment on pull request #17090: URL: https://github.com/apache/flink/pull/17090#issuecomment-909842676 ## CI report: * 390a00fd764ab7763d83fabd72610bce34949542 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17085: [FLINK-24081][table-blink-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestamp

flinkbot edited a comment on pull request #17085: URL: https://github.com/apache/flink/pull/17085#issuecomment-909410759 ## CI report: * 6ce983467e3a4ac8b339f48023141666e427dffd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17075: [FLINK-24035][network][refactor] Move the blocking allocation of one floating buffer logic from the constructor of LocalBufferPool to

flinkbot edited a comment on pull request #17075: URL: https://github.com/apache/flink/pull/17075#issuecomment-909241018 ## CI report: * ccdf9bfaaa9e6d6eefb728b07ccf69df8233e93a Azure:

[jira] [Closed] (FLINK-24062) Exception encountered during timer serialization in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-24062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-24062. --- Resolution: Fixed Fixed in - master via 4ba14cc3ef786623885e3b92a2f949a83edab2aa - release-1.14 via

[GitHub] [flink] dianfu closed pull request #17065: [FLINK-24062][python] Fix the serialization of timer to avoid serializing timer data partially

dianfu closed pull request #17065: URL: https://github.com/apache/flink/pull/17065 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #16192: [FLINK-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate

flinkbot edited a comment on pull request #16192: URL: https://github.com/apache/flink/pull/16192#issuecomment-863860019 ## CI report: * 832a44171672a679bb17556b94afa3381d30157c Azure:

[jira] [Commented] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407791#comment-17407791 ] lixu commented on FLINK-23857: -- hive 1.1.0 > insert overwirite table select * from t where 1 != 1, Unable

[GitHub] [flink] flinkbot commented on pull request #17092: [FLINK-24093] Supports setting the percentage of kubernetes Request resources

flinkbot commented on pull request #17092: URL: https://github.com/apache/flink/pull/17092#issuecomment-909849783 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] [Created] (FLINK-24094) Could not execute ALTER TABLE check_rule_base_hive_catalog.test_flink.test_partition DROP PARTITION (dt=2021-08-31)

lixu created FLINK-24094: Summary: Could not execute ALTER TABLE check_rule_base_hive_catalog.test_flink.test_partition DROP PARTITION (dt=2021-08-31) Key: FLINK-24094 URL:

[GitHub] [flink] flinkbot commented on pull request #17091: [FLINK-24083][python] Fix Python UDTF to handle properly when the result is str

flinkbot commented on pull request #17091: URL: https://github.com/apache/flink/pull/17091#issuecomment-909848929 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] [Closed] (FLINK-23924) Distribution is lacking Python Datastream examples

[ https://issues.apache.org/jira/browse/FLINK-23924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23924. --- Resolution: Fixed Merged to - master via 8fc624b83476b999c9a08518a67005aee994561a - release-1.14 via

[jira] [Commented] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407788#comment-17407788 ] Rui Li commented on FLINK-23857: bq. insert overwrite table t1 partition(f2=1) select * from t2 where 1

[jira] [Updated] (FLINK-24093) Supports setting the percentage of kubernetes Request resources

[ https://issues.apache.org/jira/browse/FLINK-24093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liuzhuo updated FLINK-24093: External issue URL: https://github.com/apache/flink/pull/17092 > Supports setting the percentage of

[jira] [Comment Edited] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient

[ https://issues.apache.org/jira/browse/FLINK-24088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407771#comment-17407771 ] Caizhi Weng edited comment on FLINK-24088 at 9/1/21, 3:38 AM: -- Hi! >From

[jira] [Updated] (FLINK-24093) Supports setting the percentage of kubernetes Request resources

[ https://issues.apache.org/jira/browse/FLINK-24093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24093: --- Labels: pull-request-available (was: ) > Supports setting the percentage of kubernetes

[GitHub] [flink] spoon-lz opened a new pull request #17092: [FLINK-24093] Supports setting the percentage of kubernetes Request resources

spoon-lz opened a new pull request #17092: URL: https://github.com/apache/flink/pull/17092 ## What is the purpose of the change For the current native Kubernetes, we start the job to apply for resources (CPU,Memory) of the same **limit** and **request**, so as to achieve

[jira] [Updated] (FLINK-24083) The result isn't as expected when the result type is generator of string for Python UDTF

[ https://issues.apache.org/jira/browse/FLINK-24083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24083: --- Labels: pull-request-available (was: ) > The result isn't as expected when the result type

[GitHub] [flink] dianfu opened a new pull request #17091: [FLINK-24083][python] Fix Python UDTF to handle properly when the result is str

dianfu opened a new pull request #17091: URL: https://github.com/apache/flink/pull/17091 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[jira] [Created] (FLINK-24093) Supports setting the percentage of kubernetes Request resources

liuzhuo created FLINK-24093: --- Summary: Supports setting the percentage of kubernetes Request resources Key: FLINK-24093 URL: https://issues.apache.org/jira/browse/FLINK-24093 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #17090: [FLINK-24082][python] Fix Python UDTF to handle properly when the result is a generator of Row

flinkbot commented on pull request #17090: URL: https://github.com/apache/flink/pull/17090#issuecomment-909842676 ## CI report: * 390a00fd764ab7763d83fabd72610bce34949542 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17089: [FLINK-22601][table-planner] PushWatermarkIntoScan should produce digest created by Expression.

flinkbot commented on pull request #17089: URL: https://github.com/apache/flink/pull/17089#issuecomment-909842605 ## CI report: * 485a949b351a4df7a691740bcdf9f8e5e6e4a7f5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17088: [FLINK-23817][docs] Add metric description to Kafka source. [1.14]

flinkbot edited a comment on pull request #17088: URL: https://github.com/apache/flink/pull/17088#issuecomment-909652631 ## CI report: * 073a325e226137c54f582b6924d39fbe12455b68 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17085: [FLINK-24081][table-blink-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestamp

flinkbot edited a comment on pull request #17085: URL: https://github.com/apache/flink/pull/17085#issuecomment-909410759 ## CI report: * 6ce983467e3a4ac8b339f48023141666e427dffd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source.

flinkbot edited a comment on pull request #17067: URL: https://github.com/apache/flink/pull/17067#issuecomment-908989247 ## CI report: * 2a4d75712d460c5bf001b999680c5a3cf6523977 UNKNOWN * 4190ce5b0ae580e8b8dc81579bfdcd1a99828bfe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16983: [FLINK-23750][docs][table] Add documentation for Window Top-N after Windowing TVF.

flinkbot edited a comment on pull request #16983: URL: https://github.com/apache/flink/pull/16983#issuecomment-905482325 ## CI report: * caaedbb8c3a4bc251fea4ddcbae105541d737314 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

flinkbot edited a comment on pull request #16723: URL: https://github.com/apache/flink/pull/16723#issuecomment-893364145 ## CI report: * ce83c52813ef9b754a0aded512e80503507b1547 Azure:

[jira] [Commented] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1740#comment-1740 ] Zhihao Wang commented on FLINK-22113: - [~twalthr] Thanks for your time to review it. Yes, it's a

[jira] [Commented] (FLINK-24087) Kafka connector StartupMode requires a table dependency

[ https://issues.apache.org/jira/browse/FLINK-24087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407773#comment-17407773 ] Leonard Xu commented on FLINK-24087: [~airblader] It doesn't matter, I just found the issue and want

[jira] [Updated] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient

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

[jira] [Updated] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient

[ https://issues.apache.org/jira/browse/FLINK-24088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24088: Component/s: API / DataStream > "Internal server error" when quitting a SELECT query in the

[jira] [Comment Edited] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient

[ https://issues.apache.org/jira/browse/FLINK-24088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407771#comment-17407771 ] Caizhi Weng edited comment on FLINK-24088 at 9/1/21, 2:39 AM: -- Hi! >From

[jira] [Comment Edited] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient

[ https://issues.apache.org/jira/browse/FLINK-24088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407771#comment-17407771 ] Caizhi Weng edited comment on FLINK-24088 at 9/1/21, 2:36 AM: -- Hi! >From

[jira] [Commented] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient

[ https://issues.apache.org/jira/browse/FLINK-24088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407771#comment-17407771 ] Caizhi Weng commented on FLINK-24088: - Hi! >From the discussion in FLINK-23850 this issue seems to

[GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

flinkbot edited a comment on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537 ## CI report: * e83ed6ab33d450ff7532b84c13e1a3a942d98fd6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16983: [FLINK-23750][docs][table] Add documentation for Window Top-N after Windowing TVF.

flinkbot edited a comment on pull request #16983: URL: https://github.com/apache/flink/pull/16983#issuecomment-905482325 ## CI report: * caaedbb8c3a4bc251fea4ddcbae105541d737314 Azure:

[jira] [Comment Edited] (FLINK-23544) Window TVF Supports session window

[ https://issues.apache.org/jira/browse/FLINK-23544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407770#comment-17407770 ] godfrey he edited comment on FLINK-23544 at 9/1/21, 2:33 AM: - [~twalthr] I

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

flinkbot edited a comment on pull request #16723: URL: https://github.com/apache/flink/pull/16723#issuecomment-893364145 ## CI report: * ce83c52813ef9b754a0aded512e80503507b1547 Azure:

[jira] [Issue Comment Deleted] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient

[ https://issues.apache.org/jira/browse/FLINK-24088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24088: Comment: was deleted (was: Hi [~mapohl], thanks for raising this issue. Are you using the mini

[jira] [Commented] (FLINK-23544) Window TVF Supports session window

[ https://issues.apache.org/jira/browse/FLINK-23544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407770#comment-17407770 ] godfrey he commented on FLINK-23544: [~twalthr] I didn't realize the syntax mistake when reviewing

[jira] [Commented] (FLINK-23747) Testing Window TVF offset

[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407769#comment-17407769 ] liwei li commented on FLINK-23747: -- Okay, I get it. I initially thought this ticket was for adding

[jira] [Commented] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407767#comment-17407767 ] Jin Xing commented on FLINK-22672: -- Yes, Joe ~ I believe the open source work of Lattice is on the

[GitHub] [flink] flinkbot commented on pull request #17090: [FLINK-24082][python] Fix Python UDTF to handle properly when the result is a generator of Row

flinkbot commented on pull request #17090: URL: https://github.com/apache/flink/pull/17090#issuecomment-909816631 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] [Commented] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient

[ https://issues.apache.org/jira/browse/FLINK-24088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407764#comment-17407764 ] Caizhi Weng commented on FLINK-24088: - Hi [~mapohl], thanks for raising this issue. Are you using

[GitHub] [flink] flinkbot commented on pull request #17089: [FLINK-22601][table-planner] PushWatermarkIntoScan should produce digest created by Expression.

flinkbot commented on pull request #17089: URL: https://github.com/apache/flink/pull/17089#issuecomment-909815682 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-24082) Python UDTF throws exception when the result type is generator of Row

[ https://issues.apache.org/jira/browse/FLINK-24082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24082: --- Labels: pull-request-available (was: ) > Python UDTF throws exception when the result type

[GitHub] [flink] dianfu opened a new pull request #17090: [FLINK-24082][python] Fix Python UDTF to handle properly when the result is a generator of Row

dianfu opened a new pull request #17090: URL: https://github.com/apache/flink/pull/17090 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[GitHub] [flink] wuchong commented on pull request #17085: [FLINK-24081][table-blink-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

wuchong commented on pull request #17085: URL: https://github.com/apache/flink/pull/17085#issuecomment-909812575 The compile is failed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Comment Edited] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type

[ https://issues.apache.org/jira/browse/FLINK-24081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407759#comment-17407759 ] Jark Wu edited comment on FLINK-24081 at 9/1/21, 2:17 AM: -- Fixed in - master:

[jira] [Commented] (FLINK-23544) Window TVF Supports session window

[ https://issues.apache.org/jira/browse/FLINK-23544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407760#comment-17407760 ] JING ZHANG commented on FLINK-23544: [~jark] [~twalthr] Sorry for late response. [~twalthr] I agree

[GitHub] [flink] wuchong merged pull request #17083: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

wuchong merged pull request #17083: URL: https://github.com/apache/flink/pull/17083 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type

[ https://issues.apache.org/jira/browse/FLINK-24081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407759#comment-17407759 ] Jark Wu commented on FLINK-24081: - Fixed in - master: e68b3a4e6ba3ca8f6b9256a2a34c622d5ef7cda0 -

[GitHub] [flink] wuchong merged pull request #17074: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

wuchong merged pull request #17074: URL: https://github.com/apache/flink/pull/17074 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Created] (FLINK-24092) OrcFsStreamingSinkITCase.testPart times out on azure

Xintong Song created FLINK-24092: Summary: OrcFsStreamingSinkITCase.testPart times out on azure Key: FLINK-24092 URL: https://issues.apache.org/jira/browse/FLINK-24092 Project: Flink Issue

[jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407757#comment-17407757 ] Xintong Song commented on FLINK-23828: --

[jira] [Updated] (FLINK-22601) PushWatermarkIntoScan should produce digest created by Expression

[ https://issues.apache.org/jira/browse/FLINK-22601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22601: --- Labels: auto-deprioritized-major pull-request-available (was: auto-deprioritized-major) >

[GitHub] [flink] xuyangzhong opened a new pull request #17089: [FLINK-22601][Table SQL/Planner]PushWatermarkIntoScan should produce digest created by Expression.

xuyangzhong opened a new pull request #17089: URL: https://github.com/apache/flink/pull/17089 ### What is the purpose of the change --- "In PushWatermarkIntoTableSourceScanRuleBase, the digest is created by RexNode instead of Expression, RexNode rely on field index but Expression

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407756#comment-17407756 ] Xintong Song commented on FLINK-22889: --

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15493: - Fix Version/s: 1.15.0 >

[jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407755#comment-17407755 ] Xintong Song commented on FLINK-15493: --

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15493: - Affects Version/s: 1.15.0 >

[jira] [Created] (FLINK-24091) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure fails on azure

Xintong Song created FLINK-24091: Summary: TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure fails on azure Key: FLINK-24091 URL: https://issues.apache.org/jira/browse/FLINK-24091

[jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407754#comment-17407754 ] Xintong Song commented on FLINK-23828: --

[jira] [Commented] (FLINK-23747) Testing Window TVF offset

[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407752#comment-17407752 ] Xintong Song commented on FLINK-23747: -- [~liliwei], This ticket is for the new feature to be

[GitHub] [flink] flinkbot edited a comment on pull request #17025: [FLINK-24029][docs] Update doc example sql field in release-1.13.2 to dept_id

flinkbot edited a comment on pull request #17025: URL: https://github.com/apache/flink/pull/17025#issuecomment-907189639 ## CI report: * 20abcd8ee08baa3acb52d606bf1db76df6e9769e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

flinkbot edited a comment on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537 ## CI report: * e83ed6ab33d450ff7532b84c13e1a3a942d98fd6 Azure:

[GitHub] [flink-training] alpinegizmo opened a new pull request #38: [hotfix] update flink version to 1.13.2

alpinegizmo opened a new pull request #38: URL: https://github.com/apache/flink-training/pull/38 FWIW, 1.13.2 has a bugfix for windowed top-n queries that I am particularly interested in. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink-training] alpinegizmo opened a new pull request #37: [hotfix] test imports wrong solution class

alpinegizmo opened a new pull request #37: URL: https://github.com/apache/flink-training/pull/37 Without this fix, the tests fail unless scala is enabled. -- 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

  1   2   3   4   5   6   7   8   >