[GitHub] [flink] YikSanChan commented on pull request #15813: [FLINK-22519][flink-python] support tar python archives

YikSanChan commented on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-899243239 > @YikSanChan Since this feature is very important and you don't have much bandwidth on this work. If you don't mind, I'd like to take over this PR and continue the work

[GitHub] [flink] PatrickRen commented on pull request #16809: [FLINK-22914][connector/kafka] Use FLIP-27 KafkaSource in table connector

PatrickRen commented on pull request #16809: URL: https://github.com/apache/flink/pull/16809#issuecomment-899242933 @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] syhily commented on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

syhily commented on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-899240028 @AHeise The CI turns to green, let's finished the last review.  Hope I can catch up the deadline. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] dianfu commented on pull request #15813: [FLINK-22519][flink-python] support tar python archives

dianfu commented on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-899240030 @YikSanChan Since this feature is very important and you don't have much bandwidth on this work. If you don't mind, I'd like to take over this PR and continue the work based on

[GitHub] [flink] flinkbot edited a comment on pull request #16835: [FLINK-15532][rocksdb] Enable strict capacity limit for memory usage for RocksDB

flinkbot edited a comment on pull request #16835: URL: https://github.com/apache/flink/pull/16835#issuecomment-899222388 ## CI report: * cb9bab9b91b5aec13f5c4e3174cf5bde201ea88a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15237: [FLINK-21278][streaming-java] NullpointExecption error is reported wh…

flinkbot edited a comment on pull request #15237: URL: https://github.com/apache/flink/pull/15237#issuecomment-800167686 ## CI report: * 883ee4a01230289c733482d4d6e3c7795c119dfb Azure:

[GitHub] [flink-statefun-docker] tzulitai opened a new pull request #14: [FLINK-22752] More robust state configurations in base flink-conf.yaml

tzulitai opened a new pull request #14: URL: https://github.com/apache/flink-statefun-docker/pull/14 This PR complements https://github.com/apache/flink-statefun/pull/257 by adapting the changes to our official released Docker images. -- This is an automated message from the Apache Git

[jira] [Commented] (FLINK-23495) [GCP PubSub] Make checkpoint optional for preview/staging mode

