[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413468#comment-17413468 ] Yufan Sheng commented on FLINK-23969: - [~Jiangang] Just add my wechat: syhily. We can debug this

[GitHub] [flink] flinkbot edited a comment on pull request #17198: [FLINK-24212][kerbernets] fix the problem that kerberos krb5.conf file is mounted as empty directory, not a expected file

flinkbot edited a comment on pull request #17198: URL: https://github.com/apache/flink/pull/17198#issuecomment-915217186 ## CI report: * 0cf21ddabc21af46f66d74bdc86e4dd971f53f7f Azure:

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413464#comment-17413464 ] Liu commented on FLINK-23969: - [~syhily] I have written E2E test just like KafkaSourceE2ECase, but it is

[GitHub] [flink] flinkbot edited a comment on pull request #17198: [FLINK-24212][kerbernets] fix the problem that kerberos krb5.conf file is mounted as empty directory, not a expected file

flinkbot edited a comment on pull request #17198: URL: https://github.com/apache/flink/pull/17198#issuecomment-915217186 ## CI report: * 0cf21ddabc21af46f66d74bdc86e4dd971f53f7f Azure:

[GitHub] [flink] lzshlzsh commented on pull request #17198: [FLINK-24212][kerbernets] fix the problem that kerberos krb5.conf file is mounted as empty directory, not a expected file

lzshlzsh commented on pull request #17198: URL: https://github.com/apache/flink/pull/17198#issuecomment-917329268 > Thanks for the contribution @lzshlzsh . Your fix looks good. Have you verified it in your local env? Also, it would be good to add a test for it. @KarmaGYZ I have

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

[ https://issues.apache.org/jira/browse/FLINK-22739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22739: --- Labels: auto-deprioritized-major stale-major test-stability (was: auto-deprioritized-major

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

[ https://issues.apache.org/jira/browse/FLINK-23349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23349: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-23210) Running HA per-job cluster (hashmap, sync) end-to-end test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-23210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23210: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

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

[ https://issues.apache.org/jira/browse/FLINK-22626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22626: --- Labels: auto-deprioritized-major stale-major test-stability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-22769) yarnship do not support symbolic directory

[ https://issues.apache.org/jira/browse/FLINK-22769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22769: --- Labels: flink-yarn pull-request-available pull-requests-available stale-assigned

[GitHub] [flink] flinkbot edited a comment on pull request #17242: [hotfix] [sql/planner] REGEXP_EXTRACT return type should always be nullable

flinkbot edited a comment on pull request #17242: URL: https://github.com/apache/flink/pull/17242#issuecomment-917060604 ## CI report: * cdffda2cf6039ccce638bbb78bd19f8c20e558d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17243: [BP-1.13][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

flinkbot edited a comment on pull request #17243: URL: https://github.com/apache/flink/pull/17243#issuecomment-917060704 ## CI report: * 0c73acabf65f2a73073fe37738e6b46598fd2b53 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17240: [FLINK-24255][tests] Test environments respect configuration when being instantiated

flinkbot edited a comment on pull request #17240: URL: https://github.com/apache/flink/pull/17240#issuecomment-916978082 ## CI report: * c5f86fc46384f29f95566d59b276d10b972e1b51 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16940: [FLINK-23914][connector/testing-framework] Improve logging and error message in testing framework

flinkbot edited a comment on pull request #16940: URL: https://github.com/apache/flink/pull/16940#issuecomment-903640018 ## CI report: * 32f2f8c7acb6e0a0df70cd83a4ba3e08b2010795 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17204: [FLINK-22942] [sql/planner] Disable UPSERT INTO statement

flinkbot edited a comment on pull request #17204: URL: https://github.com/apache/flink/pull/17204#issuecomment-915424597 ## CI report: * 08737f676be9cb8dd784258b17eb6a92e4b1b715 UNKNOWN * 56a3348b9dd0289aec214280cb304284706b543d UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #17242: [hotfix] [sql/planner] REGEXP_EXTRACT return type should always be nullable

flinkbot edited a comment on pull request #17242: URL: https://github.com/apache/flink/pull/17242#issuecomment-917060604 ## CI report: * cdffda2cf6039ccce638bbb78bd19f8c20e558d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17243: [BP-1.13][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

flinkbot edited a comment on pull request #17243: URL: https://github.com/apache/flink/pull/17243#issuecomment-917060704 ## CI report: * 0c73acabf65f2a73073fe37738e6b46598fd2b53 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17241: 文字修改:"做报"->"做法"

flinkbot edited a comment on pull request #17241: URL: https://github.com/apache/flink/pull/17241#issuecomment-916997095 ## CI report: * 39c72cb22806724e25901f6b8a990cfd7bebfde1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17204: [FLINK-22942] [sql/planner] Disable UPSERT INTO statement

flinkbot edited a comment on pull request #17204: URL: https://github.com/apache/flink/pull/17204#issuecomment-915424597 ## CI report: * 08737f676be9cb8dd784258b17eb6a92e4b1b715 UNKNOWN * 56a3348b9dd0289aec214280cb304284706b543d UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #17243: [BP-1.13][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

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

[GitHub] [flink] flinkbot commented on pull request #17242: [hotfix] [sql/planner] REGEXP_EXTRACT return type should always be nullable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

flinkbot edited a comment on pull request #17227: URL: https://github.com/apache/flink/pull/17227#issuecomment-916400703 ## CI report: * 66e05983bb45f81010df23da6cee79ed28683c4e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17204: [FLINK-22942] [sql/planner] Disable UPSERT INTO statement

flinkbot edited a comment on pull request #17204: URL: https://github.com/apache/flink/pull/17204#issuecomment-915424597 ## CI report: * 08737f676be9cb8dd784258b17eb6a92e4b1b715 UNKNOWN * 56a3348b9dd0289aec214280cb304284706b543d UNKNOWN *

[GitHub] [flink] zuston commented on pull request #16994: [FLINK-23991][yarn] Specifying yarn.staging-dir fail when staging scheme is…

zuston commented on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-917030972 Oh take easy and please have a good rest @gaborgsomogyi -- 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 #17241: 文字修改:"做报"->"做法"

flinkbot edited a comment on pull request #17241: URL: https://github.com/apache/flink/pull/17241#issuecomment-916997095 ## CI report: * 39c72cb22806724e25901f6b8a990cfd7bebfde1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17187: [FLINK-11250][runtime] Added method init for RecordWriter for initialization resources(OutputFlusher) outside of constructor

flinkbot edited a comment on pull request #17187: URL: https://github.com/apache/flink/pull/17187#issuecomment-914504554 ## CI report: * 9bda457c20e12e90d7956e725ee6004b53073fdc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16940: [FLINK-23914][connector/testing-framework] Improve logging and error message in testing framework

flinkbot edited a comment on pull request #16940: URL: https://github.com/apache/flink/pull/16940#issuecomment-903640018 ## CI report: * b1f10989978d1273860f77f163066f81e3e2a960 Azure:

[GitHub] [flink] flinkbot commented on pull request #17242: [hotfix] [sql/planner] REGEXP_EXTRACT return type should always be nullable

flinkbot commented on pull request #17242: URL: https://github.com/apache/flink/pull/17242#issuecomment-917019975 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 #17243: [BP-1.13][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

flinkbot commented on pull request #17243: URL: https://github.com/apache/flink/pull/17243#issuecomment-917019942 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] slinkydeveloper commented on a change in pull request #17204: [FLINK-22942] [sql/planner] Disable UPSERT INTO statement

slinkydeveloper commented on a change in pull request #17204: URL: https://github.com/apache/flink/pull/17204#discussion_r706297346 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidatorTest.java ## @@ -0,0

[GitHub] [flink] PatrickRen opened a new pull request #17243: [BP-1.13][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

PatrickRen opened a new pull request #17243: URL: https://github.com/apache/flink/pull/17243 Unchanged backport of #16870 on release-1.13 -- 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] slinkydeveloper opened a new pull request #17242: [hotfix] [sql/planner] REGEXP_EXTRACT return type should always be nullable

slinkydeveloper opened a new pull request #17242: URL: https://github.com/apache/flink/pull/17242 Signed-off-by: slinkydeveloper ## What is the purpose of the change This change fixes an issue found out while investigating on `COALESCE` bad type inference behaviour,

[GitHub] [flink] flinkbot edited a comment on pull request #17240: [FLINK-24255][tests] Test environments respect configuration when being instantiated

flinkbot edited a comment on pull request #17240: URL: https://github.com/apache/flink/pull/17240#issuecomment-916978082 ## CI report: * c5f86fc46384f29f95566d59b276d10b972e1b51 Azure:

[GitHub] [flink] flinkbot commented on pull request #17241: 文字修改:"做报"->"做法"

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

[GitHub] [flink] flinkbot edited a comment on pull request #17239: [FLINK-24245][python] Fix the problem caused by multiple jobs sharing the loopback mode address stored in the environment variable in

flinkbot edited a comment on pull request #17239: URL: https://github.com/apache/flink/pull/17239#issuecomment-916850624 ## CI report: * 36084a2c0427502ecd2e77ca8342bf080ed38459 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16940: [FLINK-23914][connector/testing-framework] Improve logging and error message in testing framework

flinkbot edited a comment on pull request #16940: URL: https://github.com/apache/flink/pull/16940#issuecomment-903640018 ## CI report: * b1f10989978d1273860f77f163066f81e3e2a960 Azure:

[jira] [Comment Edited] (FLINK-21647) 'Run kubernetes session test (default input)' failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-21647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413242#comment-17413242 ] Kevin edited comment on FLINK-21647 at 9/10/21, 3:28 PM: - Hello [~wangyang0918],

[jira] [Comment Edited] (FLINK-21647) 'Run kubernetes session test (default input)' failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-21647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413242#comment-17413242 ] Kevin edited comment on FLINK-21647 at 9/10/21, 3:27 PM: - Hello [~wangyang0918],

[jira] [Commented] (FLINK-21647) 'Run kubernetes session test (default input)' failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-21647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413242#comment-17413242 ] Kevin commented on FLINK-21647: --- Hello [~wangyang0918], thanks for you reply! My goal is to run Kafka

[GitHub] [flink] flinkbot commented on pull request #17241: 文字修改:"做报"->"做法"

flinkbot commented on pull request #17241: URL: https://github.com/apache/flink/pull/17241#issuecomment-916988216 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] mycsoft opened a new pull request #17241: 文字修改:"做报"->"做法"

mycsoft opened a new pull request #17241: URL: https://github.com/apache/flink/pull/17241 ## 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 them

[GitHub] [flink] PatrickRen commented on a change in pull request #16940: [FLINK-23914][connector/testing-framework] Improve logging and error message in testing framework

PatrickRen commented on a change in pull request #16940: URL: https://github.com/apache/flink/pull/16940#discussion_r706265359 ## File path: flink-test-utils-parent/flink-connector-testing/src/test/java/org/apache/flink/connectors/test/common/utils/TestDataMatchersTest.java

[GitHub] [flink] flinkbot commented on pull request #17240: [FLINK-24255][tests] Test environments respect configuration when being instantiated

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

[GitHub] [flink] flinkbot edited a comment on pull request #17237: [FLINK-24243][python] Cleanup code to use latest API to avoid warnings

flinkbot edited a comment on pull request #17237: URL: https://github.com/apache/flink/pull/17237#issuecomment-916817312 ## CI report: * a4e1c5089f9b5141ffaa3d53c8cd7860fc4ea9f6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17231: (1.14) [FLINK-24065][connector] Upgrade the state of TwoPhaseCommitSink to support empty transaction after finished

flinkbot edited a comment on pull request #17231: URL: https://github.com/apache/flink/pull/17231#issuecomment-916679291 ## CI report: * ff4868d020b0714a9304db5ff2dab92e1e47d405 Azure:

[jira] [Commented] (FLINK-24086) Do not re-register SharedStateRegistry to reduce the recovery time of the job

[ https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413232#comment-17413232 ] ming li commented on FLINK-24086: - Hi, [~dwysakowicz], Here I have a question: {quote}it reuses old 

[GitHub] [flink-statefun] igalshilman opened a new pull request #269: [FLINK-24256][sdk] Add a JavaScript SDK.

igalshilman opened a new pull request #269: URL: https://github.com/apache/flink-statefun/pull/269 ## This PR adds a new remote functions SDK in JavaScript for `node js`. * The following snippet demonstrate a minimal function that is invoked with a `string` message and emits an

[jira] [Updated] (FLINK-24256) Add JavaScript SDK for Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-24256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24256: --- Labels: pull-request-available (was: ) > Add JavaScript SDK for Stateful Functions >

[jira] [Assigned] (FLINK-23385) Fix nullability of COALESCE

[ https://issues.apache.org/jira/browse/FLINK-23385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-23385: Assignee: Francesco Guardiani > Fix nullability of COALESCE >

[jira] [Commented] (FLINK-15832) Test jars are installed twice

[ https://issues.apache.org/jira/browse/FLINK-15832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413225#comment-17413225 ] Fei Feng commented on FLINK-15832: -- Is there any progress on this issue ? I met the same problem too. 

[GitHub] [flink] flinkbot commented on pull request #17240: [FLINK-24255][tests] Test environments respect configuration when being instantiated

flinkbot commented on pull request #17240: URL: https://github.com/apache/flink/pull/17240#issuecomment-916959236 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] StephanEwen commented on a change in pull request #17240: [FLINK-24255][tests] Test environments respect configuration when being instantiated

StephanEwen commented on a change in pull request #17240: URL: https://github.com/apache/flink/pull/17240#discussion_r706239304 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java ## @@ -85,7 +92,7 @@

[jira] [Updated] (FLINK-24255) Test Environment / Mini Cluster do not forward configuration.

[ https://issues.apache.org/jira/browse/FLINK-24255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24255: --- Labels: pull-request-available (was: ) > Test Environment / Mini Cluster do not forward

[GitHub] [flink] StephanEwen commented on a change in pull request #17240: [FLINK-24255][tests] Test environments respect configuration when being instantiated

StephanEwen commented on a change in pull request #17240: URL: https://github.com/apache/flink/pull/17240#discussion_r706239304 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java ## @@ -85,7 +92,7 @@

[GitHub] [flink] StephanEwen opened a new pull request #17240: [FLINK-24255][tests] Test environments respect configuration when being instantiated

StephanEwen opened a new pull request #17240: URL: https://github.com/apache/flink/pull/17240 ## What is the purpose of the change Ensure that the `Configuration` passed to `StreamExecutionEnvironment getExecutionEnvironment(Configuration)` is also respected when instantiating

[jira] [Assigned] (FLINK-24256) Add JavaScript SDK for Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-24256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-24256: Assignee: Igal Shilman > Add JavaScript SDK for Stateful Functions >

[jira] [Created] (FLINK-24256) Add JavaScript SDK for Stateful Functions

Igal Shilman created FLINK-24256: Summary: Add JavaScript SDK for Stateful Functions Key: FLINK-24256 URL: https://issues.apache.org/jira/browse/FLINK-24256 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #17238: [FLINK-24233][runtime] Ignore message about new buffer size if the re…

flinkbot edited a comment on pull request #17238: URL: https://github.com/apache/flink/pull/17238#issuecomment-916817365 ## CI report: * 0b1e925a05a2eb992ab0396381234ba661ad66c6 Azure:

[jira] [Created] (FLINK-24255) Test Environment / Mini Cluster do not forward configuration.

Stephan Ewen created FLINK-24255: Summary: Test Environment / Mini Cluster do not forward configuration. Key: FLINK-24255 URL: https://issues.apache.org/jira/browse/FLINK-24255 Project: Flink

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413207#comment-17413207 ] Timo Walther commented on FLINK-20370: -- I opened FLINK-24254. Any opinion to my other suggestion

[jira] [Updated] (FLINK-24254) Support configuration hints for table sources and sinks

[ https://issues.apache.org/jira/browse/FLINK-24254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24254: - Description: We currently offer config option that modify the behavior of sources and sinks.

[jira] [Updated] (FLINK-24254) Support configuration hints for table sources and sinks

[ https://issues.apache.org/jira/browse/FLINK-24254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24254: - Issue Type: Improvement (was: Bug) > Support configuration hints for table sources and sinks >

[jira] [Updated] (FLINK-24254) Support configuration hints for table sources and sinks

[ https://issues.apache.org/jira/browse/FLINK-24254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24254: - Component/s: Table SQL / API > Support configuration hints for table sources and sinks >

[jira] [Updated] (FLINK-24254) Support configuration hints for table sources and sinks

[ https://issues.apache.org/jira/browse/FLINK-24254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24254: - Summary: Support configuration hints for table sources and sinks (was: Support hints

[jira] [Created] (FLINK-24254) Support hints configuration hints

Timo Walther created FLINK-24254: Summary: Support hints configuration hints Key: FLINK-24254 URL: https://issues.apache.org/jira/browse/FLINK-24254 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #15703: [FLINK-22275][table] Support random past for timestamp types in datagen connector

flinkbot edited a comment on pull request #15703: URL: https://github.com/apache/flink/pull/15703#issuecomment-823980125 ## CI report: * 68074dc1aea5ece8d4e11e19c15f04f85d6fc652 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #17204: [FLINK-22942] [sql/planner] Disable UPSERT INTO statement

twalthr commented on a change in pull request #17204: URL: https://github.com/apache/flink/pull/17204#discussion_r706206929 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidatorTest.java ## @@ -0,0 +1,64 @@

[jira] [Created] (FLINK-24253) Load JdbcDialects via Service Loaders

Seth Wiesman created FLINK-24253: Summary: Load JdbcDialects via Service Loaders Key: FLINK-24253 URL: https://issues.apache.org/jira/browse/FLINK-24253 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-24252) HybridSource should return TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-24252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24252: --- Assignee: Arvid Heise > HybridSource should return TypeInformation >

[jira] [Created] (FLINK-24252) HybridSource should return TypeInformation

Arvid Heise created FLINK-24252: --- Summary: HybridSource should return TypeInformation Key: FLINK-24252 URL: https://issues.apache.org/jira/browse/FLINK-24252 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

flinkbot edited a comment on pull request #17227: URL: https://github.com/apache/flink/pull/17227#issuecomment-916400703 ## CI report: * 4c250aeecd45453d6028d0bf25174d5812893da6 Azure:

[jira] [Updated] (FLINK-23639) Migrate Table API to new KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23639: Release Note: Table API/SQL write to Kafka with the new `KafkaSink`. When migrating from a query

[GitHub] [flink] AHeise commented on a change in pull request #17182: [release] Create 1.14 release-notes

AHeise commented on a change in pull request #17182: URL: https://github.com/apache/flink/pull/17182#discussion_r706181805 ## File path: docs/content.zh/release-notes/flink-1.14.md ## @@ -0,0 +1,424 @@ +--- +title: "Release Notes - Flink 1.14" +--- + + +# Release Notes - Flink

[jira] [Updated] (FLINK-23639) Migrate Table API to new KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23639: Release Note: Table API/SQL write to Kafka with the new `KafkaSink`. To run in exactly-once

[GitHub] [flink] AHeise commented on a change in pull request #17182: [release] Create 1.14 release-notes

AHeise commented on a change in pull request #17182: URL: https://github.com/apache/flink/pull/17182#discussion_r706176761 ## File path: docs/content.zh/release-notes/flink-1.14.md ## @@ -0,0 +1,424 @@ +--- +title: "Release Notes - Flink 1.14" +--- + + +# Release Notes - Flink

[jira] [Updated] (FLINK-22902) Port KafkaSink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22902: Release Note: `KafkaSink` supersedes `FlinkKafkaProducer` and provides efficient exactly-once and

[GitHub] [flink] AHeise commented on a change in pull request #17182: [release] Create 1.14 release-notes

AHeise commented on a change in pull request #17182: URL: https://github.com/apache/flink/pull/17182#discussion_r706176761 ## File path: docs/content.zh/release-notes/flink-1.14.md ## @@ -0,0 +1,424 @@ +--- +title: "Release Notes - Flink 1.14" +--- + + +# Release Notes - Flink

[jira] [Updated] (FLINK-22902) Port KafkaSink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22902: Release Note: KafkaSink supersedes FlinkKafkaProducer and provides efficient exactly-once and

[GitHub] [flink] AHeise commented on a change in pull request #17182: [release] Create 1.14 release-notes

AHeise commented on a change in pull request #17182: URL: https://github.com/apache/flink/pull/17182#discussion_r706176761 ## File path: docs/content.zh/release-notes/flink-1.14.md ## @@ -0,0 +1,424 @@ +--- +title: "Release Notes - Flink 1.14" +--- + + +# Release Notes - Flink

[jira] [Updated] (FLINK-24055) Deprecate FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-24055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24055: Release Note: `FlinkKafkaConsumer` has been deprecated in favor of `KafkaSource`. To upgrade to

[jira] [Updated] (FLINK-22902) Port KafkaSink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22902: Release Note: KafkaSink supersedes FlinkKafkaProducer and provides efficient exactly-once and

[jira] [Resolved] (FLINK-22902) Port KafkaSink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22902. - Resolution: Fixed > Port KafkaSink to new Unified Sink API (FLIP-143) >

[GitHub] [flink] AHeise commented on a change in pull request #17182: [release] Create 1.14 release-notes

AHeise commented on a change in pull request #17182: URL: https://github.com/apache/flink/pull/17182#discussion_r706175484 ## File path: docs/content.zh/release-notes/flink-1.14.md ## @@ -0,0 +1,424 @@ +--- +title: "Release Notes - Flink 1.14" +--- + + +# Release Notes - Flink

[jira] [Updated] (FLINK-24055) Deprecate FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-24055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24055: Release Note: `FlinkKafkaConsumer` has been deprecated in favor of `KafkaSource`. To upgrade to

[jira] [Commented] (FLINK-24157) do you have a plan for support dotnet

[ https://issues.apache.org/jira/browse/FLINK-24157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413176#comment-17413176 ] Clement commented on FLINK-24157: - ok thank you i can contribute to it > do you have a plan for support

[GitHub] [flink] flinkbot edited a comment on pull request #17235: [FLINK-24246][connector/pulsar] Bump pulsar client to latest 2.8.1 release

flinkbot edited a comment on pull request #17235: URL: https://github.com/apache/flink/pull/17235#issuecomment-916768949 ## CI report: * 60a0ecd0be1b561cecf95677153d17603efc45b3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17234: [FLINK-24244][python] Logging whether it's executed in loopback mode

flinkbot edited a comment on pull request #17234: URL: https://github.com/apache/flink/pull/17234#issuecomment-916768884 ## CI report: * 9b5f449530196810dbeaab43e181ed1979374170 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

flinkbot edited a comment on pull request #17227: URL: https://github.com/apache/flink/pull/17227#issuecomment-916400703 ## CI report: * 4c250aeecd45453d6028d0bf25174d5812893da6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17208: [BP-1.14][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

flinkbot edited a comment on pull request #17208: URL: https://github.com/apache/flink/pull/17208#issuecomment-915763233 ## CI report: * 5b9a5d1c9ddb5d53f4ef6558bb214b2a05300498 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure:

[jira] [Commented] (FLINK-23864) The document for Pulsar Source

[ https://issues.apache.org/jira/browse/FLINK-23864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413169#comment-17413169 ] Arvid Heise commented on FLINK-23864: - Merged into master as

[jira] [Resolved] (FLINK-23864) The document for Pulsar Source

[ https://issues.apache.org/jira/browse/FLINK-23864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23864. - Resolution: Fixed > The document for Pulsar Source > -- > >

[GitHub] [flink] AHeise merged pull request #17232: [FLINK-23864][docs] Add pulsar connector document [1.14]

AHeise merged pull request #17232: URL: https://github.com/apache/flink/pull/17232 -- 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] AHeise merged pull request #17188: [FLINK-23864][docs] Add pulsar connector document

AHeise merged pull request #17188: URL: https://github.com/apache/flink/pull/17188 -- 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-24246) Bump Pulsar to 2.8.1

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24246: Fix Version/s: 1.14.1 > Bump Pulsar to 2.8.1 > > > Key:

[jira] [Commented] (FLINK-24246) Bump Pulsar to 2.8.1

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413166#comment-17413166 ] Arvid Heise commented on FLINK-24246: - Let's target 1.14.1. It's fully functional as is. > Bump

[jira] [Assigned] (FLINK-24246) Bump Pulsar to 2.8.1

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24246: --- Assignee: Yufan Sheng > Bump Pulsar to 2.8.1 > > >

[GitHub] [flink] syhily commented on pull request #17236: [FLINK-24246][connector/pulsar] Bump pulsar client to latest 2.8.1 release [1.14]

syhily commented on pull request #17236: URL: https://github.com/apache/flink/pull/17236#issuecomment-916875375 Closed for merging into 1.15 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] syhily closed pull request #17236: [FLINK-24246][connector/pulsar] Bump pulsar client to latest 2.8.1 release [1.14]

syhily closed pull request #17236: URL: https://github.com/apache/flink/pull/17236 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #17239: [FLINK-24245][python] Fix the problem caused by multiple jobs sharing the loopback mode address stored in the environment variable in

flinkbot edited a comment on pull request #17239: URL: https://github.com/apache/flink/pull/17239#issuecomment-916850624 ## CI report: * 36084a2c0427502ecd2e77ca8342bf080ed38459 Azure:

  1   2   3   4   >