[GitHub] [flink] flinkbot edited a comment on pull request #13447: [FLINK-19297][network] Make ResultPartitionWriter record-oriented

flinkbot edited a comment on pull request #13447: URL: https://github.com/apache/flink/pull/13447#issuecomment-696488834 ## CI report: * d4a56d85b6a00b8c10a4993a5f3c483ad26e5213 UNKNOWN * 620bd4aeecbb133a360cefae8c873ded05e5b720 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13448: [FLINK-19289][k8s] Remove pods terminated during JM failover.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

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

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13416: [FLINK-19179] Extend managed memory fraction calculation for various use cases.

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

[jira] [Created] (FLINK-19339) Support Avro's unions with logical types

Dawid Wysakowicz created FLINK-19339: Summary: Support Avro's unions with logical types Key: FLINK-19339 URL: https://issues.apache.org/jira/browse/FLINK-19339 Project: Flink Issue Type:

[GitHub] [flink] xintongsong commented on pull request #13448: [FLINK-19289][k8s] Remove pods terminated during JM failover.

xintongsong commented on pull request #13448: URL: https://github.com/apache/flink/pull/13448#issuecomment-696541373 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [flink] libenchao closed pull request #13431: [FLINK-19281][Table SQL / API]LIKE cannot recognize full table path

libenchao closed pull request #13431: URL: https://github.com/apache/flink/pull/13431 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 t

[GitHub] [flink] flinkbot edited a comment on pull request #13448: [FLINK-19289][k8s] Remove pods terminated during JM failover.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13447: [FLINK-19297][network] Make ResultPartitionWriter record-oriented

flinkbot edited a comment on pull request #13447: URL: https://github.com/apache/flink/pull/13447#issuecomment-696488834 ## CI report: * d4a56d85b6a00b8c10a4993a5f3c483ad26e5213 UNKNOWN * 620bd4aeecbb133a360cefae8c873ded05e5b720 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

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

[GitHub] [flink] flinkbot edited a comment on pull request #13446: [FLINK-18779][table sql/planner]Support the SupportsFilterPushDown for LookupTableSource

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

[jira] [Updated] (FLINK-18950) Add documentation for Operations in Python DataStream API.