[ https://issues.apache.org/jira/browse/FLINK-23495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399528#comment-17399528 ] Ingo Bürk commented on FLINK-23495: --- I'm also fine with this. We need to make sure to update the

[jira] [Updated] (FLINK-22752) Add robust default state configuration to StateFun

[ https://issues.apache.org/jira/browse/FLINK-22752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22752: --- Labels: pull-request-available (was: ) > Add robust default state configuration to

[GitHub] [flink-statefun] tzulitai opened a new pull request #257: [FLINK-22752] More robust state configurations in base flink-conf.yaml

tzulitai opened a new pull request #257: URL: https://github.com/apache/flink-statefun/pull/257 This PR intends to add a few configurations to the base `flink-conf.yaml`: - Activate local recovery. This includes setting a local directory for RocksDB to flush its sst / metadata files, as

[jira] [Commented] (FLINK-23795) JoinITCase.testFullJoinWithEqualPkNonEqui fails due to NPE

[ https://issues.apache.org/jira/browse/FLINK-23795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399526#comment-17399526 ] Arvid Heise commented on FLINK-23795: - Probably a duplicate of FLINK-23759. >

[jira] [Closed] (FLINK-23793) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fail due to ConcurrentModificationException

[ https://issues.apache.org/jira/browse/FLINK-23793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-23793. --- Resolution: Duplicate This is a duplicate of FLINK-23785, fix available for review. >

[GitHub] [flink] flinkbot commented on pull request #16834: [FLINK-23789][rocksdb] Remove unnecessary setTotalOrderForSeek for Rocks iterator

flinkbot commented on pull request #16834: URL: https://github.com/apache/flink/pull/16834#issuecomment-899222364 ## CI report: * 5d90e9ac0d53acf243d76239c083f9cd8101f0a4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #16835: [FLINK-15532][rocksdb] Enable strict capacity limit for memory usage for RocksDB

flinkbot commented on pull request #16835: URL: https://github.com/apache/flink/pull/16835#issuecomment-899222388 ## CI report: * cb9bab9b91b5aec13f5c4e3174cf5bde201ea88a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[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 * 61cc9c310c02dea756bc02436d7fab4654caaa1a UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16732: [FLINK-21222][python] Support loopback mode to allow Python UDF worker and client reuse the same Python VM

flinkbot edited a comment on pull request #16732: URL: https://github.com/apache/flink/pull/16732#issuecomment-893984711 ## CI report: * af08c1af7cdba855f3f68413565bd03e7c6dfa9a Azure:

[jira] [Commented] (FLINK-23776) Performance regression on 14.08.2021 in FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-23776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399522#comment-17399522 ] Arvid Heise commented on FLINK-23776: - Thanks for the report. I will investigate. > Performance

[jira] [Commented] (FLINK-23793) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fail due to ConcurrentModificationException

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

[jira] [Commented] (FLINK-23794) JdbcExactlyOnceSinkE2eTest JVM crash on Azure

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

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

flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 4dcee9f07135401160aae3f0d01bd480630f808f UNKNOWN *

[jira] [Created] (FLINK-23797) SavepointITCase.testStopSavepointWithBoundedInput fails on azure

Xintong Song created FLINK-23797: Summary: SavepointITCase.testStopSavepointWithBoundedInput fails on azure Key: FLINK-23797 URL: https://issues.apache.org/jira/browse/FLINK-23797 Project: Flink

[jira] [Commented] (FLINK-23796) UnalignedCheckpointRescaleITCase JVM crash on Azure

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

[jira] [Created] (FLINK-23796) UnalignedCheckpointRescaleITCase JVM crash on Azure

Xintong Song created FLINK-23796: Summary: UnalignedCheckpointRescaleITCase JVM crash on Azure Key: FLINK-23796 URL: https://issues.apache.org/jira/browse/FLINK-23796 Project: Flink Issue

[jira] [Commented] (FLINK-23795) JoinITCase.testFullJoinWithEqualPkNonEqui fails due to NPE

[ https://issues.apache.org/jira/browse/FLINK-23795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399514#comment-17399514 ] Xintong Song commented on FLINK-23795: -- cc [~jark] > JoinITCase.testFullJoinWithEqualPkNonEqui

[jira] [Updated] (FLINK-23788) sql-client.sh cannot run on Windows 10 & MINGW6(git-bash from git-scm)

[ https://issues.apache.org/jira/browse/FLINK-23788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xi updated FLINK-23788: --- Summary: sql-client.sh cannot run on Windows 10 & MINGW6(git-bash from git-scm) (was: sql-client.sh cannot run on

[jira] [Updated] (FLINK-23788) sql-client.sh cannot run on Windows 10 PRO Edition

[ https://issues.apache.org/jira/browse/FLINK-23788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xi updated FLINK-23788: --- Description: I'm trying to submit SQL task to my docker-desktop(docker-engine 20.10.8, Windows 10,

[jira] [Created] (FLINK-23795) JoinITCase.testFullJoinWithEqualPkNonEqui fails due to NPE

Xintong Song created FLINK-23795: Summary: JoinITCase.testFullJoinWithEqualPkNonEqui fails due to NPE Key: FLINK-23795 URL: https://issues.apache.org/jira/browse/FLINK-23795 Project: Flink

[jira] [Commented] (FLINK-23793) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fail due to ConcurrentModificationException

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

[jira] [Updated] (FLINK-23793) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fail due to ConcurrentModificationException

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

[jira] [Commented] (FLINK-23793) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fail due to ConcurrentModificationException

[ https://issues.apache.org/jira/browse/FLINK-23793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399512#comment-17399512 ] Xintong Song commented on FLINK-23793: -- cc [~guoweima] >

[GitHub] [flink] flinkbot edited a comment on pull request #15237: [FLINK-21278][streaming-java] NullpointExecption error is reported wh…

flinkbot edited a comment on pull request #15237: URL: https://github.com/apache/flink/pull/15237#issuecomment-800167686 ## CI report: * 883ee4a01230289c733482d4d6e3c7795c119dfb Azure:

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

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

[jira] [Updated] (FLINK-22821) FlinkKafkaProducerMigrationTest fails with "Address already in use"

[ https://issues.apache.org/jira/browse/FLINK-22821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22821: - Affects Version/s: 1.13.2 > FlinkKafkaProducerMigrationTest fails with "Address already in use"

[jira] [Commented] (FLINK-22821) FlinkKafkaProducerMigrationTest fails with "Address already in use"

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

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

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

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

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

[jira] [Commented] (FLINK-23793) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fail due to ConcurrentModificationException

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

[jira] [Updated] (FLINK-23794) JdbcExactlyOnceSinkE2eTest JVM crash on Azure

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

[jira] [Created] (FLINK-23794) JdbcExactlyOnceSinkE2eTest JVM crash on Azure

Xintong Song created FLINK-23794: Summary: JdbcExactlyOnceSinkE2eTest JVM crash on Azure Key: FLINK-23794 URL: https://issues.apache.org/jira/browse/FLINK-23794 Project: Flink Issue Type:

[jira] [Created] (FLINK-23793) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fail due to ConcurrentModificationException

Xintong Song created FLINK-23793: Summary: SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fail due to ConcurrentModificationException Key: FLINK-23793 URL:

[jira] [Commented] (FLINK-23792) Python test_udf.py fail on azure

[ https://issues.apache.org/jira/browse/FLINK-23792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399499#comment-17399499 ] Xintong Song commented on FLINK-23792: -- cc [~dian.fu] [~Yellow] > Python test_udf.py fail on azure

[jira] [Created] (FLINK-23792) Python test_udf.py fail on azure

Xintong Song created FLINK-23792: Summary: Python test_udf.py fail on azure Key: FLINK-23792 URL: https://issues.apache.org/jira/browse/FLINK-23792 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-19710) Fix performance regression to rebase FRocksDB with higher version RocksDB

[ https://issues.apache.org/jira/browse/FLINK-19710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-19710: -- Labels: (was: auto-deprioritized-major auto-unassigned) Priority: Major (was: Minor) > Fix

[jira] [Commented] (FLINK-23790) Python test_udtf.py fail on azure

[ https://issues.apache.org/jira/browse/FLINK-23790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399498#comment-17399498 ] Xintong Song commented on FLINK-23790: -- cc [~dian.fu] [~Yellow] > Python test_udtf.py fail on

[GitHub] [flink] flinkbot edited a comment on pull request #16732: [FLINK-21222][python] Support loopback mode to allow Python UDF worker and client reuse the same Python VM

flinkbot edited a comment on pull request #16732: URL: https://github.com/apache/flink/pull/16732#issuecomment-893984711 ## CI report: * af08c1af7cdba855f3f68413565bd03e7c6dfa9a Azure:

[GitHub] [flink] flinkbot commented on pull request #16835: [FLINK-15532][rocksdb] Enable strict capacity limit for memory usage for RocksDB

flinkbot commented on pull request #16835: URL: https://github.com/apache/flink/pull/16835#issuecomment-899209521 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] [Comment Edited] (FLINK-14482) Bump up rocksdb version

[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399497#comment-17399497 ] Yu Li edited comment on FLINK-14482 at 8/16/21, 4:39 AM: - Uploading the

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

flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 4dcee9f07135401160aae3f0d01bd480630f808f UNKNOWN *

[jira] [Updated] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-15532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15532: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[GitHub] [flink] Myasuka opened a new pull request #16835: [FLINK-15532][rocksdb] Enable strict capacity limit for memory usage for RocksDB

Myasuka opened a new pull request #16835: URL: https://github.com/apache/flink/pull/16835 ## What is the purpose of the change Enable strict capacity limit for memory usage for RocksDB. ## Brief change log Change the constructor of `LRUCache` to strict mode.

[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=17399497#comment-17399497 ] Yu Li commented on FLINK-14482: --- Uploading the screenshot of micro-benchmark performance regression since

[jira] [Assigned] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-15532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-15532: Assignee: Yun Tang > Enable strict capacity limit for memory usage for RocksDB >

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

[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14482: -- Attachment: Screenshot-for-perf-regression-after-FRocksDB-upgrade-2.png > Bump up rocksdb version >

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

[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14482: -- Attachment: Screenshot-for-perf-regression-after-FRocksDB-upgrade-1.png > Bump up rocksdb version >

[jira] [Updated] (FLINK-23789) Remove unnecessary setTotalOrderForSeek for Rocks iterator

[ https://issues.apache.org/jira/browse/FLINK-23789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23789: --- Labels: pull-request-available (was: ) > Remove unnecessary setTotalOrderForSeek for Rocks

[GitHub] [flink] Myasuka opened a new pull request #16834: [FLINK-23789][rocksdb] Remove unnecessary setTotalOrderForSeek for Rocks iterator

Myasuka opened a new pull request #16834: URL: https://github.com/apache/flink/pull/16834 ## What is the purpose of the change Remove unnecessary setTotalOrderForSeek for Rocks iterator ## Brief change log Remove unnecessary setTotalOrderForSeek for Rocks iterator and

[jira] [Updated] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-15532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-15532: - Fix Version/s: 1.14.0 > Enable strict capacity limit for memory usage for RocksDB >

[jira] [Commented] (FLINK-23756) Release FRocksDB-6.20.3 binaries

[ https://issues.apache.org/jira/browse/FLINK-23756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399493#comment-17399493 ] Yu Li commented on FLINK-23756: --- [~autophagy] Thanks for the efforts! How about the progress of the

[jira] [Assigned] (FLINK-23791) Enable RocksDB log again

[ https://issues.apache.org/jira/browse/FLINK-23791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23791: Assignee: Zakelly Lan > Enable RocksDB log again > > >

[jira] [Created] (FLINK-23791) Enable RocksDB log again

Yun Tang created FLINK-23791: Summary: Enable RocksDB log again Key: FLINK-23791 URL: https://issues.apache.org/jira/browse/FLINK-23791 Project: Flink Issue Type: Improvement

[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: * 59f1d340022c4525be5fa52597dd38c9eacbce20 Azure:

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

flinkbot edited a comment on pull request #16747: URL: https://github.com/apache/flink/pull/16747#issuecomment-894679994 ## CI report: * 5386153efe0e5301d480fd5a72f84158283f12ab Azure:

[GitHub] [flink] dianfu commented on a change in pull request #16833: [FLINK-22871][python] Support to specify python client interpreter used to compile jobs

dianfu commented on a change in pull request #16833: URL: https://github.com/apache/flink/pull/16833#discussion_r689222816 ## File path: docs/content.zh/docs/deployment/cli.md ## @@ -479,6 +479,14 @@ related options. Here's an overview of all the Python related options for

[jira] [Created] (FLINK-23790) Python test_udtf.py fail on azure

Xintong Song created FLINK-23790: Summary: Python test_udtf.py fail on azure Key: FLINK-23790 URL: https://issues.apache.org/jira/browse/FLINK-23790 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #15237: [FLINK-21278][streaming-java] NullpointExecption error is reported wh…

flinkbot edited a comment on pull request #15237: URL: https://github.com/apache/flink/pull/15237#issuecomment-800167686 ## CI report: * 883ee4a01230289c733482d4d6e3c7795c119dfb Azure:

[jira] [Created] (FLINK-23789) Remove unnecessary setTotalOrderForSeek for Rocks iterator

Yun Tang created FLINK-23789: Summary: Remove unnecessary setTotalOrderForSeek for Rocks iterator Key: FLINK-23789 URL: https://issues.apache.org/jira/browse/FLINK-23789 Project: Flink Issue

[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: * 499c1d3a72d1ee2f1aa35e26532f9538be00a53b 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=17399484#comment-17399484 ] Xintong Song commented on FLINK-22387: --

[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=17399483#comment-17399483 ] Xintong Song commented on FLINK-23493: --

[jira] [Updated] (FLINK-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23493: - Priority: Blocker (was: Critical) > python tests hang on Azure > -- >

[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: Blocker (was: Critical) > UpsertKafkaTableITCase hangs when setting up kafka >

[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=17399482#comment-17399482 ] Xintong Song commented on FLINK-22387: --

[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: - Labels: test-stability (was: auto-deprioritized-critical test-stability) >

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

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

[jira] [Updated] (FLINK-23788) sql-client.sh cannot run on Windows 10 PRO Edition

[ https://issues.apache.org/jira/browse/FLINK-23788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xi updated FLINK-23788: --- Description: I'm trying to submit SQL task to my docker-desktop(docker-engine 20.10.8, Windows 10, git-bash 4.4.23

[jira] [Commented] (FLINK-22480) KafkaChangelogTableITCase hangs on Azure

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

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

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

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

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

[jira] [Updated] (FLINK-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23493: - Priority: Critical (was: Major) > python tests hang on Azure > -- > >

[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=17399474#comment-17399474 ] Xintong Song commented on FLINK-23493: --

[jira] [Updated] (FLINK-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23493: - Fix Version/s: 1.14.0 > python tests hang on Azure > -- > >

[GitHub] [flink] flinkbot commented on pull request #16833: [FLINK-22871][python] Support to specify python client interpreter used to compile jobs

flinkbot commented on pull request #16833: URL: https://github.com/apache/flink/pull/16833#issuecomment-899190803 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 edited a comment on pull request #16778: [FLINK-23715][parquet] Support for reading fields that do not exist in Parquet files

flinkbot edited a comment on pull request #16778: URL: https://github.com/apache/flink/pull/16778#issuecomment-896639363 ## CI report: * 52f2594db37bf9b4c80b549273505a7ab3b25296 Azure:

[jira] [Updated] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19863: - Labels: auto-unassigned pull-request-available test-stability (was:

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

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

[jira] [Updated] (FLINK-22871) Support to execute PyFlink jobs in YARN application mode

[ https://issues.apache.org/jira/browse/FLINK-22871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22871: --- Labels: auto-unassigned pull-request-available (was: auto-unassigned) > Support to execute

[GitHub] [flink] HuangXingBo opened a new pull request #16833: [FLINK-22871][python] Support to specify python client interpreter used to compile jobs

HuangXingBo opened a new pull request #16833: URL: https://github.com/apache/flink/pull/16833 ## What is the purpose of the change *This pull request will support to specify python client interpreter used to compile jobs* ## Brief change log - *Support to specify

[GitHub] [flink] flinkbot edited a comment on pull request #15237: [FLINK-21278][streaming-java] NullpointExecption error is reported wh…

flinkbot edited a comment on pull request #15237: URL: https://github.com/apache/flink/pull/15237#issuecomment-800167686 ## CI report: * 883ee4a01230289c733482d4d6e3c7795c119dfb Azure:

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

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

[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: * 499c1d3a72d1ee2f1aa35e26532f9538be00a53b Azure:

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

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

[jira] [Commented] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

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

[jira] [Updated] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

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

[jira] [Updated] (FLINK-23788) sql-client.sh cannot run on Windows 10 PRO Edition

[ https://issues.apache.org/jira/browse/FLINK-23788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xi updated FLINK-23788: --- Description: I'm trying to submit SQL task to my docker-desktop(docker-engine 20.10.8, Windows 10, git-bash 4.4.23

[jira] [Comment Edited] (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=17399457#comment-17399457 ] Xintong Song edited comment on FLINK-23556 at 8/16/21, 3:30 AM: Before

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

[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23556: - Fix Version/s: 1.14.0 > SQLClientSchemaRegistryITCase fails with " Subject ... not found" >

[jira] [Comment Edited] (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=17399457#comment-17399457 ] Xintong Song edited comment on FLINK-23556 at 8/16/21, 3:28 AM: Before

[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=17399466#comment-17399466 ] Xintong Song commented on FLINK-22387: --

[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=17399464#comment-17399464 ] Xintong Song commented on FLINK-22387: --

[jira] [Updated] (FLINK-21292) Python StreamRowBasedOperationITTests fails on azure

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

  1   2   3   >