[jira] [Commented] (FLINK-11186) Event-time balancing for multiple Kafka partitions

[ https://issues.apache.org/jira/browse/FLINK-11186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725627#comment-16725627 ] Paul Lin commented on FLINK-11186: -- [~tschamberger] Your reasoning is right. For the di

[jira] [Comment Edited] (FLINK-11174) flink Metrics Prometheus labels support chinese

[ https://issues.apache.org/jira/browse/FLINK-11174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725618#comment-16725618 ] lamber-ken edited comment on FLINK-11174 at 12/20/18 6:38 AM:

[jira] [Commented] (FLINK-11174) flink Metrics Prometheus labels support chinese

[ https://issues.apache.org/jira/browse/FLINK-11174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725618#comment-16725618 ] lamber-ken commented on FLINK-11174: hi, [~fanweiwen], you can follow [https://flin

[GitHub] klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#issuecomment-448885155 @azagrebin @zentol thank you for the review, I've just updated the code, leave the logic of `g

[GitHub] dianfu commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction

dianfu commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction URL: https://github.com/apache/flink/pull/7237#discussion_r243160395 ## File path: flink-libraries/flink-table/src/main/scala/org/a

[GitHub] yxu-valleytider commented on a change in pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink

yxu-valleytider commented on a change in pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink URL: https://github.com/apache/flink/pull/6968#discussion_r243132804 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/fli

[GitHub] walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction

walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction URL: https://github.com/apache/flink/pull/7237#discussion_r243154482 ## File path: flink-libraries/flink-table/src/main/scala/or

[jira] [Closed] (FLINK-11077) Make subtask aware of the timeout of checkpoint and abort the current ongoing asynccheckpoint

[ https://issues.apache.org/jira/browse/FLINK-11077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aitozi closed FLINK-11077. -- Resolution: Won't Fix > Make subtask aware of the timeout of checkpoint and abort the current ongoing > async

[GitHub] dianfu commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction

dianfu commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction URL: https://github.com/apache/flink/pull/7237#discussion_r243143806 ## File path: flink-libraries/flink-table/src/main/scala/org/a

[GitHub] hequn8128 edited a comment on issue #6236: [FLINK-9699] [table] Add api to replace registered table

hequn8128 edited a comment on issue #6236: [FLINK-9699] [table] Add api to replace registered table URL: https://github.com/apache/flink/pull/6236#issuecomment-448821407 Hi @bowenli86 , great to have your comments from the perspective of Catalog. I had taken a look at the Catalog API. It s

[GitHub] Clarkkkkk commented on issue #7258: [FLINK-11084]Throw a hard exception to remind developers while there's no stream node between two split transformation

Clark commented on issue #7258: [FLINK-11084]Throw a hard exception to remind developers while there's no stream node between two split transformation URL: https://github.com/apache/flink/pull/7258#issuecomment-448830390 cc @dawidwys ---

[GitHub] yxu-valleytider commented on a change in pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink

yxu-valleytider commented on a change in pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink URL: https://github.com/apache/flink/pull/6968#discussion_r243132804 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/fli

[GitHub] yxu-valleytider commented on a change in pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink

yxu-valleytider commented on a change in pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink URL: https://github.com/apache/flink/pull/6968#discussion_r243132531 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/fli

[GitHub] hequn8128 commented on issue #6236: [FLINK-9699] [table] Add api to replace registered table

hequn8128 commented on issue #6236: [FLINK-9699] [table] Add api to replace registered table URL: https://github.com/apache/flink/pull/6236#issuecomment-448821407 Hi @bowenli86 , thanks for your advice. The internal replace flag may fit well with the API of Catalog. The flag can be rep

[jira] [Commented] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725476#comment-16725476 ] lining commented on FLINK-11162: @Chesnay Schepler, thanks your reply. Maybe we need dis

[GitHub] aljoscha commented on a change in pull request #7313: [FLINK-11116][fs-connector] Removed randomness from HDFS and Local fs writers.

aljoscha commented on a change in pull request #7313: [FLINK-6][fs-connector] Removed randomness from HDFS and Local fs writers. URL: https://github.com/apache/flink/pull/7313#discussion_r243039964 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/r

[GitHub] joerg84 commented on issue #7338: Fixed comment about scala versions.

joerg84 commented on issue #7338: Fixed comment about scala versions. URL: https://github.com/apache/flink/pull/7338#issuecomment-448706656 > This is incorrect as Flink 1.7 also builds with scala 2.12. 👍 This is an automa

[GitHub] bowenli86 commented on issue #6236: [FLINK-9699] [table] Add api to replace registered table

bowenli86 commented on issue #6236: [FLINK-9699] [table] Add api to replace registered table URL: https://github.com/apache/flink/pull/6236#issuecomment-448693612 I got your points. Sounds good. Thanks This is an automated me

[GitHub] walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction

walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction URL: https://github.com/apache/flink/pull/7237#discussion_r243014619 ## File path: flink-libraries/flink-table/src/main/scala/or

[GitHub] walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction

walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction URL: https://github.com/apache/flink/pull/7237#discussion_r243015377 ## File path: flink-libraries/flink-table/src/main/scala/or

[GitHub] XuQianJin-Stars commented on issue #7318: [FLINK-11099][Table API&SQL] Migrate flink-table runtime CRow Types classes

XuQianJin-Stars commented on issue #7318: [FLINK-11099][Table API&SQL] Migrate flink-table runtime CRow Types classes URL: https://github.com/apache/flink/pull/7318#issuecomment-448658898 @twalthr I update the branch or do a force push. thanks qianjin -

[GitHub] aljoscha commented on a change in pull request #7313: [FLINK-11116][fs-connector] Removed randomness from HDFS and Local fs writers.

aljoscha commented on a change in pull request #7313: [FLINK-6][fs-connector] Removed randomness from HDFS and Local fs writers. URL: https://github.com/apache/flink/pull/7313#discussion_r242982233 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/r

[GitHub] kl0u removed a comment on issue #7313: [FLINK-11116][fs-connector] Removed randomness from HDFS and Local fs writers.

kl0u removed a comment on issue #7313: [FLINK-6][fs-connector] Removed randomness from HDFS and Local fs writers. URL: https://github.com/apache/flink/pull/7313#issuecomment-448653987 Yes, this is why I said "if the FS allows it". Thanks for the review @igalshilman ! I will merge... -

[GitHub] kl0u commented on issue #7313: [FLINK-11116][fs-connector] Removed randomness from HDFS and Local fs writers.

kl0u commented on issue #7313: [FLINK-6][fs-connector] Removed randomness from HDFS and Local fs writers. URL: https://github.com/apache/flink/pull/7313#issuecomment-448653987 Yes, this is why I said "if the FS allows it". Thanks for the review @igalshilman ! I will merge... -

[GitHub] kl0u commented on issue #7313: [FLINK-11116][fs-connector] Removed randomness from HDFS and Local fs writers.

kl0u commented on issue #7313: [FLINK-6][fs-connector] Removed randomness from HDFS and Local fs writers. URL: https://github.com/apache/flink/pull/7313#issuecomment-448653989 Yes, this is why I said "if the FS allows it". Thanks for the review @igalshilman ! I will merge... -

[jira] [Commented] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725145#comment-16725145 ] Alex Vinnik commented on FLINK-11143: - [~QiLuo] we tried it, but it didn't solve the

[jira] [Commented] (FLINK-11201) flink-test-utils dependency issue

[ https://issues.apache.org/jira/browse/FLINK-11201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725130#comment-16725130 ] eugen yushin commented on FLINK-11201: -- at the same time, looks like to sbt issue m

[jira] [Comment Edited] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak

[ https://issues.apache.org/jira/browse/FLINK-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725121#comment-16725121 ] Nawaid Shamim edited comment on FLINK-9080 at 12/19/18 3:49 PM: ---

[jira] [Commented] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak

[ https://issues.apache.org/jira/browse/FLINK-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725121#comment-16725121 ] Nawaid Shamim commented on FLINK-9080: -- *Workaround:* Copy Flink job JAR into /usr/l

[jira] [Updated] (FLINK-11205) Task Manager Metaspace Memory Leak

[ https://issues.apache.org/jira/browse/FLINK-11205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nawaid Shamim updated FLINK-11205: -- Attachment: Screenshot 2018-12-18 at 15.47.55.png > Task Manager Metaspace Memory Leak >

[jira] [Commented] (FLINK-11205) Task Manager Metaspace Memory Leak

[ https://issues.apache.org/jira/browse/FLINK-11205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725120#comment-16725120 ] Nawaid Shamim commented on FLINK-11205: --- *Workaround:* Copy Flink job JAR into /us

[jira] [Updated] (FLINK-11205) Task Manager Metaspace Memory Leak

[ https://issues.apache.org/jira/browse/FLINK-11205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nawaid Shamim updated FLINK-11205: -- Attachment: (was: Screenshot 2018-12-18 at 12.12.15.png) > Task Manager Metaspace Memory L

[jira] [Updated] (FLINK-11205) Task Manager Metaspace Memory Leak

[ https://issues.apache.org/jira/browse/FLINK-11205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nawaid Shamim updated FLINK-11205: -- Attachment: Screenshot 2018-12-18 at 12.12.15.png > Task Manager Metaspace Memory Leak >

[jira] [Updated] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak

[ https://issues.apache.org/jira/browse/FLINK-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nawaid Shamim updated FLINK-9080: - Attachment: Screenshot 2018-12-18 at 12.14.11.png > Flink Scheduler goes OOM, suspecting a memory

[jira] [Commented] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak

[ https://issues.apache.org/jira/browse/FLINK-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725118#comment-16725118 ] Nawaid Shamim commented on FLINK-9080: -- I noticed similar issue on job restarts - h

[jira] [Commented] (FLINK-11202) Split log file per job

[ https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725111#comment-16725111 ] vinoyang commented on FLINK-11202: -- OK, Got it. Before I start this issue, I will provi

[jira] [Commented] (FLINK-10317) Configure Metaspace size by default

[ https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725116#comment-16725116 ] Nawaid Shamim commented on FLINK-10317: --- I noticed similar issue on job restart -

[jira] [Updated] (FLINK-10317) Configure Metaspace size by default

[ https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nawaid Shamim updated FLINK-10317: -- Attachment: Screenshot 2018-12-18 at 12.14.11.png > Configure Metaspace size by default >

[jira] [Commented] (FLINK-11202) Split log file per job

[ https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725108#comment-16725108 ] Chesnay Schepler commented on FLINK-11202: -- This was brought up before and I ca

[jira] [Commented] (FLINK-11201) flink-test-utils dependency issue

[ https://issues.apache.org/jira/browse/FLINK-11201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725115#comment-16725115 ] eugen yushin commented on FLINK-11201: -- It's a behavior change which is not reflect

[jira] [Updated] (FLINK-11205) Task Manager Metaspace Memory Leak

[ https://issues.apache.org/jira/browse/FLINK-11205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nawaid Shamim updated FLINK-11205: -- Description: Job Restarts causes task manager to dynamically load duplicate classes. Metaspac

[jira] [Updated] (FLINK-11205) Task Manager Metaspace Memory Leak

[ https://issues.apache.org/jira/browse/FLINK-11205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nawaid Shamim updated FLINK-11205: -- Description: Job Restarts causes task manager to dynamically load duplicate classes. Metaspac

[jira] [Updated] (FLINK-11205) Task Manager Metaspace Memory Leak

[ https://issues.apache.org/jira/browse/FLINK-11205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nawaid Shamim updated FLINK-11205: -- Description: Job Restarts causes task manager to dynamically load duplicate classes. Metaspac

[jira] [Created] (FLINK-11205) Task Manager Metaspace Memory Leak

Nawaid Shamim created FLINK-11205: - Summary: Task Manager Metaspace Memory Leak Key: FLINK-11205 URL: https://issues.apache.org/jira/browse/FLINK-11205 Project: Flink Issue Type: Bug Aff

[jira] [Assigned] (FLINK-11202) Split log file per job

[ https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11202: Assignee: vinoyang > Split log file per job > -- > > Key: FLI

[jira] [Commented] (FLINK-11202) Split log file per job

[ https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725083#comment-16725083 ] vinoyang commented on FLINK-11202: -- [~Zentol] Do you think we should split log file per

[GitHub] zentol removed a comment on issue #7338: Fixed comment about scala versions.

zentol removed a comment on issue #7338: Fixed comment about scala versions. URL: https://github.com/apache/flink/pull/7338#issuecomment-448621648 This is incorrect as Flink 1.7 also builds with scala 2.12. The entire section nee

[GitHub] zentol commented on issue #7338: Fixed comment about scala versions.

zentol commented on issue #7338: Fixed comment about scala versions. URL: https://github.com/apache/flink/pull/7338#issuecomment-448621648 This is incorrect as Flink 1.7 also builds with scala 2.12. The entire section nee Thi

[GitHub] zentol commented on issue #7338: Fixed comment about scala versions.

zentol commented on issue #7338: Fixed comment about scala versions. URL: https://github.com/apache/flink/pull/7338#issuecomment-448621675 This is incorrect as Flink 1.7 also builds with scala 2.12. This is an automated messag

[jira] [Updated] (FLINK-11202) Split log file per job

[ https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11202: - Description: Debugging issues is difficult since Task-/JobManagers create a single log f

[jira] [Updated] (FLINK-11202) Split log file per job

[ https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11202: - Summary: Split log file per job (was: log split file, every job has one log file ) > S

[jira] [Commented] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725045#comment-16725045 ] Chesnay Schepler commented on FLINK-11162: -- No. As I said _before_ you opened y

[jira] [Commented] (FLINK-11200) Port DataView classes to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-11200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725040#comment-16725040 ] Hequn Cheng commented on FLINK-11200: - [~twalthr] Make sense, I will try to follow y

[GitHub] twalthr commented on issue #7318: [FLINK-11099][Table API&SQL] Migrate flink-table runtime CRow Types classes

twalthr commented on issue #7318: [FLINK-11099][Table API&SQL] Migrate flink-table runtime CRow Types classes URL: https://github.com/apache/flink/pull/7318#issuecomment-448610899 @XuQianJin-Stars no need for a new PR, just update the branch or do a force push. Thanks. -

[jira] [Comment Edited] (FLINK-11200) Port DataView classes to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-11200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725032#comment-16725032 ] Timo Walther edited comment on FLINK-11200 at 12/19/18 2:14 PM: --

[jira] [Commented] (FLINK-11200) Port DataView classes to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-11200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725032#comment-16725032 ] Timo Walther commented on FLINK-11200: -- You are right. I haven't seen the transitiv

[GitHub] igalshilman commented on issue #7313: [FLINK-11116][fs-connector] Removed randomness from HDFS and Local fs writers.

igalshilman commented on issue #7313: [FLINK-6][fs-connector] Removed randomness from HDFS and Local fs writers. URL: https://github.com/apache/flink/pull/7313#issuecomment-448601803 Good point @kl0u, however in HDFS there would be a single writer at a time, protected by the writer lea

[jira] [Commented] (FLINK-11204) flink start-scala-shell.sh do not work in security mode with kerberos authentication.

[ https://issues.apache.org/jira/browse/FLINK-11204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724997#comment-16724997 ] Jeff Zhang commented on FLINK-11204: Do you run kinit before starting scala-shell ?

[GitHub] joerg84 commented on issue #7338: Fixed comment about scala versions.

joerg84 commented on issue #7338: Fixed comment about scala versions. URL: https://github.com/apache/flink/pull/7338#issuecomment-448596345 @fhueske PTAL This is an automated message from the Apache Git Service. To respond to

[GitHub] joerg84 opened a new pull request #7338: Fixed comment about scala versions.

joerg84 opened a new pull request #7338: Fixed comment about scala versions. URL: https://github.com/apache/flink/pull/7338 ## 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 wa

[GitHub] jinglining commented on issue #7325: [FLINK-11162][rest] Provide a rest API to list all logical operators

jinglining commented on issue #7325: [FLINK-11162][rest] Provide a rest API to list all logical operators URL: https://github.com/apache/flink/pull/7325#issuecomment-448594791 @zentol can you review it. This is an automated m

[jira] [Commented] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724995#comment-16724995 ] lining commented on FLINK-11162: [~Zentol] I have pushed the code， can you review it. >

[jira] [Updated] (FLINK-11204) flink start-scala-shell.sh do not work in security mode with kerberos authentication.

[ https://issues.apache.org/jira/browse/FLINK-11204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kelun wang updated FLINK-11204: --- Description: Hello, When using flink start-scala-shell.sh in a cluster with kerberos credential, t

[GitHub] zentol commented on issue #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

zentol commented on issue #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#issuecomment-448593297 Will address my last comment while merging. ---

[jira] [Created] (FLINK-11204) flink start-scala-shell.sh do not work in security mode with kerberos authentication.

kelun wang created FLINK-11204: -- Summary: flink start-scala-shell.sh do not work in security mode with kerberos authentication. Key: FLINK-11204 URL: https://issues.apache.org/jira/browse/FLINK-11204 Pro

[GitHub] dawidwys commented on issue #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

dawidwys commented on issue #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#issuecomment-448590963 Just to sum up my review. - Personally would prefer method `execute(String jobName, Sa

[GitHub] zentol closed pull request #7319: [hotfix][typo] fix typo in MLUtils

zentol closed pull request #7319: [hotfix][typo] fix typo in MLUtils URL: https://github.com/apache/flink/pull/7319 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request

[GitHub] zentol closed pull request #7337: [hotfix] Fix typos in ExecutionGraph

zentol closed pull request #7337: [hotfix] Fix typos in ExecutionGraph URL: https://github.com/apache/flink/pull/7337 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull reque

[GitHub] zentol commented on issue #7337: [hotfix] Fix typos in ExecutionGraph

zentol commented on issue #7337: [hotfix] Fix typos in ExecutionGraph URL: https://github.com/apache/flink/pull/7337#issuecomment-448589639 This typo does not affect the semantics of the variable, but merging this PR would obfuscate the git history. I will hence close the PR; it just

[GitHub] mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r242907203 ## File path: flink-streaming-java/src/main/java/org/apache/flink/stream

[GitHub] kisimple opened a new pull request #7337: [hotfix] Fix typos in ExecutionGraph

kisimple opened a new pull request #7337: [hotfix] Fix typos in ExecutionGraph URL: https://github.com/apache/flink/pull/7337 topologially -> topologically Rename the parameter. This is an automated message from the Apache

[jira] [Commented] (FLINK-11201) flink-test-utils dependency issue

[ https://issues.apache.org/jira/browse/FLINK-11201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724969#comment-16724969 ] Chesnay Schepler commented on FLINK-11201: -- In 1.6 the MiniClusterResource resi

[jira] [Created] (FLINK-11203) FunctionContext of AggregateFunction will not be initialized for window GroupBy

Hequn Cheng created FLINK-11203: --- Summary: FunctionContext of AggregateFunction will not be initialized for window GroupBy Key: FLINK-11203 URL: https://issues.apache.org/jira/browse/FLINK-11203 Project

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r242903778 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/

[GitHub] zentol opened a new pull request #7336: [FLINK-11194][hbase] Use type instead of classifier

zentol opened a new pull request #7336: [FLINK-11194][hbase] Use type instead of classifier URL: https://github.com/apache/flink/pull/7336 ## What is the purpose of the change The hbase-connector module has been disabling the shade-plugin due to an infinite loop that occurs when cre

[jira] [Updated] (FLINK-11194) missing Scala 2.12 build of HBase connector

[ https://issues.apache.org/jira/browse/FLINK-11194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11194: --- Labels: artifact build hbase pull-request-available scala (was: artifact build hbase scala)

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r242901812 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/

[jira] [Commented] (FLINK-11198) Access to MetricGroup in an AggregateFunction(Non Rich)

[ https://issues.apache.org/jira/browse/FLINK-11198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724959#comment-16724959 ] Hequn Cheng commented on FLINK-11198: - [~chiggi_dev] Thanks for opening the issue. I

[GitHub] zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r242899744 ## File path: flink-connectors/flink-connector-cassandra/src/main/java/or

[GitHub] zentol commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

zentol commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r242898360 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/mai

[jira] [Assigned] (FLINK-11198) Access to MetricGroup in an AggregateFunction(Non Rich)

[ https://issues.apache.org/jira/browse/FLINK-11198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-11198: --- Assignee: Hequn Cheng > Access to MetricGroup in an AggregateFunction(Non Rich) > -

[GitHub] dawidwys commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

dawidwys commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r242894460 ## File path: flink-streaming-java/src/main/java/org/apache/flink/s

[GitHub] kl0u edited a comment on issue #7313: [FLINK-11116][fs-connector] Removed randomness from HDFS and Local fs writers.

kl0u edited a comment on issue #7313: [FLINK-6][fs-connector] Removed randomness from HDFS and Local fs writers. URL: https://github.com/apache/flink/pull/7313#issuecomment-448570597 Actually the only scenario where the randomness in the tmp files can help is in the case where we have

[GitHub] kl0u commented on issue #7313: [FLINK-11116][fs-connector] Removed randomness from HDFS and Local fs writers.

kl0u commented on issue #7313: [FLINK-6][fs-connector] Removed randomness from HDFS and Local fs writers. URL: https://github.com/apache/flink/pull/7313#issuecomment-448570597 Actually the only scenario where the randomness in the tmp files can help is in the case where we have a "spli

[GitHub] kl0u edited a comment on issue #7313: [FLINK-11116][fs-connector] Removed randomness from HDFS and Local fs writers.

kl0u edited a comment on issue #7313: [FLINK-6][fs-connector] Removed randomness from HDFS and Local fs writers. URL: https://github.com/apache/flink/pull/7313#issuecomment-448570597 Actually the only scenario where the randomness in the tmp files can help is in the case where we have

[GitHub] kl0u edited a comment on issue #7313: [FLINK-11116][fs-connector] Removed randomness from HDFS and Local fs writers.

kl0u edited a comment on issue #7313: [FLINK-6][fs-connector] Removed randomness from HDFS and Local fs writers. URL: https://github.com/apache/flink/pull/7313#issuecomment-448570597 Actually the only scenario where the randomness in the tmp files can help is in the case where we have

[GitHub] kl0u edited a comment on issue #7313: [FLINK-11116][fs-connector] Removed randomness from HDFS and Local fs writers.

kl0u edited a comment on issue #7313: [FLINK-6][fs-connector] Removed randomness from HDFS and Local fs writers. URL: https://github.com/apache/flink/pull/7313#issuecomment-448519244 Thanks for the review @igalshilman ! I am not sure for the reason for introducing the randomness

[jira] [Commented] (FLINK-11201) flink-test-utils dependency issue

[ https://issues.apache.org/jira/browse/FLINK-11201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724931#comment-16724931 ] eugen yushin commented on FLINK-11201: -- it works like a charm in 1.6, so I think so

[jira] [Closed] (FLINK-11180) ProcessFailureCancelingITCase#testCancelingOnProcessFailure

[ https://issues.apache.org/jira/browse/FLINK-11180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11180. Resolution: Fixed Fix Version/s: 1.8.0 1.7.2 master: b02121c4673

[GitHub] zentol closed pull request #7327: [FLINK-11180][tests] Fix ProcessFailureCancelingITCase.testCancelingOnProcessFailure error by specifying a free port

zentol closed pull request #7327: [FLINK-11180][tests] Fix ProcessFailureCancelingITCase.testCancelingOnProcessFailure error by specifying a free port URL: https://github.com/apache/flink/pull/7327 This is a PR merged from a forked repository. As GitHub hides the original diff on merge,

[GitHub] mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r242884502 ## File path: flink-streaming-java/src/main/java/org/apache/flink/stream

[GitHub] mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r242884359 ## File path: flink-streaming-java/src/main/java/org/apache/flink/stream

[GitHub] dawidwys closed pull request #7321: [hotfix] Fix typo in AbstractStreamOperator

dawidwys closed pull request #7321: [hotfix] Fix typo in AbstractStreamOperator URL: https://github.com/apache/flink/pull/7321 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign p

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724901#comment-16724901 ] Maximilian Michels commented on FLINK-10672: No, [~thw] just set the Fix Ver

[GitHub] dawidwys closed pull request #7335: Release 1.7

dawidwys closed pull request #7335: Release 1.7 URL: https://github.com/apache/flink/pull/7335 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to

[jira] [Commented] (FLINK-11186) Event-time balancing for multiple Kafka partitions

[ https://issues.apache.org/jira/browse/FLINK-11186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724899#comment-16724899 ] Tom Schamberger commented on FLINK-11186: - [~Paul Lin] The proposed source inter

[jira] [Commented] (FLINK-11201) flink-test-utils dependency issue

[ https://issues.apache.org/jira/browse/FLINK-11201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724897#comment-16724897 ] Chesnay Schepler commented on FLINK-11201: -- flink-test-utils has a dependency o

[jira] [Commented] (FLINK-11194) missing Scala 2.12 build of HBase connector

[ https://issues.apache.org/jira/browse/FLINK-11194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724896#comment-16724896 ] Chesnay Schepler commented on FLINK-11194: -- hmmm..so t's not that flink

[jira] [Updated] (FLINK-11198) Access to MetricGroup in an AggregateFunction(Non Rich)

[ https://issues.apache.org/jira/browse/FLINK-11198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11198: - Fix Version/s: (was: 1.6.3) > Access to MetricGroup in an AggregateFunction(Non Rich

[jira] [Assigned] (FLINK-11194) missing Scala 2.12 build of HBase connector

[ https://issues.apache.org/jira/browse/FLINK-11194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-11194: Assignee: Chesnay Schepler (was: vinoyang) > missing Scala 2.12 build of HBase c

  1   2   >