[GitHub] [flink] wangyang0918 commented on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod

wangyang0918 commented on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-749403427 The commit message also needs to be refined. I think it could be `[FLINK-20664][k8s] Support setting service account for TaskManager pod`.

[GitHub] [flink] wangyang0918 commented on a change in pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod

wangyang0918 commented on a change in pull request #14447: URL: https://github.com/apache/flink/pull/14447#discussion_r547112827 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java ## @@ -60,6 +60,13 @@

[jira] [Updated] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job

[ https://issues.apache.org/jira/browse/FLINK-20714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackwangcs updated FLINK-20714: --- Description: Hive delegation token is not obtained when using `kinit` to submit Yarn per-job.  In 

[jira] [Created] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job

jackwangcs created FLINK-20714: -- Summary: Hive delegation token is not obtained when using `kinit` to submit Yarn per-job Key: FLINK-20714 URL: https://issues.apache.org/jira/browse/FLINK-20714

[jira] [Updated] (FLINK-20713) out/err file support rolling

[ https://issues.apache.org/jira/browse/FLINK-20713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] muzimusi updated FLINK-20713: - Description: It is meaningful for out / err files to support scrolling. In particular, when you have

[jira] [Created] (FLINK-20713) out/err file support rolling

muzimusi created FLINK-20713: Summary: out/err file support rolling Key: FLINK-20713 URL: https://issues.apache.org/jira/browse/FLINK-20713 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253313#comment-17253313 ] Piotr Nowojski commented on FLINK-20654: [~xintongsong], I suspect this being a real bug. >

[GitHub] [flink] xiaoHoly commented on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

xiaoHoly commented on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-749394141 @wangxlong ,@wuchong i had put it in JdbcConnectionOptions and exposing isConnectionValid! take a look

[GitHub] [flink] danny0405 commented on pull request #14451: [FLINK-20704][table-planner] Some rel data type does not implement th…

danny0405 commented on pull request #14451: URL: https://github.com/apache/flink/pull/14451#issuecomment-749393109 > is there any tests to cover the changes? Yes, i have added some tests. This is an automated message

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253309#comment-17253309 ] Huang Xingbo commented on FLINK-20654: --

[GitHub] [flink-docker] wangyang0918 edited a comment on pull request #49: [FLINK-20650] Rename "native-k8s" command to a more general name in docker-entrypoint.sh

wangyang0918 edited a comment on pull request #49: URL: https://github.com/apache/flink-docker/pull/49#issuecomment-749390118 cc @rogaha @tianon I have updated this PR and prepared a testing docker image with the new entrypoint. You could directly run the following examples. Note

[GitHub] [flink-docker] wangyang0918 commented on pull request #49: [FLINK-20650] Rename "native-k8s" command to a more general name in docker-entrypoint.sh

wangyang0918 commented on pull request #49: URL: https://github.com/apache/flink-docker/pull/49#issuecomment-749390118 cc @rogaha @tianon I have updated this PR and prepared a testing docker image with the new entrypoint. You could directly run the following examples. Note that if

[GitHub] [flink] leonardBang commented on a change in pull request #13800: [FLINK-19650][connectors jdbc]Support the limit push down for the Jdb…

leonardBang commented on a change in pull request #13800: URL: https://github.com/apache/flink/pull/13800#discussion_r547108176 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala ## @@ -244,6

[GitHub] [flink] HuangXingBo commented on pull request #14410: [FLINK-20616][python] Support row-based operation to accept user-defined function directly

HuangXingBo commented on pull request #14410: URL: https://github.com/apache/flink/pull/14410#issuecomment-749383498 @dianfu Thanks a lot for the review. I have addressed the comments at the latest commit. This is an

[jira] [Created] (FLINK-20712) Add row-based support in join_lateral/left_outer_join_lateral in Python Table API

Huang Xingbo created FLINK-20712: Summary: Add row-based support in join_lateral/left_outer_join_lateral in Python Table API Key: FLINK-20712 URL: https://issues.apache.org/jira/browse/FLINK-20712

[GitHub] [flink] HuangXingBo commented on a change in pull request #14410: [FLINK-20616][python] Support row-based operation to accept user-defined function directly

HuangXingBo commented on a change in pull request #14410: URL: https://github.com/apache/flink/pull/14410#discussion_r547100592 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/python/PythonTableFunction.java ## @@ -48,6 +48,7 @@

[jira] [Updated] (FLINK-20703) HiveSinkCompactionITCase test timeout

[ https://issues.apache.org/jira/browse/FLINK-20703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-20703: - Issue Type: Bug (was: Test) > HiveSinkCompactionITCase test timeout >

[jira] [Closed] (FLINK-20703) HiveSinkCompactionITCase test timeout

[ https://issues.apache.org/jira/browse/FLINK-20703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-20703. Fix Version/s: 1.12.1 Resolution: Fixed release-1.12: 

[jira] [Updated] (FLINK-20703) HiveSinkCompactionITCase test timeout

[ https://issues.apache.org/jira/browse/FLINK-20703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-20703: - Issue Type: Test (was: Improvement) > HiveSinkCompactionITCase test timeout >

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253303#comment-17253303 ] Xintong Song commented on FLINK-20654: -- Hi [~roman_khachatryan], How are things going with this

[GitHub] [flink] JingsongLi merged pull request #14453: [FLINK-20703][table] HiveSinkCompactionITCase test timeout

JingsongLi merged pull request #14453: URL: https://github.com/apache/flink/pull/14453 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

[GitHub] [flink-statefun-docker] tzulitai closed pull request #5: Introducing scala 2.11 build

tzulitai closed pull request #5: URL: https://github.com/apache/flink-statefun-docker/pull/5 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

[jira] [Commented] (FLINK-20679) JobMasterTest.testSlotRequestTimeoutWhenNoSlotOffering test failed

[ https://issues.apache.org/jira/browse/FLINK-20679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253301#comment-17253301 ] Huang Xingbo commented on FLINK-20679: --

[jira] [Commented] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253302#comment-17253302 ] Xintong Song commented on FLINK-20648: -- Just to add my two cents. IIUC, the reason we convert a

[GitHub] [flink-statefun-docker] tzulitai opened a new pull request #12: [release] Stateful Functions 2.2.2

tzulitai opened a new pull request #12: URL: https://github.com/apache/flink-statefun-docker/pull/12 To be merged after vote passes for release 2.2.2. This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink-web] tzulitai opened a new pull request #404: [release] Stateful Functions 2.2.2 release announcement

tzulitai opened a new pull request #404: URL: https://github.com/apache/flink-web/pull/404 Publish date is TBD. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] lirui-apache commented on pull request #14453: [FLINK-20703][table] HiveSinkCompactionITCase test timeout

lirui-apache commented on pull request #14453: URL: https://github.com/apache/flink/pull/14453#issuecomment-749367990 > > +1. Thanks for fixing the issue. > > And perhaps we should make `UnsupportedOperationException` part of the API contract. Otherwise, we'll be depending on

[jira] [Commented] (FLINK-20385) Allow to read metadata for Canal-json format

[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253298#comment-17253298 ] wangfei commented on FLINK-20385: - [~nicholasjiang] [~jark]Thank you. When did this get merged into the

[GitHub] [flink] JingsongLi commented on pull request #14453: [FLINK-20703][table] HiveSinkCompactionITCase test timeout

JingsongLi commented on pull request #14453: URL: https://github.com/apache/flink/pull/14453#issuecomment-749365527 > +1. Thanks for fixing the issue. > And perhaps we should make `UnsupportedOperationException` part of the API contract. Otherwise, we'll be depending on implementation

[GitHub] [flink] xiaoHoly commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

xiaoHoly commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r547089038 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcBatchingOutputFormat.java ## @@ -179,11

[jira] [Updated] (FLINK-20711) Parameter enumeration value error in ES doc

[ https://issues.apache.org/jira/browse/FLINK-20711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 孙铮 updated FLINK-20711: --- Priority: Minor (was: Major) > Parameter enumeration value error in ES doc >

[GitHub] [flink] flinkbot commented on pull request #14458: [FLINK-20708][table-planner-blink] Introduce StreamPhysicalDropUpdateBefore, and make StreamExecDropUpdateBefore only extended from ExecNode

flinkbot commented on pull request #14458: URL: https://github.com/apache/flink/pull/14458#issuecomment-749356042 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-20708) Separate the implementation of StreamExecDropUpdateBefore

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

[GitHub] [flink] godfreyhe opened a new pull request #14458: [FLINK-20708][table-planner-blink] Introduce StreamPhysicalDropUpdateBefore, and make StreamExecDropUpdateBefore only extended from ExecNod

godfreyhe opened a new pull request #14458: URL: https://github.com/apache/flink/pull/14458 ## What is the purpose of the change *Separate the implementation of StreamExecDropUpdateBefore* ## Brief change log - *Introduce StreamPhysicalDropUpdateBefore, and make

[jira] [Assigned] (FLINK-20708) Separate the implementation of StreamExecDropUpdateBefore

[ https://issues.apache.org/jira/browse/FLINK-20708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20708: -- Assignee: godfrey he > Separate the implementation of StreamExecDropUpdateBefore >

[jira] [Closed] (FLINK-20699) Feedback invocation_id must not be constant.

[ https://issues.apache.org/jira/browse/FLINK-20699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-20699. --- Resolution: Fixed statefun/master: 9b53e600e088264ff5ccec3c606a202636baa68b

[jira] [Assigned] (FLINK-20707) Separate the implementation of BatchExecExpand and StreamExecExpand

[ https://issues.apache.org/jira/browse/FLINK-20707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20707: -- Assignee: godfrey he > Separate the implementation of BatchExecExpand and StreamExecExpand >

[jira] [Updated] (FLINK-20364) Add support for scheduling with slot sharing

[ https://issues.apache.org/jira/browse/FLINK-20364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-20364: Affects Version/s: (was: statefun-2.2.1) > Add support for scheduling with

[jira] [Updated] (FLINK-20364) Add support for scheduling with slot sharing

[ https://issues.apache.org/jira/browse/FLINK-20364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-20364: Fix Version/s: (was: statefun-2.2.2) > Add support for scheduling with slot

[jira] [Updated] (FLINK-20336) RequestReplyFunction should not silently ignore UNRECOGNIZED state value mutations types

[ https://issues.apache.org/jira/browse/FLINK-20336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-20336: Priority: Major (was: Blocker) > RequestReplyFunction should not silently ignore

[jira] [Updated] (FLINK-20336) RequestReplyFunction should not silently ignore UNRECOGNIZED state value mutations types

[ https://issues.apache.org/jira/browse/FLINK-20336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-20336: Fix Version/s: (was: statefun-2.2.2) > RequestReplyFunction should not

[jira] [Closed] (FLINK-20689) Upgrade StateFun to Flink 1.11.3

[ https://issues.apache.org/jira/browse/FLINK-20689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-20689. --- Fix Version/s: statefun-2.3.0 Resolution: Fixed statefun/master:

[jira] [Closed] (FLINK-20636) Require unaligned checkpoints to be disabled in StateFun applications

[ https://issues.apache.org/jira/browse/FLINK-20636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-20636. --- Resolution: Fixed statefun/master: 163dd030767f823a097168578bd2e05b7747c30d

[GitHub] [flink] wuchong commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

wuchong commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r547079548 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcBatchingOutputFormat.java ## @@ -179,11

[GitHub] [flink] flinkbot commented on pull request #14457: [FLINK-20707][table-planner-blink] Separate the implementation of BatchExecExpand and StreamExecExpand

flinkbot commented on pull request #14457: URL: https://github.com/apache/flink/pull/14457#issuecomment-749351582 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-statefun] tzulitai closed pull request #184: [FLINK-20335] Remove support for module YAML versions 1.0 / 2.0

tzulitai closed pull request #184: URL: https://github.com/apache/flink-statefun/pull/184 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

[jira] [Updated] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20648: - Priority: Blocker (was: Critical) > Unable to restore job from savepoint when using Kubernetes

[jira] [Closed] (FLINK-20264) Zero-downtime / dynamic function upgrades in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-20264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-20264. --- Resolution: Fixed > Zero-downtime / dynamic function upgrades in Stateful Functions

[jira] [Updated] (FLINK-20707) Separate the implementation of BatchExecExpand and StreamExecExpand

[ https://issues.apache.org/jira/browse/FLINK-20707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20707: --- Labels: pull-request-available (was: ) > Separate the implementation of BatchExecExpand

[jira] [Closed] (FLINK-20335) Remove support for eager state specifications in module YAML definitions

[ https://issues.apache.org/jira/browse/FLINK-20335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-20335. --- Resolution: Fixed Merged to statefun/master:

[GitHub] [flink] godfreyhe opened a new pull request #14457: [FLINK-20707][table-planner-blink] Separate the implementation of BatchExecExpand and StreamExecExpand

godfreyhe opened a new pull request #14457: URL: https://github.com/apache/flink/pull/14457 ## What is the purpose of the change *Separate the implementation of BatchExecExpand and StreamExecExpand* ## Brief change log - *[FLINK-20707][table-planner-blink]

[GitHub] [flink-statefun] tzulitai closed pull request #190: [FLINK-20699] Set FeedbackKey invocation_id explicitly

tzulitai closed pull request #190: URL: https://github.com/apache/flink-statefun/pull/190 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

[GitHub] [flink-statefun] tzulitai closed pull request #189: [FLINK-20689] Upgrade to Flink 1.11.3

tzulitai closed pull request #189: URL: https://github.com/apache/flink-statefun/pull/189 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

[GitHub] [flink-statefun] tzulitai closed pull request #187: [FLINK-20636] Validate that unaligned checkpoints is not enabled

tzulitai closed pull request #187: URL: https://github.com/apache/flink-statefun/pull/187 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

[GitHub] [flink-statefun] tzulitai closed pull request #188: [hotfix] fix typos in StatefulFunctionModule.java.

tzulitai closed pull request #188: URL: https://github.com/apache/flink-statefun/pull/188 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

[jira] [Updated] (FLINK-20664) Support setting service account for TaskManager pod

[ https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20664: - Priority: Blocker (was: Critical) > Support setting service account for TaskManager pod >

[GitHub] [flink] flinkbot commented on pull request #14456: [FLINK-20519][hbase] Fix NOTICE file for bundled dependencies in flink-sql-connector-hbase-2.2

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

[GitHub] [flink-statefun] tzulitai commented on pull request #189: [FLINK-20689] Upgrade to Flink 1.11.3

tzulitai commented on pull request #189: URL: https://github.com/apache/flink-statefun/pull/189#issuecomment-749345618 Thanks, will remove those no longer needed files. This is an automated message from the Apache Git

[jira] [Assigned] (FLINK-20664) Support setting service account for TaskManager pod

[ https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20664: Assignee: Boris Lublinsky (was: Yang Wang) > Support setting service account for

[GitHub] [flink-statefun] tzulitai closed pull request #186: [FLINK-20574] [core] Block further inputs until first invocation completes

tzulitai closed pull request #186: URL: https://github.com/apache/flink-statefun/pull/186 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

[GitHub] [flink-statefun] tzulitai commented on pull request #186: [FLINK-20574] [core] Block further inputs until first invocation completes

tzulitai commented on pull request #186: URL: https://github.com/apache/flink-statefun/pull/186#issuecomment-749344193 Yes makes sense! This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-statefun] tzulitai commented on pull request #190: [FLINK-20699] Set FeedbackKey invocation_id explicitly

tzulitai commented on pull request #190: URL: https://github.com/apache/flink-statefun/pull/190#issuecomment-749343443 Thanks @igalshilman, +1 LGTM. Merging this ... This is an automated message from the Apache Git Service.

[GitHub] [flink] xintongsong closed pull request #14416: [hotfix][k8s] Fix k8s ha service doc.

xintongsong closed pull request #14416: URL: https://github.com/apache/flink/pull/14416 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

[GitHub] [flink] flinkbot edited a comment on pull request #14455: [FLINK-20706][table-planner-blink] Separate the implementation of BatchExecUnion and StreamExecUnion

flinkbot edited a comment on pull request #14455: URL: https://github.com/apache/flink/pull/14455#issuecomment-749335031 ## CI report: * a718e57ca82adef10f2875b996997507ee5ef0f8 Azure:

[GitHub] [flink] flinkbot commented on pull request #14456: [FLINK-20519][hbase] Fix NOTICE file for bundled dependencies in flink-sql-connector-hbase-2.2

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

[jira] [Commented] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253275#comment-17253275 ] Yangze Guo commented on FLINK-17295: Hi, there. Since the 1.12 has been released, I'd like to revive

[GitHub] [flink] xiaoHoly commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

xiaoHoly commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r547069065 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcBatchingOutputFormat.java ## @@ -179,11

[GitHub] [flink] wangxlong commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

wangxlong commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r547069026 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcBatchingOutputFormat.java ## @@ -179,11

[GitHub] [flink] xintongsong commented on pull request #14456: [FLINK-20519][hbase] Fix NOTICE file for bundled dependencies in flink-sql-connector-hbase-2.2

xintongsong commented on pull request #14456: URL: https://github.com/apache/flink/pull/14456#issuecomment-749338661 @zentol, would you have time to take a look? This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-20519) Extend HBase notice with transitively bundled dependencies

[ https://issues.apache.org/jira/browse/FLINK-20519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20519: --- Labels: pull-request-available (was: ) > Extend HBase notice with transitively bundled

[GitHub] [flink] xintongsong opened a new pull request #14456: [FLINK-20519][hbase] Fix NOTICE file for bundled dependencies in flink-sql-connector-hbase-2.2

xintongsong opened a new pull request #14456: URL: https://github.com/apache/flink/pull/14456 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] xiaoHoly commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

xiaoHoly commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r547066842 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactory.java ## @@ -322,6

[GitHub] [flink] flinkbot commented on pull request #14455: [FLINK-20706][table-planner-blink] Separate the implementation of BatchExecUnion and StreamExecUnion

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

[GitHub] [flink] flinkbot edited a comment on pull request #14454: [FLINK-20705][table-planner-blink] Separate the implementation of BatchExecValues and StreamExecValues

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

[jira] [Commented] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253272#comment-17253272 ] Jark Wu commented on FLINK-20552: - [~meijies], yes, I also find it's not easy to get SinkOperator from

[GitHub] [flink] flinkbot edited a comment on pull request #14453: [FLINK-20703][table] HiveSinkCompactionITCase test timeout

flinkbot edited a comment on pull request #14453: URL: https://github.com/apache/flink/pull/14453#issuecomment-749326588 ## CI report: * 7444fb9f69f7c34ff78a4872033414d45c1a9901 Azure:

[GitHub] [flink] flinkbot commented on pull request #14454: [FLINK-20705][table-planner-blink] Separate the implementation of BatchExecValues and StreamExecValues

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

[GitHub] [flink] flinkbot edited a comment on pull request #14452: [FLINK-20710][Hive] HiveTableInputFormat throws IllegalArgumentException when creating splits for tables with partitions on different

flinkbot edited a comment on pull request #14452: URL: https://github.com/apache/flink/pull/14452#issuecomment-749326545 ## CI report: * ba07d2c9d8311e27035cdadd84fd1fca9e7e232c Azure:

[GitHub] [flink] flinkbot commented on pull request #14455: [FLINK-20706][table-planner-blink] Separate the implementation of BatchExecUnion and StreamExecUnion

flinkbot commented on pull request #14455: URL: https://github.com/apache/flink/pull/14455#issuecomment-749330323 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-20706) Separate the implementation of BatchExecUnion and StreamExecUnion

[ https://issues.apache.org/jira/browse/FLINK-20706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20706: --- Labels: pull-request-available (was: ) > Separate the implementation of BatchExecUnion and

[jira] [Assigned] (FLINK-20706) Separate the implementation of BatchExecUnion and StreamExecUnion

[ https://issues.apache.org/jira/browse/FLINK-20706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20706: -- Assignee: godfrey he > Separate the implementation of BatchExecUnion and StreamExecUnion >

[GitHub] [flink] godfreyhe opened a new pull request #14455: [FLINK-20706][table-planner-blink] Separate the implementation of BatchExecUnion and StreamExecUnion

godfreyhe opened a new pull request #14455: URL: https://github.com/apache/flink/pull/14455 ## What is the purpose of the change *Separate the implementation of BatchExecUnion and StreamExecUnion* ## Brief change log - *Introduce StreamPhysicalUnion, and make

[jira] [Commented] (FLINK-20710) HiveTableInputFormat throws IllegalArgumentException when creating splits for tables with partitions on different hdfs nameservices

[ https://issues.apache.org/jira/browse/FLINK-20710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253267#comment-17253267 ] laystax commented on FLINK-20710: - Hi [~lzljs3620320], could you please take a look at this? Thank you

[jira] [Commented] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253266#comment-17253266 ] Yang Wang commented on FLINK-20648: --- Yes, the {{KubernetesLeaderElector#run}} is started in a separate

[GitHub] [flink] leonardBang commented on a change in pull request #14084: [FLINK-15867][table-planner-blink] Support time-related types for FIRST_VALUE and LAST_VALUE aggregate functions

leonardBang commented on a change in pull request #14084: URL: https://github.com/apache/flink/pull/14084#discussion_r547050151 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/AggFunctionFactory.scala ## @@ -480,15

[jira] [Created] (FLINK-20711) Parameter enumeration value error in ES doc

孙铮 created FLINK-20711: -- Summary: Parameter enumeration value error in ES doc Key: FLINK-20711 URL: https://issues.apache.org/jira/browse/FLINK-20711 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-20704) Some rel data type does not implement the digest correctly

[ https://issues.apache.org/jira/browse/FLINK-20704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20704: --- Assignee: Danny Chen > Some rel data type does not implement the digest correctly >

[GitHub] [flink] wuchong commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

wuchong commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r547057104 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcBatchingOutputFormat.java ## @@ -179,11

[GitHub] [flink] flinkbot commented on pull request #14453: [FLINK-20703][table] HiveSinkCompactionITCase test timeout

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

[GitHub] [flink] flinkbot commented on pull request #14452: [FLINK-20710][Hive] HiveTableInputFormat throws IllegalArgumentException when creating splits for tables with partitions on different hdfs n

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

[GitHub] [flink] flinkbot edited a comment on pull request #14443: [FLINK-20690][table-planner-blink] Separate the implementation of BatchExecCorrelate and StreamExecCorrelate

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

[GitHub] [flink] flinkbot edited a comment on pull request #14451: [FLINK-20704][table-planner] Some rel data type does not implement th…

flinkbot edited a comment on pull request #14451: URL: https://github.com/apache/flink/pull/14451#issuecomment-749321360 ## CI report: * ab709c5979a892af8c01e736f85364ecd535788e Azure:

[GitHub] [flink] flinkbot commented on pull request #14454: [FLINK-20705][table-planner-blink] Separate the implementation of BatchExecValues and StreamExecValues

flinkbot commented on pull request #14454: URL: https://github.com/apache/flink/pull/14454#issuecomment-749325670 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-web] Jennifer88huang opened a new pull request #403: [blog] Add Pulsar Flink Connector blog

Jennifer88huang opened a new pull request #403: URL: https://github.com/apache/flink-web/pull/403 ### Modification Contribute the blog to Flink website. This is an automated message from the Apache Git Service. To

[jira] [Assigned] (FLINK-20705) Separate the implementation of BatchExecValues and StreamExecValues

[ https://issues.apache.org/jira/browse/FLINK-20705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20705: -- Assignee: godfrey he > Separate the implementation of BatchExecValues and StreamExecValues >

[jira] [Updated] (FLINK-20705) Separate the implementation of BatchExecValues and StreamExecValues

[ https://issues.apache.org/jira/browse/FLINK-20705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20705: --- Labels: pull-request-available (was: ) > Separate the implementation of BatchExecValues

[GitHub] [flink] godfreyhe opened a new pull request #14454: [FLINK-20705][table-planner-blink] Separate the implementation of BatchExecValues and StreamExecValues

godfreyhe opened a new pull request #14454: URL: https://github.com/apache/flink/pull/14454 ## What is the purpose of the change *Separate the implementation of BatchExecValues and StreamExecValues* ## Brief change log - *Introduce StreamPhysicalValues, and make

[GitHub] [flink] wuchong commented on a change in pull request #14444: [FLINK-20091][avro] add ignore-parse-error for

wuchong commented on a change in pull request #1: URL: https://github.com/apache/flink/pull/1#discussion_r547049153 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java ## @@ -85,9 +88,27 @@ public

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

V1ncentzzZ commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r547052214 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactory.java ## @@ -322,6

[GitHub] [flink] flinkbot commented on pull request #14453: [FLINK-20703][table] HiveSinkCompactionITCase test timeout

flinkbot commented on pull request #14453: URL: https://github.com/apache/flink/pull/14453#issuecomment-749321764 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

  1   2   3   4   5   >