[jira] [Closed] (FLINK-27436) option `properties.group.id` is not effective in kafka connector for finksql

2022-05-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-27436. -- Resolution: Not A Problem [~SpongebobZ] That makes sense right? There's nothing to checkpoint

[jira] [Commented] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

2022-05-01 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530623#comment-17530623 ] Arvid Heise commented on FLINK-27318: - This is exactly what I meant: You don't resta

[jira] [Commented] (FLINK-27156) [FLIP-171] MongoDB implementation of Async Sink

2022-05-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530621#comment-17530621 ] Martijn Visser commented on FLINK-27156: [~almogtavor] What would be holding you

[jira] [Created] (FLINK-27466) JDBC metaspace leak fix is misleading

2022-05-01 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27466: Summary: JDBC metaspace leak fix is misleading Key: FLINK-27466 URL: https://issues.apache.org/jira/browse/FLINK-27466 Project: Flink Issue Type: Bug

[GitHub] [flink] MartijnVisser commented on pull request #19608: [FLINK-27450][hive][JDK11]SessionState can't be initialized due to classloader

2022-05-01 Thread GitBox
MartijnVisser commented on PR #19608: URL: https://github.com/apache/flink/pull/19608#issuecomment-1114549234 > This PR is to solve the problem that the current HiveParserSessionState cannot be initialized under JDK11. Can you explain how that helps if Hive doesn't work under Java 11?

[GitHub] [flink] zentol commented on a diff in pull request #19590: [FLINK-27352][tests] [JUnit5 Migration] Module: flink-json

2022-05-01 Thread GitBox
zentol commented on code in PR #19590: URL: https://github.com/apache/flink/pull/19590#discussion_r862613016 ## flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonBatchFileSystemITCase.java: ## @@ -20,26 +20,31 @@ import org.apache.flink.table.api.TableR

[jira] [Commented] (FLINK-27462) could not trigger checkpoint when using table function

2022-05-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530613#comment-17530613 ] Martijn Visser commented on FLINK-27462: As mentioned by [~SpongebobZ] in the re

[jira] [Updated] (FLINK-27462) could not trigger checkpoint when using table function

