[jira] [Comment Edited] (FLINK-28863) Snapshot result of RocksDB native savepoint should have empty shared-state

2022-11-02 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627484#comment-17627484 ] Jinzhong Li edited comment on FLINK-28863 at 11/2/22 6:45 AM: -- [~yunta] 

[GitHub] [flink] rmetzger commented on a diff in pull request #21200: [FLINK-29779] Pass PluginManager into MiniCluster

2022-11-02 Thread GitBox
rmetzger commented on code in PR #21200: URL: https://github.com/apache/flink/pull/21200#discussion_r1011303799 ## flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterConfiguration.java: ## @@ -50,6 +51,8 @@ public class MiniClusterConfiguration {

[GitHub] [flink] qingwei91 commented on a diff in pull request #20140: [Flink 16024][Connector][JDBC] Support FilterPushdown

2022-11-02 Thread GitBox
qingwei91 commented on code in PR #20140: URL: https://github.com/apache/flink/pull/20140#discussion_r1011302797 ## flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java: ## @@ -93,39 +99,74 @@

[GitHub] [flink] tisonkun commented on pull request #21204: [FLINK-29709][Connector/Pulsar] Bump the Pulsar to latest 2.10.2

2022-11-02 Thread GitBox
tisonkun commented on PR #21204: URL: https://github.com/apache/flink/pull/21204#issuecomment-1299880573 I guess the reason is that Pulsar service uses Java 11 or Java 17 so that some methods cannot be found when Flink uses Java 8. -- This is an automated message from the Apache Git

[GitHub] [flink-connector-elasticsearch] zentol merged pull request #42: [FLINK-29472] Integrate shared release utils

2022-11-02 Thread GitBox
zentol merged PR #42: URL: https://github.com/apache/flink-connector-elasticsearch/pull/42 -- 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-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-02 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1011476914 ## pom.xml: ## @@ -0,0 +1,457 @@ + + +http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd; +

[GitHub] [flink] reswqa commented on pull request #21137: [FLINK-29234][runtime] JobMasterServiceLeadershipRunner handle leader event in a separate executor to avoid dead lock

2022-11-02 Thread GitBox
reswqa commented on PR #21137: URL: https://github.com/apache/flink/pull/21137#issuecomment-1299649118 @XComp Thank you very much for your suggestions and review. I totally agree with you that introduction of such callbacks in the `TestingLeaderSelectionDriver` will make things a bit

[jira] [Closed] (FLINK-29812) Remove deprecated Netty API usages

2022-11-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29812. Resolution: Fixed master: 03c0f155c2f5198bf1fda35de43afc34a4b12f6e > Remove deprecated

[GitHub] [flink] zentol commented on pull request #21214: [FLINK-29834] Clear Jackson TypeFactory cache on CL release

2022-11-02 Thread GitBox
zentol commented on PR #21214: URL: https://github.com/apache/flink/pull/21214#issuecomment-1299679656 @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 comment.

[GitHub] [flink-kubernetes-operator] mbalassi merged pull request #419: [hotfix][docs]Update overview.md to include flink version 1.16

2022-11-02 Thread GitBox
mbalassi merged PR #419: URL: https://github.com/apache/flink-kubernetes-operator/pull/419 -- 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-kubernetes-operator] mbalassi commented on pull request #419: [hotfix][docs]Update overview.md to include flink version 1.16

2022-11-02 Thread GitBox
mbalassi commented on PR #419: URL: https://github.com/apache/flink-kubernetes-operator/pull/419#issuecomment-1299698951 Both makes sense, thanks. -- 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

[GitHub] [flink] snuyanzin commented on pull request #20128: [FLINK-28347][Test infrastructure] Update testcontainers dependency to v1.17.5

2022-11-02 Thread GitBox
snuyanzin commented on PR #20128: URL: https://github.com/apache/flink/pull/20128#issuecomment-1299758486 not 100% sure it seems like a kind of leak, same test is passing if it is running alone on ci need to have a look deeper -- This is an automated message from the Apache Git

