[jira] [Commented] (FLINK-30129) Push projection through ChangelogNormalize

[ https://issues.apache.org/jira/browse/FLINK-30129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678553#comment-17678553 ] Jun Qin commented on FLINK-30129: - Do we have a plan for this fix?  > Push projection through

[jira] [Resolved] (FLINK-30724) Update doc of kafka per-partition watermark to FLIP-27 source

[ https://issues.apache.org/jira/browse/FLINK-30724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-30724. -- Fix Version/s: 1.16.1 1.15.4 Resolution: Fixed merged master:

[jira] [Commented] (FLINK-30717) Migrate Travis CI to Github Actions

[ https://issues.apache.org/jira/browse/FLINK-30717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678635#comment-17678635 ] Chesnay Schepler commented on FLINK-30717: -- benchmarks:

[jira] [Commented] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678650#comment-17678650 ] Matt Wang commented on FLINK-30680: --- In our production environment, during the peak business period,

[GitHub] [flink-connector-cassandra] zentol commented on a diff in pull request #3: [FLINK-26822] Add Cassandra Source

zentol commented on code in PR #3: URL: https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1081173791 ## flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/CassandraSplitSerializer.java: ## @@ -0,0 +1,63 @@ +/* + *

[jira] [Updated] (FLINK-30232) shading of netty epoll shared library does not account for ARM64 platform

[ https://issues.apache.org/jira/browse/FLINK-30232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30232: --- Fix Version/s: shaded-17.0 > shading of netty epoll shared library does not account for

[jira] [Created] (FLINK-30754) Fix ExceptionThrowingDelegationTokenProvider/Receiver multi-threaded test issues

Gabor Somogyi created FLINK-30754: - Summary: Fix ExceptionThrowingDelegationTokenProvider/Receiver multi-threaded test issues Key: FLINK-30754 URL: https://issues.apache.org/jira/browse/FLINK-30754

[jira] [Updated] (FLINK-30219) Fetch results api in sql gateway return error result.

[ https://issues.apache.org/jira/browse/FLINK-30219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30219: --- Fix Version/s: (was: 1.16.1) > Fetch results api in sql gateway return error result. >

[jira] [Updated] (FLINK-29530) CommittableMessageTypeInfo#toString may force client to have S3 credentials

[ https://issues.apache.org/jira/browse/FLINK-29530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29530: --- Fix Version/s: (was: 1.16.1) > CommittableMessageTypeInfo#toString may force client to

[jira] [Updated] (FLINK-29370) Protobuf in flink-sql-protobuf is not shaded

[ https://issues.apache.org/jira/browse/FLINK-29370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29370: --- Fix Version/s: (was: 1.16.1) > Protobuf in flink-sql-protobuf is not shaded >

[jira] [Updated] (FLINK-30694) Translate "Windowing TVF" page of "Querys" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-30694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30694: --- Fix Version/s: (was: 1.16.1) > Translate "Windowing TVF" page of "Querys" into Chinese

[jira] [Updated] (FLINK-27077) Setup per-commit builds

[ https://issues.apache.org/jira/browse/FLINK-27077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27077: --- Fix Version/s: (was: 1.16.1) > Setup per-commit builds > --- > >

[jira] [Updated] (FLINK-27079) Setup cron jobs

[ https://issues.apache.org/jira/browse/FLINK-27079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27079: --- Fix Version/s: (was: 1.16.1) > Setup cron jobs > --- > >

[jira] [Updated] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29459: --- Fix Version/s: (was: 1.16.1) > Sink v2 has bugs in supporting legacy v1 implementations

[jira] [Updated] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28959: --- Fix Version/s: (was: 1.16.1) > 504 gateway timeout when consume large number of topics

[jira] [Updated] (FLINK-29859) TPC-DS end-to-end test with adaptive batch scheduler failed due to oo non-empty .out files.

[ https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29859: --- Fix Version/s: (was: 1.16.1) > TPC-DS end-to-end test with adaptive batch scheduler

[jira] [Updated] (FLINK-30596) Multiple POST /jars/:jarid/run requests with the same jobId, runs duplicate jobs

[ https://issues.apache.org/jira/browse/FLINK-30596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30596: --- Fix Version/s: (was: 1.16.1) > Multiple POST /jars/:jarid/run requests with the same

[jira] [Updated] (FLINK-27954) JobVertexFlameGraphHandler does not work on standby Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27954: --- Fix Version/s: (was: 1.16.1) > JobVertexFlameGraphHandler does not work on standby

[jira] [Updated] (FLINK-27082) Disable tests relying on non-writable directories

[ https://issues.apache.org/jira/browse/FLINK-27082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27082: --- Fix Version/s: (was: 1.16.1) > Disable tests relying on non-writable directories >

[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29339: --- Fix Version/s: (was: 1.16.1) >

[jira] [Updated] (FLINK-30657) Remove Shared and Key_Shared related tests in Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-30657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30657: --- Fix Version/s: (was: 1.16.1) > Remove Shared and Key_Shared related tests in Pulsar

[jira] [Updated] (FLINK-27075) Migrate CI from Azure to Github Actions

[ https://issues.apache.org/jira/browse/FLINK-27075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27075: --- Fix Version/s: (was: 1.16.1) > Migrate CI from Azure to Github Actions >

[jira] [Updated] (FLINK-27080) Enable builds for pull requests

[ https://issues.apache.org/jira/browse/FLINK-27080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27080: --- Fix Version/s: (was: 1.16.1) > Enable builds for pull requests >

[jira] [Updated] (FLINK-30112) Improve docs re state compression

[ https://issues.apache.org/jira/browse/FLINK-30112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30112: --- Fix Version/s: (was: 1.16.1) > Improve docs re state compression >

[GitHub] [flink] SinBex commented on a diff in pull request #21695: [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks.

SinBex commented on code in PR #21695: URL: https://github.com/apache/flink/pull/21695#discussion_r1081135014 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/slowtaskdetector/ExecutionTimeBasedSlowTaskDetector.java: ## @@ -225,10 +244,56 @@ private long

[GitHub] [flink] SinBex commented on a diff in pull request #21695: [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks.

SinBex commented on code in PR #21695: URL: https://github.com/apache/flink/pull/21695#discussion_r1081134730 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/slowtaskdetector/ExecutionTimeBasedSlowTaskDetector.java: ## @@ -225,10 +244,56 @@ private long

[jira] [Closed] (FLINK-30058) Move existing Google Cloud PubSub connector code from Flink repo to dedicated Google PubSub repo

[ https://issues.apache.org/jira/browse/FLINK-30058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30058. -- Fix Version/s: gcp-pubsub-3.0.0 Resolution: Fixed Fixed in main, last commit:

[GitHub] [flink] zentol commented on a diff in pull request #21492: [FLINK-30378][docs] Add v2 sql_connector_download_table shortcode

zentol commented on code in PR #21492: URL: https://github.com/apache/flink/pull/21492#discussion_r1081201261 ## docs/setup_docs.sh: ## @@ -27,19 +27,12 @@ function integrate_connector_docs { local connector ref additional_folders connector=$1 ref=$2 -

[jira] [Assigned] (FLINK-30751) Remove references to disableDataSync in RocksDB documentation

[ https://issues.apache.org/jira/browse/FLINK-30751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-30751: -- Assignee: David Christle > Remove references to disableDataSync in RocksDB

[GitHub] [flink] SinBex commented on a diff in pull request #21695: [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks.

SinBex commented on code in PR #21695: URL: https://github.com/apache/flink/pull/21695#discussion_r1081129947 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AllToAllBlockingResultInfo.java: ## @@ -119,4 +120,17 @@ public List

[jira] [Comment Edited] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678650#comment-17678650 ] Matt Wang edited comment on FLINK-30680 at 1/19/23 11:39 AM: - Thanks 

[GitHub] [flink-connector-gcp-pubsub] MartijnVisser merged pull request #1: [FLINK-30058][Connector/Google PubSub] Move existing Google Cloud PubSub connector code from Flink repo

MartijnVisser merged PR #1: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/1 -- 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:

[GitHub] [flink-connector-gcp-pubsub] boring-cyborg[bot] commented on pull request #1: [FLINK-30058][Connector/Google PubSub] Move existing Google Cloud PubSub connector code from Flink repo

boring-cyborg[bot] commented on PR #1: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/1#issuecomment-1396892642 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] pnowojski commented on pull request #21690: [FLINK-30623][runtime][bug] The canEmitBatchOfRecords should check recordWriter and changelogWriterAvailabilityProvider are available

pnowojski commented on PR #21690: URL: https://github.com/apache/flink/pull/21690#issuecomment-1396636736 @lindong28 I don't understand your concerns. With separate functional interface as you are proposing you will have exact same "problems". If you add functional interface to the

[jira] [Comment Edited] (FLINK-30530) Flink configuration from user-provided ConfigMap

[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17677432#comment-17677432 ] Arseniy Tashoyan edited comment on FLINK-30530 at 1/19/23 9:16 AM: ---

[jira] [Created] (FLINK-30753) Py4J cannot acquire Table.explain() method

Yunfeng Zhou created FLINK-30753: Summary: Py4J cannot acquire Table.explain() method Key: FLINK-30753 URL: https://issues.apache.org/jira/browse/FLINK-30753 Project: Flink Issue Type:

[GitHub] [flink] zentol merged pull request #21691: [FLINK-30678][tests] Use random port

zentol merged PR #21691: URL: https://github.com/apache/flink/pull/21691 -- 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:

[GitHub] [flink] yunfengzhou-hub opened a new pull request, #21730: [FLINK-30753][python] Fix the invocation process of Table.explain()

yunfengzhou-hub opened a new pull request, #21730: URL: https://github.com/apache/flink/pull/21730 ## What is the purpose of the change This PR fixes the bug that PyFlink cannot invoke `Explainable.explain()` method through py4j. ## Brief change log - invoke

[jira] [Updated] (FLINK-30753) Py4J cannot acquire Table.explain() method

[ https://issues.apache.org/jira/browse/FLINK-30753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30753: --- Labels: pull-request-available (was: ) > Py4J cannot acquire Table.explain() method >

[GitHub] [flink] Myasuka merged pull request #21714: [FLINK-30724][docs] Update kafka-per-partition watermark to new source

Myasuka merged PR #21714: URL: https://github.com/apache/flink/pull/21714 -- 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:

[jira] [Updated] (FLINK-27075) Migrate CI from Azure to Github Actions

[ https://issues.apache.org/jira/browse/FLINK-27075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27075: --- Fix Version/s: 1.16.2 > Migrate CI from Azure to Github Actions >

[jira] [Updated] (FLINK-29370) Protobuf in flink-sql-protobuf is not shaded

[ https://issues.apache.org/jira/browse/FLINK-29370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29370: --- Fix Version/s: 1.16.2 > Protobuf in flink-sql-protobuf is not shaded >

[jira] [Updated] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28959: --- Fix Version/s: 1.16.2 > 504 gateway timeout when consume large number of topics using

[jira] [Updated] (FLINK-27080) Enable builds for pull requests

[ https://issues.apache.org/jira/browse/FLINK-27080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27080: --- Fix Version/s: 1.16.2 > Enable builds for pull requests > --- >

[jira] [Updated] (FLINK-27079) Setup cron jobs

[ https://issues.apache.org/jira/browse/FLINK-27079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27079: --- Fix Version/s: 1.16.2 > Setup cron jobs > --- > > Key:

[jira] [Updated] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29459: --- Fix Version/s: 1.16.2 > Sink v2 has bugs in supporting legacy v1 implementations with

[jira] [Updated] (FLINK-29530) CommittableMessageTypeInfo#toString may force client to have S3 credentials

[ https://issues.apache.org/jira/browse/FLINK-29530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29530: --- Fix Version/s: 1.16.2 > CommittableMessageTypeInfo#toString may force client to have S3

[jira] [Updated] (FLINK-30694) Translate "Windowing TVF" page of "Querys" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-30694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30694: --- Fix Version/s: 1.16.2 > Translate "Windowing TVF" page of "Querys" into Chinese >

[jira] [Updated] (FLINK-30112) Improve docs re state compression

[ https://issues.apache.org/jira/browse/FLINK-30112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30112: --- Fix Version/s: 1.16.2 > Improve docs re state compression >

[jira] [Updated] (FLINK-30596) Multiple POST /jars/:jarid/run requests with the same jobId, runs duplicate jobs

[ https://issues.apache.org/jira/browse/FLINK-30596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30596: --- Fix Version/s: 1.16.2 > Multiple POST /jars/:jarid/run requests with the same jobId, runs

[jira] [Updated] (FLINK-30219) Fetch results api in sql gateway return error result.

[ https://issues.apache.org/jira/browse/FLINK-30219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30219: --- Fix Version/s: 1.16.2 > Fetch results api in sql gateway return error result. >

[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29339: --- Fix Version/s: 1.16.2 >

[jira] [Updated] (FLINK-29859) TPC-DS end-to-end test with adaptive batch scheduler failed due to oo non-empty .out files.

[ https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29859: --- Fix Version/s: 1.16.2 > TPC-DS end-to-end test with adaptive batch scheduler failed due to

[jira] [Updated] (FLINK-27077) Setup per-commit builds

[ https://issues.apache.org/jira/browse/FLINK-27077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27077: --- Fix Version/s: 1.16.2 > Setup per-commit builds > --- > >

[jira] [Updated] (FLINK-30657) Remove Shared and Key_Shared related tests in Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-30657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30657: --- Fix Version/s: 1.16.2 > Remove Shared and Key_Shared related tests in Pulsar connector >

[jira] [Updated] (FLINK-27082) Disable tests relying on non-writable directories

[ https://issues.apache.org/jira/browse/FLINK-27082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27082: --- Fix Version/s: 1.16.2 > Disable tests relying on non-writable directories >

[jira] [Updated] (FLINK-27954) JobVertexFlameGraphHandler does not work on standby Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27954: --- Fix Version/s: 1.16.2 > JobVertexFlameGraphHandler does not work on standby Dispatcher >

[GitHub] [flink] pnowojski commented on a diff in pull request #20151: [FLINK-26803][checkpoint] Merging channel state files

pnowojski commented on code in PR #20151: URL: https://github.com/apache/flink/pull/20151#discussion_r1081118070 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java: ## @@ -51,27 +66,40 @@ class

[GitHub] [flink] SinBex commented on a diff in pull request #21695: [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks.

SinBex commented on code in PR #21695: URL: https://github.com/apache/flink/pull/21695#discussion_r1081130568 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AbstractBlockingResultInfo.java: ## @@ -72,4 +73,15 @@ public void

[GitHub] [flink] SinBex commented on a diff in pull request #21695: [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks.

SinBex commented on code in PR #21695: URL: https://github.com/apache/flink/pull/21695#discussion_r1081130145 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/PointwiseBlockingResultInfo.java: ## @@ -60,4 +61,23 @@ public long

[GitHub] [flink] SinBex commented on a diff in pull request #21695: [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks.

SinBex commented on code in PR #21695: URL: https://github.com/apache/flink/pull/21695#discussion_r1081138788 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AbstractBlockingResultInfo.java: ## @@ -72,4 +73,15 @@ public void

[GitHub] [flink] hehuiyuan opened a new pull request, #21731: [FLINK-30679][hive]Fix IndexOutOfBoundsException for Hive lookup join when column pushdown to Hive lookup table source

hehuiyuan opened a new pull request, #21731: URL: https://github.com/apache/flink/pull/21731 ## What is the purpose of the change Can not load the data of hive dim table when project-push-down is introduced ## Does this pull request potentially affect one of the

[GitHub] [flink] kristoffSC commented on a diff in pull request #21393: [FLINK-27246][TableSQL/Runtime][master] - Include WHILE blocks in split generated java methods

kristoffSC commented on code in PR #21393: URL: https://github.com/apache/flink/pull/21393#discussion_r1081192318 ## flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementSplitter.java: ## @@ -0,0 +1,326 @@ +/* + * Licensed to the

[GitHub] [flink] kristoffSC commented on a diff in pull request #21393: [FLINK-27246][TableSQL/Runtime][master] - Include WHILE blocks in split generated java methods

kristoffSC commented on code in PR #21393: URL: https://github.com/apache/flink/pull/21393#discussion_r1081214977 ## flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementSplitter.java: ## @@ -0,0 +1,326 @@ +/* + * Licensed to the

[jira] [Closed] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li closed FLINK-30093. -- Fix Version/s: 1.17.0 Resolution: Fixed Fixed via

[GitHub] [flink] yunfengzhou-hub commented on pull request #21730: [FLINK-30753][python] Fix the invocation process of Table.explain()

yunfengzhou-hub commented on PR #21730: URL: https://github.com/apache/flink/pull/21730#issuecomment-1396705985 @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] yunfengzhou-hub commented on pull request #21730: [FLINK-30753][python] Fix the invocation process of Table.explain()

yunfengzhou-hub commented on PR #21730: URL: https://github.com/apache/flink/pull/21730#issuecomment-1396816878 @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] SinBex commented on a diff in pull request #21695: [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks.

SinBex commented on code in PR #21695: URL: https://github.com/apache/flink/pull/21695#discussion_r1081141135 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchScheduler.java: ## @@ -327,6 +332,41 @@ private ParallelismAndInputInfos

[GitHub] [flink] libenchao commented on pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

libenchao commented on PR #21613: URL: https://github.com/apache/flink/pull/21613#issuecomment-1396915307 @laughingman7743 Thanks for your contribution and @maosuhan thanks for your review. The PR looks good, I'm merging. -- This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-29421) Support python 3.10

[ https://issues.apache.org/jira/browse/FLINK-29421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo closed FLINK-29421. Resolution: Fixed Merged into master via 838b79f5b9cc1a4cf253b2c17009f337bf569ecc > Support

[GitHub] [flink] libenchao closed pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

libenchao closed pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type URL: https://github.com/apache/flink/pull/21613 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-26088) Add Elasticsearch 8.0 support

[ https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678555#comment-17678555 ] Martijn Visser commented on FLINK-26088: [~mtfelisb] I'm fine, thanks for asking. You're right,

[jira] [Assigned] (FLINK-26088) Add Elasticsearch 8.0 support

[ https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-26088: -- Assignee: Matheus Felisberto (was: zhenzhenhua) > Add Elasticsearch 8.0 support >

[GitHub] [flink] ruanhang1993 commented on a diff in pull request #21589: [FLINK-25509][connector-base] Add RecordEvaluator to dynamically stop source based on de-serialized records

ruanhang1993 commented on code in PR #21589: URL: https://github.com/apache/flink/pull/21589#discussion_r1080945750 ## flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/FinishSplitsTask.java: ## @@ -0,0 +1,69 @@ +/* + *

[jira] [Closed] (FLINK-30232) shading of netty epoll shared library does not account for ARM64 platform

[ https://issues.apache.org/jira/browse/FLINK-30232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30232. -- Resolution: Fixed Fixed in master: ba56570bbe395385c17240a2119c1c2cf8141675 > shading of

[GitHub] [flink] flinkbot commented on pull request #21730: [FLINK-30753][python] Fix the invocation process of Table.explain()

flinkbot commented on PR #21730: URL: https://github.com/apache/flink/pull/21730#issuecomment-1396706686 ## CI report: * 8bdcb25e0f606d7055d5541b6349d37bd98fac8b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] SinBex commented on a diff in pull request #21695: [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks.

SinBex commented on code in PR #21695: URL: https://github.com/apache/flink/pull/21695#discussion_r1081130568 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AbstractBlockingResultInfo.java: ## @@ -72,4 +73,15 @@ public void

[GitHub] [flink] SinBex commented on a diff in pull request #21695: [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks.

SinBex commented on code in PR #21695: URL: https://github.com/apache/flink/pull/21695#discussion_r1081134448 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/slowtaskdetector/ExecutionTimeBasedSlowTaskDetector.java: ## @@ -225,10 +244,56 @@ private long

[GitHub] [flink] SinBex commented on a diff in pull request #21695: [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks.

SinBex commented on code in PR #21695: URL: https://github.com/apache/flink/pull/21695#discussion_r1081138221 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/slowtaskdetector/ExecutionTimeBasedSlowTaskDetector.java: ## @@ -168,21 +168,34 @@ private double

[GitHub] [flink] SinBex commented on pull request #21695: [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks.

SinBex commented on PR #21695: URL: https://github.com/apache/flink/pull/21695#issuecomment-1396851350 @zhuzhurk @wanglijie95 Thanks for the review! I have updated this pr in the fix-up commit. Please take a look. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] tsreaper commented on a diff in pull request #21393: [FLINK-27246][TableSQL/Runtime][master] - Include WHILE blocks in split generated java methods

tsreaper commented on code in PR #21393: URL: https://github.com/apache/flink/pull/21393#discussion_r1081158207 ## flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementSplitter.java: ## @@ -0,0 +1,326 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot commented on pull request #21731: [FLINK-30679][hive]Fix IndexOutOfBoundsException for Hive lookup join when column pushdown to Hive lookup table source

flinkbot commented on PR #21731: URL: https://github.com/apache/flink/pull/21731#issuecomment-1396905973 ## CI report: * 482d706d44343a8f86fb27d178385f1fa118ffa9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] ruanhang1993 commented on a diff in pull request #21589: [FLINK-25509][connector-base] Add RecordEvaluator to dynamically stop source based on de-serialized records

ruanhang1993 commented on code in PR #21589: URL: https://github.com/apache/flink/pull/21589#discussion_r1080920855 ## flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/SingleThreadMultiplexSourceReaderBase.java: ## @@ -113,4

[GitHub] [flink] lincoln-lil commented on pull request #21676: [FLINK-30662][table] Planner supports delete

lincoln-lil commented on PR #21676: URL: https://github.com/apache/flink/pull/21676#issuecomment-1396596929 @luoyuxia the merged commits look like there are some changes and commits that are not aligned, so could you merge them again when you have time？ Chinese New Year is coming,

[GitHub] [flink] ruanhang1993 commented on a diff in pull request #21589: [FLINK-25509][connector-base] Add RecordEvaluator to dynamically stop source based on de-serialized records

ruanhang1993 commented on code in PR #21589: URL: https://github.com/apache/flink/pull/21589#discussion_r1080938338 ## flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/SourceReaderBase.java: ## @@ -328,14 +348,82 @@ private

[jira] [Comment Edited] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678650#comment-17678650 ] Matt Wang edited comment on FLINK-30680 at 1/19/23 12:00 PM: - Thanks 

[GitHub] [flink-connector-cassandra] zentol commented on pull request #3: [FLINK-26822] Add Cassandra Source

zentol commented on PR #3: URL: https://github.com/apache/flink-connector-cassandra/pull/3#issuecomment-1396864643 > I did not author the RingRange and SplitsGenerator classes. I got them from the Apache Beam Cassandra connector. If you're copying stuff from other projects it please

[GitHub] [flink] fsk119 commented on a diff in pull request #21725: [FLINK-29000][python] Support python UDF in the SQL Gateway

fsk119 commented on code in PR #21725: URL: https://github.com/apache/flink/pull/21725#discussion_r1080917570 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/DefaultContext.java: ## @@ -55,15 +58,31 @@ public

[jira] [Closed] (FLINK-30678) NettyConnectionManagerTest.testManualConfiguration appears to be unstable

[ https://issues.apache.org/jira/browse/FLINK-30678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-30678. Fix Version/s: 1.17.0 1.16.1 Resolution: Fixed master:

[jira] [Assigned] (FLINK-30754) Fix ExceptionThrowingDelegationTokenProvider/Receiver multi-threaded test issues

[ https://issues.apache.org/jira/browse/FLINK-30754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-30754: - Assignee: Gabor Somogyi > Fix ExceptionThrowingDelegationTokenProvider/Receiver

[jira] [Updated] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed

[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29830: --- Parent: (was: FLINK-28352) Issue Type: Bug (was: Sub-task) >

[jira] [Updated] (FLINK-27731) Remove Hugo Modules integration

[ https://issues.apache.org/jira/browse/FLINK-27731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27731: --- Issue Type: Technical Debt (was: Bug) > Remove Hugo Modules integration >

[jira] [Updated] (FLINK-30016) Update Flink 1.16 release notes about updated oshi-core

[ https://issues.apache.org/jira/browse/FLINK-30016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30016: --- Issue Type: Improvement (was: Bug) > Update Flink 1.16 release notes about updated

[jira] [Commented] (FLINK-30594) Update Java version because of JDK bug in the operator

[ https://issues.apache.org/jira/browse/FLINK-30594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678618#comment-17678618 ] Gabor Somogyi commented on FLINK-30594: --- I've just double checked and seems like there is no new

[jira] [Created] (FLINK-30755) Make SinkV2 support speculative execution for batch jobs

Biao Liu created FLINK-30755: Summary: Make SinkV2 support speculative execution for batch jobs Key: FLINK-30755 URL: https://issues.apache.org/jira/browse/FLINK-30755 Project: Flink Issue Type:

[GitHub] [flink] tsreaper commented on a diff in pull request #21393: [FLINK-27246][TableSQL/Runtime][master] - Include WHILE blocks in split generated java methods

tsreaper commented on code in PR #21393: URL: https://github.com/apache/flink/pull/21393#discussion_r1081163322 ## flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementSplitter.java: ## @@ -0,0 +1,326 @@ +/* + * Licensed to the

[GitHub] [flink] HuangXingBo closed pull request #21730: [FLINK-30753][python] Fix the invocation process of Table.explain()

HuangXingBo closed pull request #21730: [FLINK-30753][python] Fix the invocation process of Table.explain() URL: https://github.com/apache/flink/pull/21730 -- 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

[GitHub] [flink] HuangXingBo closed pull request #21699: [FLINK-29421][python] Support python 3.10

HuangXingBo closed pull request #21699: [FLINK-29421][python] Support python 3.10 URL: https://github.com/apache/flink/pull/21699 -- 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] Myasuka commented on a diff in pull request #21729: [FLINK-30751] [docs] Remove references to disableDataSync in RocksDB documentation

Myasuka commented on code in PR #21729: URL: https://github.com/apache/flink/pull/21729#discussion_r1080950829 ## flink-python/pyflink/datastream/state_backend.py: ## @@ -956,16 +956,20 @@ class PredefinedOptions(Enum): determined to be beneficial for performance under

[GitHub] [flink-shaded] MartijnVisser merged pull request #118: [FLINK-30232][Build/Shaded] Include all platforms incl ARM64 while shading Netty

MartijnVisser merged PR #118: URL: https://github.com/apache/flink-shaded/pull/118 -- 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:

  1   2   3   >