[jira] [Created] (FLINK-17314) 【Flink Kafka Connector】The Config（connector.topic）support list topic

zhisheng created FLINK-17314: Summary: 【Flink Kafka Connector】The Config（connector.topic）support list topic Key: FLINK-17314 URL: https://issues.apache.org/jira/browse/FLINK-17314 Project: Flink

[GitHub] [flink] zjuwangg opened a new pull request #11848: [FLINK-17313]fix type validation error when sink table ddl exists column with precision of decimal/timestamp/varchar

zjuwangg opened a new pull request #11848: URL: https://github.com/apache/flink/pull/11848 ## What is the purpose of the change * Now TypeMappingUtils#checkPhysicalLogicalTypeCompatible method doesn't consider the different physical and logical type validation logic of source and si

[jira] [Updated] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17313: --- Labels: pull-request-available (was: ) > Validation error when insert decimal/timestamp/var

[jira] [Commented] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089258#comment-17089258 ] Terry Wang commented on FLINK-17313: I open a [https://github.com/apache/flink/pull

[GitHub] [flink] flinkbot commented on issue #11848: [FLINK-17313]fix type validation error when sink table ddl exists column with precision of decimal/timestamp/varchar

flinkbot commented on issue #11848: URL: https://github.com/apache/flink/pull/11848#issuecomment-617530206 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 progress

[GitHub] [flink] flinkbot edited a comment on issue #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed

flinkbot edited a comment on issue #11397: URL: https://github.com/apache/flink/pull/11397#issuecomment-598575354 ## CI report: * 14bde242e3aca096cbfc4e36782d055f8c01c119 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160840112) Azure: [FAILURE](https://dev

[jira] [Commented] (FLINK-17012) Expose stage of task initialization

