[jira] [Closed] (FLINK-22912) Support state ttl in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-22912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-22912. --- Resolution: Fixed Merged to master via a77d0523ffd8aac907e062ace259f9699a276388 > Support state ttl in

[GitHub] [flink] RocMarshal commented on pull request #16780: [FLINK-13092][docs-zh] Translate "deployment/resource-providers/standalone/kubernetes.md" page into Chinese

RocMarshal commented on pull request #16780: URL: https://github.com/apache/flink/pull/16780#issuecomment-898209648 @hapihu @wuchong I'll check it ASAP. Thank you. -- 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] dianfu closed pull request #16667: [FLINK-22912][python] Support state ttl in Python DataStream API

dianfu closed pull request #16667: URL: https://github.com/apache/flink/pull/16667 -- 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-23742) test_keyed_co_process test failed in py36 and py37

[ https://issues.apache.org/jira/browse/FLINK-23742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398449#comment-17398449 ] Dian Fu commented on FLINK-23742: - Fixed in master via 37df9b70d82ce73b43035530787630d0a707c16b >

[jira] [Closed] (FLINK-23742) test_keyed_co_process test failed in py36 and py37

[ https://issues.apache.org/jira/browse/FLINK-23742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23742. --- Resolution: Fixed > test_keyed_co_process test failed in py36 and py37 >

[GitHub] [flink] PatrickRen commented on a change in pull request #16590: [FLINK-19554][connector/testing-framework] Connector Testing Framework

PatrickRen commented on a change in pull request #16590: URL: https://github.com/apache/flink/pull/16590#discussion_r688258957 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceITCase.java ## @@ -26,6 +26,15

[GitHub] [flink] flinkbot edited a comment on pull request #16792: [FLINK-23739][table]BlackHoleSink & PrintSink implement SupportsParti…

flinkbot edited a comment on pull request #16792: URL: https://github.com/apache/flink/pull/16792#issuecomment-897629413 ## CI report: * 955ea9b07c4e74ada0538976afb71f1103cf2ea7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

flinkbot edited a comment on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-896196766 ## CI report: * f11f93a01d1d0e769d04eb0b66a34914526096cc UNKNOWN * f8933682134ebc6c8b7ca40a56852a1459854fb1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16770: [FLINK-23652][datastream] FLIP-179: Add common connector metrics

flinkbot edited a comment on pull request #16770: URL: https://github.com/apache/flink/pull/16770#issuecomment-896050027 ## CI report: * ce61eedf5930a24fff2feeb5881c910253b8de3b UNKNOWN * 1924e887787a072b5db1c759424fdd9552885660 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16768: [FLINK-23473][runtime] Do not create transaction in TwoPhaseCommitSinkFunction after finish

flinkbot edited a comment on pull request #16768: URL: https://github.com/apache/flink/pull/16768#issuecomment-896023656 ## CI report: * aa88f9f91dfd92a4b7204bb8b13800349bd1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16699: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

flinkbot edited a comment on pull request #16699: URL: https://github.com/apache/flink/pull/16699#issuecomment-892415455 ## CI report: * cbd9c3e0b04fd380bf7f982ce651f701ce5c0daa Azure:

[GitHub] [flink] flinkbot commented on pull request #16803: [FLINK-23744][sql-client] Fix unstable CliClientTest

flinkbot commented on pull request #16803: URL: https://github.com/apache/flink/pull/16803#issuecomment-898202566 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] [Updated] (FLINK-23744) CliClientTest.testCancelExecutionInteractiveMode fails on azure

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

[GitHub] [flink] fsk119 opened a new pull request #16803: [FLINK-23744][sql-client] Fix unstable CliClientTest

fsk119 opened a new pull request #16803: URL: https://github.com/apache/flink/pull/16803 …ionInteractiveMode ## What is the purpose of the change *Fix the unstable test `CliClientTest`. The main reason why it is unstable is because we use the main thread to observe

[GitHub] [flink] flinkbot edited a comment on pull request #16792: [FLINK-23739][table]BlackHoleSink & PrintSink implement SupportsParti…

flinkbot edited a comment on pull request #16792: URL: https://github.com/apache/flink/pull/16792#issuecomment-897629413 ## CI report: * 955ea9b07c4e74ada0538976afb71f1103cf2ea7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16770: [FLINK-23652][datastream] FLIP-179: Add common connector metrics

flinkbot edited a comment on pull request #16770: URL: https://github.com/apache/flink/pull/16770#issuecomment-896050027 ## CI report: * ce61eedf5930a24fff2feeb5881c910253b8de3b UNKNOWN * 1924e887787a072b5db1c759424fdd9552885660 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16699: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

flinkbot edited a comment on pull request #16699: URL: https://github.com/apache/flink/pull/16699#issuecomment-892415455 ## CI report: * cbd9c3e0b04fd380bf7f982ce651f701ce5c0daa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

flinkbot edited a comment on pull request #16687: URL: https://github.com/apache/flink/pull/16687#issuecomment-891705871 ## CI report: * 7df21cab84cfa7fbbfdae5bb81fe1f9add40afe5 Azure:

[GitHub] [flink] tsreaper commented on pull request #16699: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

tsreaper commented on pull request #16699: URL: https://github.com/apache/flink/pull/16699#issuecomment-898191329 @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

[GitHub] [flink] flinkbot edited a comment on pull request #16794: [FLINK-14482][rocksdb] Bump FRocksDB version to 6.20.3

flinkbot edited a comment on pull request #16794: URL: https://github.com/apache/flink/pull/16794#issuecomment-897676540 ## CI report: * 84e9a502fcd95254036489a7a28db976b6a61593 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16776: [FLINK-16201][table] Support JSON_VALUE

flinkbot edited a comment on pull request #16776: URL: https://github.com/apache/flink/pull/16776#issuecomment-896566536 ## CI report: * 22d7f3da27d3b59eab215687708ee18900f78161 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

flinkbot edited a comment on pull request #16687: URL: https://github.com/apache/flink/pull/16687#issuecomment-891705871 ## CI report: * 7df21cab84cfa7fbbfdae5bb81fe1f9add40afe5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16750: [FLINK-23627] [Runtime / Metrics] Migrate all OperatorMG instantiations to factory method

flinkbot edited a comment on pull request #16750: URL: https://github.com/apache/flink/pull/16750#issuecomment-894720946 ## CI report: * e35d6889922d7b306207f7337a946f5f1ce803e4 Azure:

[GitHub] [flink] autophagy commented on pull request #16794: [FLINK-14482][rocksdb] Bump FRocksDB version to 6.20.3

autophagy commented on pull request #16794: URL: https://github.com/apache/flink/pull/16794#issuecomment-898185254 @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

[GitHub] [flink] Airblader commented on pull request #16776: [FLINK-16201][table] Support JSON_VALUE

Airblader commented on pull request #16776: URL: https://github.com/apache/flink/pull/16776#issuecomment-898184480 @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-23702) SQL casting to decimal which cannot hold its original value throws 'Column 'EXPR$0' is NOT NULL, however, a null value is being written into it'

[ https://issues.apache.org/jira/browse/FLINK-23702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398432#comment-17398432 ] Yao Zhang commented on FLINK-23702: --- Hi [~lzljs3620320], I debugged the codegen process and the

[GitHub] [flink] flinkbot edited a comment on pull request #16780: [FLINK-13092][docs-zh] Translate "deployment/resource-providers/standalone/kubernetes.md" page into Chinese

flinkbot edited a comment on pull request #16780: URL: https://github.com/apache/flink/pull/16780#issuecomment-896705916 ## CI report: * bb43d8daea78de87fa0d1a504cee8141fe09cec8 UNKNOWN * bd6bbce71ba31d8c4bcf1415c5e0e4611811 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16750: [FLINK-23627] [Runtime / Metrics] Migrate all OperatorMG instantiations to factory method

flinkbot edited a comment on pull request #16750: URL: https://github.com/apache/flink/pull/16750#issuecomment-894720946 ## CI report: * 8c01440679ea9b7012d25704f8682d4e962d5197 Azure:

[GitHub] [flink] Thesharing commented on a change in pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

Thesharing commented on a change in pull request #16687: URL: https://github.com/apache/flink/pull/16687#discussion_r688227194 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -94,12 +98,34 @@

[jira] [Closed] (FLINK-21454) FLIP-163: SQL Client Improvements

[ https://issues.apache.org/jira/browse/FLINK-21454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21454. --- Resolution: Fixed > FLIP-163: SQL Client Improvements > - > >

[GitHub] [flink] Thesharing commented on a change in pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

Thesharing commented on a change in pull request #16687: URL: https://github.com/apache/flink/pull/16687#discussion_r688226620 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -214,87 +245,87 @@

[GitHub] [flink] Thesharing commented on a change in pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

Thesharing commented on a change in pull request #16687: URL: https://github.com/apache/flink/pull/16687#discussion_r688226405 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -214,87 +245,87 @@

[GitHub] [flink] curcur commented on a change in pull request #16768: [FLINK-23473][runtime] Do not create transaction in TwoPhaseCommitSinkFunction after finish

curcur commented on a change in pull request #16768: URL: https://github.com/apache/flink/pull/16768#discussion_r688219308 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java ## @@ -332,11 +346,18 @@

[GitHub] [flink] curcur commented on a change in pull request #16768: [FLINK-23473][runtime] Do not create transaction in TwoPhaseCommitSinkFunction after finish

curcur commented on a change in pull request #16768: URL: https://github.com/apache/flink/pull/16768#discussion_r688219308 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java ## @@ -332,11 +346,18 @@

[GitHub] [flink] GOODBOY008 commented on a change in pull request #16787: [FLINK-18080][docs-zh] Translate "security-kerberos" page into Chinese

GOODBOY008 commented on a change in pull request #16787: URL: https://github.com/apache/flink/pull/16787#discussion_r688219460 ## File path: docs/content.zh/docs/deployment/security/security-kerberos.md ## @@ -25,103 +25,107 @@ specific language governing permissions and

[GitHub] [flink] curcur commented on a change in pull request #16768: [FLINK-23473][runtime] Do not create transaction in TwoPhaseCommitSinkFunction after finish

curcur commented on a change in pull request #16768: URL: https://github.com/apache/flink/pull/16768#discussion_r688219308 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java ## @@ -332,11 +346,18 @@

[GitHub] [flink] curcur commented on a change in pull request #16768: [FLINK-23473][runtime] Do not create transaction in TwoPhaseCommitSinkFunction after finish

curcur commented on a change in pull request #16768: URL: https://github.com/apache/flink/pull/16768#discussion_r688220104 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java ## @@ -383,12 +404,14 @@

[GitHub] [flink] curcur commented on a change in pull request #16768: [FLINK-23473][runtime] Do not create transaction in TwoPhaseCommitSinkFunction after finish

curcur commented on a change in pull request #16768: URL: https://github.com/apache/flink/pull/16768#discussion_r688220104 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java ## @@ -383,12 +404,14 @@

[GitHub] [flink] flinkbot edited a comment on pull request #16689: [FLINK-21290][table-planner] Support project push down for window TVF.

flinkbot edited a comment on pull request #16689: URL: https://github.com/apache/flink/pull/16689#issuecomment-891706045 ## CI report: * 7320132f07fec90fe6aa6bf4e474bd02a6894621 Azure:

[GitHub] [flink] shenzhu commented on a change in pull request #16750: [FLINK-23627] [Runtime / Metrics] Migrate all OperatorMG instantiations to factory method

shenzhu commented on a change in pull request #16750: URL: https://github.com/apache/flink/pull/16750#discussion_r688220931 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTest.java ## @@ -473,7 +473,7 @@ public void

[GitHub] [flink] curcur commented on a change in pull request #16768: [FLINK-23473][runtime] Do not create transaction in TwoPhaseCommitSinkFunction after finish

curcur commented on a change in pull request #16768: URL: https://github.com/apache/flink/pull/16768#discussion_r688220104 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java ## @@ -383,12 +404,14 @@

[GitHub] [flink] curcur commented on a change in pull request #16768: [FLINK-23473][runtime] Do not create transaction in TwoPhaseCommitSinkFunction after finish

curcur commented on a change in pull request #16768: URL: https://github.com/apache/flink/pull/16768#discussion_r688220104 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java ## @@ -383,12 +404,14 @@

[jira] [Commented] (FLINK-14482) Bump up rocksdb version

[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398421#comment-17398421 ] Yun Tang commented on FLINK-14482: -- [~legojoey17] Not yet completely addressed, you could refer to the

[GitHub] [flink] curcur commented on a change in pull request #16768: [FLINK-23473][runtime] Do not create transaction in TwoPhaseCommitSinkFunction after finish

curcur commented on a change in pull request #16768: URL: https://github.com/apache/flink/pull/16768#discussion_r688220104 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java ## @@ -383,12 +404,14 @@

[GitHub] [flink] curcur commented on a change in pull request #16768: [FLINK-23473][runtime] Do not create transaction in TwoPhaseCommitSinkFunction after finish

curcur commented on a change in pull request #16768: URL: https://github.com/apache/flink/pull/16768#discussion_r688219308 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java ## @@ -332,11 +346,18 @@

[jira] [Commented] (FLINK-23703) Support unrecoverable exception class list in configuration

[ https://issues.apache.org/jira/browse/FLINK-23703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398420#comment-17398420 ] Paul Lin commented on FLINK-23703: -- cc [~arvid] [~trohrmann] WDYT? > Support unrecoverable exception

[jira] [Created] (FLINK-23752) Add document for using HiveSource API

Rui Li created FLINK-23752: -- Summary: Add document for using HiveSource API Key: FLINK-23752 URL: https://issues.apache.org/jira/browse/FLINK-23752 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23751) Testing Window Top-N after Windowing TVF

JING ZHANG created FLINK-23751: -- Summary: Testing Window Top-N after Windowing TVF Key: FLINK-23751 URL: https://issues.apache.org/jira/browse/FLINK-23751 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-23751) Testing Window Top-N after Windowing TVF

[ https://issues.apache.org/jira/browse/FLINK-23751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23751: --- Labels: release-testing (was: ) > Testing Window Top-N after Windowing TVF >

[jira] [Created] (FLINK-23750) Add document for Window Top-N after Windowing TVF

JING ZHANG created FLINK-23750: -- Summary: Add document for Window Top-N after Windowing TVF Key: FLINK-23750 URL: https://issues.apache.org/jira/browse/FLINK-23750 Project: Flink Issue Type:

[jira] [Updated] (FLINK-23749) Testing Window Join

[ https://issues.apache.org/jira/browse/FLINK-23749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23749: --- Labels: release-testing (was: ) > Testing Window Join > --- > >

[jira] [Updated] (FLINK-23748) Testing window TVF session window

[ https://issues.apache.org/jira/browse/FLINK-23748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23748: --- Summary: Testing window TVF session window (was: Testing session window) > Testing window TVF

[jira] [Created] (FLINK-23749) Testing Window Join

JING ZHANG created FLINK-23749: -- Summary: Testing Window Join Key: FLINK-23749 URL: https://issues.apache.org/jira/browse/FLINK-23749 Project: Flink Issue Type: Sub-task Components:

[GitHub] [flink] flinkbot edited a comment on pull request #16787: [FLINK-18080][docs-zh] Translate "security-kerberos" page into Chinese

flinkbot edited a comment on pull request #16787: URL: https://github.com/apache/flink/pull/16787#issuecomment-897334392 ## CI report: * 3ed84b7328381aefff30f7d587a54d0886910894 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16770: [FLINK-23652][datastream] FLIP-179: Add common connector metrics

flinkbot edited a comment on pull request #16770: URL: https://github.com/apache/flink/pull/16770#issuecomment-896050027 ## CI report: * ce61eedf5930a24fff2feeb5881c910253b8de3b UNKNOWN * 1924e887787a072b5db1c759424fdd9552885660 UNKNOWN *

[jira] [Updated] (FLINK-23748) Testing window TVF session window

[ https://issues.apache.org/jira/browse/FLINK-23748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23748: --- Labels: release-testing (was: ) > Testing window TVF session window >

[GitHub] [flink] flinkbot edited a comment on pull request #16689: [FLINK-21290][table-planner] Support project push down for window TVF.

flinkbot edited a comment on pull request #16689: URL: https://github.com/apache/flink/pull/16689#issuecomment-891706045 ## CI report: * 7320132f07fec90fe6aa6bf4e474bd02a6894621 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16667: [FLINK-22912][python] Support state ttl in Python DataStream API

flinkbot edited a comment on pull request #16667: URL: https://github.com/apache/flink/pull/16667#issuecomment-890801858 ## CI report: * 727c94923a9c0136157bcad429a00bf009dfcada Azure:

[jira] [Created] (FLINK-23748) Testing session window

JING ZHANG created FLINK-23748: -- Summary: Testing session window Key: FLINK-23748 URL: https://issues.apache.org/jira/browse/FLINK-23748 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23747) Teting Window TVF offset

JING ZHANG created FLINK-23747: -- Summary: Teting Window TVF offset Key: FLINK-23747 URL: https://issues.apache.org/jira/browse/FLINK-23747 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-23747) Teting Window TVF offset

[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23747: --- Labels: release-testing (was: ) > Teting Window TVF offset > > >

[jira] [Resolved] (FLINK-23032) Refactor HiveSource to make it usable in data stream job

[ https://issues.apache.org/jira/browse/FLINK-23032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23032. Resolution: Fixed > Refactor HiveSource to make it usable in data stream job >

[jira] [Commented] (FLINK-23032) Refactor HiveSource to make it usable in data stream job

[ https://issues.apache.org/jira/browse/FLINK-23032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398415#comment-17398415 ] Rui Li commented on FLINK-23032: Pushed to master: c4bdcac8ea255fd5a3eb6d49e349c6c5b9270939 > Refactor

[GitHub] [flink] lirui-apache closed pull request #16430: [FLINK-23032][hive] Refactor HiveSource to make it usable in data str…

lirui-apache closed pull request #16430: URL: https://github.com/apache/flink/pull/16430 -- 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-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398413#comment-17398413 ] Xintong Song commented on FLINK-23493: --

[jira] [Updated] (FLINK-23582) Add document for session window

[ https://issues.apache.org/jira/browse/FLINK-23582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23582: --- Fix Version/s: 1.14.0 > Add document for session window > --- > >

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

[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22387: - Priority: Critical (was: Major) > UpsertKafkaTableITCase hangs when setting up kafka >

[jira] [Updated] (FLINK-23055) Add document for Window TVF offset

[ https://issues.apache.org/jira/browse/FLINK-23055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23055: --- Priority: Blocker (was: Major) > Add document for Window TVF offset >

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

[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398412#comment-17398412 ] Xintong Song commented on FLINK-22387: --

[jira] [Updated] (FLINK-23287) Create user document for Window Join in SQL

[ https://issues.apache.org/jira/browse/FLINK-23287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23287: --- Fix Version/s: 1.14.0 > Create user document for Window Join in SQL >

[jira] [Closed] (FLINK-22673) Add document about add jar related commands

[ https://issues.apache.org/jira/browse/FLINK-22673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22673. --- Assignee: Shengkai Fang Resolution: Fixed Fixed in master:5c951da05d8fa60b921f77a083c302638d8e1bfb >

[GitHub] [flink] wuchong merged pull request #16779: [FLINK-22673][docs] Add docs about JAR related commands and remove th…

wuchong merged pull request #16779: URL: https://github.com/apache/flink/pull/16779 -- 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-23713) SavepointITCase.testStopWithSavepointWithDrainGlobalFailoverIfSavepointAborted failed with "Stop with savepoint operation could not be completed"

[ https://issues.apache.org/jira/browse/FLINK-23713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398410#comment-17398410 ] Xintong Song commented on FLINK-23713: --

[jira] [Updated] (FLINK-23742) test_keyed_co_process test failed in py36 and py37

[ https://issues.apache.org/jira/browse/FLINK-23742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23742: - Priority: Blocker (was: Major) > test_keyed_co_process test failed in py36 and py37 >

[jira] [Commented] (FLINK-23745) Python test_keyed_co_process fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398409#comment-17398409 ] Xintong Song commented on FLINK-23745: --

[jira] [Updated] (FLINK-23746) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure fails due to AskTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-23746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23746: - Labels: test-stability (was: ) >

[jira] [Updated] (FLINK-23742) test_keyed_co_process test failed in py36 and py37

[ https://issues.apache.org/jira/browse/FLINK-23742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23742: Fix Version/s: 1.14.0 > test_keyed_co_process test failed in py36 and py37 >

[jira] [Closed] (FLINK-23745) Python test_keyed_co_process fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23745. --- Resolution: Duplicate > Python test_keyed_co_process fails on azure >

[jira] [Created] (FLINK-23746) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure fails due to AskTimeoutException

Xintong Song created FLINK-23746: Summary: SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure fails due to AskTimeoutException Key: FLINK-23746 URL:

[jira] [Updated] (FLINK-23745) Python test_keyed_co_process fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23745: - Description:

[jira] [Updated] (FLINK-23745) Python test_keyed_co_process fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23745: - Labels: test-stability (was: ) > Python test_keyed_co_process fails on azure >

[jira] [Created] (FLINK-23745) Python test_keyed_co_process fails on azure

Xintong Song created FLINK-23745: Summary: Python test_keyed_co_process fails on azure Key: FLINK-23745 URL: https://issues.apache.org/jira/browse/FLINK-23745 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-23744) CliClientTest.testCancelExecutionInteractiveMode fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398401#comment-17398401 ] Jark Wu commented on FLINK-23744: - cc [~fsk119] > CliClientTest.testCancelExecutionInteractiveMode

[jira] [Assigned] (FLINK-13636) Translate "Flink DataStream API Programming Guide" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13636: --- Assignee: wuguihu > Translate "Flink DataStream API Programming Guide" page into Chinese >

[GitHub] [flink] flinkbot edited a comment on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

flinkbot edited a comment on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-896196766 ## CI report: * 08a27d75402018220361ac1fc8e1ccd73b20dd74 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398400#comment-17398400 ] Xintong Song commented on FLINK-22387: --

[GitHub] [flink] wuchong commented on pull request #16787: [FLINK-18080][docs-zh] Translate "security-kerberos" page into Chinese

wuchong commented on pull request #16787: URL: https://github.com/apache/flink/pull/16787#issuecomment-898129817 cc @RocMarshal , do you have time to review this? -- 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] flinkbot edited a comment on pull request #16667: [FLINK-22912][python] Support state ttl in Python DataStream API

flinkbot edited a comment on pull request #16667: URL: https://github.com/apache/flink/pull/16667#issuecomment-890801858 ## CI report: * 727c94923a9c0136157bcad429a00bf009dfcada Azure:

[GitHub] [flink] wuchong commented on pull request #16780: [FLINK-13092][docs-zh] Translate "deployment/resource-providers/standalone/kubernetes.md" page into Chinese

wuchong commented on pull request #16780: URL: https://github.com/apache/flink/pull/16780#issuecomment-898129419 cc @RocMarshal , do you have time to review this ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-23683) KafkaSinkITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398398#comment-17398398 ] Xintong Song commented on FLINK-23683: --

[jira] [Commented] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398395#comment-17398395 ] Xintong Song commented on FLINK-23556: --

[GitHub] [flink] flinkbot edited a comment on pull request #16109: [hotfix][connector-kafka] Fixed typo of the method name constructKafk…

flinkbot edited a comment on pull request #16109: URL: https://github.com/apache/flink/pull/16109#issuecomment-856657950 ## CI report: * b1f04c305343bd9eb8d763c7b031768dcb2fe321 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16108: [FLINK-22821][connector-kafka] FlinkKafkaProducerMigrationTest fails …

flinkbot edited a comment on pull request #16108: URL: https://github.com/apache/flink/pull/16108#issuecomment-856641884 ## CI report: * 7dfa9f7b6a707e25f0857f19629236e48801bc5b Azure:

[jira] [Updated] (FLINK-22568) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails with Timeout

[ https://issues.apache.org/jira/browse/FLINK-22568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22568: - Priority: Major (was: Minor) >

[jira] [Updated] (FLINK-22568) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails with Timeout

[ https://issues.apache.org/jira/browse/FLINK-22568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22568: - Labels: test-stability (was: auto-deprioritized-major test-stability) >

[jira] [Updated] (FLINK-22568) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails with Timeout

[ https://issues.apache.org/jira/browse/FLINK-22568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22568: - Fix Version/s: 1.14.0 > RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList

[jira] [Commented] (FLINK-22568) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails with Timeout

[ https://issues.apache.org/jira/browse/FLINK-22568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398393#comment-17398393 ] Xintong Song commented on FLINK-22568: --

[jira] [Commented] (FLINK-23683) KafkaSinkITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398392#comment-17398392 ] Xintong Song commented on FLINK-23683: --

[GitHub] [flink] flinkbot edited a comment on pull request #14395: [FLINK-16491][formats] Add compression support for ParquetAvroWriters

flinkbot edited a comment on pull request #14395: URL: https://github.com/apache/flink/pull/14395#issuecomment-745744218 ## CI report: * 07407367ad601c684d652677ed8844bf8e28158b Azure:

[jira] [Commented] (FLINK-23744) CliClientTest.testCancelExecutionInteractiveMode fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398391#comment-17398391 ] Xintong Song commented on FLINK-23744: -- cc [~jark] [~loyi] Seems introduced by FLINK-23645. >

  1   2   3   4   5   6   >