[jira] [Closed] (FLINK-12216) Respect the number of bytes from input parameters in HybridMemorySegment

2019-11-07 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-12216. > Respect the number of bytes from input parameters in HybridMemorySegment >

[jira] [Resolved] (FLINK-12216) Respect the number of bytes from input parameters in HybridMemorySegment

2019-11-07 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-12216. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Created] (FLINK-14658) Drop ".returns()" for TypeInformation in the DataStream API

2019-11-07 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-14658: Summary: Drop ".returns()" for TypeInformation in the DataStream API Key: FLINK-14658 URL: https://issues.apache.org/jira/browse/FLINK-14658 Project: Flink

[jira] [Commented] (FLINK-14642) Flink TupleSerializer and CaseClassSerializer shoud support copy NULL values

2019-11-07 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969306#comment-16969306 ] Stephan Ewen commented on FLINK-14642: -- Seems reasonable to me. Do you want to prepare a patch for

[jira] [Assigned] (FLINK-14654) Fix the arguments number mismatching with placeholders in log statements

2019-11-07 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-14654: Assignee: Yun Tang > Fix the arguments number mismatching with placeholders in log

[jira] [Commented] (FLINK-14654) Fix the arguments number mismatching with placeholders in log statements

2019-11-07 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969299#comment-16969299 ] Stephan Ewen commented on FLINK-14654: -- Makes sense to fix those, thanks for looking at this. >

[jira] [Assigned] (FLINK-14652) Refactor checkpointing related parts into one place on task side

2019-11-07 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-14652: Assignee: Yun Tang > Refactor checkpointing related parts into one place on task side >

[jira] [Commented] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

2019-11-07 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969289#comment-16969289 ] Stephan Ewen commented on FLINK-13856: -- [~andrew_lin] S3 FS is faking recursive deletes. It makes a

[jira] [Resolved] (FLINK-13469) Resource used by StateMapSnapshot can not be released if snapshot fails

2019-11-06 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13469. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Closed] (FLINK-13469) Resource used by StateMapSnapshot can not be released if snapshot fails

2019-11-06 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13469. > Resource used by StateMapSnapshot can not be released if snapshot fails >

[jira] [Closed] (FLINK-13034) Improve the performance when checking whether mapstate is empty for RocksDBStateBackend

2019-11-06 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13034. > Improve the performance when checking whether mapstate is empty for > RocksDBStateBackend >

[jira] [Resolved] (FLINK-13034) Improve the performance when checking whether mapstate is empty for RocksDBStateBackend

2019-11-06 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13034. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Commented] (FLINK-14635) Don't use relocated imports in Kinesis End-2-End Tests

2019-11-06 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968495#comment-16968495 ] Stephan Ewen commented on FLINK-14635: -- The main issue is that records coming from the Flink

[jira] [Created] (FLINK-14635) Don't use relocated imports in Kinesis End-2-End Tests

2019-11-06 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-14635: Summary: Don't use relocated imports in Kinesis End-2-End Tests Key: FLINK-14635 URL: https://issues.apache.org/jira/browse/FLINK-14635 Project: Flink Issue

[jira] [Commented] (FLINK-14380) Type Extractor POJO setter check does not allow for Immutable Case Class

2019-10-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952835#comment-16952835 ] Stephan Ewen commented on FLINK-14380: -- [~elliotvilhelm] What [~aljoscha] mentioned is that the

[jira] [Commented] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

2019-10-03 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943577#comment-16943577 ] Stephan Ewen commented on FLINK-14118: -- Did we have significant changes in that part of the network

[jira] [Commented] (FLINK-14225) Travis is unable to parse one of the secure environment variables

2019-10-03 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943574#comment-16943574 ] Stephan Ewen commented on FLINK-14225: -- Do you know which variable that is? I am not aware of any

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