[jira] [Commented] (FLINK-29818) HsResultPartitionTest.testAvailability fails

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627515#comment-17627515 ] Martijn Visser commented on FLINK-29818:

[GitHub] [flink] flinkbot commented on pull request #21219: [FLINK-29849][table-planner] Fix event time temporal join on an upsert source may produce incorrect execution plan

2022-11-02 Thread GitBox
flinkbot commented on PR #21219: URL: https://github.com/apache/flink/pull/21219#issuecomment-1299885246 ## CI report: * 243bb7c0c11b245b8c645df032c7633cd2d350b6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-29846) Upgrade Archunit to 1.0.0

2022-11-02 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627539#comment-17627539 ] Sergey Nuyanzin commented on FLINK-29846: - Hi [~martijnvisser] do you mind if i help with this

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-02 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1011401782 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoSerdeUtils.java: ## @@ -0,0 +1,90 @@ +/* + * Licensed to

[GitHub] [flink] zentol commented on a diff in pull request #21200: [FLINK-29779] Pass PluginManager into MiniCluster

2022-11-02 Thread GitBox
zentol commented on code in PR #21200: URL: https://github.com/apache/flink/pull/21200#discussion_r1011398783 ## flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterConfiguration.java: ## @@ -50,6 +51,8 @@ public class MiniClusterConfiguration {

[GitHub] [flink] PatrickRen opened a new pull request, #21220: [FLINK-29567][connector/common] Change numRecordsSend / numBytesSend / numRecordsSendError back to numRecordsOut / numBytesOut / numRecor

2022-11-02 Thread GitBox
PatrickRen opened a new pull request, #21220: URL: https://github.com/apache/flink/pull/21220 Unchanged backport of #21065 on release 1.15 -- 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] [Commented] (FLINK-29398) Utilize Rack Awareness in Flink Consumer

2022-11-02 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627555#comment-17627555 ] Qingsheng Ren commented on FLINK-29398: --- [~jeremy.degroot] Thanks for the FLIP! Could you start a

[jira] [Commented] (FLINK-29839) HiveServer2 endpoint doesn't support TGetInfoType value 'CLI_ODBC_KEYWORDS'

2022-11-02 Thread Qizhu Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627554#comment-17627554 ] Qizhu Chan commented on FLINK-29839: [~yzl] Thank you. I got it > HiveServer2 endpoint doesn't

[GitHub] [flink] PatrickRen commented on a diff in pull request #20475: [FLINK-28842][Connector/Kafka] Add client.id.prefix for the KafkaSink

2022-11-02 Thread GitBox
PatrickRen commented on code in PR #20475: URL: https://github.com/apache/flink/pull/20475#discussion_r1011466634 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkOptions.java: ## @@ -0,0 +1,31 @@ +/* + * Licensed to the

[jira] [Assigned] (FLINK-29846) Upgrade Archunit to 1.0.0

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-29846: -- Assignee: Sergey Nuyanzin > Upgrade Archunit to 1.0.0 > - >

[jira] [Commented] (FLINK-29846) Upgrade Archunit to 1.0.0

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627596#comment-17627596 ] Martijn Visser commented on FLINK-29846: [~Sergey Nuyanzin] Not at all, I've assigned it to you

[jira] [Updated] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

2022-11-02 Thread Krzysztof Chmielewski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-27246: -- Attachment: endInput_falseFilter9123_split9704.txt > Code of method >

[GitHub] [flink] dannycranmer commented on pull request #21102: [FLINK-26890][Connector/Kinesis] Handle invalid shards in DynamoDB

2022-11-02 Thread GitBox
dannycranmer commented on PR #21102: URL: https://github.com/apache/flink/pull/21102#issuecomment-1300024465 @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-28863) Snapshot result of RocksDB native savepoint should have empty shared-state

2022-11-02 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627484#comment-17627484 ] Jinzhong Li commented on FLINK-28863: - [~yunta]  1. I found that the changes I metioned above would

