[jira] [Commented] (FLINK-30619) AdaptiveSchedulerTest.testStatusMetrics is not stable

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680129#comment-17680129 ] Matthias Pohl commented on FLINK-30619: --- [~chesnay] may you have a look at that one? >

[jira] [Assigned] (FLINK-30777) Allow Kinesis Table API Connector to specify shard assigner

2023-01-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-30777: -- Assignee: Martijn Visser (was: Karthi Thyagarajan) > Allow Kinesis Table API

[jira] [Commented] (FLINK-30767) Unable to fetch com.nimbusds:nimbus-jose-jwt:jar:9.29 artifact

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680128#comment-17680128 ] Matthias Pohl commented on FLINK-30767: --- Same issue appeared for the {{master}} build

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680127#comment-17680127 ] Matthias Pohl commented on FLINK-30727: ---

[jira] [Commented] (FLINK-29405) InputFormatCacheLoaderTest is unstable

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680126#comment-17680126 ] Matthias Pohl commented on FLINK-29405: ---

[jira] [Commented] (FLINK-30618) flink-connector-pulsar not retrievable from Apache's Snapshot Maven repository

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680123#comment-17680123 ] Matthias Pohl commented on FLINK-30618: ---

[jira] [Commented] (FLINK-25343) HBaseConnectorITCase.testTableSourceSinkWithDDL fail on azure

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680121#comment-17680121 ] Matthias Pohl commented on FLINK-25343: ---

[jira] [Assigned] (FLINK-30777) Allow Kinesis Table API Connector to specify shard assigner

2023-01-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-30777: -- Assignee: Karthi Thyagarajan (was: Martijn Visser) > Allow Kinesis Table API

[jira] [Assigned] (FLINK-30777) Allow Kinesis Table API Connector to specify shard assigner

2023-01-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-30777: -- Assignee: Karthi Thyagarajan > Allow Kinesis Table API Connector to specify shard

[jira] [Updated] (FLINK-30733) The AzureCI Slack bot does not list all failed builds in the Slack channel

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30733: -- Description: We've experienced failing builds not being reported by the AzureCI Slack bot in

[jira] [Commented] (FLINK-29405) InputFormatCacheLoaderTest is unstable

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680118#comment-17680118 ] Matthias Pohl commented on FLINK-29405: ---

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680117#comment-17680117 ] Matthias Pohl commented on FLINK-30727: ---

[jira] [Commented] (FLINK-30774) flink-utils module

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680111#comment-17680111 ] Matthias Pohl commented on FLINK-30774: --- I guess that could be done on a use-case basis. Like we

[GitHub] [flink] SmirAlex closed pull request #20920: [FLINK-29405] Fix unstable test InputFormatCacheLoaderTest

2023-01-23 Thread via GitHub
SmirAlex closed pull request #20920: [FLINK-29405] Fix unstable test InputFormatCacheLoaderTest URL: https://github.com/apache/flink/pull/20920 -- 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

[GitHub] [flink] SmirAlex commented on a diff in pull request #20919: [FLINK-29405] Fix unstable test InputFormatCacheLoaderTest

2023-01-23 Thread via GitHub
SmirAlex commented on code in PR #20919: URL: https://github.com/apache/flink/pull/20919#discussion_r1084842995 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/fullcache/LookupFullCache.java: ## @@ -109,7 +116,9 @@ public

[GitHub] [flink] SmirAlex commented on a diff in pull request #20919: [FLINK-29405] Fix unstable test InputFormatCacheLoaderTest

2023-01-23 Thread via GitHub
SmirAlex commented on code in PR #20919: URL: https://github.com/apache/flink/pull/20919#discussion_r1084842890 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/CachingLookupFunction.java: ## @@ -107,12 +107,12 @@ public

[GitHub] [flink] SmirAlex commented on a diff in pull request #20919: [FLINK-29405] Fix unstable test InputFormatCacheLoaderTest

2023-01-23 Thread via GitHub
SmirAlex commented on code in PR #20919: URL: https://github.com/apache/flink/pull/20919#discussion_r1084842647 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/CachingLookupFunction.java: ## @@ -107,12 +107,12 @@ public

