[GitHub] [flink] Myasuka commented on a change in pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

2022-03-15 Thread GitBox
Myasuka commented on a change in pull request #19051: URL: https://github.com/apache/flink/pull/19051#discussion_r826716970 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractStateChangeLogger.java ## @@ -145,

[GitHub] [flink] flinkbot edited a comment on pull request #19070: [FLINK-26618][sql-client] Fix Remove-Jar statement not effective

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19070: URL: https://github.com/apache/flink/pull/19070#issuecomment-1066030702 ## CI report: * Unknown: [CANCELED](TBD) * 183293c8d6cc788d92de34bc97c48784dc731acf UNKNOWN Bot commands The @flinkbot bot supports the fo

[GitHub] [flink] flinkbot edited a comment on pull request #19089: [FLINK-26607][python] There are multiple MAX_LONG_VALUE value errors in pyflink code

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19089: URL: https://github.com/apache/flink/pull/19089#issuecomment-1067544609 ## CI report: * 103331d5386317a184e7f363fa490a43842b8915 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Updated] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26646: --- Labels: pull-request-available (was: ) > Flink kubernetes operator helm template is broken

[GitHub] [flink] KarmaGYZ opened a new pull request #19095: [FLINK-26641] Optimize the time of fetching job status in the job submission of session cluster

2022-03-15 Thread GitBox
KarmaGYZ opened a new pull request #19095: URL: https://github.com/apache/flink/pull/19095 ## What is the purpose of the change Optimize the time of fetching job status in the job submission of session cluster. ## Brief change log - Introduce rest api to fetch job

[jira] [Updated] (FLINK-26641) Optimize the time of fetching job status in the job submission of session cluster

2022-03-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26641: --- Labels: pull-request-available (was: ) > Optimize the time of fetching job status in the jo

[jira] [Created] (FLINK-26648) Ban dependencies on flink-table-planner and depend on flink-table-planner-loader instead

2022-03-15 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-26648: --- Summary: Ban dependencies on flink-table-planner and depend on flink-table-planner-loader instead Key: FLINK-26648 URL: https://issues.apache.org/jira/browse/FLINK-26648

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #41: [FLINK-26535] Introduce StoreTableSource And StoreTableSink

2022-03-15 Thread GitBox
LadyForest commented on a change in pull request #41: URL: https://github.com/apache/flink-table-store/pull/41#discussion_r826723223 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -84,14 +109,15 @@ pu

[GitHub] [flink] realdengziqi commented on pull request #18982: [FLINK-26334][datastream] Fix getWindowStartWithOffset in TimeWindow.java

2022-03-15 Thread GitBox
realdengziqi commented on pull request #18982: URL: https://github.com/apache/flink/pull/18982#issuecomment-1067722277 @godfreyhe Could you please help review and merge this code if it's ok. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot commented on pull request #19093: [FLINK-24960][yarn]enable log line of YarnClusterDescriptor

2022-03-15 Thread GitBox
flinkbot commented on pull request #19093: URL: https://github.com/apache/flink/pull/19093#issuecomment-1067723030 ## CI report: * c36721c2627db4772167d093840664bda88a1157 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] echauchot commented on a change in pull request #19059: [FLINK-25771][connectors][Cassandra][tests][flaky] Remove testRetrialAndDropTables and make drop tables atomic

2022-03-15 Thread GitBox
echauchot commented on a change in pull request #19059: URL: https://github.com/apache/flink/pull/19059#discussion_r826724781 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java ##

[GitHub] [flink] wanglijie95 commented on pull request #19040: [FLINK-26548][runtime] set the source parallelism correctly when using legacy file sources with AdaptiveBatcheScheduler

2022-03-15 Thread GitBox
wanglijie95 commented on pull request #19040: URL: https://github.com/apache/flink/pull/19040#issuecomment-1067723796 Thanks for all the efforts on this PR @zhoulii, but unfortunately this PR doesn't fully solve the problem and introduces some new problems. Currently, the solution di

[GitHub] [flink] wanglijie95 edited a comment on pull request #19040: [FLINK-26548][runtime] set the source parallelism correctly when using legacy file sources with AdaptiveBatcheScheduler