[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089260#comment-17089260 ] Wenlong Lyu commented on FLINK-17012: - [~pnowojski] I think whether the task is read

[GitHub] [flink] flinkbot edited a comment on issue #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode.

flinkbot edited a comment on issue #11801: URL: https://github.com/apache/flink/pull/11801#issuecomment-615388238 ## CI report: * 01721ae7a8a1aa84931c80a3ef99580324944c4d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160771983) Azure: [SUCCESS](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

flinkbot edited a comment on issue #11727: URL: https://github.com/apache/flink/pull/11727#issuecomment-613273432 ## CI report: * fa5592cec0a6a5dcecc4f45c4bf72caf6e166eb4 UNKNOWN * a3901b149f603721be62fbb3d8bf46143d08c3d1 UNKNOWN * fabc951d769b00e1dac471b75ba2c99e62fcbf47 Tr

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN * cba096ae3d8eba4a0d39c64659f76ad10a62be27 UN

[GitHub] [flink] flinkbot edited a comment on issue #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

flinkbot edited a comment on issue #11749: URL: https://github.com/apache/flink/pull/11749#issuecomment-613901508 ## CI report: * 0d7615e1c79289a0561529c8b2709ab5fa969ca4 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161355622) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot commented on issue #11848: [FLINK-17313]fix type validation error when sink table ddl exists column with precision of decimal/timestamp/varchar

flinkbot commented on issue #11848: URL: https://github.com/apache/flink/pull/11848#issuecomment-617531785 ## CI report: * 9b24a40f43a101b63ab73d1fa1e0c0f31178b36d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run trav

[GitHub] [flink] mrzhangboss opened a new pull request #11849: [FLINK-17312][sqlclient] support sql client savepoint

mrzhangboss opened a new pull request #11849: URL: https://github.com/apache/flink/pull/11849 ## What is the purpose of the change Support sql client insert job start from a savepoint. ## Brief change log - *The SQL Client document about execution* - *

[jira] [Updated] (FLINK-17312) Support sql client savepoint

[ https://issues.apache.org/jira/browse/FLINK-17312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17312: --- Labels: pull-request-available (was: ) > Support sql client savepoint > ---

[GitHub] [flink] flinkbot commented on issue #11849: [FLINK-17312][sqlclient] support sql client savepoint

flinkbot commented on issue #11849: URL: https://github.com/apache/flink/pull/11849#issuecomment-617534213 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 progress

[jira] [Commented] (FLINK-17309) TPC-DS fail to run data generator

[ https://issues.apache.org/jira/browse/FLINK-17309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089261#comment-17089261 ] Leonard Xu commented on FLINK-17309: I checked related scripts hasn't modified, and

[GitHub] [flink] SteNicholas commented on issue #11769: [FLINK-16766][python]Support create StreamTableEnvironment without pa…

SteNicholas commented on issue #11769: URL: https://github.com/apache/flink/pull/11769#issuecomment-617534947 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] SteNicholas removed a comment on issue #11769: [FLINK-16766][python]Support create StreamTableEnvironment without pa…

SteNicholas removed a comment on issue #11769: URL: https://github.com/apache/flink/pull/11769#issuecomment-617534947 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089263#comment-17089263 ] Zhijiang commented on FLINK-17274: -- Another instance  [https://dev.azure.com/apache-fli

[GitHub] [flink] xintongsong commented on a change in pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

xintongsong commented on a change in pull request #11323: URL: https://github.com/apache/flink/pull/11323#discussion_r412654890 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java ## @@ -311,7 +322,9 @@ protected double getCp

[GitHub] [flink] flinkbot edited a comment on issue #11848: [FLINK-17313]fix type validation error when sink table ddl exists column with precision of decimal/timestamp/varchar

flinkbot edited a comment on issue #11848: URL: https://github.com/apache/flink/pull/11848#issuecomment-617531785 ## CI report: * 9b24a40f43a101b63ab73d1fa1e0c0f31178b36d Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161363103) Azure: [PENDING](https://dev

[GitHub] [flink] flinkbot commented on issue #11849: [FLINK-17312][sqlclient] support sql client savepoint

flinkbot commented on issue #11849: URL: https://github.com/apache/flink/pull/11849#issuecomment-617537614 ## CI report: * c5817c1743c657627346fdf3e71b5e5ca9335e18 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run trav

[jira] [Created] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

Zhijiang created FLINK-17315: Summary: UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout Key: FLINK-17315 URL: https://issues.apache.org/jira/browse/FLINK-17315

[GitHub] [flink] lsyldliu commented on a change in pull request #11830: [FLINK-17096] [table] Support state ttl for Mini-Batch Group Agg using StateTtlConfig

lsyldliu commented on a change in pull request #11830: URL: https://github.com/apache/flink/pull/11830#discussion_r412659241 ## File path: flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/aggregate/MiniBatchGroupAggFunctionTest.java

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN * cba096ae3d8eba4a0d39c64659f76ad10a62be27 UN

[GitHub] [flink] flinkbot edited a comment on issue #11769: [FLINK-16766][python]Support create StreamTableEnvironment without pa…

flinkbot edited a comment on issue #11769: URL: https://github.com/apache/flink/pull/11769#issuecomment-614500814 ## CI report: * 91e11790567ac173db216ac8d0a4bae76d2b81ae Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160512177) Azure: [SUCCESS](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11836: [FLINK-17188][python] Use pip instead of conda to install flake8 and sphinx

flinkbot edited a comment on issue #11836: URL: https://github.com/apache/flink/pull/11836#issuecomment-616922166 ## CI report: * 8cfe6bcc6cee878730f9cfa75d7fa598f88a9833 UNKNOWN * 3ca11194996f3b2e7d51221f8f51ae928d93c3a3 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci

[GitHub] [flink] flinkbot edited a comment on issue #11849: [FLINK-17312][sqlclient] support sql client savepoint

flinkbot edited a comment on issue #11849: URL: https://github.com/apache/flink/pull/11849#issuecomment-617537614 ## CI report: * c5817c1743c657627346fdf3e71b5e5ca9335e18 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161365046) Azure: [PENDING](https://dev

[GitHub] [flink] dianfu commented on issue #11836: [FLINK-17188][python] Use pip instead of conda to install flake8 and sphinx

dianfu commented on issue #11836: URL: https://github.com/apache/flink/pull/11836#issuecomment-617544976 @HuangXingBo Thanks a lot for investigating this problem and thanks @rmetzger for offering the help. I looked through the tests in [azure pipelines](https://dev.azure.com/rmetzger/Flink

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

KarmaGYZ commented on a change in pull request #11615: URL: https://github.com/apache/flink/pull/11615#discussion_r412625928 ## File path: docs/_includes/generated/expert_scheduling_section.html ## @@ -14,6 +14,12 @@ Boolean Enable the slot spread out

[GitHub] [flink-training] alpinegizmo commented on issue #7: [hotfix] two description updates

alpinegizmo commented on issue #7: URL: https://github.com/apache/flink-training/pull/7#issuecomment-617546490 +1 LGTM This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[GitHub] [flink] flinkbot edited a comment on issue #11769: [FLINK-16766][python]Support create StreamTableEnvironment without pa…

flinkbot edited a comment on issue #11769: URL: https://github.com/apache/flink/pull/11769#issuecomment-614500814 ## CI report: * 91e11790567ac173db216ac8d0a4bae76d2b81ae Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160512177) Azure: [SUCCESS](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11849: [FLINK-17312][sqlclient] support sql client savepoint

flinkbot edited a comment on issue #11849: URL: https://github.com/apache/flink/pull/11849#issuecomment-617537614 ## CI report: * c5817c1743c657627346fdf3e71b5e5ca9335e18 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161365046) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11829: [FLINK-17021][table-planner-blink] Blink batch planner set GlobalDataExchangeMode

flinkbot edited a comment on issue #11829: URL: https://github.com/apache/flink/pull/11829#issuecomment-616561190 ## CI report: * c15a8214d2883f5a5c07bb6357dbfa465dd5cd39 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161357311) Azure: [PENDING](https://dev

[GitHub] [flink] JingsongLi commented on a change in pull request #11755: [FLINK-14257][Connectors / FileSystem]Integrate csv to FileSystemTableFactory

JingsongLi commented on a change in pull request #11755: URL: https://github.com/apache/flink/pull/11755#discussion_r412665572 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/BaseRowCsvInputformatTest.java ## @@ -0,0 +1,798 @@ +/* + * Licensed

[GitHub] [flink] WeiZhong94 commented on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client.

WeiZhong94 commented on issue #11702: URL: https://github.com/apache/flink/pull/11702#issuecomment-617551402 @dianfu Thanks for your review! I have updated this PR according to your comments. This is an automated message fro

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN * cba096ae3d8eba4a0d39c64659f76ad10a62be27 UN

[GitHub] [flink] flinkbot edited a comment on issue #11832: [FLINK-17148][python] Support converting pandas dataframe to flink table

flinkbot edited a comment on issue #11832: URL: https://github.com/apache/flink/pull/11832#issuecomment-616617636 ## CI report: * b463662a390b45757a682cee7ea89ed52e1fa6f6 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161065718) Azure: [SUCCESS](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11615: [FLINK-16605] Add max limitation to the total number of slots

flinkbot edited a comment on issue #11615: URL: https://github.com/apache/flink/pull/11615#issuecomment-607717339 ## CI report: * 2db316d977d0e790de8fa98b27dd219b68abb136 UNKNOWN * 0b0111ba893c9ecc7632394fc59e455f8d5c9db7 UNKNOWN * be9e8eb0b0906dff84686fb4db6ec72fd39f1292 Tr

[GitHub] [flink] KarmaGYZ opened a new pull request #11850: [FLINK-17297] Log the lineage information between ExecutionAttemptID …

KarmaGYZ opened a new pull request #11850: URL: https://github.com/apache/flink/pull/11850 …and SlotRequestID ## What is the purpose of the change Log the lineage information between ExecutionAttemptID and SlotRequestID. ## Brief change log Log the lineag

[jira] [Updated] (FLINK-17297) Log the lineage information between ExecutionAttemptID and SlotRequestID

[ https://issues.apache.org/jira/browse/FLINK-17297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17297: --- Labels: pull-request-available (was: ) > Log the lineage information between ExecutionAttem

[GitHub] [flink] wuchong commented on a change in pull request #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter

wuchong commented on a change in pull request #11766: URL: https://github.com/apache/flink/pull/11766#discussion_r412677524 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/source/row/converter/PostgresRowConverter.java ## @@ -28,4 +34,

[GitHub] [flink] flinkbot commented on issue #11850: [FLINK-17297] Log the lineage information between ExecutionAttemptID …

flinkbot commented on issue #11850: URL: https://github.com/apache/flink/pull/11850#issuecomment-617557431 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 progress

[jira] [Updated] (FLINK-17314) 【Flink Kafka Connector】The Config（connector.topic）support list topic

[ https://issues.apache.org/jira/browse/FLINK-17314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17314: Component/s: Table SQL / Ecosystem Connectors / Kafka > 【Flink Kafka Connector】The Config

[jira] [Commented] (FLINK-17314) 【Flink Kafka Connector】The Config（connector.topic）support list topic

[ https://issues.apache.org/jira/browse/FLINK-17314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089297#comment-17089297 ] Jark Wu commented on FLINK-17314: - Is the topic discovery [1] what you are looking for?

[GitHub] [flink] flinkbot edited a comment on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client.

flinkbot edited a comment on issue #11702: URL: https://github.com/apache/flink/pull/11702#issuecomment-612221236 ## CI report: * b839e592856b50429a5097c7094d883fdbef1f2d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161042493) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11615: [FLINK-16605] Add max limitation to the total number of slots

flinkbot edited a comment on issue #11615: URL: https://github.com/apache/flink/pull/11615#issuecomment-607717339 ## CI report: * 2db316d977d0e790de8fa98b27dd219b68abb136 UNKNOWN * 0b0111ba893c9ecc7632394fc59e455f8d5c9db7 UNKNOWN * be9e8eb0b0906dff84686fb4db6ec72fd39f1292 Tr

[GitHub] [flink] flinkbot edited a comment on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

flinkbot edited a comment on issue #11727: URL: https://github.com/apache/flink/pull/11727#issuecomment-613273432 ## CI report: * fa5592cec0a6a5dcecc4f45c4bf72caf6e166eb4 UNKNOWN * a3901b149f603721be62fbb3d8bf46143d08c3d1 UNKNOWN * fabc951d769b00e1dac471b75ba2c99e62fcbf47 Tr

[GitHub] [flink] flinkbot commented on issue #11850: [FLINK-17297] Log the lineage information between ExecutionAttemptID …

flinkbot commented on issue #11850: URL: https://github.com/apache/flink/pull/11850#issuecomment-617559978 ## CI report: * ba4ab2b747e1d13d1776e977523d9facd7865ffa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run trav

[GitHub] [flink] flinkbot edited a comment on issue #11832: [FLINK-17148][python] Support converting pandas dataframe to flink table

flinkbot edited a comment on issue #11832: URL: https://github.com/apache/flink/pull/11832#issuecomment-616617636 ## CI report: * b463662a390b45757a682cee7ea89ed52e1fa6f6 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161065718) Azure: [SUCCESS](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11836: [FLINK-17188][python] Use pip instead of conda to install flake8 and sphinx

flinkbot edited a comment on issue #11836: URL: https://github.com/apache/flink/pull/11836#issuecomment-616922166 ## CI report: * 8cfe6bcc6cee878730f9cfa75d7fa598f88a9833 UNKNOWN * 3ca11194996f3b2e7d51221f8f51ae928d93c3a3 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci

[jira] [Commented] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089300#comment-17089300 ] Jark Wu commented on FLINK-17313: - I think the root cause is that you are using the lega

[GitHub] [flink] KarmaGYZ opened a new pull request #11851: [FLINK-17298] Log the lineage information between SlotRequestID and A…

KarmaGYZ opened a new pull request #11851: URL: https://github.com/apache/flink/pull/11851 …llocationID ## What is the purpose of the change Log the lineage information between SlotRequestID and AllocationID. ## Brief change log Log the lineage information

[jira] [Updated] (FLINK-17298) Log the lineage information between SlotRequestID and AllocationID

[ https://issues.apache.org/jira/browse/FLINK-17298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17298: --- Labels: pull-request-available (was: ) > Log the lineage information between SlotRequestID

[GitHub] [flink] flinkbot commented on issue #11851: [FLINK-17298] Log the lineage information between SlotRequestID and A…

flinkbot commented on issue #11851: URL: https://github.com/apache/flink/pull/11851#issuecomment-617561608 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 progress

[jira] [Assigned] (FLINK-15006) Add option to close shuffle when dynamic partition inserting

[ https://issues.apache.org/jira/browse/FLINK-15006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-15006: Assignee: Jingsong Lee > Add option to close shuffle when dynamic partition inserting > -

[GitHub] [flink] flinkbot edited a comment on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client.

flinkbot edited a comment on issue #11702: URL: https://github.com/apache/flink/pull/11702#issuecomment-612221236 ## CI report: * b839e592856b50429a5097c7094d883fdbef1f2d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161042493) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN * cba096ae3d8eba4a0d39c64659f76ad10a62be27 UN

[GitHub] [flink] flinkbot edited a comment on issue #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed

flinkbot edited a comment on issue #11397: URL: https://github.com/apache/flink/pull/11397#issuecomment-598575354 ## CI report: * 3e020148288d2a3cddb7c8a6025e01f04898b4a0 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161361177) Azure: [PENDING](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11850: [FLINK-17297] Log the lineage information between ExecutionAttemptID …

flinkbot edited a comment on issue #11850: URL: https://github.com/apache/flink/pull/11850#issuecomment-617559978 ## CI report: * ba4ab2b747e1d13d1776e977523d9facd7865ffa Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161371639) Azure: [PENDING](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11829: [FLINK-17021][table-planner-blink] Blink batch planner set GlobalDataExchangeMode

flinkbot edited a comment on issue #11829: URL: https://github.com/apache/flink/pull/11829#issuecomment-616561190 ## CI report: * c15a8214d2883f5a5c07bb6357dbfa465dd5cd39 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161357311) Azure: [SUCCESS](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11832: [FLINK-17148][python] Support converting pandas dataframe to flink table

flinkbot edited a comment on issue #11832: URL: https://github.com/apache/flink/pull/11832#issuecomment-616617636 ## CI report: * b463662a390b45757a682cee7ea89ed52e1fa6f6 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161065718) Azure: [SUCCESS](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11845: [FLINK-17240][docs] Add tutorial on Event-driven Apps

flinkbot edited a comment on issue #11845: URL: https://github.com/apache/flink/pull/11845#issuecomment-617236902 ## CI report: * e30b1b23a9eb209b9fdac786aed7010577d32e08 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161296189) Azure: [PENDING](https://dev

[GitHub] [flink] flinkbot commented on issue #11851: [FLINK-17298] Log the lineage information between SlotRequestID and A…

flinkbot commented on issue #11851: URL: https://github.com/apache/flink/pull/11851#issuecomment-617565355 ## CI report: * 7d139f0b9c78f7a4dd986d38da0aecf4642ff047 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run trav

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089308#comment-17089308 ] Piotr Nowojski commented on FLINK-17274: another instance: https://dev.azure.co

[jira] [Updated] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17274: --- Priority: Critical (was: Major) > Maven: Premature end of Content-Length delimited message

[jira] [Updated] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17274: --- Affects Version/s: (was: 1.11.0) > Maven: Premature end of Content-Length delimited mess

[jira] [Updated] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17274: --- Fix Version/s: 1.11.0 > Maven: Premature end of Content-Length delimited message body >

[jira] [Commented] (FLINK-11086) Add support for Hadoop 3

[ https://issues.apache.org/jira/browse/FLINK-11086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089314#comment-17089314 ] Robert Metzger commented on FLINK-11086: I started a discussion about this ticke

[jira] [Updated] (FLINK-13733) FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13733: --- Attachment: 20200421.13.tar.gz > FlinkKafkaInternalProducerITCase.testHappyPath fails on Tra

[jira] [Commented] (FLINK-13733) FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089322#comment-17089322 ] Robert Metzger commented on FLINK-13733: Another instance: https://dev.azure.co

[GitHub] [flink] flinkbot edited a comment on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client.

flinkbot edited a comment on issue #11702: URL: https://github.com/apache/flink/pull/11702#issuecomment-612221236 ## CI report: * b839e592856b50429a5097c7094d883fdbef1f2d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161042493) Azure: [FAILURE](https://dev

[jira] [Updated] (FLINK-13733) FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13733: --- Affects Version/s: 1.11.0 > FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis >

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN * cba096ae3d8eba4a0d39c64659f76ad10a62be27 UN

[jira] [Comment Edited] (FLINK-13733) FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089322#comment-17089322 ] Robert Metzger edited comment on FLINK-13733 at 4/22/20, 6:10 AM:

[GitHub] [flink] flinkbot edited a comment on issue #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode.

flinkbot edited a comment on issue #11801: URL: https://github.com/apache/flink/pull/11801#issuecomment-615388238 ## CI report: * 40bb9f80fe4a3944121756cf08a6beb843af8461 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161361316) Azure: [PENDING](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11832: [FLINK-17148][python] Support converting pandas dataframe to flink table

flinkbot edited a comment on issue #11832: URL: https://github.com/apache/flink/pull/11832#issuecomment-616617636 ## CI report: * b463662a390b45757a682cee7ea89ed52e1fa6f6 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161065718) Azure: [SUCCESS](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11851: [FLINK-17298] Log the lineage information between SlotRequestID and A…

flinkbot edited a comment on issue #11851: URL: https://github.com/apache/flink/pull/11851#issuecomment-617565355 ## CI report: * 7d139f0b9c78f7a4dd986d38da0aecf4642ff047 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161373381) Azure: [PENDING](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11845: [FLINK-17240][docs] Add tutorial on Event-driven Apps

flinkbot edited a comment on issue #11845: URL: https://github.com/apache/flink/pull/11845#issuecomment-617236902 ## CI report: * e30b1b23a9eb209b9fdac786aed7010577d32e08 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161296189) Azure: [PENDING](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11849: [FLINK-17312][sqlclient] support sql client savepoint

flinkbot edited a comment on issue #11849: URL: https://github.com/apache/flink/pull/11849#issuecomment-617537614 ## CI report: * c5817c1743c657627346fdf3e71b5e5ca9335e18 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161365046) Azure: [FAILURE](https://dev

[GitHub] [flink] xintongsong commented on a change in pull request #11363: [FLINK-16440][runtime] Extend SlotManager metrics and status for dynamic slot allocation.

xintongsong commented on a change in pull request #11363: URL: https://github.com/apache/flink/pull/11363#discussion_r412697593 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/StandaloneResourceManagerFactory.java ## @@ -28,31 +28,35 @@ impo

[GitHub] [flink] KarmaGYZ opened a new pull request #11852: [FLINK-17300] Log the lineage information between ExecutionAttemptID …

KarmaGYZ opened a new pull request #11852: URL: https://github.com/apache/flink/pull/11852 …and AllocationID ## What is the purpose of the change Log the lineage information between ExecutionAttemptID and AllocationID ## Brief change log Log the lineage in

[jira] [Updated] (FLINK-17300) Log the lineage information between ExecutionAttemptID and AllocationID

[ https://issues.apache.org/jira/browse/FLINK-17300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17300: --- Labels: pull-request-available (was: ) > Log the lineage information between ExecutionAttem

[GitHub] [flink] xintongsong commented on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

xintongsong commented on issue #11323: URL: https://github.com/apache/flink/pull/11323#issuecomment-617574832 Thanks @tillrohrmann, I've addressed your comments, except for two that I have some questions about. This is a

[jira] [Commented] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089326#comment-17089326 ] Terry Wang commented on FLINK-17313: [~jark] I agree with you that new sink interfa

[jira] [Comment Edited] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089326#comment-17089326 ] Terry Wang edited comment on FLINK-17313 at 4/22/20, 6:19 AM:

[GitHub] [flink] flinkbot commented on issue #11852: [FLINK-17300] Log the lineage information between ExecutionAttemptID …

flinkbot commented on issue #11852: URL: https://github.com/apache/flink/pull/11852#issuecomment-617575327 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 progress

[jira] [Updated] (FLINK-15006) Add option to close shuffle when dynamic partition inserting

[ https://issues.apache.org/jira/browse/FLINK-15006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15006: --- Labels: pull-request-available (was: ) > Add option to close shuffle when dynamic partition

[GitHub] [flink] JingsongLi opened a new pull request #11853: [FLINK-15006][table-planner] Add option to shuffle-by-partition when dynamic inserting

JingsongLi opened a new pull request #11853: URL: https://github.com/apache/flink/pull/11853 ## What is the purpose of the change When partition values are rare or have skew, if we shuffle by dynamic partitions, will break the performance. We can have an option to close shuffl

[GitHub] [flink] flinkbot commented on issue #11853: [FLINK-15006][table-planner] Add option to shuffle-by-partition when dynamic inserting

flinkbot commented on issue #11853: URL: https://github.com/apache/flink/pull/11853#issuecomment-617577180 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 progress

[GitHub] [flink] wsry commented on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

wsry commented on issue #11351: URL: https://github.com/apache/flink/pull/11351#issuecomment-617578042 @zhijiangW I did some performance tests, all tests are configured 1s checkpoint Interval, the test job has three vertices (source -> map -> sink) and up/down streams are connected by Remo

[jira] [Commented] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089331#comment-17089331 ] Dawid Wysakowicz commented on FLINK-17313: -- Hi [~Terry1897] First of all I do a

[GitHub] [flink] flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on issue #11323: URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: * edd2f98c2a607655aef8823024753fccebe29a7d UNKNOWN * 7618202f65eaef2a659f52768d3c87ae3b20df9e Travis: [SUCCESS](https://travis-ci.com/github/flink-ci

[GitHub] [flink] KarmaGYZ opened a new pull request #11854: [WIP] Introduce external resource framework

KarmaGYZ opened a new pull request #11854: URL: https://github.com/apache/flink/pull/11854 ## What is the purpose of the change Introduce external resource framework ## Brief change log - 6edb419: Introduce interfaces for external resource framework - 92e6fe1:

[GitHub] [flink] flinkbot edited a comment on issue #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed

flinkbot edited a comment on issue #11397: URL: https://github.com/apache/flink/pull/11397#issuecomment-598575354 ## CI report: * 3e020148288d2a3cddb7c8a6025e01f04898b4a0 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161361177) Azure: [SUCCESS](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client.

flinkbot edited a comment on issue #11702: URL: https://github.com/apache/flink/pull/11702#issuecomment-612221236 ## CI report: * 9f0e138f75100bd547e4a7ca612c57df7729fec9 Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161371530) Azure: [PENDING](https://de

[GitHub] [flink] flinkbot edited a comment on issue #11849: [FLINK-17312][sqlclient] support sql client savepoint

flinkbot edited a comment on issue #11849: URL: https://github.com/apache/flink/pull/11849#issuecomment-617537614 ## CI report: * c5817c1743c657627346fdf3e71b5e5ca9335e18 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161365046) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11848: [FLINK-17313]fix type validation error when sink table ddl exists column with precision of decimal/timestamp/varchar

flinkbot edited a comment on issue #11848: URL: https://github.com/apache/flink/pull/11848#issuecomment-617531785 ## CI report: * 9b24a40f43a101b63ab73d1fa1e0c0f31178b36d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161363103) Azure: [PENDING](https://dev

[GitHub] [flink] flinkbot commented on issue #11852: [FLINK-17300] Log the lineage information between ExecutionAttemptID …

flinkbot commented on issue #11852: URL: https://github.com/apache/flink/pull/11852#issuecomment-617579676 ## CI report: * 4e682b06757524da0011bf0b236c9b37158dcf80 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run trav

[GitHub] [flink] flinkbot edited a comment on issue #11832: [FLINK-17148][python] Support converting pandas dataframe to flink table

flinkbot edited a comment on issue #11832: URL: https://github.com/apache/flink/pull/11832#issuecomment-616617636 ## CI report: * c2105e0170d56fb95b849c4b830ca7a7b9d48fd3 UNKNOWN * 1e4aee0d61292ed92724bcabb97ce307833366da Travis: [CANCELED](https://travis-ci.com/github/flink-c

  1   2   3   4   5   6   7   >