[GitHub] [flink] SmirAlex commented on a diff in pull request #20919: [FLINK-29405] Fix unstable test InputFormatCacheLoaderTest

2023-01-23 Thread via GitHub
SmirAlex commented on code in PR #20919: URL: https://github.com/apache/flink/pull/20919#discussion_r1084842440 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/fullcache/inputformat/InputFormatCacheLoader.java: ## @@ -71,56

[GitHub] [flink] flinkbot commented on pull request #21750: fix(sec): upgrade org.apache.hadoop:hadoop-hdfs to 3.3.2

2023-01-23 Thread via GitHub
flinkbot commented on PR #21750: URL: https://github.com/apache/flink/pull/21750#issuecomment-1401397577 ## CI report: * 3b5660725a6951353ade613f8d56152a4ae48c4c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-30739) SqlGatewayRestEndpointStatementITCase failed with NullPointer

2023-01-23 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680088#comment-17680088 ] Wencong Liu commented on FLINK-30739: - I seems like a existed similar issue. cc [~fsk119]  >

[jira] [Commented] (FLINK-30774) flink-utils module

2023-01-23 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680085#comment-17680085 ] Wencong Liu commented on FLINK-30774: - Hello [~mapohl]. I think your proposal is reasonable! But I

[GitHub] [flink] masteryhx commented on pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-23 Thread via GitHub
masteryhx commented on PR #21635: URL: https://github.com/apache/flink/pull/21635#issuecomment-1401341853 > I started the review, but since I started finding issues or potential issues in the migrated methods, would you be so kind and split migrating serializers/snapshots to separate

[GitHub] [flink] masteryhx commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-23 Thread via GitHub
masteryhx commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1084778811 ## flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializerSnapshot.java: ## @@ -56,6 +55,9 @@ /** Contains the actual content for

[GitHub] [flink] masteryhx commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-23 Thread via GitHub
masteryhx commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1084777905 ## flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArraySerializerSnapshot.java: ## @@ -76,10 +80,26 @@ protected void readOuterSnapshot(

[GitHub] [flink] masteryhx commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-23 Thread via GitHub
masteryhx commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1084775911 ## flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeTypeSerializerSnapshot.java: ## @@ -290,26 +332,26 @@ protected void readOuterSnapshot(

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

2023-01-23 Thread via GitHub
lindong28 commented on PR #21690: URL: https://github.com/apache/flink/pull/21690#issuecomment-1401300664 > So that's not true as well. Regardless how you implement it, the caller has to care about how many times the DataOutput#emitRecord() can be called in a row. If you hide this logic in

[GitHub] [flink] flinkbot commented on pull request #21749: Remove redundant char

2023-01-23 Thread via GitHub
flinkbot commented on PR #21749: URL: https://github.com/apache/flink/pull/21749#issuecomment-1401295570 ## CI report: * db00eb9f06604d4af0cdacac4a58ff5c3d7ebd73 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] co63oc opened a new pull request, #21749: Remove redundant char

2023-01-23 Thread via GitHub
co63oc opened a new pull request, #21749: URL: https://github.com/apache/flink/pull/21749 Remove redundant char ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we

[jira] [Commented] (FLINK-30771) different performance of conversion between datetime type in mysql and timestamp in flink

2023-01-23 Thread jingjing dong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680065#comment-17680065 ] jingjing dong commented on FLINK-30771: --- in ORM framework JAP/Mybatis, they choose the function

[jira] [Commented] (FLINK-30771) different performance of conversion between datetime type in mysql and timestamp in flink

2023-01-23 Thread jingjing dong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680064#comment-17680064 ] jingjing dong commented on FLINK-30771: --- function one and two are overloaded functions . in the

[jira] [Updated] (FLINK-30777) Allow Kinesis Table API Connector to specify shard assigner

2023-01-23 Thread Karthi Thyagarajan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Karthi Thyagarajan updated FLINK-30777: --- Description: As a follow up to the fix involving UniformShardAssigner

