[GitHub] [flink] flinkbot edited a comment on pull request #14861: [FLINK-21088][runtime][checkpoint] Pass the flag about whether a task is finished on restore on recovery

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #14861: URL: https://github.com/apache/flink/pull/14861#issuecomment-773094467 ## CI report: * 8ba0101759ed6e13f8384493d90fed39cfd1828b Azure:

[GitHub] [flink] wsry commented on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

2021-07-11 Thread GitBox
wsry commented on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-877983397 Hi @pnowojski , I have updated the PR with a fixup commit. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot edited a comment on pull request #14861: [FLINK-21088][runtime][checkpoint] Pass the flag about whether a task is finished on restore on recovery

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #14861: URL: https://github.com/apache/flink/pull/14861#issuecomment-773094467 ## CI report: * 8ba0101759ed6e13f8384493d90fed39cfd1828b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16461: Update flink-operations-playground.md

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16461: URL: https://github.com/apache/flink/pull/16461#issuecomment-877954138 ## CI report: * 294de893b01d1284b05387bfec1a5e9b7b6cd0c2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16436: [FLINK-22017][coordination] Allow BLOCKING result partition to be individually consumable

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16436: URL: https://github.com/apache/flink/pull/16436#issuecomment-877041347 ## CI report: * Unknown: [CANCELED](TBD) * b690ed71930125c3db45f646ae45f5da74cb6cd7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * e280421bc1009e2462551e76f81c3ec980cf3f77 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14861: [FLINK-21088][runtime][checkpoint] Pass the flag about whether a task is finished on restore on recovery

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #14861: URL: https://github.com/apache/flink/pull/14861#issuecomment-773094467 ## CI report: * 8ba0101759ed6e13f8384493d90fed39cfd1828b Azure:

[GitHub] [flink] wuchong merged pull request #16394: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input in 1.12 version

2021-07-11 Thread GitBox
wuchong merged pull request #16394: URL: https://github.com/apache/flink/pull/16394 -- 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] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378895#comment-17378895 ] Xintong Song commented on FLINK-22198: --

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378898#comment-17378898 ] Xintong Song commented on FLINK-20495: --

[jira] [Closed] (FLINK-23109) Translate "Scala API Extensions" pages into Chinese

2021-07-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23109. --- Fix Version/s: 1.14.0 Resolution: Fixed Fixed in master: 7d3b5e604fb745d5fb98875da4a1fba48bc3 >

[GitHub] [flink] wuchong merged pull request #16319: [FLINK-23109]Translate "Scala API Extensions" pages into Chinese

2021-07-11 Thread GitBox
wuchong merged pull request #16319: URL: https://github.com/apache/flink/pull/16319 -- 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-23352) Collect Sink Operator Factory does not support to configure max bytes per batch

2021-07-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-23352: Component/s: (was: Runtime / Network) Table SQL / Ecosystem API /