2022-03-15 Thread GitBox
wanglijie95 edited a comment on pull request #19040: URL: https://github.com/apache/flink/pull/19040#issuecomment-1067723796 Thanks for all the efforts on this PR @zhoulii, but unfortunately this PR doesn't fully solve the problem and introduces new problems. Currently, the solution

[GitHub] [flink] echauchot commented on pull request #19059: [FLINK-25771][connectors][Cassandra][tests][flaky] Remove testRetrialAndDropTables and make drop tables atomic

2022-03-15 Thread GitBox
echauchot commented on pull request #19059: URL: https://github.com/apache/flink/pull/19059#issuecomment-1067724693 @zentol I addressed all your comments. PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[GitHub] [flink] echauchot edited a comment on pull request #19059: [FLINK-25771][connectors][Cassandra][tests][flaky] Remove testRetrialAndDropTables and make drop tables atomic

2022-03-15 Thread GitBox
echauchot edited a comment on pull request #19059: URL: https://github.com/apache/flink/pull/19059#issuecomment-1067724693 @zentol I addressed all your comments. I should be ok now. PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] echauchot edited a comment on pull request #19059: [FLINK-25771][connectors][Cassandra][tests][flaky] Remove testRetrialAndDropTables and make drop tables atomic

2022-03-15 Thread GitBox
echauchot edited a comment on pull request #19059: URL: https://github.com/apache/flink/pull/19059#issuecomment-1067724693 @zentol I addressed all your comments. It should be ok now. PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink-table-store] JingsongLi merged pull request #45: [hotfix] Remove 'table.path' option and let FileStore construct table path dynamically

2022-03-15 Thread GitBox
JingsongLi merged pull request #45: URL: https://github.com/apache/flink-table-store/pull/45 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issue

[GitHub] [flink] flinkbot commented on pull request #19094: [FLINK-26642][connector/pulsar] Fix support for non-partitioned topic

2022-03-15 Thread GitBox
flinkbot commented on pull request #19094: URL: https://github.com/apache/flink/pull/19094#issuecomment-1067727689 ## CI report: * b3f828d7e69e5032b9e79053e5cc5290f4c7d0e1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-03-15 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506799#comment-17506799 ] Etienne Chauchot commented on FLINK-25771: -- [~gaoyunhaii] thanks for reporting

[GitHub] [flink] rkhachatryan commented on a change in pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

2022-03-15 Thread GitBox
rkhachatryan commented on a change in pull request #19051: URL: https://github.com/apache/flink/pull/19051#discussion_r826733692 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractStateChangeLogger.java ## @@

[GitHub] [flink] JingGe commented on a change in pull request #19083: [FLINK-26604][doc] add more information for Avro records support and clean up redundant content of bounded and unbounded data

2022-03-15 Thread GitBox
JingGe commented on a change in pull request #19083: URL: https://github.com/apache/flink/pull/19083#discussion_r826180052 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -39,46 +39,71 @@ To use the format you need to add the Flink Parquet depend

[GitHub] [flink] zhoulii commented on pull request #19040: [FLINK-26548][runtime] set the source parallelism correctly when using legacy file sources with AdaptiveBatcheScheduler

2022-03-15 Thread GitBox
zhoulii commented on pull request #19040: URL: https://github.com/apache/flink/pull/19040#issuecomment-1067738895 > Thanks for all the efforts on this PR @zhoulii, but unfortunately this PR doesn't fully solve the problem and introduces new problems. > > Currently, the solution discu

[jira] [Created] (FLINK-26649) Add startTime in JobStatus

2022-03-15 Thread Yang Wang (Jira)
Yang Wang created FLINK-26649: - Summary: Add startTime in JobStatus Key: FLINK-26649 URL: https://issues.apache.org/jira/browse/FLINK-26649 Project: Flink Issue Type: Sub-task Component

[jira] [Created] (FLINK-26650) Avoid to print stack trace for checkpoint trigger failure if not all tasks are started

2022-03-15 Thread Yun Tang (Jira)
Yun Tang created FLINK-26650: Summary: Avoid to print stack trace for checkpoint trigger failure if not all tasks are started Key: FLINK-26650 URL: https://issues.apache.org/jira/browse/FLINK-26650 Projec