2022-05-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27462: --- Release Note: (was: Flink will stop checkpointing when some subtasks turn to be finished.

[jira] [Commented] (FLINK-27463) The JDBC connector should support option for ‘upsert’ or ‘insert’

2022-05-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530611#comment-17530611 ] Martijn Visser commented on FLINK-27463: [~liam8] Thanks for opening this ticket

[jira] [Closed] (FLINK-27464) java.lang.NoClassDefFoundError

2022-05-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-27464. -- Resolution: Invalid [~YanShen] Thanks for reporting the issue. However, I see flink-cdc-connec

[GitHub] [flink] zentol commented on a diff in pull request #19590: [FLINK-27352][tests] [JUnit5 Migration] Module: flink-json

2022-05-01 Thread GitBox
zentol commented on code in PR #19590: URL: https://github.com/apache/flink/pull/19590#discussion_r862612817 ## flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonBatchFileSystemITCase.java: ## @@ -36,10 +36,14 @@ import java.util.Arrays; import java.util

[jira] [Commented] (FLINK-27156) [FLIP-171] MongoDB implementation of Async Sink

2022-05-01 Thread Almog Tavor (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530608#comment-17530608 ] Almog Tavor commented on FLINK-27156: - [~martijnvisser] Sounds great, but I'd like t

[jira] [Created] (FLINK-27465) AvroRowDeserializationSchema.convertToTimestamp fails with negative nano seconds

2022-05-01 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-27465: Summary: AvroRowDeserializationSchema.convertToTimestamp fails with negative nano seconds Key: FLINK-27465 URL: https://issues.apache.org/jira/browse/FLINK-27465 Proj

[jira] [Commented] (FLINK-25970) SerializedThrowable should record type of the original throwable.

2022-05-01 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530592#comment-17530592 ] Wencong Liu commented on FLINK-25970: - Hello [~xtsong], the problem you mentioned ha

[GitHub] [flink] ChengkaiYang2022 commented on pull request #19496: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment"

2022-05-01 Thread GitBox
ChengkaiYang2022 commented on PR #19496: URL: https://github.com/apache/flink/pull/19496#issuecomment-1114376209 > @ChengkaiYang2022 sorry for the late check. Would you mind resolving the conflicts before the review work ? Thanks a lot. @RocMarshal ,I see some pr discussions to use re

[GitHub] [flink] flinkbot commented on pull request #19618: [hotfix][cep][docs] Corrected version mentioned from Flink-1.3 to Flink-1.13

2022-05-01 Thread GitBox
flinkbot commented on PR #19618: URL: https://github.com/apache/flink/pull/19618#issuecomment-1114334437 ## CI report: * 0e6c482eff08cbaa8d78d773402e895704862000 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] mans2singh opened a new pull request, #19618: [hotfix][cep][docs] Corrected version mentioned from Flink-1.3 to Flink-1.13

2022-05-01 Thread GitBox
mans2singh opened a new pull request, #19618: URL: https://github.com/apache/flink/pull/19618 ## What is the purpose of the change * The intro section regarding migration mentions ...from an older Flink version to **Flink-1.3**.. Changed it to ...from an older Flink version to *

[jira] [Created] (FLINK-27464) java.lang.NoClassDefFoundError

2022-05-01 Thread zhangxin (Jira)
zhangxin created FLINK-27464: Summary: java.lang.NoClassDefFoundError Key: FLINK-27464 URL: https://issues.apache.org/jira/browse/FLINK-27464 Project: Flink Issue Type: Bug Components:

[GitHub] [flink] flinkbot commented on pull request #19617: [FLINK-26945][Table SQL / API] Add DATE_SUB supported in SQL & Table API

2022-05-01 Thread GitBox
flinkbot commented on PR #19617: URL: https://github.com/apache/flink/pull/19617#issuecomment-1114282111 ## CI report: * 84b98d00b94c9e05330f72287916161408fa9b0e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-26945) Add DATE_SUB supported in SQL & Table API

2022-05-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26945: --- Labels: pull-request-available (was: ) > Add DATE_SUB supported in SQL & Table API > --

[GitHub] [flink] artiship opened a new pull request, #19617: [FLINK-26945][Table SQL / API] Add DATE_SUB supported in SQL & Table API

2022-05-01 Thread GitBox
artiship opened a new pull request, #19617: URL: https://github.com/apache/flink/pull/19617 ## What is the purpose of the change Add date_sub(startDate, numDays) SQL function. ```sql > SELECT date_sub('2016-07-30', 1); 2016-07-29 ``` ## Brief change log -

[GitHub] [flink] RocMarshal commented on pull request #19496: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment"

2022-05-01 Thread GitBox
RocMarshal commented on PR #19496: URL: https://github.com/apache/flink/pull/19496#issuecomment-1114256587 @ChengkaiYang2022 sorry for the late check. Would you mind resolving the conflicts before the review work ? Thanks a lot. -- This is an automated message from the Apache Git Service.

[jira] [Commented] (FLINK-26052) Update chinese documentation regarding FLIP-203

2022-05-01 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530518#comment-17530518 ] Feifan Wang commented on FLINK-26052: - Thanks [~dwysakowicz] , sorry for late reply

[GitHub] [flink] flinkbot commented on pull request #19616: [FLINK-26052][docs-zh] Document savepoint format

2022-05-01 Thread GitBox
flinkbot commented on PR #19616: URL: https://github.com/apache/flink/pull/19616#issuecomment-1114241109 ## CI report: * 185d047b7c8f915f09cce5642382b339cf165f19 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-26052) Update chinese documentation regarding FLIP-203

2022-05-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26052: --- Labels: pull-request-available translation-zh (was: translation-zh) > Update chinese docume

[GitHub] [flink] zoltar9264 opened a new pull request, #19616: [FLINK-26052][docs-zh] Document savepoint format

2022-05-01 Thread GitBox
zoltar9264 opened a new pull request, #19616: URL: https://github.com/apache/flink/pull/19616 ## What is the purpose of the change Update Chinese documentation regarding FLIP-203 ## Does this pull request potentially affect one of the following parts: - Dependencies (do

[GitHub] [flink] flinkbot commented on pull request #19615: [FLINK-25970][core] Add type of original exception to the detailMessage of SerializedThrowable.

2022-05-01 Thread GitBox
flinkbot commented on PR #19615: URL: https://github.com/apache/flink/pull/19615#issuecomment-1114210516 ## CI report: * d8b66739c4f5ce82e7c644d4cd4e281447caf1c5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] WencongLiu opened a new pull request, #19615: [FLINK-25970][core] Add type of original exception to the detailMessage of SerializedThrowable.

2022-05-01 Thread GitBox
WencongLiu opened a new pull request, #19615: URL: https://github.com/apache/flink/pull/19615 SerializedThrowable will return itself as a stand in if an exception occurs when calling deserializeError(ClassLoader classloader). When this happens, the call stack printed by logger will not cont

[GitHub] [flink] WencongLiu closed pull request #19614: [FLINK-25970][core] Add type of original exception to the detailMessage of SerializedThrowable.

2022-05-01 Thread GitBox
WencongLiu closed pull request #19614: [FLINK-25970][core] Add type of original exception to the detailMessage of SerializedThrowable. URL: https://github.com/apache/flink/pull/19614 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[jira] [Created] (FLINK-27463) The JDBC connector should support option for ‘upsert’ or ‘insert’

2022-05-01 Thread Liam (Jira)
Liam created FLINK-27463: Summary: The JDBC connector should support option for ‘upsert’ or ‘insert’ Key: FLINK-27463 URL: https://issues.apache.org/jira/browse/FLINK-27463 Project: Flink Issue Type

[jira] [Commented] (FLINK-27174) Non-null check for bootstrapServers field is incorrect in KafkaSink

2022-05-01 Thread Zhengqi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530500#comment-17530500 ] Zhengqi Zhang commented on FLINK-27174: --- [~fpaul], If you think this proposal work

[jira] [Commented] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

2022-05-01 Thread Zhengqi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530498#comment-17530498 ] Zhengqi Zhang commented on FLINK-27318: --- This can happen if the task runs for a wh

[jira] [Updated] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

2022-05-01 Thread Zhengqi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhengqi Zhang updated FLINK-27318: -- Attachment: image-2022-05-01-16-50-27-264.png > KafkaSink: when init transaction, it take too

[jira] [Assigned] (FLINK-27422) Do not create temporary pod template files for JobManager and TaskManager if not configured explicitly

2022-05-01 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-27422: - Assignee: Nicholas Jiang > Do not create temporary pod template files for JobManager and TaskMa

[GitHub] [flink] flinkbot commented on pull request #19614: [FLINK-25970][core] Add type of original exception to the detailMessage of SerializedThrowable.

2022-05-01 Thread GitBox
flinkbot commented on PR #19614: URL: https://github.com/apache/flink/pull/19614#issuecomment-1114166272 ## CI report: * 96f405a9f8b43b0ac85a2ed126d067ac86df2a81 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] WencongLiu opened a new pull request, #19614: [FLINK-25970][core] Add type of original exception to the detailMessage of SerializedThrowable.

2022-05-01 Thread GitBox
WencongLiu opened a new pull request, #19614: URL: https://github.com/apache/flink/pull/19614 SerializedThrowable will return itself as a stand in if an exception occurs when calling deserializeError(ClassLoader classloader). When this happens, the call stack printed by logger will not cont

[jira] [Closed] (FLINK-27462) could not trigger checkpoint when using table function

2022-05-01 Thread Spongebob (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spongebob closed FLINK-27462. - Release Note: Flink will stop checkpointing when some subtasks turn to be finished. And we can switch o