[jira] [Created] (FLINK-29845) ThroughputCalculator throws java.lang.IllegalArgumentException: Time should be non negative under very low throughput cluster

2022-11-02 Thread Jingxiao GU (Jira)
Jingxiao GU created FLINK-29845: --- Summary: ThroughputCalculator throws java.lang.IllegalArgumentException: Time should be non negative under very low throughput cluster Key: FLINK-29845 URL:

[GitHub] [flink] lincoln-lil commented on pull request #21173: [FLINK-29781][table-planner] Fix ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeR

2022-11-02 Thread GitBox
lincoln-lil commented on PR #21173: URL: https://github.com/apache/flink/pull/21173#issuecomment-1299719653 @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-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-02 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1011346508 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config/MongoWriteOptions.java: ## @@ -0,0 +1,205 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627520#comment-17627520 ] Martijn Visser commented on FLINK-29461:

[jira] [Commented] (FLINK-29495) PulsarSinkE2ECase hang

2022-11-02 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627533#comment-17627533 ] Yufan Sheng commented on FLINK-29495: - [~martijnvisser] I have checked the CI logs. It's wired and

[GitHub] [flink] lincoln-lil opened a new pull request, #21219: [FLINK-29849][table-planner] Fix event time temporal join on an upsert source may produce incorrect execution plan

2022-11-02 Thread GitBox
lincoln-lil opened a new pull request, #21219: URL: https://github.com/apache/flink/pull/21219 ## What is the purpose of the change For current implementation, the execution plan is incorrect when do event time temporal join on an upsert source. There's two problems: 1. for an upsert

[jira] [Updated] (FLINK-29849) Event time temporal join on an upsert source may produce incorrect execution plan

2022-11-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29849: --- Labels: pull-request-available (was: ) > Event time temporal join on an upsert source may

[jira] [Updated] (FLINK-29712) The same batch task works fine in 1.15.2 and 1.16.0-rc1, but fails in 1.16.0-rc2

2022-11-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29712: - Fix Version/s: (was: 1.16.0) > The same batch task works fine in 1.15.2 and

[jira] [Commented] (FLINK-29567) Revert sink output metric names from numRecordsSend back to numRecordsOut

2022-11-02 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627552#comment-17627552 ] Qingsheng Ren commented on FLINK-29567: --- Ah thanks for the reminder [~hxb] ! I created the

[GitHub] [flink] PatrickRen commented on a diff in pull request #20475: [FLINK-28842][Connector/Kafka] Add client.id.prefix for the KafkaSink

2022-11-02 Thread GitBox
PatrickRen commented on code in PR #20475: URL: https://github.com/apache/flink/pull/20475#discussion_r1011487987 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java: ## @@ -398,6 +407,11 @@ private void

[GitHub] [flink-ml] zhipeng93 merged pull request #170: [FLINK-29843] Avoid negative euclidean distance square

2022-11-02 Thread GitBox
zhipeng93 merged PR #170: URL: https://github.com/apache/flink-ml/pull/170 -- 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-ml] zhipeng93 commented on pull request #170: [FLINK-29843] Avoid negative euclidean distance square

2022-11-02 Thread GitBox
zhipeng93 commented on PR #170: URL: https://github.com/apache/flink-ml/pull/170#issuecomment-1299674421 Thanks for the PR. LGTM. -- 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] [Reopened] (FLINK-29495) PulsarSinkE2ECase hang

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reopened FLINK-29495: Assignee: (was: Martijn Visser) > PulsarSinkE2ECase hang > -- >

[GitHub] [flink] MartijnVisser commented on a diff in pull request #21128: [FLINK-29710] Bump minimum supported Hadoop version to 2.10.2

2022-11-02 Thread GitBox
MartijnVisser commented on code in PR #21128: URL: https://github.com/apache/flink/pull/21128#discussion_r1011352861 ## flink-connectors/flink-connector-hive/pom.xml: ## @@ -1099,33 +1007,8 @@ under the License. 3.1.3