[jira] [Commented] (FLINK-26650) Avoid to print stack trace for checkpoint trigger failure if not all tasks are started

2022-03-15 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506806#comment-17506806 ] Yun Tang commented on FLINK-26650: -- cc [~pnowojski] > Avoid to print stack trace for c

[GitHub] [flink] rkhachatryan opened a new pull request #19096: [FLINK-26063][runtime] Set current key before polling next PQ element

2022-03-15 Thread GitBox
rkhachatryan opened a new pull request #19096: URL: https://github.com/apache/flink/pull/19096 ## What is the purpose of the change Key group is logged so that state changes can be re-distributed or shuffled. It is currently obtained from keyContext for remove() operations. Howe

[GitHub] [flink] rkhachatryan commented on a change in pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

2022-03-15 Thread GitBox
rkhachatryan commented on a change in pull request #19051: URL: https://github.com/apache/flink/pull/19051#discussion_r826750073 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractStateChangeLogger.java ## @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

2022-03-15 Thread GitBox
rkhachatryan commented on a change in pull request #19051: URL: https://github.com/apache/flink/pull/19051#discussion_r826750073 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractStateChangeLogger.java ## @@

[GitHub] [flink] gaoyunhaii opened a new pull request #19097: [hotfix][release] Add 1.16 to the flink versions enum

2022-03-15 Thread GitBox
gaoyunhaii opened a new pull request #19097: URL: https://github.com/apache/flink/pull/19097 ## What is the purpose of the change This PR completes the 1.16 version to the flink versions enum ## Does this pull request potentially affect one of the following parts: - De

[GitHub] [flink] JingGe commented on a change in pull request #19083: [FLINK-26604][doc] add more information for Avro records support and clean up redundant content of bounded and unbounded data

2022-03-15 Thread GitBox
JingGe commented on a change in pull request #19083: URL: https://github.com/apache/flink/pull/19083#discussion_r826139610 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -39,46 +39,71 @@ To use the format you need to add the Flink Parquet depend

[GitHub] [flink] XComp edited a comment on pull request #19082: [FLINK-26596][BP-1.14][runtime][test] Adds leadership loss handling

2022-03-15 Thread GitBox
XComp edited a comment on pull request #19082: URL: https://github.com/apache/flink/pull/19082#issuecomment-1067659895 Errors in [ci run](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=33030&view=results) are unrelated: * FLINK-26220 * FLINK-26621 -- This i

[jira] [Closed] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26646. -- Resolution: Fixed merged: 81593eca3643bd7f17db5fe371d4f355967f70df > Flink kubernetes operator helm t

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 39c6e525639eea1a578f99d7dc03b44b6c36cbeb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] Myasuka commented on a change in pull request #19096: [FLINK-26063][runtime] Set current key before polling next PQ element

2022-03-15 Thread GitBox
Myasuka commented on a change in pull request #19096: URL: https://github.com/apache/flink/pull/19096#discussion_r826764473 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/InternalPriorityQueue.java ## @@ -77,6 +80,9 @@ /** * Check if the se

[jira] [Updated] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

2022-03-15 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-25916: Priority: Major (was: Critical) > Using upsert-kafka with a flush buffer results in Null Pointer

[GitHub] [flink] flinkbot edited a comment on pull request #18646: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #18646: URL: https://github.com/apache/flink/pull/18646#issuecomment-1031503295 ## CI report: * cb7d3ffbe8d6e057a68a473747998c3a646e9ce7 UNKNOWN * 5219c94d1e14bb5f9c717caf685ad39760b7b539 Azure: [SUCCESS](https://dev.azure.com/apache-f

[jira] [Updated] (FLINK-26650) Avoid to print stack trace for checkpoint trigger failure if not all tasks are started

2022-03-15 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-26650: - Fix Version/s: 1.16.0 > Avoid to print stack trace for checkpoint trigger failure if not all tasks > ar

[jira] [Commented] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

2022-03-15 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506812#comment-17506812 ] Fabian Paul commented on FLINK-25916: - [~paul8263] yes your analysis is correct but

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

