[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

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

[jira] [Commented] (FLINK-25495) Client support attach mode when using the deployment of application mode

[ https://issues.apache.org/jira/browse/FLINK-25495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471736#comment-17471736 ] Junfan Zhang commented on FLINK-25495: -- [~wangyang0918] Thanks for your reply. {no

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

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

[GitHub] [flink] flinkbot edited a comment on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

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

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[jira] [Updated] (FLINK-25583) FLIP-191: Support compacting small files for FileSink

[ https://issues.apache.org/jira/browse/FLINK-25583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25583: Parent: FLINK-2 Issue Type: Sub-task (was: New Feature) > FLIP-191: Support compacting small

[jira] [Updated] (FLINK-25583) Support compacting small files for FileSink

[ https://issues.apache.org/jira/browse/FLINK-25583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25583: Summary: Support compacting small files for FileSink (was: FLIP-191: Support compacting small files for F

[GitHub] [flink] flinkbot edited a comment on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

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

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

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

[jira] [Commented] (FLINK-25280) KafkaPartitionSplitReaderTest failed on azure due to Offsets out of range with no configured reset policy for partitions

[ https://issues.apache.org/jira/browse/FLINK-25280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471732#comment-17471732 ] Fabian Paul commented on FLINK-25280: - [~renqs] can you take a look at this? It is p

[GitHub] [flink] alpreu commented on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

alpreu commented on pull request #18301: URL: https://github.com/apache/flink/pull/18301#issuecomment-1008612902 @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 to the specific

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[jira] [Commented] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471728#comment-17471728 ] Fabian Paul commented on FLINK-22068: - [~dannycranmer] can you take a look at this?

[jira] [Commented] (FLINK-25495) Client support attach mode when using the deployment of application mode

[ https://issues.apache.org/jira/browse/FLINK-25495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471726#comment-17471726 ] Yang Wang commented on FLINK-25495: --- I am afraid that depending on the attach mode is

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[jira] [Commented] (FLINK-25557) Introduce incremental/full checkpoint size stats

[ https://issues.apache.org/jira/browse/FLINK-25557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471713#comment-17471713 ] Yun Tang commented on FLINK-25557: -- [~liufangqi] Thanks for your attention. I will intr

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[jira] [Commented] (FLINK-25586) ExecutionGraphInfoStore in session cluster should split failed and successful jobs

[ https://issues.apache.org/jira/browse/FLINK-25586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471704#comment-17471704 ] Shammon commented on FLINK-25586: - [~Zhanghao Chen] Would you like to pick up this issue

[jira] [Created] (FLINK-25586) ExecutionGraphInfoStore in session cluster should split failed and successful jobs

Shammon created FLINK-25586: --- Summary: ExecutionGraphInfoStore in session cluster should split failed and successful jobs Key: FLINK-25586 URL: https://issues.apache.org/jira/browse/FLINK-25586 Project: Fli

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[GitHub] [flink] flinkbot edited a comment on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

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

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[jira] [Commented] (FLINK-25181) KafkaSourceITCase.testValueOnlyDeserializer fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471695#comment-17471695 ] Yun Gao commented on FLINK-25181: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-25585) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed on the azure

[ https://issues.apache.org/jira/browse/FLINK-25585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471694#comment-17471694 ] Yun Gao commented on FLINK-25585: - perhaps cc [~dmvk] ~ > JobManagerHAProcessFailureRec

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

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

[jira] [Created] (FLINK-25585) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed on the azure

Yun Gao created FLINK-25585: --- Summary: JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed on the azure Key: FLINK-25585 URL: https://issues.apache.org/jira/browse/FLINK-25585 Proj

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

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

[GitHub] [flink] zjureel commented on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

zjureel commented on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008580687 @KarmaGYZ I create a new PR for FLINK-25085 to add a thread pool in RpcEndpoint for periodic tasks and I will run the ci for several times. Could you please review it first? th

[jira] [Commented] (FLINK-25579) Py4JException: window([class org.apache.flink.table.api.SlideWithSizeAndSlide]) does not exist

[ https://issues.apache.org/jira/browse/FLINK-25579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471691#comment-17471691 ] Huang Xingbo commented on FLINK-25579: -- It looks like your pyflink version is 1.14.

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

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

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471690#comment-17471690 ] Yun Gao commented on FLINK-20928: - 1.14: https://dev.azure.com/apache-flink/apache-flin

[GitHub] [flink] zjureel commented on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

zjureel commented on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008579220 @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 to the specific

[jira] [Commented] (FLINK-25374) Azure pipeline get stalled on scanning project

[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471689#comment-17471689 ] Yun Gao commented on FLINK-25374: - One possible reproduced cased: https://dev.azure.com

[jira] [Commented] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471687#comment-17471687 ] Wenlong Lyu commented on FLINK-23031: - hi, [~aitozi], according to your description:

[jira] [Created] (FLINK-25584) Azure failed on install node and npm for Flink : Runtime web

Yun Gao created FLINK-25584: --- Summary: Azure failed on install node and npm for Flink : Runtime web Key: FLINK-25584 URL: https://issues.apache.org/jira/browse/FLINK-25584 Project: Flink Issue Typ

[jira] [Assigned] (FLINK-25583) FLIP-191: Support compacting small files for FileSink

[ https://issues.apache.org/jira/browse/FLINK-25583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-25583: --- Assignee: Gen Luo > FLIP-191: Support compacting small files for FileSink > ---

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

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

[jira] [Updated] (FLINK-25583) FLIP-191: Support compacting small files for FileSink

[ https://issues.apache.org/jira/browse/FLINK-25583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25583: Summary: FLIP-191: Support compacting small files for FileSink (was: [FLIP-191] Support compacting small

[jira] [Created] (FLINK-25583) [FLIP-191] Support compacting small files for FileSink

Yun Gao created FLINK-25583: --- Summary: [FLIP-191] Support compacting small files for FileSink Key: FLINK-25583 URL: https://issues.apache.org/jira/browse/FLINK-25583 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471677#comment-17471677 ] Yao Zhang commented on FLINK-25471: --- Thank you [~twalthr] . > wrong result if table t

[jira] [Comment Edited] (FLINK-25280) KafkaPartitionSplitReaderTest failed on azure due to Offsets out of range with no configured reset policy for partitions

[ https://issues.apache.org/jira/browse/FLINK-25280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471676#comment-17471676 ] Yun Gao edited comment on FLINK-25280 at 1/10/22, 6:17 AM: --- pe

[jira] [Commented] (FLINK-25280) KafkaPartitionSplitReaderTest failed on azure due to Offsets out of range with no configured reset policy for partitions

[ https://issues.apache.org/jira/browse/FLINK-25280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471674#comment-17471674 ] Yun Gao commented on FLINK-25280: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-25280) KafkaPartitionSplitReaderTest failed on azure due to Offsets out of range with no configured reset policy for partitions

[ https://issues.apache.org/jira/browse/FLINK-25280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471676#comment-17471676 ] Yun Gao commented on FLINK-25280: - cc [~fpaul] > KafkaPartitionSplitReaderTest failed o

[jira] [Updated] (FLINK-25280) KafkaPartitionSplitReaderTest failed on azure due to Offsets out of range with no configured reset policy for partitions

[ https://issues.apache.org/jira/browse/FLINK-25280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25280: Description: {code:java} 2021-12-13T03:30:12.8392593Z Dec 13 03:30:12 [ERROR] Tests run: 6, Failures: 0,

[jira] [Commented] (FLINK-12005) [State TTL] Event time support

[ https://issues.apache.org/jira/browse/FLINK-12005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471675#comment-17471675 ] Yu Li commented on FLINK-12005: --- Update the ML discussion link for better history tracking

[jira] [Updated] (FLINK-25280) KafkaPartitionSplitReaderTest failed on azure due to Offsets out of range with no configured reset policy for partitions

[ https://issues.apache.org/jira/browse/FLINK-25280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25280: Description: {code:java} 2021-12-13T03:30:12.8392593Z Dec 13 03:30:12 [ERROR] Tests run: 6, Failures: 0,

[jira] [Updated] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22068: Affects Version/s: 1.15.0 > FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure > --

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471671#comment-17471671 ] Yun Gao commented on FLINK-18356: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471672#comment-17471672 ] Yun Gao commented on FLINK-22068: - Perhapse cc [~fpaul] [~arvid] > FlinkKinesisConsumer

[jira] [Commented] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471670#comment-17471670 ] Yun Gao commented on FLINK-22068: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] flinkbot edited a comment on pull request #18308: [FLINK-25471][streaming-java] Wrong result if table transforms to Dat…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18308: [FLINK-25471][streaming-java] Wrong result if table transforms to Dat…

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

[GitHub] [flink] cuibo01 commented on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.0 due to CVEs

cuibo01 commented on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-1008534995 @rmetzger @AHeise @tsreaper hi can you review this pr？ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot edited a comment on pull request #18310: [FLINK-16627] Flink-SQL json format add non-null optinon

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

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

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

[GitHub] [flink] flinkbot edited a comment on pull request #18309: [FLINK-25582] [TABLE SQL / API] flink sql kafka source cannot special custom parallelism

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

[jira] [Comment Edited] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

[ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471650#comment-17471650 ] Bruce Wong edited comment on FLINK-25330 at 1/10/22, 3:19 AM:

[jira] [Commented] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

[ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471650#comment-17471650 ] Bruce Wong commented on FLINK-25330: Hi [~jingge] , I created a new task to solve t

[GitHub] [flink] flinkbot edited a comment on pull request #18310: [FLINK-16627] Flink-SQL json format add non-null optinon

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

[GitHub] [flink] flinkbot commented on pull request #18310: [FLINK-16627] Flink-SQL json format add non-null optinon

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

[GitHub] [flink] flinkbot edited a comment on pull request #18309: [FLINK-25582] [TABLE SQL / API] flink sql kafka source cannot special custom parallelism

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

[jira] [Comment Edited] (FLINK-25445) TaskExecutor always creates local file for task even when local state store is not used

[ https://issues.apache.org/jira/browse/FLINK-25445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471347#comment-17471347 ] Junfan Zhang edited comment on FLINK-25445 at 1/10/22, 3:10 AM: --

[GitHub] [flink] flinkbot commented on pull request #18310: [FLINK-16627] Flink-SQL json format add non-null optinon

flinkbot commented on pull request #18310: URL: https://github.com/apache/flink/pull/18310#issuecomment-1008507720 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 pr

[GitHub] [flink] flinkbot commented on pull request #18309: [FLINK-25582] [TABLE SQL / API] flink sql kafka source cannot special custom parallelism

flinkbot commented on pull request #18309: URL: https://github.com/apache/flink/pull/18309#issuecomment-1008506471 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 pr

[jira] [Updated] (FLINK-16627) Support only generate non-null values when serializing into JSON

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16627: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-avail

[GitHub] [flink] HeChuanXUPT opened a new pull request #18310: [FLINK-16627] Flink-SQL json format add non-null optinon

HeChuanXUPT opened a new pull request #18310: URL: https://github.com/apache/flink/pull/18310 ## What is the purpose of the change json encode only with non-null fields ## Brief change log - *flink-sql json optinoal add 'json.encode.non-null'* ## Verifying this chan

[GitHub] [flink] flinkbot commented on pull request #18309: [FLINK-25582] [TABLE SQL / API] flink sql kafka source cannot special custom parallelism

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

[jira] [Updated] (FLINK-25582) flink sql kafka source cannot special custom parallelism

[ https://issues.apache.org/jira/browse/FLINK-25582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25582: --- Labels: pull-request-available (was: ) > flink sql kafka source cannot special custom paral

[GitHub] [flink] springMoon opened a new pull request #18309: [FLINK-25582] [TABLE SQL / API] flink sql kafka source cannot special custom parallelism

springMoon opened a new pull request #18309: URL: https://github.com/apache/flink/pull/18309 ## What is the purpose of the change flink sql kafka source cannot special custom parallelism ## Brief change log flink sql kafka source cannot special custom parallelism

[GitHub] [flink] JingsongLi commented on a change in pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

JingsongLi commented on a change in pull request #18219: URL: https://github.com/apache/flink/pull/18219#discussion_r780872242 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/TableSinkTest.scala ## @@ -135,4 +135,45 @@

[jira] [Commented] (FLINK-25528) state processor api do not support increment checkpoint

[ https://issues.apache.org/jira/browse/FLINK-25528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471644#comment-17471644 ] 刘方奇 commented on FLINK-25528: - [~sjwiesman] What do you think about this? In my opinion, it'

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[jira] [Created] (FLINK-25582) flink sql kafka source cannot special custom parallelism

venn wu created FLINK-25582: --- Summary: flink sql kafka source cannot special custom parallelism Key: FLINK-25582 URL: https://issues.apache.org/jira/browse/FLINK-25582 Project: Flink Issue Type: Im

[GitHub] [flink] flinkbot edited a comment on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

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

[GitHub] [flink] ruanhang1993 commented on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

ruanhang1993 commented on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-1008494542 @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 to the spe

[GitHub] [flink] flinkbot edited a comment on pull request #18308: [FLINK-25471][streaming-java] Wrong result if table transforms to Dat…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

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

[GitHub] [flink] flinkbot edited a comment on pull request #18308: [FLINK-25471][streaming-java] Wrong result if table transforms to Dat…

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

[GitHub] [flink] SteNicholas commented on pull request #18307: Update match_recognize.md

SteNicholas commented on pull request #18307: URL: https://github.com/apache/flink/pull/18307#issuecomment-1008490858 @MartijnVisser , could you help to find a committer to merge this simple pull request? I have reviewed this pull request. -- This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * Unknown: [CANCELED](TBD) * 94fa63008c237a2206befeae332159bf21cc1e1f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-462

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * Unknown: [CANCELED](TBD) * 94fa63008c237a2206befeae332159bf21cc1e1f UNKNOWN Bot commands The @flinkbot bot supports the fo

[GitHub] [flink] zjureel commented on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

zjureel commented on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008483896 @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 to the specific

[jira] [Assigned] (FLINK-25577) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-25577: Assignee: Galen Warren > Update GCS documentation > > >

[jira] [Updated] (FLINK-25577) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-25577: - Description: Update GCS documentation with respect to: - flink-shaded-hadoop artifacts and hadoo

[jira] [Updated] (FLINK-25577) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-25577: - Description: Update GCS documentation with respect to: - Artifacts that are no longer supported

[jira] [Updated] (FLINK-25577) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-25577: - Summary: Update GCS documentation (was: Update GCS documentation not to use no longer supported

[GitHub] [flink] xintongsong commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r780739757 ## File path: tools/ci/maven-utils.sh ## @@ -104,7 +104,7 @@ MVN_GLOBAL_OPTIONS_WITHOUT_MIRROR+="--no-snapshot-updates " # enable non-interactive bat

[GitHub] [flink] cuibo01 commented on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.0 due to CVEs

cuibo01 commented on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-1008474641 @xintongsong hi can you review this pr？ -- 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 t

[GitHub] [flink] flinkbot edited a comment on pull request #18308: [FLINK-25471][streaming-java] Wrong result if table transforms to Dat…

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

[GitHub] [flink] flinkbot commented on pull request #18308: [FLINK-25471][streaming-java] Wrong result if table transforms to Dat…

flinkbot commented on pull request #18308: URL: https://github.com/apache/flink/pull/18308#issuecomment-1008462604 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 pr

[GitHub] [flink] flinkbot commented on pull request #18308: [FLINK-25471][streaming-java] Wrong result if table transforms to Dat…

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

[jira] [Updated] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25471: --- Labels: pull-request-available (was: ) > wrong result if table transfrom to DataStream then

  1   2   >