2019-10-03 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943572#comment-16943572 ] Stephan Ewen commented on FLINK-13417: -- Sorry for having been out of this thread for a while. If

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-09-30 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16941325#comment-16941325 ] Stephan Ewen commented on FLINK-14123: -- [~xintongsong][~azagrebin] Given that in the future, we

[jira] [Commented] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

2019-09-27 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939689#comment-16939689 ] Stephan Ewen commented on FLINK-13808: -- Thank you [~klion26] for the debugging and the suggestion

[jira] [Commented] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

2019-09-27 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939683#comment-16939683 ] Stephan Ewen commented on FLINK-13808: -- [~Caesar] yes, each checkpoint spawns per task a background

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-09-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934441#comment-16934441 ] Stephan Ewen commented on FLINK-14123: -- Would the behavior be the same when using G1 GC? Or CMS?

[jira] [Commented] (FLINK-14035) Introduce/Change some log for snapshot to better analysis checkpoint problem

2019-09-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934202#comment-16934202 ] Stephan Ewen commented on FLINK-14035: -- [~klion26] no problem and no need to apologize. That is

[jira] [Commented] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

2019-09-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934194#comment-16934194 ] Stephan Ewen commented on FLINK-14118: -- I agree, looking at the code, in theory there should be no

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-09-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934190#comment-16934190 ] Stephan Ewen commented on FLINK-14123: -- Thanks! What GC were you using? G1, CMS, Parallel? The logs

[jira] [Closed] (FLINK-13845) Drop all the content of removed "Checkpointed" interface

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13845. > Drop all the content of removed "Checkpointed" interface >

[jira] [Resolved] (FLINK-13845) Drop all the content of removed "Checkpointed" interface

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13845. -- Fix Version/s: 1.9.1 Resolution: Fixed Fixed in - 1.9.1 via

[jira] [Closed] (FLINK-13796) Remove unused variable

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13796. > Remove unused variable > -- > > Key: FLINK-13796 >

[jira] [Closed] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-9941. --- > Flush in ScalaCsvOutputFormat before close method > -

[jira] [Resolved] (FLINK-13796) Remove unused variable

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13796. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Resolved] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-9941. - Fix Version/s: 1.9.1 1.10.0 Resolution: Fixed Fixed in - 1.9.1 via

[jira] [Resolved] (FLINK-13449) Add ARM architecture to MemoryArchitecture

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13449. -- Fix Version/s: 1.9.1 1.10.0 Resolution: Fixed Fixed in - 1.9.1

[jira] [Closed] (FLINK-13449) Add ARM architecture to MemoryArchitecture

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13449. > Add ARM architecture to MemoryArchitecture > -- > >

[jira] [Resolved] (FLINK-11859) Improve SpanningRecordSerializer performance by serializing record length to serialization buffer directly

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-11859. -- Resolution: Fixed Fixed via 35e57a8460c7f03010972f587bb24052ea694cce > Improve

[jira] [Closed] (FLINK-11859) Improve SpanningRecordSerializer performance by serializing record length to serialization buffer directly

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-11859. > Improve SpanningRecordSerializer performance by serializing record length to > serialization

[jira] [Closed] (FLINK-13896) Scala 2.11 maven compile should target Java 1.8

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13896. > Scala 2.11 maven compile should target Java 1.8 > --- >

[jira] [Resolved] (FLINK-13896) Scala 2.11 maven compile should target Java 1.8

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13896. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Reopened] (FLINK-13796) Remove unused variable

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reopened FLINK-13796: -- Assignee: Fokko Driesprong > Remove unused variable > -- > >

[jira] [Commented] (FLINK-13796) Remove unused variable

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933243#comment-16933243 ] Stephan Ewen commented on FLINK-13796: -- I think it is okay to merge this. Removing dead code makes

[jira] [Assigned] (FLINK-13449) Add ARM architecture to MemoryArchitecture

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-13449: Assignee: wangxiyuan > Add ARM architecture to MemoryArchitecture >