2022-03-15 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506813#comment-17506813 ] hehuiyuan commented on FLINK-26498: --- Thanks   [~jark] [~paul8263] , learned knowledge

[GitHub] [flink] Myasuka opened a new pull request #19098: [FLINK-26650][checkpoint] Avoid to print stack trace for checkpoint trigger failure if not all tasks are started

2022-03-15 Thread GitBox
Myasuka opened a new pull request #19098: URL: https://github.com/apache/flink/pull/19098 ## What is the purpose of the change Avoid to print stack trace for checkpoint trigger failure if not all tasks are started. This is somehow like FLINK-22117. ## Brief change log C

[jira] [Updated] (FLINK-26650) Avoid to print stack trace for checkpoint trigger failure if not all tasks are started

2022-03-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26650: --- Labels: pull-request-available (was: ) > Avoid to print stack trace for checkpoint trigger

[jira] [Commented] (FLINK-26649) Add startTime in JobStatus

2022-03-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506814#comment-17506814 ] Gyula Fora commented on FLINK-26649: do you think we need both update and startTime?

[GitHub] [flink] flinkbot edited a comment on pull request #18868: [FLINK-26206][runtime-web] add service layer abstraction and refactor config service

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #18868: URL: https://github.com/apache/flink/pull/18868#issuecomment-1047395206 ## CI report: * 62c14add633d8b84609053af807c6591658580fd Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26649) Add startTime in JobStatus

2022-03-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506821#comment-17506821 ] Yang Wang commented on FLINK-26649: --- I think it is useful to have the update time espe

[GitHub] [flink] flinkbot edited a comment on pull request #19039: [FLINK-26582][table] Convert table modules assertions to AssertJ

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19039: URL: https://github.com/apache/flink/pull/19039#issuecomment-1063993450 ## CI report: * 998e593852998bd5a20784a01317821cd54e436d UNKNOWN * 5a5518531c03404f5b39b1774930e23e1e6a553c Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] zentol merged pull request #19059: [FLINK-25771][connectors][Cassandra][tests][flaky] Remove testRetrialAndDropTables and make drop tables atomic

2022-03-15 Thread GitBox
zentol merged pull request #19059: URL: https://github.com/apache/flink/pull/19059 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] ZhangChaoming commented on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

2022-03-15 Thread GitBox
ZhangChaoming commented on pull request #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-1067783935 @flinkbot run azure -- 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

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-03-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506822#comment-17506822 ] Chesnay Schepler commented on FLINK-25771: -- Cluster load reduced: master: 3bb6f

[GitHub] [flink] gaoyunhaii commented on pull request #19073: [FLINK-26613][streaming] Allow setting operator uid hashes for predefined sink operators

2022-03-15 Thread GitBox
gaoyunhaii commented on pull request #19073: URL: https://github.com/apache/flink/pull/19073#issuecomment-1067784125 Very thanks @fapaul for the fix! LGTM. For another point, should we also unify the uid format compared to the 1.13? In all the versions, the writer always have the sam

[GitHub] [flink] dianfu commented on a change in pull request #19089: [FLINK-26607][python] There are multiple MAX_LONG_VALUE value errors in pyflink code

2022-03-15 Thread GitBox
dianfu commented on a change in pull request #19089: URL: https://github.com/apache/flink/pull/19089#discussion_r826782273 ## File path: flink-python/pyflink/fn_execution/table/window_aggregate_slow.py ## @@ -33,11 +32,11 @@ MergingWindowAssigner from pyflink.fn_execution

[jira] [Created] (FLINK-26651) The connector CI build timeout in azure

2022-03-15 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-26651: -- Summary: The connector CI build timeout in azure Key: FLINK-26651 URL: https://issues.apache.org/jira/browse/FLINK-26651 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #19053: [FLINK-26595][flink-connector-jdbc][postgreSQL]Improve the PostgresDi…

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19053: URL: https://github.com/apache/flink/pull/19053#issuecomment-1064816386 ## CI report: * 6842edbb9efd8c04a7cc4d1bf3089fc8a7ec3295 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19070: [FLINK-26618][sql-client] Fix Remove-Jar statement not effective

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19070: URL: https://github.com/apache/flink/pull/19070#issuecomment-1066030702 ## CI report: * Unknown: [CANCELED](TBD) * 183293c8d6cc788d92de34bc97c48784dc731acf Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-462