[jira] [Issue Comment Deleted] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20495: - Comment: was deleted (was:

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378899#comment-17378899 ] Xintong Song commented on FLINK-20495: --

[GitHub] [flink] flinkbot commented on pull request #16461: Update flink-operations-playground.md

2021-07-11 Thread GitBox
flinkbot commented on pull request #16461: URL: https://github.com/apache/flink/pull/16461#issuecomment-877954138 ## CI report: * 294de893b01d1284b05387bfec1a5e9b7b6cd0c2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16460: [FLINK-23150][table-planner] Remove the old code split implementation

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16460: URL: https://github.com/apache/flink/pull/16460#issuecomment-877942496 ## CI report: * 027853d037bf5d5ce9944eab01948acab1301b7b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16441: [FLINK-23235][connector] Fix SinkITCase instability

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16441: URL: https://github.com/apache/flink/pull/16441#issuecomment-877063785 ## CI report: * 3f5e10bd9f8670ef3d91100055805bbc816ba754 Azure:

[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378901#comment-17378901 ] Xintong Song commented on FLINK-22387: --

[GitHub] [flink] flinkbot edited a comment on pull request #16436: [FLINK-22017][coordination] Allow BLOCKING result partition to be individually consumable

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16436: URL: https://github.com/apache/flink/pull/16436#issuecomment-877041347 ## CI report: * Unknown: [CANCELED](TBD) * b690ed71930125c3db45f646ae45f5da74cb6cd7 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * e280421bc1009e2462551e76f81c3ec980cf3f77 Azure:

[GitHub] [flink] wuchong commented on a change in pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

2021-07-11 Thread GitBox
wuchong commented on a change in pull request #16060: URL: https://github.com/apache/flink/pull/16060#discussion_r667608901 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliStrings.java ## @@ -36,91 +43,149 @@ private CliStrings()

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * cc3d738cf5e776e5f19d67ff15d39b2d4e37b00f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14861: [FLINK-21088][runtime][checkpoint] Pass the flag about whether a task is finished on restore on recovery

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #14861: URL: https://github.com/apache/flink/pull/14861#issuecomment-773094467 ## CI report: * 8ba0101759ed6e13f8384493d90fed39cfd1828b Azure:

[jira] [Commented] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378904#comment-17378904 ] Xintong Song commented on FLINK-22333: --

[jira] [Commented] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378902#comment-17378902 ] Xintong Song commented on FLINK-22333: --

[jira] [Comment Edited] (FLINK-23318) AkkaRpcActorTest#testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378864#comment-17378864 ] Xintong Song edited comment on FLINK-23318 at 7/12/21, 3:58 AM:

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378897#comment-17378897 ] Xintong Song commented on FLINK-22198: --

[GitHub] [flink] Thesharing commented on pull request #16436: [FLINK-22017][coordination] Allow BLOCKING result partition to be individually consumable

2021-07-11 Thread GitBox
Thesharing commented on pull request #16436: URL: https://github.com/apache/flink/pull/16436#issuecomment-877949815 @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

[jira] [Commented] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378893#comment-17378893 ] Xintong Song commented on FLINK-22457: --

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378894#comment-17378894 ] Xintong Song commented on FLINK-20495: --

[jira] [Commented] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP

2021-07-11 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378892#comment-17378892 ] Rui Li commented on FLINK-20975: Sure I'll look into this. > HiveTableSourceITCase.testPartitionFilter

[jira] [Updated] (FLINK-20321) Get NPE when using AvroDeserializationSchema to deserialize null input

2021-07-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20321: Fix Version/s: 1.12.6 > Get NPE when using AvroDeserializationSchema to deserialize null input >

[jira] [Commented] (FLINK-20321) Get NPE when using AvroDeserializationSchema to deserialize null input

2021-07-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378890#comment-17378890 ] Jark Wu commented on FLINK-20321: - Fixed in release-1.12: 2eaabca6075f91617d8c7f2bfd363964e893d65e >

[jira] [Assigned] (FLINK-12438) Translate "Task Lifecycle" page into Chinese

2021-07-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-12438: --- Assignee: wuguihu > Translate "Task Lifecycle" page into Chinese >

[GitHub] [flink] wuchong commented on pull request #16304: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

2021-07-11 Thread GitBox
wuchong commented on pull request #16304: URL: https://github.com/apache/flink/pull/16304#issuecomment-877946837 cc @RocMarshal , do you want to help reviewing this page? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Closed] (FLINK-23268) [DOCS]The link on page docs/dev/table/sql/queries/match_recognize/ is failed and 404 is returned

2021-07-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23268. --- Fix Version/s: 1.14.0 Resolution: Fixed Fixed in master: 2fe17acef83cca24a021e3ee0392f9bf57b4bbd6 >

[GitHub] [flink] wuchong merged pull request #16384: [FLINK-23268][docs] Fix some link issues on page "docs/dev/table/sql…

2021-07-11 Thread GitBox
wuchong merged pull request #16384: URL: https://github.com/apache/flink/pull/16384 -- 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-23285) The link on page docs/dev/datastream/event-time/generating_atermarks/ is failed and 404 is returned

2021-07-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23285. --- Fix Version/s: 1.14.0 Assignee: wuguihu Resolution: Fixed Fixed in master:

[GitHub] [flink] wuchong merged pull request #16400: [FLINK-23285][docs] Fix some link issues on page "docs/dev/datastrea…

2021-07-11 Thread GitBox
wuchong merged pull request #16400: URL: https://github.com/apache/flink/pull/16400 -- 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-23292) [DOCS]Some links on page docs/content/docs/dev/table/concepts/dynamic_tables is failed and 404 is returned

2021-07-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23292. --- Fix Version/s: 1.14.0 Assignee: wuguihu Resolution: Fixed Fixed in master:

[GitHub] [flink] wuchong merged pull request #16410: [FLINK-23292][docs] Fix some link issues on page "docs/content/docs/…

2021-07-11 Thread GitBox
wuchong merged pull request #16410: URL: https://github.com/apache/flink/pull/16410 -- 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-23352) Collect Sink Operator Factory does not support to configure max bytes per batch

2021-07-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-23352: Summary: Collect Sink Operator Factory does not support to configure max bytes per batch Key: FLINK-23352 URL: https://issues.apache.org/jira/browse/FLINK-23352 Project:

[jira] [Created] (FLINK-23351) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails due to "too few watermarks emitted" on azure

2021-07-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-23351: Summary: FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails due to "too few watermarks emitted" on azure Key: FLINK-23351 URL:

[GitHub] [flink] belary opened a new pull request #16461: Update flink-operations-playground.md

2021-07-11 Thread GitBox
belary opened a new pull request #16461: URL: https://github.com/apache/flink/pull/16461 /tmp/flink-checkpoints-directory /tmp/flink-savepoints-directory needs to be writable ## What is the purpose of the change *(For example: This pull request makes task

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

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378881#comment-17378881 ] Xintong Song commented on FLINK-22068: --

[jira] [Commented] (FLINK-21751) Improve handling of freed slots if final requirement message is in flight

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378880#comment-17378880 ] Xintong Song commented on FLINK-21751: -- [~chesnay], could you please check this instability? It

[jira] [Comment Edited] (FLINK-21751) Improve handling of freed slots if final requirement message is in flight

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378880#comment-17378880 ] Xintong Song edited comment on FLINK-21751 at 7/12/21, 3:31 AM:

[GitHub] [flink] flinkbot commented on pull request #16461: Update flink-operations-playground.md

2021-07-11 Thread GitBox
flinkbot commented on pull request #16461: URL: https://github.com/apache/flink/pull/16461#issuecomment-877942677 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #16460: [FLINK-23150][table-planner] Remove the old code split implementation

2021-07-11 Thread GitBox
flinkbot commented on pull request #16460: URL: https://github.com/apache/flink/pull/16460#issuecomment-877942496 ## CI report: * 027853d037bf5d5ce9944eab01948acab1301b7b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16459: [FLINK-23348][kafka][test] Activate at-least-once related kafka it cases.

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16459: URL: https://github.com/apache/flink/pull/16459#issuecomment-877934605 ## CI report: * ba96c00c00aee490e823a97b4d36604a7975597c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16441: [FLINK-23235][connector] Fix SinkITCase instability

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16441: URL: https://github.com/apache/flink/pull/16441#issuecomment-877063785 ## CI report: * 3f5e10bd9f8670ef3d91100055805bbc816ba754 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * dece519b97d7825c48a2b3a4092ba7acdae2545d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14861: [FLINK-21088][runtime][checkpoint] Pass the flag about whether a task is finished on restore on recovery

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #14861: URL: https://github.com/apache/flink/pull/14861#issuecomment-773094467 ## CI report: * c3a823c9cff52362f5674f8fde80b2db77c60f64 Azure:

[jira] [Closed] (FLINK-23243) Translate "SELECT & WHERE clause" page into Chinese

2021-07-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23243. --- Fix Version/s: (was: 1.13.0) 1.14.0 Resolution: Fixed > Translate "SELECT &

[jira] [Commented] (FLINK-23243) Translate "SELECT & WHERE clause" page into Chinese

2021-07-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378879#comment-17378879 ] Jark Wu commented on FLINK-23243: - Fixed in master: 5a40a9b739581cd4c9e0b91eb40fed6b2b53ceab >

[jira] [Commented] (FLINK-23346) RocksDBStateBackend may core dump in flink_compactionfilterjni.cc

2021-07-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378878#comment-17378878 ] Yun Tang commented on FLINK-23346: -- [~klion26] Thanks for your debugging. Would you please tell me what

[GitHub] [flink] wuchong merged pull request #16418: [FLINK-23243][docs-zh]Translate "SELECT & WHERE clause" page into Chinese

2021-07-11 Thread GitBox
wuchong merged pull request #16418: URL: https://github.com/apache/flink/pull/16418 -- 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] [Commented] (FLINK-22985) NullPointerException when cast string literal to date or time

2021-07-11 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378877#comment-17378877 ] Caizhi Weng commented on FLINK-22985: - After researching on the behavior of some databases, I found

[jira] [Updated] (FLINK-23346) RocksDBStateBackend may core dump in flink_compactionfilterjni.cc

2021-07-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23346: - Description: The code in [flink_compactionfilte.cpp 

[jira] [Updated] (FLINK-23346) RocksDBStateBackend may core dump in flink_compactionfilterjni.cc

2021-07-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23346: - Description: The code in [flink_compactionfilte.cpp 

[GitHub] [flink] flinkbot commented on pull request #16460: [FLINK-23150][table-planner] Remove the old code split implementation

2021-07-11 Thread GitBox
flinkbot commented on pull request #16460: URL: https://github.com/apache/flink/pull/16460#issuecomment-877939573 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Closed] (FLINK-22841) how to update configuration of the native kubernetes deployment model flink cluster?

2021-07-11 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-22841. - Resolution: Information Provided If you still have questions, let's discuss it in the user/dev ML.

[GitHub] [flink] tsreaper opened a new pull request #16460: [FLINK-23150][table-planner] Remove the old code split implementation

2021-07-11 Thread GitBox
tsreaper opened a new pull request #16460: URL: https://github.com/apache/flink/pull/16460 ## What is the purpose of the change This is the final step of FLINK-23007. This parent issue aims to solve the issue in one shot, that some methods of the generated Java code may grow beyond

[jira] [Commented] (FLINK-23218) Distribute the ShuffleDescriptors via blob server

2021-07-11 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378872#comment-17378872 ] Yang Wang commented on FLINK-23218: --- Just a side input, the Yarn local resource cache also has a

[GitHub] [flink] flinkbot commented on pull request #16459: [FLINK-23348][kafka][test] Activate at-least-once related kafka it cases.

2021-07-11 Thread GitBox
flinkbot commented on pull request #16459: URL: https://github.com/apache/flink/pull/16459#issuecomment-877934605 ## CI report: * ba96c00c00aee490e823a97b4d36604a7975597c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Closed] (FLINK-23023) Support offset in window TVF

2021-07-11 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-23023. -- Resolution: Fixed Fixed in 1.14.0: 5cc769d451d97614a99015caee2f63350ad0913d > Support offset in

[GitHub] [flink] flinkbot edited a comment on pull request #16441: [FLINK-23235][connector] Fix SinkITCase instability

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16441: URL: https://github.com/apache/flink/pull/16441#issuecomment-877063785 ## CI report: * 3f5e10bd9f8670ef3d91100055805bbc816ba754 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16417: FLINK-22969

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16417: URL: https://github.com/apache/flink/pull/16417#issuecomment-876088562 ## CI report: * dfc073dc704129e4a99002494765dff0948b02a2 UNKNOWN * 68e33105ba388305297e052376e8ce8e0a39cbaf Azure:

[GitHub] [flink] godfreyhe closed pull request #16215: [FLINK-23023][table-planner-blink] Support offset in window TVF.

2021-07-11 Thread GitBox
godfreyhe closed pull request #16215: URL: https://github.com/apache/flink/pull/16215 -- 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] guoweiM commented on pull request #16441: [FLINK-23235][connector] Fix SinkITCase instability

2021-07-11 Thread GitBox
guoweiM commented on pull request #16441: URL: https://github.com/apache/flink/pull/16441#issuecomment-877932696 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] flinkbot commented on pull request #16459: [FLINK-23348][kafka][test] Activate at-least-once related kafka it cases.

2021-07-11 Thread GitBox
flinkbot commented on pull request #16459: URL: https://github.com/apache/flink/pull/16459#issuecomment-877931120 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-23318) AkkaRpcActorTest#testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378864#comment-17378864 ] Xintong Song commented on FLINK-23318: --

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-11 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378865#comment-17378865 ] longwang0616 commented on FLINK-22969: -- [~luoyuxia]Hello, maybe it is not what we understand? >

[jira] [Commented] (FLINK-22985) NullPointerException when cast string literal to date or time

2021-07-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378860#comment-17378860 ] Jingsong Lee commented on FLINK-22985: -- Thanks [~TsReaper] > NullPointerException when cast string

[jira] [Assigned] (FLINK-22985) NullPointerException when cast string literal to date or time

2021-07-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22985: Assignee: Caizhi Weng > NullPointerException when cast string literal to date or time >

[jira] [Commented] (FLINK-22626) KafkaITCase.testTimestamps fails on Azure

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378859#comment-17378859 ] Xintong Song commented on FLINK-22626: --

[jira] [Updated] (FLINK-22626) KafkaITCase.testTimestamps fails on Azure

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22626: - Priority: Major (was: Minor) > KafkaITCase.testTimestamps fails on Azure >

[jira] [Updated] (FLINK-22626) KafkaITCase.testTimestamps fails on Azure

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22626: - Affects Version/s: 1.13.1 > KafkaITCase.testTimestamps fails on Azure >

[jira] [Updated] (FLINK-23350) Write doc for change log disorder by special operators

2021-07-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-23350: - Description: (Copy from FLINK-20374) We can start documenting the change log behavior of the

[jira] [Updated] (FLINK-23350) Write doc for change log disorder by special operators

2021-07-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-23350: - Environment: (was: (Copy from FLINK-20374) We can start documenting the change log behavior

[jira] [Created] (FLINK-23350) Write doc for change log disorder by special operators

2021-07-11 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-23350: Summary: Write doc for change log disorder by special operators Key: FLINK-23350 URL: https://issues.apache.org/jira/browse/FLINK-23350 Project: Flink Issue

[jira] [Created] (FLINK-23349) GroupWindowITCase JVM crash on azure

2021-07-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-23349: Summary: GroupWindowITCase JVM crash on azure Key: FLINK-23349 URL: https://issues.apache.org/jira/browse/FLINK-23349 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns

2021-07-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378858#comment-17378858 ] Jingsong Lee commented on FLINK-20374: -- [~twalthr] Good idea, I will create a related Jira for doc.

[jira] [Updated] (FLINK-22739) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail due to TestTimedOutException

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22739: - Priority: Major (was: Minor) > CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail due to

[jira] [Commented] (FLINK-22739) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail due to TestTimedOutException

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378857#comment-17378857 ] Xintong Song commented on FLINK-22739: --

[jira] [Commented] (FLINK-23348) Kafka At-Least-Once related IT cases are not activated

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378856#comment-17378856 ] Xintong Song commented on FLINK-23348: -- I tried re-activated the two cases and they work fine for

[jira] [Comment Edited] (FLINK-23348) Kafka At-Least-Once related IT cases are not activated

2021-07-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378856#comment-17378856 ] Xintong Song edited comment on FLINK-23348 at 7/12/21, 2:42 AM: I've

[jira] [Updated] (FLINK-23348) Kafka At-Least-Once related IT cases are not activated

2021-07-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23348: --- Labels: pull-request-available (was: ) > Kafka At-Least-Once related IT cases are not

[GitHub] [flink] xintongsong opened a new pull request #16459: [FLINK-23348][kafka][test] Activate at-least-once related kafka it cases.

2021-07-11 Thread GitBox
xintongsong opened a new pull request #16459: URL: https://github.com/apache/flink/pull/16459 ## 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 avoid re-transferring

[jira] [Created] (FLINK-23348) Kafka At-Least-Once related IT cases are not activated

2021-07-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-23348: Summary: Kafka At-Least-Once related IT cases are not activated Key: FLINK-23348 URL: https://issues.apache.org/jira/browse/FLINK-23348 Project: Flink Issue

[GitHub] [flink] RocMarshal commented on pull request #16417: FLINK-22969

2021-07-11 Thread GitBox
RocMarshal commented on pull request #16417: URL: https://github.com/apache/flink/pull/16417#issuecomment-877924725 @LongWangXX Hi, I notice that the implements of `org.apache.flink.util.StringUtils#isNullOrWhitespaceOnly` is samilar to the implements of

[jira] [Updated] (FLINK-23267) Activate Java code splitter for all generated classes

2021-07-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-23267: - Fix Version/s: 1.14.0 > Activate Java code splitter for all generated classes >

[jira] [Closed] (FLINK-23267) Activate Java code splitter for all generated classes

2021-07-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-23267. Assignee: Caizhi Weng Resolution: Fixed Implemented via: master: 

[GitHub] [flink] JingsongLi merged pull request #16349: [FLINK-23267][table-planner-blink] Enable Java code splitting for all generated classes

2021-07-11 Thread GitBox
JingsongLi merged pull request #16349: URL: https://github.com/apache/flink/pull/16349 -- 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] gaoyunhaii commented on pull request #16441: [FLINK-23235][connector] Fix SinkITCase instability

2021-07-11 Thread GitBox
gaoyunhaii commented on pull request #16441: URL: https://github.com/apache/flink/pull/16441#issuecomment-877924110 Hi @guoweiM , very sorry for missing it at the first pass: if there are both possibility that "end of input" would be added, do we also need to remove it from the expected

[GitHub] [flink] flinkbot edited a comment on pull request #16457: [hotfix][runtime] Log slot pool status if unable to fulfill job requirements

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16457: URL: https://github.com/apache/flink/pull/16457#issuecomment-877915805 ## CI report: * 48113937331f9eaf9da6f16b70e7c86680eef30b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16456: [hotfix][runtime] Log TaskThread StackTrace from the WatchDog

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16456: URL: https://github.com/apache/flink/pull/16456#issuecomment-877915721 ## CI report: * 0695be187ad29e0257fc7a7492e26c9ec7e6869d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16458: [hotfix][tests] Increase log level in JdbcExactlyOnceSinkE2eTest programmatically

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16458: URL: https://github.com/apache/flink/pull/16458#issuecomment-877915883 ## CI report: * 661dd83c1eafbd2b3496ec9979a9a68dc0dbbccb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16417: FLINK-22969

2021-07-11 Thread GitBox
flinkbot edited a comment on pull request #16417: URL: https://github.com/apache/flink/pull/16417#issuecomment-876088562 ## CI report: * dfc073dc704129e4a99002494765dff0948b02a2 UNKNOWN * 68e33105ba388305297e052376e8ce8e0a39cbaf Azure:

  1   2   3   >