[jira] [Commented] (FLINK-13652) Setup instructions for creating an ARM environment

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933225#comment-16933225 ] Stephan Ewen commented on FLINK-13652: -- What do you think about adding some guides about how to do

[jira] [Commented] (FLINK-13598) frocksdb doesn't have arm release

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933222#comment-16933222 ] Stephan Ewen commented on FLINK-13598: -- I think we are trying to move back to more vanilla RocksDB

[jira] [Assigned] (FLINK-13450) Adjust tests to tolerate arithmetic differences between x86 and ARM

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-13450: Assignee: wangxiyuan > Adjust tests to tolerate arithmetic differences between x86 and

[jira] [Commented] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933200#comment-16933200 ] Stephan Ewen commented on FLINK-14118: -- Great diagnosis and great fix! Do we have any data as to

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-09-19 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933186#comment-16933186 ] Stephan Ewen commented on FLINK-14123: -- I get the reasoning behind this, it probably makes sense.

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

2019-09-18 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932720#comment-16932720 ] Stephan Ewen commented on FLINK-14112: -- >From the RM / JM side (leader contender) can we treat the

[jira] [Commented] (FLINK-13985) Use native memory for managed memory.

2019-09-17 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931307#comment-16931307 ] Stephan Ewen commented on FLINK-13985: -- I would put {{allocate()}} and void {{release(long)}} in a

[jira] [Commented] (FLINK-13862) Remove or rewrite Execution Plan docs

2019-09-12 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928682#comment-16928682 ] Stephan Ewen commented on FLINK-13862: -- Is that plan visualizer something we want to keep

[jira] [Commented] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

2019-09-12 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928515#comment-16928515 ] Stephan Ewen commented on FLINK-14034: -- I would suggest to go with the variant that does not extend

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

2019-09-12 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928511#comment-16928511 ] Stephan Ewen commented on FLINK-13025: -- [~lilyevsky] would you be up to working closely together

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

2019-09-12 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928499#comment-16928499 ] Stephan Ewen commented on FLINK-13417: -- @Tison would it be safer to shade Flink's ZK and then let

[jira] [Commented] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout

2019-09-11 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927487#comment-16927487 ] Stephan Ewen commented on FLINK-14038: -- What happened here is that the update to a partition

[jira] [Commented] (FLINK-13445) Distinguishing Memory Configuration for TaskManager and JobManager

2019-09-11 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927365#comment-16927365 ] Stephan Ewen commented on FLINK-13445: -- Agreed, we should do this for the master process the same

[jira] [Commented] (FLINK-13985) Use native memory for managed memory.

2019-09-11 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927357#comment-16927357 ] Stephan Ewen commented on FLINK-13985: -- Can you share some details about the exact mechanics? In

[jira] [Commented] (FLINK-13996) Maven instructions for 3.3+ do not cover all shading special cases

2019-09-11 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927352#comment-16927352 ] Stephan Ewen commented on FLINK-13996: -- We want to remove the shading logic from the file systems

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

2019-09-11 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927347#comment-16927347 ] Stephan Ewen commented on FLINK-13025: -- Regarding committer, we need to look for someone else to

[jira] [Updated] (FLINK-14049) Update error message for failed partition updates to include task name

2019-09-11 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-14049: - Fix Version/s: 1.8.3 > Update error message for failed partition updates to include task name >

[jira] [Updated] (FLINK-14049) Update error message for failed partition updates to include task name

2019-09-11 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-14049: - Fix Version/s: 1.10.0 > Update error message for failed partition updates to include task name

[jira] [Created] (FLINK-14049) Update error message for failed partition updates to include task name

2019-09-11 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-14049: Summary: Update error message for failed partition updates to include task name Key: FLINK-14049 URL: https://issues.apache.org/jira/browse/FLINK-14049 Project:

[jira] [Commented] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

2019-09-11 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927324#comment-16927324 ] Stephan Ewen commented on FLINK-14034: -- I agree, to make things clear, the current design,