[GitHub] [flink] HarshaR99 closed pull request #19071: FLINK-25730

2022-03-15 Thread GitBox
HarshaR99 closed pull request #19071: URL: https://github.com/apache/flink/pull/19071 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsub

[GitHub] [flink] flinkbot edited a comment on pull request #19089: [FLINK-26607][python] There are multiple MAX_LONG_VALUE value errors in pyflink code

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19089: URL: https://github.com/apache/flink/pull/19089#issuecomment-1067544609 ## CI report: * 36faf315257032ac88e6bbb103e22b60409dff7e Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19093: [FLINK-24960][yarn]enable log line of YarnClusterDescriptor

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19093: URL: https://github.com/apache/flink/pull/19093#issuecomment-1067723030 ## CI report: * c36721c2627db4772167d093840664bda88a1157 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19094: [FLINK-26642][connector/pulsar] Fix support for non-partitioned topic

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19094: URL: https://github.com/apache/flink/pull/19094#issuecomment-1067727689 ## CI report: * b3f828d7e69e5032b9e79053e5cc5290f4c7d0e1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Comment Edited] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-03-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506822#comment-17506822 ] Chesnay Schepler edited comment on FLINK-25771 at 3/15/22, 10:04 AM: -

[GitHub] [flink] flinkbot commented on pull request #19095: [FLINK-26641] Optimize the time of fetching job status in the job submission of session cluster

2022-03-15 Thread GitBox
flinkbot commented on pull request #19095: URL: https://github.com/apache/flink/pull/19095#issuecomment-1067790182 ## CI report: * 1d18fa1b166b364b8e5a1d40ffdd8f14925d2de8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Closed] (FLINK-24328) Long term fix for receiving new buffer size before network reader configured

2022-03-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24328. Fix Version/s: (was: 1.15.0) Resolution: Won't Fix We decided the "temporary" f

[jira] [Comment Edited] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-03-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506822#comment-17506822 ] Chesnay Schepler edited comment on FLINK-25771 at 3/15/22, 10:07 AM: -

[jira] [Closed] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-03-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25771. Resolution: Fixed > CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP > --

[jira] [Comment Edited] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-03-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506822#comment-17506822 ] Chesnay Schepler edited comment on FLINK-25771 at 3/15/22, 10:07 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-997659194 ## CI report: * 74c203d84576d6a8c9406a42ffb82cb9cfba5e81 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] fapaul commented on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

2022-03-15 Thread GitBox
fapaul commented on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1067803940 I rebased locally and ran all tests successfully I will for now only merge this to master and see how it goes until the end of this week before enabling the tests on the release

[GitHub] [flink] flinkbot edited a comment on pull request #18868: [FLINK-26206][runtime-web] add service layer abstraction and refactor config service

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #18868: URL: https://github.com/apache/flink/pull/18868#issuecomment-1047395206 ## CI report: * 62c14add633d8b84609053af807c6591658580fd Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] fapaul merged pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

2022-03-15 Thread GitBox
fapaul merged pull request #18838: URL: https://github.com/apache/flink/pull/18838 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout

2022-03-15 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506830#comment-17506830 ] Fabian Paul commented on FLINK-26177: - Merged in master: 1572908edbb17455a83f9e45974

[GitHub] [flink] echauchot commented on pull request #19059: [FLINK-25771][connectors][Cassandra][tests][flaky] Remove testRetrialAndDropTables and make drop tables atomic

2022-03-15 Thread GitBox
echauchot commented on pull request #19059: URL: https://github.com/apache/flink/pull/19059#issuecomment-1067805817 thanks @zentol for reviewing and merging ! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[GitHub] [flink-web] MartijnVisser merged pull request #513: Restore verification for Google Search Console