[jira] [Updated] (FLINK-30777) Allow Kinesis Table API Connector to specify shard assigner

2023-01-23 Thread Karthi Thyagarajan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Karthi Thyagarajan updated FLINK-30777: --- Description: As a follow up to the fix involving UniformShardAssigner

[jira] [Updated] (FLINK-30777) Allow Kinesis Table API Connector to specify shard assigner

2023-01-23 Thread Karthi Thyagarajan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Karthi Thyagarajan updated FLINK-30777: --- Description: As a follow up to the fix involving UniformShardAssigner

[jira] [Created] (FLINK-30777) Allow Kinesis Table API Connector to specify shard assigner

2023-01-23 Thread Karthi Thyagarajan (Jira)
Karthi Thyagarajan created FLINK-30777: -- Summary: Allow Kinesis Table API Connector to specify shard assigner Key: FLINK-30777 URL: https://issues.apache.org/jira/browse/FLINK-30777 Project:

[jira] [Updated] (FLINK-30653) Trigger resource Events on autoscaler actions

2023-01-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30653: --- Labels: pull-request-available (was: ) > Trigger resource Events on autoscaler actions >

[GitHub] [flink-kubernetes-operator] morhidi opened a new pull request, #509: [FLINK-30653] Trigger resource Events on autoscaler actions

2023-01-23 Thread via GitHub
morhidi opened a new pull request, #509: URL: https://github.com/apache/flink-kubernetes-operator/pull/509 ## What is the purpose of the change The autoscaler currently doesn't trigger any events. We should use Kube events to notify users about scaling actions on a per-vertex level

[jira] [Updated] (FLINK-30328) TaskManagerWideRocksDbMemorySharingITCase.testBlockCache failed

2023-01-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30328: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] AlanConfluent commented on a diff in pull request #21733: [FLINK-30328][tests] Assert memory usage deviation is within bounds instead of min/max

2023-01-23 Thread via GitHub
AlanConfluent commented on code in PR #21733: URL: https://github.com/apache/flink/pull/21733#discussion_r1084601474 ## flink-tests/src/test/java/org/apache/flink/test/state/TaskManagerWideRocksDbMemorySharingITCase.java: ## @@ -125,36 +129,45 @@ public void testBlockCache()

[GitHub] [flink-connector-kafka] mas-chen commented on pull request #1: [FLINK-30052][Connectors/Kafka] Move existing Kafka connector code from Flink repo to dedicated Kafka repo

2023-01-23 Thread via GitHub
mas-chen commented on PR #1: URL: https://github.com/apache/flink-connector-kafka/pull/1#issuecomment-1400915953 @zentol PTAL, pom changes should be much easier to review now -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-30773) Allow rescaling of jobs based on per-vertex parallelism overrides

2023-01-23 Thread Pedro Cardoso Silva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679952#comment-17679952 ] Pedro Cardoso Silva commented on FLINK-30773: - Disclaimer: I am neither the author or

[jira] [Commented] (FLINK-30773) Allow rescaling of jobs based on per-vertex parallelism overrides

2023-01-23 Thread Swathi Chandrashekar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679946#comment-17679946 ] Swathi Chandrashekar commented on FLINK-30773: -- The logic looks great, this would be

[jira] [Commented] (FLINK-30773) Allow rescaling of jobs based on per-vertex parallelism overrides

2023-01-23 Thread Pedro Cardoso Silva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679895#comment-17679895 ] Pedro Cardoso Silva commented on FLINK-30773: - For other ideas around efficient scaling of

[jira] [Updated] (FLINK-30773) Allow rescaling of jobs based on per-vertex parallelism overrides

2023-01-23 Thread Pedro Cardoso Silva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pedro Cardoso Silva updated FLINK-30773: Attachment: meces.patch > Allow rescaling of jobs based on per-vertex parallelism

[jira] [Created] (FLINK-30776) Move autoscaler code into a seperate module