[jira] [Commented] (FLINK-14035) Introduce/Change some log for snapshot to better analysis checkpoint problem

2019-09-11 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927322#comment-16927322 ] Stephan Ewen commented on FLINK-14035: -- -1 I think we originally had these log statements on INFO

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

2019-09-09 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16925864#comment-16925864 ] Stephan Ewen commented on FLINK-13025: -- Would the other contributors in this discussion agree with

[jira] [Commented] (FLINK-13445) Distinguishing Memory Configuration for TaskManager and JobManager

2019-09-09 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16925783#comment-16925783 ] Stephan Ewen commented on FLINK-13445: -- Hi David! Flink 1.10 will not have the {{heap-cutoff}}

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

2019-09-09 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16925583#comment-16925583 ] Stephan Ewen commented on FLINK-13417: -- @Tison is that a mismatch between ZK versions now? That the

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

2019-09-09 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16925580#comment-16925580 ] Stephan Ewen commented on FLINK-13025: -- Having an ElasticSearch 7 connector makes sense. I am also

[jira] [Commented] (FLINK-13958) Job class loader may not be reused after batch job recovery

2019-09-09 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16925516#comment-16925516 ] Stephan Ewen commented on FLINK-13958: -- We had a similar problem initially with RocksDB. The

[jira] [Created] (FLINK-13862) Remove or rewrite Execution Plan docs

2019-08-26 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-13862: Summary: Remove or rewrite Execution Plan docs Key: FLINK-13862 URL: https://issues.apache.org/jira/browse/FLINK-13862 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-13791) Speed up sidenav by using group_by

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13791. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Closed] (FLINK-13791) Speed up sidenav by using group_by

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13791. > Speed up sidenav by using group_by > -- > > Key:

[jira] [Closed] (FLINK-13726) Build docs with jekyll 4.0.0.pre.beta1

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13726. > Build docs with jekyll 4.0.0.pre.beta1 > -- > >

[jira] [Resolved] (FLINK-13726) Build docs with jekyll 4.0.0.pre.beta1

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13726. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Resolved] (FLINK-13725) Use sassc for faster doc generation

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13725. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Resolved] (FLINK-13729) Update website generation dependencies

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13729. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Closed] (FLINK-13729) Update website generation dependencies

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13729. > Update website generation dependencies > -- > >

[jira] [Closed] (FLINK-13725) Use sassc for faster doc generation

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13725. > Use sassc for faster doc generation > --- > > Key:

[jira] [Closed] (FLINK-13723) Use liquid-c for faster doc generation

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13723. > Use liquid-c for faster doc generation > -- > >

[jira] [Resolved] (FLINK-13723) Use liquid-c for faster doc generation

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13723. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Closed] (FLINK-13724) Remove unnecessary whitespace from the docs' sidenav

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13724. > Remove unnecessary whitespace from the docs' sidenav >

[jira] [Resolved] (FLINK-13724) Remove unnecessary whitespace from the docs' sidenav

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13724. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Commented] (FLINK-13728) Fix wrong closing tag order in sidenav

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915723#comment-16915723 ] Stephan Ewen commented on FLINK-13728: -- Fixed in 1.9.1 via 9ba0a8906e24fa864a89df65edbc95c25ec3f6dd

[jira] [Closed] (FLINK-13728) Fix wrong closing tag order in sidenav

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13728. > Fix wrong closing tag order in sidenav > -- > >

[jira] [Updated] (FLINK-13728) Fix wrong closing tag order in sidenav

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-13728: - Fix Version/s: 1.9.1 > Fix wrong closing tag order in sidenav >

[jira] [Updated] (FLINK-13728) Fix wrong closing tag order in sidenav

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-13728: - Fix Version/s: 1.10.0 > Fix wrong closing tag order in sidenav >

[jira] [Resolved] (FLINK-13728) Fix wrong closing tag order in sidenav

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13728. -- Resolution: Fixed Fixed via b1c2e213302cd68758761c60a1ccff85c5c67203 > Fix wrong closing tag