[ https://issues.apache.org/jira/browse/FLINK-18950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18950: Component/s: Documentation > Add documentation for Operations in Python DataStream API. > ---

[GitHub] [flink] rmetzger merged pull request #13409: [FLINK-17910][e2e] Fix debug log output to investigate rare test failure

rmetzger merged pull request #13409: URL: https://github.com/apache/flink/pull/13409 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] rmetzger commented on pull request #13409: [FLINK-17910][e2e] Fix debug log output to investigate rare test failure

rmetzger commented on pull request #13409: URL: https://github.com/apache/flink/pull/13409#issuecomment-696535895 Thanks a lot for the review. I'll merge the change. This is an automated message from the Apache Git Service. T

[jira] [Closed] (FLINK-18950) Add documentation for Operations in Python DataStream API.

[ https://issues.apache.org/jira/browse/FLINK-18950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18950. --- Resolution: Fixed master: 7569a74de8f9ef39c63cc8a2f0218185aaea2c34 > Add documentation for Operations in Py

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13303: [FLINK-19098][format] Make row data converters public

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

[GitHub] [flink] dianfu closed pull request #13230: [FLINK-18950][python][docs] Add documentation for Operations in Python DataStream API.

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

[jira] [Closed] (FLINK-18725) "Run Kubernetes test" failed with "30025: provided port is already allocated"

[ https://issues.apache.org/jira/browse/FLINK-18725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-18725. -- Fix Version/s: 1.11.3 1.12.0 Assignee: Yang Wang Resolution:

[GitHub] [flink] rmetzger merged pull request #13440: [FLINK-18725][e2e] Use ClusterIP instead of NodePort and remove query port in internal jobmanager service

rmetzger merged pull request #13440: URL: https://github.com/apache/flink/pull/13440 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] rmetzger commented on pull request #13440: [FLINK-18725][e2e] Use ClusterIP instead of NodePort and remove query port in internal jobmanager service

rmetzger commented on pull request #13440: URL: https://github.com/apache/flink/pull/13440#issuecomment-696529610 I'll merge it. This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot edited a comment on pull request #13303: [FLINK-19098][format] Make row data converters public

flinkbot edited a comment on pull request #13303: URL: https://github.com/apache/flink/pull/13303#issuecomment-685551684 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot edited a comment on pull request #13442: [FLINK-19321][Table SQL / Runtime]CollectSinkFunction does not define serialVersionUID

flinkbot edited a comment on pull request #13442: URL: https://github.com/apache/flink/pull/13442#issuecomment-696198270 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] shuiqiangchen commented on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

shuiqiangchen commented on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-696526998 @wangyang0918 Thank you for reviewing， I have added the corresponding unit test and e2e test in the latest commit, please have a look. ---

[GitHub] [flink] flinkbot edited a comment on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

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

[GitHub] [flink] flinkbot edited a comment on pull request #13446: [FLINK-18779][table sql/planner]Support the SupportsFilterPushDown for LookupTableSource

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

[GitHub] [flink] flinkbot edited a comment on pull request #13421: [FLINK-19186][python] Add Python building blocks to make sure the basic functionality of Pandas Batch Group Aggregation could work

flinkbot edited a comment on pull request #13421: URL: https://github.com/apache/flink/pull/13421#issuecomment-694793689 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot edited a comment on pull request #13303: [FLINK-19098][format] Make row data converters public

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

[GitHub] [flink] flinkbot edited a comment on pull request #13327: [FLINK-19134][python] Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for Python DataStream API.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13327: [FLINK-19134][python] Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for Python DataStream API.

flinkbot edited a comment on pull request #13327: URL: https://github.com/apache/flink/pull/13327#issuecomment-687006937 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] dianfu commented on a change in pull request #13421: [FLINK-19186][python] Add Python building blocks to make sure the basic functionality of Pandas Batch Group Aggregation could work

dianfu commented on a change in pull request #13421: URL: https://github.com/apache/flink/pull/13421#discussion_r492476885 ## File path: flink-python/pyflink/table/udf.py ## @@ -421,3 +600,53 @@ def udtf(f=None, input_types=None, result_types=None, deterministic=None, name=N

[GitHub] [flink] HuangXingBo commented on pull request #13421: [FLINK-19186][python] Add Python building blocks to make sure the basic functionality of Pandas Batch Group Aggregation could work

HuangXingBo commented on pull request #13421: URL: https://github.com/apache/flink/pull/13421#issuecomment-696522696 @dianfu Thanks a lot for the review. I agree with the comments. This is an automated message from the Apache

[jira] [Commented] (FLINK-19237) LeaderChangeClusterComponentsTest.testReelectionOfJobMaster failed with "NoResourceAvailableException: Could not allocate the required slot within slot request timeout

[ https://issues.apache.org/jira/browse/FLINK-19237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199828#comment-17199828 ] Matthias commented on FLINK-19237: -- The problem seems to be caused by [65ed0393|https:

[GitHub] [flink] flinkbot edited a comment on pull request #13421: [FLINK-19186][python] Add Python building blocks to make sure the basic functionality of Pandas Batch Group Aggregation could work

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

[GitHub] [flink] flinkbot edited a comment on pull request #13303: [FLINK-19098][format] Make row data converters public

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

[GitHub] [flink] flinkbot edited a comment on pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

flinkbot edited a comment on pull request #13228: URL: https://github.com/apache/flink/pull/13228#issuecomment-679099456 ## CI report: * d141f10ef060063162dc073b1cd66729f5f75a3b UNKNOWN * 89b0550c7b223f304b67a6f64dfc4252509eb76e UNKNOWN * f23e2a14cbbbf4c7ced3d66eea8073eb1d8c

[GitHub] [flink] flinkbot commented on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

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

[jira] [Closed] (FLINK-19321) CollectSinkFunction does not define serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-19321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19321. --- Fix Version/s: 1.11.3 1.12.0 Resolution: Fixed Fixed in - master: 1b0cba3cfd113c

[jira] [Assigned] (FLINK-19334) Translate page 'Streaming File Sink' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19334: --- Assignee: hailong wang > Translate page 'Streaming File Sink' into Chinese > --

[GitHub] [flink] flinkbot edited a comment on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

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

[GitHub] [flink] wuchong merged pull request #13442: [FLINK-19321][Table SQL / Runtime]CollectSinkFunction does not define serialVersionUID

wuchong merged pull request #13442: URL: https://github.com/apache/flink/pull/13442 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] flinkbot edited a comment on pull request #13448: [FLINK-19289][k8s] Remove pods terminated during JM failover.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

flinkbot edited a comment on pull request #13228: URL: https://github.com/apache/flink/pull/13228#issuecomment-679099456 ## CI report: * d141f10ef060063162dc073b1cd66729f5f75a3b UNKNOWN * 89b0550c7b223f304b67a6f64dfc4252509eb76e UNKNOWN * f23e2a14cbbbf4c7ced3d66eea8073eb1d8c

[GitHub] [flink] flinkbot edited a comment on pull request #13421: [FLINK-19186][python] Add Python building blocks to make sure the basic functionality of Pandas Batch Group Aggregation could work

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

[jira] [Commented] (FLINK-19289) Remove pods terminated during JM failover

[ https://issues.apache.org/jira/browse/FLINK-19289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199791#comment-17199791 ] Yi Tang commented on FLINK-19289: - [~xintongsong] Looks good. > Remove pods terminated

[jira] [Created] (FLINK-19338) New source interface cannot unregister unregistered source

Arvid Heise created FLINK-19338: --- Summary: New source interface cannot unregister unregistered source Key: FLINK-19338 URL: https://issues.apache.org/jira/browse/FLINK-19338 Project: Flink Issu

[jira] [Updated] (FLINK-19338) New source interface cannot unregister unregistered source

[ https://issues.apache.org/jira/browse/FLINK-19338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19338: Component/s: Connectors / Common > New source interface cannot unregister unregistered source > --

[GitHub] [flink] HuangXingBo commented on pull request #13421: [FLINK-19186][python] Add Python building blocks to make sure the basic functionality of Pandas Batch Group Aggregation could work

HuangXingBo commented on pull request #13421: URL: https://github.com/apache/flink/pull/13421#issuecomment-696507110 @dianfu Thanks a lot for the review. I have addressed the comments at the latest commit. This is an automat

[jira] [Commented] (FLINK-19335) Automatically get udf's resource files from hdfs when running a job that uses hive-udf

[ https://issues.apache.org/jira/browse/FLINK-19335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199804#comment-17199804 ] Jark Wu commented on FLINK-19335: - Module is a mechanism to support built-in functions w

[jira] [Commented] (FLINK-19334) Translate page 'Streaming File Sink' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199799#comment-17199799 ] hailong wang commented on FLINK-19334: -- Hi [~jark], Could you please assgin it to m

[GitHub] [flink] flinkbot edited a comment on pull request #13421: [FLINK-19186][python] Add Python building blocks to make sure the basic functionality of Pandas Batch Group Aggregation could work

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

[jira] [Comment Edited] (FLINK-19335) Automatically get udf's resource files from hdfs when running a job that uses hive-udf

[ https://issues.apache.org/jira/browse/FLINK-19335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199804#comment-17199804 ] Jark Wu edited comment on FLINK-19335 at 9/22/20, 4:47 AM: --- Mo

[GitHub] [flink] flinkbot edited a comment on pull request #13446: [FLINK-18779][table sql/planner]Support the SupportsFilterPushDown for LookupTableSource

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

[jira] [Comment Edited] (FLINK-19335) Automatically get udf's resource files from hdfs when running a job that uses hive-udf

[ https://issues.apache.org/jira/browse/FLINK-19335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199804#comment-17199804 ] Jark Wu edited comment on FLINK-19335 at 9/22/20, 4:47 AM: --- Mo

[jira] [Comment Edited] (FLINK-19335) Automatically get udf's resource files from hdfs when running a job that uses hive-udf

[ https://issues.apache.org/jira/browse/FLINK-19335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199804#comment-17199804 ] Jark Wu edited comment on FLINK-19335 at 9/22/20, 4:47 AM: --- Mo

[GitHub] [flink] dianfu commented on a change in pull request #13421: [FLINK-19186][python] Add Python building blocks to make sure the basic functionality of Pandas Batch Group Aggregation could work

dianfu commented on a change in pull request #13421: URL: https://github.com/apache/flink/pull/13421#discussion_r492475798 ## File path: flink-python/pyflink/table/udf.py ## @@ -421,3 +600,53 @@ def udtf(f=None, input_types=None, result_types=None, deterministic=None, name=N

[GitHub] [flink] flinkbot edited a comment on pull request #13446: [FLINK-18779][table sql/planner]Support the SupportsFilterPushDown for LookupTableSource

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

[GitHub] [flink] flinkbot commented on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

flinkbot commented on pull request #13449: URL: https://github.com/apache/flink/pull/13449#issuecomment-696505414 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] [Assigned] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19291: --- Assignee: xiaozilong > Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink

[GitHub] [flink] fsk119 opened a new pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

fsk119 opened a new pull request #13449: URL: https://github.com/apache/flink/pull/13449 …ermarkStrategy 1. convert class FunctionContext to interface which allows us convert WatermarkStrategy.Context to FunctionContext; 2. add bindConstructorTerm in ExprCodeGenerator; 3. add s

[jira] [Commented] (FLINK-19291) Meeting `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

[ https://issues.apache.org/jira/browse/FLINK-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199798#comment-17199798 ] Jark Wu commented on FLINK-19291: - Thanks for reporting this [~xiaozilong]. This is a bu

[GitHub] [flink] wuchong merged pull request #13275: [FLINK-19064][hbase] HBaseRowDataInputFormat is leaking resources

wuchong merged pull request #13275: URL: https://github.com/apache/flink/pull/13275 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-19282) Support watermark push down with WatermarkStrategy

[ https://issues.apache.org/jira/browse/FLINK-19282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19282: --- Labels: pull-request-available (was: ) > Support watermark push down with WatermarkStrategy

[jira] [Closed] (FLINK-19328) flink sql

[ https://issues.apache.org/jira/browse/FLINK-19328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19328. --- Fix Version/s: (was: 1.11.3) Resolution: Not A Problem {{CONCAT_AGG}} was renamed to {{LISTAGG}}

[jira] [Updated] (FLINK-19334) Translate page 'Streaming File Sink' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19334: Component/s: chinese-translation > Translate page 'Streaming File Sink' into Chinese > ---

[GitHub] [flink] flinkbot commented on pull request #13444: [BP-1.11][FLINK-19244] CsvRowDataDeserializationSchema throws cast ex…

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

[GitHub] [flink] libenchao commented on a change in pull request #13427: [FLINK-17767][table-planner-blink]Tumbling/Sliding window aggregate support window start offset in batch and streaming mode

libenchao commented on a change in pull request #13427: URL: https://github.com/apache/flink/pull/13427#discussion_r491855446 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/WindowAggregateITCase.scala ## @@

[GitHub] [flink] tzulitai commented on a change in pull request #13102: [FLINK-18515][Kinesis] Adding FanOutRecordPublisher for Kinesis EFO support

tzulitai commented on a change in pull request #13102: URL: https://github.com/apache/flink/pull/13102#discussion_r491800519 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java ## @@ -1

[jira] [Closed] (FLINK-18713) Allow default ms unit for table.exec.mini-batch.allow-latency etc.

[ https://issues.apache.org/jira/browse/FLINK-18713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18713. --- Resolution: Implemented Implemented in master: 607919c6ea6983ae5ad3f82d63b7d6455c73d225 > Allow default ms

[GitHub] [flink] leonardBang commented on a change in pull request #13128: [FLINK-18795][hbase] Support for HBase 2

leonardBang commented on a change in pull request #13128: URL: https://github.com/apache/flink/pull/13128#discussion_r491940668 ## File path: flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/table/descriptors/AbstractHBaseValidator.java ## @@ -44,20 +

[GitHub] [flink] wangyang0918 commented on pull request #13440: [FLINK-18725][e2e] Use ClusterIP instead of NodePort and remove query port in internal jobmanager service

wangyang0918 commented on pull request #13440: URL: https://github.com/apache/flink/pull/13440#issuecomment-696452209 cc @rmetzger, could you please have a look? This is an automated message from the Apache Git Service. To re

[jira] [Updated] (FLINK-18713) Change duration ConfigOption to duration type in blink planner

[ https://issues.apache.org/jira/browse/FLINK-18713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18713: Summary: Change duration ConfigOption to duration type in blink planner (was: Allow default ms unit for t

[GitHub] [flink] flinkbot commented on pull request #13429: [FLINK-19140] Fix UDTF documentation which uses wrong alias

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

[jira] [Closed] (FLINK-19337) Make a little bit improvement for PyFlink package structure and class name.

[ https://issues.apache.org/jira/browse/FLINK-19337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-19337. --- Resolution: Fixed > Make a little bit improvement for PyFlink package structure and class name. > --

[GitHub] [flink] wuchong merged pull request #13426: [FLINK-19244] CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

wuchong merged pull request #13426: URL: https://github.com/apache/flink/pull/13426 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] fsk119 opened a new pull request #13446: [FLINK-18779]Support the SupportsFilterPushDown for LookupTableSource

fsk119 opened a new pull request #13446: URL: https://github.com/apache/flink/pull/13446 1. add rule that will transpose the filter and snapshot and PushFilterIntoTableSourceScanRule will push filter into DynamicTableSource. 2. add tests including ut, itcase. ## What is th

[GitHub] [flink] wuchong merged pull request #13392: [FLINK-18713][table-planner-blink] Change duration configOption to duration type

wuchong merged pull request #13392: URL: https://github.com/apache/flink/pull/13392 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] leonardBang commented on pull request #13289: [FLINK-18548][table-planner] support flexible syntax for Temporal table join

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

[GitHub] [flink] HuangXingBo commented on a change in pull request #13421: [FLINK-19186][python] Add Python building blocks to make sure the basic functionality of Pandas Batch Group Aggregation could

HuangXingBo commented on a change in pull request #13421: URL: https://github.com/apache/flink/pull/13421#discussion_r491994679 ## File path: flink-python/pyflink/fn_execution/beam/beam_operations_fast.pyx ## @@ -173,6 +173,28 @@ cdef class DataStreamStatelessFunctionOperation

[GitHub] [flink] JingsongLi commented on a change in pull request #13401: [FLINK-19161][file connector] Add first version of the FLIP-27 File Source

JingsongLi commented on a change in pull request #13401: URL: https://github.com/apache/flink/pull/13401#discussion_r491894894 ## File path: flink-formats/flink-orc/src/main/java/org/apache/flink/orc/util/SerializableHadoopConfigWrapper.java ## @@ -0,0 +1,78 @@ +/* + * License

[GitHub] [flink] wuchong commented on a change in pull request #13427: [FLINK-17767][table-planner-blink]Tumbling/Sliding window aggregate support window start offset in batch and streaming mode

wuchong commented on a change in pull request #13427: URL: https://github.com/apache/flink/pull/13427#discussion_r492461768 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/WindowAggregateITCase.scala ## @@ -3

[GitHub] [flink] flinkbot edited a comment on pull request #13447: [FLINK-19297][network] Make ResultPartitionWriter record-oriented

flinkbot edited a comment on pull request #13447: URL: https://github.com/apache/flink/pull/13447#issuecomment-696488834 ## CI report: * d4a56d85b6a00b8c10a4993a5f3c483ad26e5213 UNKNOWN * 620bd4aeecbb133a360cefae8c873ded05e5b720 UNKNOWN Bot commands The @flinkbo

[jira] [Closed] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

[ https://issues.apache.org/jira/browse/FLINK-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19244. --- Fix Version/s: 1.11.3 1.12.0 Resolution: Fixed Fixed in - master: 83795aaeaa25196

[GitHub] [flink] yingshin commented on a change in pull request #13426: [FLINK-19244] CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

yingshin commented on a change in pull request #13426: URL: https://github.com/apache/flink/pull/13426#discussion_r492442435 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvRowDataSerDeSchemaTest.java ## @@ -331,6 +364,16 @@ private Row test

[GitHub] [flink] wuchong merged pull request #13432: [FLINK-19280][connectors] fix the bug of the option "sink.buffer-flush.max-rows" for JDBC can't be disabled by set to zero

wuchong merged pull request #13432: URL: https://github.com/apache/flink/pull/13432 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] flinkbot edited a comment on pull request #13401: [FLINK-19161][file connector] Add first version of the FLIP-27 File Source

flinkbot edited a comment on pull request #13401: URL: https://github.com/apache/flink/pull/13401#issuecomment-693392192 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot edited a comment on pull request #13447: [FLINK-19297][network] Make ResultPartitionWriter record-oriented

flinkbot edited a comment on pull request #13447: URL: https://github.com/apache/flink/pull/13447#issuecomment-696488834 ## CI report: * d4a56d85b6a00b8c10a4993a5f3c483ad26e5213 UNKNOWN * 620bd4aeecbb133a360cefae8c873ded05e5b720 Azure: [PENDING](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-19289) Remove pods terminated during JM failover

[ https://issues.apache.org/jira/browse/FLINK-19289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199789#comment-17199789 ] Xintong Song commented on FLINK-19289: -- [~yittg], I've opened a PR to fix this prob

[GitHub] [flink] lsyldliu commented on pull request #13432: [FLINK-19280][connectors] fix the bug of the option "sink.buffer-flush.max-rows" for JDBC can't be disabled by set to zero

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

[GitHub] [flink] flinkbot edited a comment on pull request #13230: [FLINK-18950][python][docs] Add documentation for Operations in Python DataStream API.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13426: [FLINK-19244] CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

flinkbot edited a comment on pull request #13426: URL: https://github.com/apache/flink/pull/13426#issuecomment-695222031 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot commented on pull request #13430: [BP-1.11][FLINK-19140] Fix UDTF documentation which uses wrong alias

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

[jira] [Updated] (FLINK-19244) CSV format can't deserialize null ROW field

[ https://issues.apache.org/jira/browse/FLINK-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19244: Summary: CSV format can't deserialize null ROW field (was: CsvRowDataDeserializationSchema throws cast ex

[GitHub] [flink] XComp commented on a change in pull request #13316: [FLINK-14422][runtime] Expose network memory usage to TaskManagerDetailsHandler's endpoint

XComp commented on a change in pull request #13316: URL: https://github.com/apache/flink/pull/13316#discussion_r491921585 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java ## @@ -58,7 +58,19 @@ pu

[jira] [Created] (FLINK-19337) Make a little bit improvement for PyFlink package structure and class name.

sunjincheng created FLINK-19337: --- Summary: Make a little bit improvement for PyFlink package structure and class name. Key: FLINK-19337 URL: https://issues.apache.org/jira/browse/FLINK-19337 Project: Fl

[GitHub] [flink] wuchong commented on a change in pull request #13427: [FLINK-17767][table-planner-blink]Tumbling/Sliding window aggregate support window start offset in batch and streaming mode

wuchong commented on a change in pull request #13427: URL: https://github.com/apache/flink/pull/13427#discussion_r491938910 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/WindowAggregateITCase.scala ## @@ -3

[GitHub] [flink] flinkbot commented on pull request #13432: [FLINK-19280][connectors] fix the bug of the option "sink.buffer-flush.max-rows" for JDBC can't be disabled by set to zero

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

[GitHub] [flink-statefun] tzulitai commented on pull request #155: [FLINK-19290] [docs] Add documentation for Flink DataStream integration SDK

tzulitai commented on pull request #155: URL: https://github.com/apache/flink-statefun/pull/155#issuecomment-695903343 Thanks for the review @sjwiesman! I'll address your comments and merge this. This is an automated message

[GitHub] [flink-statefun] tzulitai closed pull request #155: [FLINK-19290] [docs] Add documentation for Flink DataStream integration SDK

tzulitai closed pull request #155: URL: https://github.com/apache/flink-statefun/pull/155 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

  1   2   3   4   5   6   >