2023-01-23 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-30776: -- Summary: Move autoscaler code into a seperate module Key: FLINK-30776 URL: https://issues.apache.org/jira/browse/FLINK-30776 Project: Flink

[jira] [Created] (FLINK-30775) Support pluggable reconciler modules

2023-01-23 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-30775: -- Summary: Support pluggable reconciler modules Key: FLINK-30775 URL: https://issues.apache.org/jira/browse/FLINK-30775 Project: Flink Issue Type:

[jira] [Created] (FLINK-30774) flink-utils module

2023-01-23 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30774: - Summary: flink-utils module Key: FLINK-30774 URL: https://issues.apache.org/jira/browse/FLINK-30774 Project: Flink Issue Type: Improvement

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #48: [FLINK-30762] Add nightly build workflow

2023-01-23 Thread via GitHub
hlteoh37 commented on code in PR #48: URL: https://github.com/apache/flink-connector-aws/pull/48#discussion_r1084264894 ## .github/workflows/nightly.yml: ## @@ -0,0 +1,33 @@ + +# Licensed to the

[jira] [Comment Edited] (FLINK-25672) FileSource enumerator remembers paths of all already processed files which can result in large state

2023-01-23 Thread Cliff Resnick (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679874#comment-17679874 ] Cliff Resnick edited comment on FLINK-25672 at 1/23/23 4:13 PM: I

[jira] [Commented] (FLINK-25672) FileSource enumerator remembers paths of all already processed files which can result in large state

2023-01-23 Thread Cliff Resnick (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679874#comment-17679874 ] Cliff Resnick commented on FLINK-25672: --- I imagine it may require a breaking change from what I

[GitHub] [flink] gaborgsomogyi commented on pull request #21732: [FLINK-30754][tests] Fix ExceptionThrowingDelegationTokenProvider/Receiver multi-threaded test issues

2023-01-23 Thread via GitHub
gaborgsomogyi commented on PR #21732: URL: https://github.com/apache/flink/pull/21732#issuecomment-1400596680 @mbalassi just fixed the related issue, let's see this run. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-25672) FileSource enumerator remembers paths of all already processed files which can result in large state

2023-01-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679870#comment-17679870 ] Martijn Visser commented on FLINK-25672: [~cre...@gmail.com] Unfortunately not, still looking

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

2023-01-23 Thread via GitHub
echauchot commented on code in PR #3: URL: https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1084247002 ## flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorStateSerializer.java: ## @@ -0,0

[jira] [Created] (FLINK-30773) Allow rescaling of jobs based on per-vertex parallelism overrides

2023-01-23 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-30773: -- Summary: Allow rescaling of jobs based on per-vertex parallelism overrides Key: FLINK-30773 URL: https://issues.apache.org/jira/browse/FLINK-30773

[jira] [Commented] (FLINK-25672) FileSource enumerator remembers paths of all already processed files which can result in large state

2023-01-23 Thread Cliff Resnick (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679868#comment-17679868 ] Cliff Resnick commented on FLINK-25672: --- This issue has turned into a real problem for us with our

[jira] [Closed] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

2023-01-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-26803. -- Resolution: Fixed merged as 8be94e6^^, 8be94e6^ and 8be94e6 into apache:master Big thanks

[GitHub] [flink] pnowojski merged pull request #20151: [FLINK-26803][checkpoint] Merging channel state files

2023-01-23 Thread via GitHub
pnowojski merged PR #20151: URL: https://github.com/apache/flink/pull/20151 -- 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] [Created] (FLINK-30772) Update Flink Shaded dependencies to the latest versions

2023-01-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30772: -- Summary: Update Flink Shaded dependencies to the latest versions Key: FLINK-30772 URL: https://issues.apache.org/jira/browse/FLINK-30772 Project: Flink

[jira] [Commented] (FLINK-30771) different performance of conversion between datetime type in mysql and timestamp in flink

2023-01-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679853#comment-17679853 ] Martijn Visser commented on FLINK-30771: [~solofire] Thanks for opening the ticket. For me it's

[jira] [Updated] (FLINK-30771) different performance of conversion between datetime type in mysql and timestamp in flink

2023-01-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30771: --- Fix Version/s: (was: 1.16.1) > different performance of conversion between datetime

[GitHub] [flink-connector-aws] boring-cyborg[bot] commented on pull request #48: [FLINK-30762] Add nightly build workflow

2023-01-23 Thread boring-cyborg
boring-cyborg[bot] commented on PR #48: URL: https://github.com/apache/flink-connector-aws/pull/48#issuecomment-1400531085 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is an

[jira] [Updated] (FLINK-30762) Add nightly builds for AWS connectors repo

2023-01-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30762: --- Labels: pull-request-available (was: ) > Add nightly builds for AWS connectors repo >

[GitHub] [flink-connector-aws] z3d1k opened a new pull request, #48: [FLINK-30762] Add nightly build workflow

2023-01-23 Thread via GitHub
z3d1k opened a new pull request, #48: URL: https://github.com/apache/flink-connector-aws/pull/48 - Extracted existing build logic into common reusable workflow - Added nightly build against SNAPSHOT versions of Flink - Update actions to address Node 12 actions deprecation notice:

[jira] [Closed] (FLINK-30741) IPv6HostnamesITCase should create remote rpc service

2023-01-23 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-30741. Resolution: Fixed master: 359217381a3a5e48133614407445435c3bc97622 > IPv6HostnamesITCase

[GitHub] [flink] zentol merged pull request #21719: [FLINK-30741][tests] Use remote rpc service

2023-01-23 Thread via GitHub
zentol merged PR #21719: URL: https://github.com/apache/flink/pull/21719 -- 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] mbalassi commented on pull request #21732: [FLINK-30754][tests] Fix ExceptionThrowingDelegationTokenProvider/Receiver multi-threaded test issues

2023-01-23 Thread via GitHub
mbalassi commented on PR #21732: URL: https://github.com/apache/flink/pull/21732#issuecomment-1400523394 @gaborgsomogyi please check the tests, multiple related ones seem to run into NPEs. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] mbalassi merged pull request #21705: [FLINK-30713][k8s] Add Hadoop related k8s decorators exclude possibility

2023-01-23 Thread via GitHub
mbalassi merged PR #21705: URL: https://github.com/apache/flink/pull/21705 -- 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] [Created] (FLINK-30771) different performance of conversion between datetime type in mysql and timestamp in flink

2023-01-23 Thread jingjing dong (Jira)
jingjing dong created FLINK-30771: - Summary: different performance of conversion between datetime type in mysql and timestamp in flink Key: FLINK-30771 URL: https://issues.apache.org/jira/browse/FLINK-30771

[GitHub] [flink] zentol closed pull request #21748: fix(sec): upgrade org.apache.hadoop:hadoop-common to 3.3.3

2023-01-23 Thread via GitHub
zentol closed pull request #21748: fix(sec): upgrade org.apache.hadoop:hadoop-common to 3.3.3 URL: https://github.com/apache/flink/pull/21748 -- 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

[jira] [Updated] (FLINK-30770) OUTER join generates partial results

2023-01-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30770: --- Component/s: Table SQL / Planner > OUTER join generates partial results >

[jira] [Updated] (FLINK-30770) OUTER join generates partial results

2023-01-23 Thread Thomas Erlenbach (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Erlenbach updated FLINK-30770: - Description: Hi,   I would like to share a scenario with you that seems to reveal a

[GitHub] [flink] XComp commented on a diff in pull request #20919: [FLINK-29405] Fix unstable test InputFormatCacheLoaderTest

2023-01-23 Thread via GitHub
XComp commented on code in PR #20919: URL: https://github.com/apache/flink/pull/20919#discussion_r1084051452 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/fullcache/inputformat/InputFormatCacheLoader.java: ## @@ -71,56

[jira] [Updated] (FLINK-30653) Trigger resource Events on autoscaler actions

2023-01-23 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi updated FLINK-30653: -- Summary: Trigger resource Events on autoscaler actions (was: Triggere resource Events on

[jira] [Commented] (FLINK-30770) OUTER join generates partial results

2023-01-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679804#comment-17679804 ] Martijn Visser commented on FLINK-30770: [~lincoln.86xy] [~godfrey] Is this a bug? > OUTER

[jira] [Created] (FLINK-30770) OUTER join generates partial results

2023-01-23 Thread Thomas Erlenbach (Jira)
Thomas Erlenbach created FLINK-30770: Summary: OUTER join generates partial results Key: FLINK-30770 URL: https://issues.apache.org/jira/browse/FLINK-30770 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30769) Use Operator SDK RuntimeInfo in Health Probe

2023-01-23 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30769: -- Summary: Use Operator SDK RuntimeInfo in Health Probe Key: FLINK-30769 URL: https://issues.apache.org/jira/browse/FLINK-30769 Project: Flink Issue Type: New

[jira] [Created] (FLINK-30768) flink-web version cleanup

2023-01-23 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30768: - Summary: flink-web version cleanup Key: FLINK-30768 URL: https://issues.apache.org/jira/browse/FLINK-30768 Project: Flink Issue Type: Improvement

[GitHub] [flink] dawidwys commented on pull request #21594: [FLINK-30483] [Formats] [Avro] Add avro format support for TIMESTAMP_LTZ

2023-01-23 Thread via GitHub
dawidwys commented on PR #21594: URL: https://github.com/apache/flink/pull/21594#issuecomment-1400326981 Thanks for the work put into that @jadireddi ! I am not sure if we should proceed with the PR. To be honest I think there is nothing to be done in regards to supporting

[jira] [Comment Edited] (FLINK-30768) flink-web version cleanup

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679788#comment-17679788 ] Matthias Pohl edited comment on FLINK-30768 at 1/23/23 12:59 PM: -

[GitHub] [flink-web] XComp commented on a diff in pull request #603: Flink 1.16.1

2023-01-23 Thread via GitHub
XComp commented on code in PR #603: URL: https://github.com/apache/flink-web/pull/603#discussion_r1084002403 ## _posts/2023-01-26-release-1.16.1.md: ## @@ -0,0 +1,258 @@ +--- +layout: post +title: "Apache Flink 1.16.1 Release Announcement" +date: 2023-01-23T22:00:00.000Z

[jira] [Commented] (FLINK-30768) flink-web version cleanup

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679788#comment-17679788 ] Matthias Pohl commented on FLINK-30768: --- Similar issues exists in q/sbt-quickstart.sh > flink-web

[GitHub] [flink] fsk119 commented on a diff in pull request #21717: [FLINK-29945][sql-client] Supports to submit SQL to a embedded SQL Ga…

2023-01-23 Thread via GitHub
fsk119 commented on code in PR #21717: URL: https://github.com/apache/flink/pull/21717#discussion_r1083995101 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/session/ConfigureSessionRequestBody.java: ## @@ -39,6 +39,10 @@ public class

[GitHub] [flink] XComp commented on a diff in pull request #21719: [FLINK-30741][tests] Use remote rpc service

2023-01-23 Thread via GitHub
XComp commented on code in PR #21719: URL: https://github.com/apache/flink/pull/21719#discussion_r1080958702 ## flink-tests/src/test/java/org/apache/flink/test/runtime/IPv6HostnamesITCase.java: ## @@ -146,15 +145,13 @@ private Inet6Address getLocalIPv6Address() {

[jira] [Comment Edited] (FLINK-30306) Audit utils can expose potentially sensitive information

2023-01-23 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679760#comment-17679760 ] Alexis Sarda-Espinosa edited comment on FLINK-30306 at 1/23/23 11:04 AM:

[jira] [Commented] (FLINK-30306) Audit utils can expose potentially sensitive information

2023-01-23 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679760#comment-17679760 ] Alexis Sarda-Espinosa commented on FLINK-30306: --- A few more thoughts from me. I'm not sure

[GitHub] [flink] dawidwys commented on pull request #21594: [FLINK-30483] [Formats] [Avro] Add avro format support for TIMESTAMP_LTZ

2023-01-23 Thread via GitHub
dawidwys commented on PR #21594: URL: https://github.com/apache/flink/pull/21594#issuecomment-1400153398 I'll take a look! -- 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.

[GitHub] [flink] MartijnVisser commented on pull request #21594: [FLINK-30483] [Formats] [Avro] Add avro format support for TIMESTAMP_LTZ

2023-01-23 Thread via GitHub
MartijnVisser commented on PR #21594: URL: https://github.com/apache/flink/pull/21594#issuecomment-1400144257 @dawidwys Is this something that you could help review? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

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

2023-01-23 Thread via GitHub
pnowojski commented on PR #21690: URL: https://github.com/apache/flink/pull/21690#issuecomment-1400094213 Hey, again I think your arguments are not fully correct: > It can be called repeatedly by the caller (Most methods can be called repeatedly by the caller, except for some special

[GitHub] [flink] LadyForest commented on a diff in pull request #21717: [FLINK-29945][sql-client] Supports to submit SQL to a embedded SQL Ga…

2023-01-23 Thread via GitHub
LadyForest commented on code in PR #21717: URL: https://github.com/apache/flink/pull/21717#discussion_r1083641565 ## flink-table/flink-sql-client/src/test/resources/sql/set.q: ## @@ -118,47 +118,61 @@ SELECT hive_add_one(1); Received a total of 1 row !ok -REMOVE JAR

[jira] [Commented] (FLINK-29671) Kubernetes e2e test fails during test initialization

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679714#comment-17679714 ] Matthias Pohl commented on FLINK-29671: --- I'm leaving it in priority Major for now because it only

[jira] [Commented] (FLINK-29405) InputFormatCacheLoaderTest is unstable

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679720#comment-17679720 ] Matthias Pohl commented on FLINK-29405: ---

[GitHub] [flink] LadyForest commented on a diff in pull request #21717: [FLINK-29945][sql-client] Supports to submit SQL to a embedded SQL Ga…

2023-01-23 Thread via GitHub
LadyForest commented on code in PR #21717: URL: https://github.com/apache/flink/pull/21717#discussion_r1083646639 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/utils/SqlGatewayServiceExtension.java: ## @@ -80,7 +81,8 @@ public void

[jira] [Commented] (FLINK-30508) CliClientITCase.testSqlStatements failed with output not matched with expected

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679719#comment-17679719 ] Matthias Pohl commented on FLINK-30508: ---

[jira] [Commented] (FLINK-25343) HBaseConnectorITCase.testTableSourceSinkWithDDL fail on azure

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679717#comment-17679717 ] Matthias Pohl commented on FLINK-25343: ---

[jira] [Commented] (FLINK-25343) HBaseConnectorITCase.testTableSourceSinkWithDDL fail on azure

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679716#comment-17679716 ] Matthias Pohl commented on FLINK-25343: --- Have you managed to work on this one? >

[jira] [Commented] (FLINK-29671) Kubernetes e2e test fails during test initialization

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679713#comment-17679713 ] Matthias Pohl commented on FLINK-29671: ---

[jira] [Commented] (FLINK-29405) InputFormatCacheLoaderTest is unstable

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679711#comment-17679711 ] Matthias Pohl commented on FLINK-29405: ---

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679709#comment-17679709 ] Matthias Pohl commented on FLINK-30727: --- Thanks [~337361...@qq.com]. Does it make sense to add log

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679710#comment-17679710 ] Matthias Pohl commented on FLINK-30727: ---

[jira] [Comment Edited] (FLINK-30298) KafkaTableITCase.testStartFromGroupOffsetsNone failed due to timeout

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679707#comment-17679707 ] Matthias Pohl edited comment on FLINK-30298 at 1/23/23 8:12 AM: Similar

[jira] [Commented] (FLINK-30298) KafkaTableITCase.testStartFromGroupOffsetsNone failed due to timeout

2023-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679707#comment-17679707 ] Matthias Pohl commented on FLINK-30298: --- Similar stacktrace with an IllegalStateException being

  1   2   >