2022-03-15 Thread GitBox
MartijnVisser merged pull request #513: URL: https://github.com/apache/flink-web/pull/513 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-u

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-03-15 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506831#comment-17506831 ] Etienne Chauchot commented on FLINK-25771: -- thanks [~chesnay] for the backports

[GitHub] [flink] flinkbot edited a comment on pull request #19033: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19033: URL: https://github.com/apache/flink/pull/19033#issuecomment-1063699541 ## CI report: * 768a998a8989828f816cbdfa009737529ec9dbd0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19039: [FLINK-26582][table] Convert table modules assertions to AssertJ

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19039: URL: https://github.com/apache/flink/pull/19039#issuecomment-1063993450 ## CI report: * 998e593852998bd5a20784a01317821cd54e436d UNKNOWN * 5a5518531c03404f5b39b1774930e23e1e6a553c Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] JingGe commented on a change in pull request #19083: [FLINK-26604][doc] add more information for Avro records support and clean up redundant content of bounded and unbounded data

2022-03-15 Thread GitBox
JingGe commented on a change in pull request #19083: URL: https://github.com/apache/flink/pull/19083#discussion_r826135126 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -39,46 +39,71 @@ To use the format you need to add the Flink Parquet depend

[GitHub] [flink] flinkbot edited a comment on pull request #19086: Update Python code on top of new TableConfig scheme

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19086: URL: https://github.com/apache/flink/pull/19086#issuecomment-1067106419 ## CI report: * 57684673dc218d593ff6a11901d38f7c034f5770 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-24194) resource-providers yarn documentation has Chinese useless characters

2022-03-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24194: --- Labels: auto-deprioritized-minor documentation (was: documentation stale-minor) Prior

[jira] [Updated] (FLINK-22449) Casting an invalid constant string to int throws exception from SinkNotNullEnforcer

2022-03-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22449: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-26358) Operator maxParallelism is lost during chaining

2022-03-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26358: --- Labels: pull-request-available stale-critical (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-25527) Add StringIndexer in FlinkML

2022-03-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25527: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available stal

[jira] [Updated] (FLINK-25450) JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable on azure

2022-03-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25450: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability) Pri

[jira] [Updated] (FLINK-24311) Support expression reduction for JSON construction functions

2022-03-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24311: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available stal

[jira] [Updated] (FLINK-25642) The standalone deployment mode should also support the parameter pipeline.jars

2022-03-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25642: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-15017) add a thrift server for Flink

2022-03-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15017: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-depr

[GitHub] [flink] flinkbot edited a comment on pull request #19089: [FLINK-26607][python] There are multiple MAX_LONG_VALUE value errors in pyflink code

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19089: URL: https://github.com/apache/flink/pull/19089#issuecomment-1067544609 ## CI report: * 36faf315257032ac88e6bbb103e22b60409dff7e Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19092: WIP: [FLINK-26645][Connector/Pulsar] Fix Pulsar source subscriber consume from all partitions when only subscribed to 1 partition

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19092: URL: https://github.com/apache/flink/pull/19092#issuecomment-1067660495 ## CI report: * 7294f936a7361d9d3e5fdb2ddb87bd323a97ed2b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19095: [FLINK-26641] Optimize the time of fetching job status in the job submission of session cluster

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19095: URL: https://github.com/apache/flink/pull/19095#issuecomment-1067790182 ## CI report: * 1d18fa1b166b364b8e5a1d40ffdd8f14925d2de8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] syhily commented on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

2022-03-15 Thread GitBox
syhily commented on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1067838095 > I rebased locally and ran all tests successfully I will for now only merge this to master and see how it goes until the end of this week before enabling the tests on the relea

[jira] [Commented] (FLINK-26649) Add startTime in JobStatus

2022-03-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506844#comment-17506844 ] Nicholas Jiang commented on FLINK-26649: [~gyfora], IMO, the update time is diff

[GitHub] [flink] flinkbot commented on pull request #19096: [FLINK-26063][runtime] Set current key before polling next PQ element

2022-03-15 Thread GitBox
flinkbot commented on pull request #19096: URL: https://github.com/apache/flink/pull/19096#issuecomment-1067840283 ## CI report: * 5331dae21376c5da2b0e1d2a841f9e3a596083ad UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] syhily commented on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