[jira] [Commented] (FLINK-29839) HiveServer2 endpoint doesn't support TGetInfoType value 'CLI_ODBC_KEYWORDS'

2022-11-02 Thread yuzelin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627525#comment-17627525 ] yuzelin commented on FLINK-29839: - Hi, I have replied in mailing list. Please check out. > HiveServer2

[jira] [Assigned] (FLINK-29849) Event time temporal join on an upsert source may produce incorrect execution plan

2022-11-02 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-29849: -- Assignee: lincoln lee > Event time temporal join on an upsert source may produce incorrect

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-02 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1011440345 ## flink-connector-mongodb/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java: ## @@ -0,0 +1,40 @@ +/* + * Licensed to the Apache

[GitHub] [flink-table-store] tsreaper opened a new pull request, #346: [FLINK-29842] Change commitIdentifier in Table Store snapshot to long value

2022-11-02 Thread GitBox
tsreaper opened a new pull request, #346: URL: https://github.com/apache/flink-table-store/pull/346 Currently `commitIdentifier` in `Snapshot` is a `String` value. However there are many scenarios where we need to compare two identifiers to find out which one is newer. For example *

[jira] [Updated] (FLINK-29842) Change commitIdentifier in Table Store snapshot to long value

2022-11-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29842: --- Labels: pull-request-available (was: ) > Change commitIdentifier in Table Store snapshot

[jira] [Assigned] (FLINK-29843) Euclidean Distance Measure generates NAN distance values

2022-11-02 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang reassigned FLINK-29843: - Assignee: Yunfeng Zhou > Euclidean Distance Measure generates NAN distance values >

[jira] [Resolved] (FLINK-29843) Euclidean Distance Measure generates NAN distance values

2022-11-02 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang resolved FLINK-29843. --- Resolution: Fixed > Euclidean Distance Measure generates NAN distance values >

[GitHub] [flink] zentol merged pull request #21216: [hotfix] Remove various deprecated API usages

2022-11-02 Thread GitBox
zentol merged PR #21216: URL: https://github.com/apache/flink/pull/21216 -- 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] zentol commented on a diff in pull request #21200: [FLINK-29779] Pass PluginManager into MiniCluster

2022-11-02 Thread GitBox
zentol commented on code in PR #21200: URL: https://github.com/apache/flink/pull/21200#discussion_r1011288899 ## flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterConfiguration.java: ## @@ -100,6 +105,10 @@ public RpcServiceSharing

[jira] [Resolved] (FLINK-29824) AgglomerativeClustering fails when the distanceThreshold is very large

2022-11-02 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang resolved FLINK-29824. --- Resolution: Fixed > AgglomerativeClustering fails when the distanceThreshold is very large

[jira] [Created] (FLINK-29846) Upgrade Archunit to 1.0.0

2022-11-02 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-29846: -- Summary: Upgrade Archunit to 1.0.0 Key: FLINK-29846 URL: https://issues.apache.org/jira/browse/FLINK-29846 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-29847) Store/cache JarUploadResponseBody

2022-11-02 Thread Daren Wong (Jira)
Daren Wong created FLINK-29847: -- Summary: Store/cache JarUploadResponseBody Key: FLINK-29847 URL: https://issues.apache.org/jira/browse/FLINK-29847 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627517#comment-17627517 ] Martijn Visser commented on FLINK-24119:

[jira] [Commented] (FLINK-26974) Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627518#comment-17627518 ] Martijn Visser commented on FLINK-26974:

[jira] [Commented] (FLINK-29831) Multiple Hive tests are failing

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627519#comment-17627519 ] Martijn Visser commented on FLINK-29831:

[jira] [Updated] (FLINK-26974) Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26974: --- Affects Version/s: 1.17.0 > Python EmbeddedThreadDependencyTests.test_add_python_file

