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

[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] [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=17089308#comment-17089308 ] Piotr Nowojski commented on FLINK-17274: another instance:

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

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

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

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

[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

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

[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

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

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

[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=17089300#comment-17089300 ] Jark Wu commented on FLINK-17313: - I think the root cause is that you are using the legacy type

[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

[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

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

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

[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

[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

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

[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=17089297#comment-17089297 ] Jark Wu commented on FLINK-17314: - Is the topic discovery [1] what you are looking for? And you want to

[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

[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

[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

[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

[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

[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

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

[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

[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

[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] 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:

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

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

[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

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

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

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

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

[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

[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

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

[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

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

[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=17089263#comment-17089263 ] Zhijiang commented on FLINK-17274: -- Another instance 

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

[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

[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=17089261#comment-17089261 ] Leonard Xu commented on FLINK-17309: I checked related scripts hasn't modified, and looked up some

[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] [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] 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* -

[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

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

[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

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

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

[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=17089260#comment-17089260 ] Wenlong Lyu commented on FLINK-17012: - [~pnowojski] I think whether the task is ready to process

[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

[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

[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=17089258#comment-17089258 ] Terry Wang commented on FLINK-17313: I open a

[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

[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

[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

[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 ] Terry Wang updated FLINK-17313: --- Description: Test code like follwing(in blink planner): {code:java}

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

[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

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

[jira] [Comment Edited] (FLINK-17273) Fix not calling ResourceManager#closeTaskManagerConnection in KubernetesResourceManager in case of registered TaskExecutor failure

[ https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089254#comment-17089254 ] Canbin Zheng edited comment on FLINK-17273 at 4/22/20, 3:25 AM: Thanks

[jira] [Commented] (FLINK-17273) Fix not calling ResourceManager#closeTaskManagerConnection in KubernetesResourceManager in case of registered TaskExecutor failure

[ https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089254#comment-17089254 ] Canbin Zheng commented on FLINK-17273: -- Thanks for your attention! [~xintongsong] [~fly_in_gis]

[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 ] Terry Wang updated FLINK-17313: --- Description: Test code like follwing(in blink planner): {code:java}

[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=17089251#comment-17089251 ] Terry Wang commented on FLINK-17313: cc [~ykt836][~jark][~dwysakowicz]Please have a look on this

[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_r412637786 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java ## @@ -239,70 +247,73 @@ private void

[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 ] Terry Wang updated FLINK-17313: --- Description: Test code like follwing(in blink planner): {code:java}

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

Terry Wang created FLINK-17313: -- Summary: Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row Key: FLINK-17313 URL:

[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: * c01e235c3048c97accdd33f7cfe2b03f6f60c8b3 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161169854) Azure:

[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_r412632853 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java ## @@ -804,16 +850,31 @@ private

[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_r412623864 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java ## @@ -804,16 +850,31 @@ private

[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: * 02287c3c91f023a4eaad10059fa9a7890c11879c Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161205815) Azure:

[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: * c01e235c3048c97accdd33f7cfe2b03f6f60c8b3 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161169854) Azure:

[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: * 7cbe2380ac7246cf703397d9a78d002c0491a959 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160664905) Azure:

[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_r412627200 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/StandaloneResourceManagerFactory.java ## @@ -74,4 +81,21 @@

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

lun zhang created FLINK-17312: - Summary: Support sql client savepoint Key: FLINK-17312 URL: https://issues.apache.org/jira/browse/FLINK-17312 Project: Flink Issue Type: Improvement

[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_r412626933 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java ## @@ -320,5 +333,16 @@ private void

[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] 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] 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_r412623864 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java ## @@ -804,16 +850,31 @@ private

[jira] [Assigned] (FLINK-17017) Implement Bulk Slot Allocation in SchedulerImpl

[ https://issues.apache.org/jira/browse/FLINK-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17017: --- Assignee: Zhu Zhu > Implement Bulk Slot Allocation in SchedulerImpl >

[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_r412623864 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java ## @@ -804,16 +850,31 @@ private

[jira] [Commented] (FLINK-17273) Fix not calling ResourceManager#closeTaskManagerConnection in KubernetesResourceManager in case of registered TaskExecutor failure

[ https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089219#comment-17089219 ] Xintong Song commented on FLINK-17273: -- I think this is a valid issue. +1 for fixing it. IIUC, we

[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: * 02287c3c91f023a4eaad10059fa9a7890c11879c Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161205815) Azure:

[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 * 60d96398326fa63e3b2e53d5e3302d70feeb862d

[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: * 7cbe2380ac7246cf703397d9a78d002c0491a959 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160664905) Azure:

[GitHub] [flink] zhuzhurk commented on a change in pull request #11829: [FLINK-17021][table-planner-blink] Blink batch planner set GlobalDataExchangeMode

zhuzhurk commented on a change in pull request #11829: URL: https://github.com/apache/flink/pull/11829#discussion_r412621866 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/ExecutorUtils.java ## @@ -85,19 +83,14 @@ public

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

xintongsong commented on a change in pull request #11615: URL: https://github.com/apache/flink/pull/11615#discussion_r412619527 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/StandaloneResourceManagerFactory.java ## @@ -74,4 +81,21 @@

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

xintongsong commented on a change in pull request #11615: URL: https://github.com/apache/flink/pull/11615#discussion_r412619527 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/StandaloneResourceManagerFactory.java ## @@ -74,4 +81,21 @@

  1   2   3   4   5   6   >