[jira] [Commented] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

2019-08-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915667#comment-16915667 ] Stephan Ewen commented on FLINK-13856: -- In general, that is a good idea. However, this is an

[jira] [Assigned] (FLINK-13799) Web Job Submit Page displays stream of error message when web submit is disables in the config

2019-08-22 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-13799: Assignee: Yadong Xie > Web Job Submit Page displays stream of error message when web

[jira] [Commented] (FLINK-13799) Web Job Submit Page displays stream of error message when web submit is disables in the config

2019-08-22 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913110#comment-16913110 ] Stephan Ewen commented on FLINK-13799: -- The old web UI hid the "submit job" page alltogether, when

[jira] [Commented] (FLINK-13770) Bump Netty to 4.1.39.Final

2019-08-22 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913084#comment-16913084 ] Stephan Ewen commented on FLINK-13770: -- Side note: We still use "NIO" as the default type, we could

[jira] [Assigned] (FLINK-13779) PrometheusPushGatewayReporter support push metrics with groupingKey

2019-08-22 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-13779: Assignee: Kaibo Zhou > PrometheusPushGatewayReporter support push metrics with

[jira] [Commented] (FLINK-13779) PrometheusPushGatewayReporter support push metrics with groupingKey

2019-08-22 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913083#comment-16913083 ] Stephan Ewen commented on FLINK-13779: -- Sounds like a useful feature. I assigned the issue to you.

[jira] [Commented] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

2019-08-22 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913079#comment-16913079 ] Stephan Ewen commented on FLINK-13808: -- [~carp84] FYI > Checkpoints expired by timeout may leak

[jira] [Commented] (FLINK-13806) Metric Fetcher floods the JM log with errors when TM is lost

2019-08-22 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913077#comment-16913077 ] Stephan Ewen commented on FLINK-13806: -- Setting to DEBUG level sounds good. > Metric Fetcher

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2019-08-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16912188#comment-16912188 ] Stephan Ewen commented on FLINK-10333: -- Great, thanks so much [~Tison] for the insights into the

[jira] [Created] (FLINK-13806) Metric Fetcher floods the JM log with errors when TM is lost

2019-08-20 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-13806: Summary: Metric Fetcher floods the JM log with errors when TM is lost Key: FLINK-13806 URL: https://issues.apache.org/jira/browse/FLINK-13806 Project: Flink

[jira] [Created] (FLINK-13805) Bad Error Message when TaskManager is lost

2019-08-20 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-13805: Summary: Bad Error Message when TaskManager is lost Key: FLINK-13805 URL: https://issues.apache.org/jira/browse/FLINK-13805 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911428#comment-16911428 ] Stephan Ewen commented on FLINK-13798: -- FYI: I believe one outcome of FLIP-27 will be to drop the

[jira] [Created] (FLINK-13799) Web Job Submit Page displays stream of error message when web submit is disables in the config

2019-08-20 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-13799: Summary: Web Job Submit Page displays stream of error message when web submit is disables in the config Key: FLINK-13799 URL: https://issues.apache.org/jira/browse/FLINK-13799

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2019-08-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911394#comment-16911394 ] Stephan Ewen commented on FLINK-10333: -- Quick question: Do we have an idea if the transactional

[jira] [Created] (FLINK-13795) Web UI logs errors when selecting Checkpoint Tab for Batch Jobs

2019-08-20 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-13795: Summary: Web UI logs errors when selecting Checkpoint Tab for Batch Jobs Key: FLINK-13795 URL: https://issues.apache.org/jira/browse/FLINK-13795 Project: Flink

[jira] [Commented] (FLINK-13717) allow to set taskmanager.host and taskmanager.bind-host separately

2019-08-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911137#comment-16911137 ] Stephan Ewen commented on FLINK-13717: -- My suggestion would be to - Set the default for "bind"

  1   2   3   4   5   6   7   8   9   10   >