[jira] [Created] (FLINK-29849) Event time temporal join on an upsert source may produce incorrect execution plan

2022-11-02 Thread lincoln lee (Jira)
lincoln lee created FLINK-29849: --- Summary: Event time temporal join on an upsert source may produce incorrect execution plan Key: FLINK-29849 URL: https://issues.apache.org/jira/browse/FLINK-29849

[jira] [Assigned] (FLINK-26974) Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure

2022-11-02 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-26974: Assignee: Huang Xingbo > Python EmbeddedThreadDependencyTests.test_add_python_file

[jira] [Commented] (FLINK-29845) ThroughputCalculator throws java.lang.IllegalArgumentException: Time should be non negative under very low throughput cluster

2022-11-02 Thread Jingxiao GU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627530#comment-17627530 ] Jingxiao GU commented on FLINK-29845: - [~chesnay] yes in 1.14.6, and actually the stacktrace are not

[GitHub] [flink] syhily commented on pull request #21204: [FLINK-29709][Connector/Pulsar] Bump the Pulsar to latest 2.10.2

2022-11-02 Thread GitBox
syhily commented on PR #21204: URL: https://github.com/apache/flink/pull/21204#issuecomment-1299887317 Yep. I think you are right. We may have to override the caffeine or drop the mocked Pulsar instance by in favor of Test container. -- This is an automated message from the Apache Git

[jira] [Comment Edited] (FLINK-29845) ThroughputCalculator throws java.lang.IllegalArgumentException: Time should be non negative under very low throughput cluster

2022-11-02 Thread Jingxiao GU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627530#comment-17627530 ] Jingxiao GU edited comment on FLINK-29845 at 11/2/22 9:46 AM: -- [~chesnay]

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-02 Thread GitBox
Jiabao-Sun commented on PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#issuecomment-1299954327 Hi @zentol. Thank you for taking the time to help with the review. Most of your comments have been addressed and some others would like to hear your suggestions.

[GitHub] [flink] PatrickRen commented on a diff in pull request #20475: [FLINK-28842][Connector/Kafka] Add client.id.prefix for the KafkaSink

2022-11-02 Thread GitBox
PatrickRen commented on code in PR #20475: URL: https://github.com/apache/flink/pull/20475#discussion_r1011493529 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java: ## @@ -156,6 +157,9 @@

[GitHub] [flink] zentol merged pull request #21215: [FLINK-29812][rest] Remove deprecated Netty API usages

2022-11-02 Thread GitBox
zentol merged PR #21215: URL: https://github.com/apache/flink/pull/21215 -- 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-kubernetes-operator] mbalassi merged pull request #418: [hotfix][docs]Update overview.md to include flink version 1.16

2022-11-02 Thread GitBox
mbalassi merged PR #418: URL: https://github.com/apache/flink-kubernetes-operator/pull/418 -- 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-29741) [FLIP-265] Remove all Scala APIs

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29741: --- Summary: [FLIP-265] Remove all Scala APIs (was: Remove all Scala APIs) > [FLIP-265] Remove