2022-03-15 Thread GitBox
syhily commented on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1067840278 @fapaul The document is also ready. Can you check it? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [flink] JingGe commented on a change in pull request #19083: [FLINK-26604][doc] add more information for Avro records support and clean up redundant content of bounded and unbounded data

2022-03-15 Thread GitBox
JingGe commented on a change in pull request #19083: URL: https://github.com/apache/flink/pull/19083#discussion_r826840345 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -39,46 +39,71 @@ To use the format you need to add the Flink Parquet depend

[GitHub] [flink] zentol commented on a change in pull request #19083: [FLINK-26604][doc] add more information for Avro records support and clean up redundant content of bounded and unbounded data

2022-03-15 Thread GitBox
zentol commented on a change in pull request #19083: URL: https://github.com/apache/flink/pull/19083#discussion_r826843387 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -39,46 +39,71 @@ To use the format you need to add the Flink Parquet depend

[GitHub] [flink] flinkbot commented on pull request #19097: [hotfix][release] Add 1.16 to the flink versions enum

2022-03-15 Thread GitBox
flinkbot commented on pull request #19097: URL: https://github.com/apache/flink/pull/19097#issuecomment-1067851691 ## CI report: * 1c525255b319cd4273f9ce3a255233b25855e5af UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] zentol commented on a change in pull request #19083: [FLINK-26604][doc] add more information for Avro records support and clean up redundant content of bounded and unbounded data

2022-03-15 Thread GitBox
zentol commented on a change in pull request #19083: URL: https://github.com/apache/flink/pull/19083#discussion_r826843387 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -39,46 +39,71 @@ To use the format you need to add the Flink Parquet depend

[GitHub] [flink] zentol commented on a change in pull request #19083: [FLINK-26604][doc] add more information for Avro records support and clean up redundant content of bounded and unbounded data

2022-03-15 Thread GitBox
zentol commented on a change in pull request #19083: URL: https://github.com/apache/flink/pull/19083#discussion_r826846224 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -39,46 +39,71 @@ To use the format you need to add the Flink Parquet depend

[GitHub] [flink] zentol commented on a change in pull request #19083: [FLINK-26604][doc] add more information for Avro records support and clean up redundant content of bounded and unbounded data

2022-03-15 Thread GitBox
zentol commented on a change in pull request #19083: URL: https://github.com/apache/flink/pull/19083#discussion_r826848366 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -39,46 +39,71 @@ To use the format you need to add the Flink Parquet depend

[GitHub] [flink] flinkbot commented on pull request #19098: [FLINK-26650][checkpoint] Avoid to print stack trace for checkpoint trigger failure if not all tasks are started

2022-03-15 Thread GitBox
flinkbot commented on pull request #19098: URL: https://github.com/apache/flink/pull/19098#issuecomment-1067858807 ## CI report: * 264eebf3ef1988d8c3b863d034bd23e4eff76275 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] zentol commented on a change in pull request #19083: [FLINK-26604][doc] add more information for Avro records support and clean up redundant content of bounded and unbounded data

2022-03-15 Thread GitBox
zentol commented on a change in pull request #19083: URL: https://github.com/apache/flink/pull/19083#discussion_r826852181 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -39,46 +39,71 @@ To use the format you need to add the Flink Parquet depend

[GitHub] [flink] zentol commented on a change in pull request #19083: [FLINK-26604][doc] add more information for Avro records support and clean up redundant content of bounded and unbounded data

2022-03-15 Thread GitBox
zentol commented on a change in pull request #19083: URL: https://github.com/apache/flink/pull/19083#discussion_r826843387 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -39,46 +39,71 @@ To use the format you need to add the Flink Parquet depend

[GitHub] [flink] zentol commented on a change in pull request #19083: [FLINK-26604][doc] add more information for Avro records support and clean up redundant content of bounded and unbounded data

2022-03-15 Thread GitBox
zentol commented on a change in pull request #19083: URL: https://github.com/apache/flink/pull/19083#discussion_r826843387 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -39,46 +39,71 @@ To use the format you need to add the Flink Parquet depend

<    1   2   3   4   5   6   >