[jira] [Updated] (FLINK-29740) [FLIP-265] Deprecate all customer-facing Scala APIs

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29740: --- Summary: [FLIP-265] Deprecate all customer-facing Scala APIs (was: Deprecate all

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-02 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1011340413 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriter.java: ## @@ -0,0 +1,183 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-29847) Store/cache JarUploadResponseBody

2022-11-02 Thread Daren Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daren Wong updated FLINK-29847: --- Description: Kubernetes operator currently uploadJar always even when the same JAR has been

[jira] [Updated] (FLINK-29847) Store/cache JarUploadResponseBody

2022-11-02 Thread Daren Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daren Wong updated FLINK-29847: --- Description: Kubernetes operator currently uploadJar always even when the same JAR has been

[jira] [Created] (FLINK-29848) Port BinaryRowDataUtil to Flink Table Store

2022-11-02 Thread Jane Chan (Jira)
Jane Chan created FLINK-29848: - Summary: Port BinaryRowDataUtil to Flink Table Store Key: FLINK-29848 URL: https://issues.apache.org/jira/browse/FLINK-29848 Project: Flink Issue Type:

[jira] [Commented] (FLINK-29495) PulsarSinkE2ECase hang

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627521#comment-17627521 ] Martijn Visser commented on FLINK-29495: [~syhily] This test is now also hanging for a JDK8 run:

[jira] [Commented] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627522#comment-17627522 ] Martijn Visser commented on FLINK-26568:

[jira] [Commented] (FLINK-29845) ThroughputCalculator throws java.lang.IllegalArgumentException: Time should be non negative under very low throughput cluster

2022-11-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627523#comment-17627523 ] Chesnay Schepler commented on FLINK-29845: -- Did you actually still see this issue 1.14.6 or a

[jira] [Updated] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

2022-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29461: --- Affects Version/s: 1.17.0 > ProcessDataStreamStreamingTests.test_process_function unstable

[jira] [Comment Edited] (FLINK-29495) PulsarSinkE2ECase hang

2022-11-02 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627533#comment-17627533 ] Yufan Sheng edited comment on FLINK-29495 at 11/2/22 8:55 AM: --

[jira] [Updated] (FLINK-29845) ThroughputCalculator throws java.lang.IllegalArgumentException: Time should be non negative under very low throughput cluster

2022-11-02 Thread Jingxiao GU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingxiao GU updated FLINK-29845: Description: Our team are using Flink@1.14.6 to process data from Kafka. It works all fine

[GitHub] [flink] rmetzger commented on a diff in pull request #21200: [FLINK-29779] Pass PluginManager into MiniCluster

2022-11-02 Thread GitBox
rmetzger commented on code in PR #21200: URL: https://github.com/apache/flink/pull/21200#discussion_r1011419988 ## flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterConfiguration.java: ## @@ -50,6 +51,8 @@ public class MiniClusterConfiguration {

[GitHub] [flink] flinkbot commented on pull request #21220: [FLINK-29567][connector/common] Change numRecordsSend / numBytesSend / numRecordsSendError back to numRecordsOut / numBytesOut / numRecordsO

2022-11-02 Thread GitBox
flinkbot commented on PR #21220: URL: https://github.com/apache/flink/pull/21220#issuecomment-1299919174 ## CI report: * 7147b7c1126d1ab6cea6af1bfbd8cdcfcdd4c083 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21111: [FLINK-29664][runtime] Collect subpartition sizes of blocking result partitions

2022-11-02 Thread GitBox
zhuzhurk commented on code in PR #2: URL: https://github.com/apache/flink/pull/2#discussion_r1011461724 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchScheduler.java: ## @@ -149,13 +159,45 @@ protected void

[jira] [Commented] (FLINK-14937) Flink WebUI could not display

2022-11-02 Thread Hang HOU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627573#comment-17627573 ] Hang HOU commented on FLINK-14937: -- [~wangyang0918] Hi ,I used mvn package..command without

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

2022-11-02 Thread Krzysztof Chmielewski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627602#comment-17627602 ] Krzysztof Chmielewski commented on FLINK-27246: --- Hi [~TsReaper] Thanks for replaying. The

[GitHub] [flink] snuyanzin opened a new pull request, #21221: [FLINK-29846] Upgrade ArchUnit to 1.0.0

2022-11-02 Thread GitBox
snuyanzin opened a new pull request, #21221: URL: https://github.com/apache/flink/pull/21221 ## What is the purpose of the change The PR upgrades ArchUnit to 1.0.0 There are some breaking changes mentioned at [1] and [2] especially ``` The ArchUnit types Function,

[GitHub] [flink] zentol commented on a diff in pull request #21012: [FLINK-29543] Jar Run Rest Handler Support Flink Configuration

2022-11-02 Thread GitBox
zentol commented on code in PR #21012: URL: https://github.com/apache/flink/pull/21012#discussion_r1011660253 ## flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java: ## @@ -69,6 +71,11 @@ enum ProgramArgsParType {

[GitHub] [flink-connector-mongodb] zentol commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-02 Thread GitBox
zentol commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1011667019 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSourceBuilder.java: ## @@ -0,0 +1,219 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

2022-11-02 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627691#comment-17627691 ] Fabian Paul commented on FLINK-29315: - What is the status of this ticket? It is marked as a blocker,

[jira] [Updated] (FLINK-27862) FLIP-235: Hybrid Shuffle Mode

2022-11-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-27862: --- Release Note: We have introduced a new Hybrid Shuffle Mode for batch executions. It combines the

[jira] [Created] (FLINK-29851) Upgrade to Fabric8 6.x.x and JOSDK 4.x.x

2022-11-02 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-29851: -- Summary: Upgrade to Fabric8 6.x.x and JOSDK 4.x.x Key: FLINK-29851 URL: https://issues.apache.org/jira/browse/FLINK-29851 Project: Flink Issue Type: New Feature

[GitHub] [flink-web] zentol opened a new pull request, #579: Add Elasticsearch connector 3.0.0

2022-11-02 Thread GitBox
zentol opened a new pull request, #579: URL: https://github.com/apache/flink-web/pull/579 Also extends the download page to list connector releases. -- 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

[GitHub] [flink] zentol merged pull request #21049: [FLINK-29626][Runtime] Update Akka to 2.6.20

2022-11-02 Thread GitBox
zentol merged PR #21049: URL: https://github.com/apache/flink/pull/21049 -- 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] [Closed] (FLINK-29626) Update Akka to 2.6.20

2022-11-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29626. Fix Version/s: 1.17.0 Resolution: Fixed master:

[jira] [Updated] (FLINK-29846) Upgrade Archunit to 1.0.0

2022-11-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29846: --- Labels: pull-request-available (was: ) > Upgrade Archunit to 1.0.0 >

[GitHub] [flink-connector-mongodb] zentol commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-02 Thread GitBox
zentol commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1011661631 ## flink-connector-mongodb/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java: ## @@ -0,0 +1,40 @@ +/* + * Licensed to the Apache

[GitHub] [flink-kubernetes-operator] mbalassi merged pull request #423: [FLINK-29655][hotfix] Move ResourceLifecycleState to api module

2022-11-02 Thread GitBox
mbalassi merged PR #423: URL: https://github.com/apache/flink-kubernetes-operator/pull/423 -- 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] flinkbot commented on pull request #21221: [FLINK-29846] Upgrade ArchUnit to 1.0.0

2022-11-02 Thread GitBox
flinkbot commented on PR #21221: URL: https://github.com/apache/flink/pull/21221#issuecomment-1300270832 ## CI report: * 8ab7e44f8ee7512fe77ad13ae8c079950de4c3f3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

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

2022-11-02 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627688#comment-17627688 ] Fabian Paul commented on FLINK-29830: - [~martijnvisser] do you think this is a block for the 1.15.3

[jira] [Created] (FLINK-29850) Flink Table Store quick start guide does not work

2022-11-02 Thread Alex Sorokoumov (Jira)
Alex Sorokoumov created FLINK-29850: --- Summary: Flink Table Store quick start guide does not work Key: FLINK-29850 URL: https://issues.apache.org/jira/browse/FLINK-29850 Project: Flink

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

2022-11-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627634#comment-17627634 ] Piotr Nowojski commented on FLINK-24119:

[jira] [Updated] (FLINK-27847) SchemaManager supports schema evolution

2022-11-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27847: --- Labels: pull-request-available (was: ) > SchemaManager supports schema evolution >

[jira] [Comment Edited] (FLINK-29234) Dead lock in DefaultLeaderElectionService

2022-11-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627706#comment-17627706 ] Weijie Guo edited comment on FLINK-29234 at 11/2/22 1:35 PM: - [~fpaul] , The

  1   2   3   >