clear query| facets| time Search criteria: .   Results from 1 to 10 from 1268 (0.0s).
Loading phrases to help you
refine your search...
[BEAM-7126] Double encoding of state keys in portable Flink runner - Beam - [issue]
...State keys currently need to be encoded as NESTED. My attempt to use the ByteString directly in BEAM-7112 caused checkpointing to fail. We should look into eliminating the redundant key enco...    Author: Thomas Weise , 2019-06-14, 08:59
Updating Kinesis Connector to latest Apache licensed libs - Flink - [mail # dev]
...Dyana, thanks for taking this up!The flink-connector-kinesis module is already part of the CI pipeline, itis just excluded when creating the release. So what needs to be done is toremove the...
   Author: Thomas Weise , 2019-06-14, 08:31
Adding Contributors in JIRA - Beam - [mail # dev]
...Hi Austin,All PMC members have access to add users to the contributor role. I canhelp you during the workshop.ThomasOn Mon, Jun 10, 2019, 11:23 PM Austin Bennett wrote:> Hi Devs,>> ...
   Author: Thomas Weise , 2019-06-11, 20:02
[BEAM-7141] Expose kv and window parameters for on_timer - Beam - [issue]
...We would like to have access to key and window inside the timer callback. Without, it is also difficult to debug. We run into this while working on BEAM-7112...    Author: Thomas Weise , 2019-06-10, 15:13
[expand - 2 more] - [Discuss] Ideas for Apache Beam presence in social media - Beam - [mail # dev]
...Here is an idea how this could be done: Create a JIRA ticket that willalways remain open. Have folks append their suggested tweets as comments.Interested PMC members can watch that ticket.Th...
   Author: Thomas Weise , 2019-06-07, 17:05
[expand - 1 more] - [VOTE] Release 2.13.0, release candidate #2 - Beam - [mail # dev]
...+1 and I think all of that can be covered with JIRA.Irrespective the release manager still needs to pay attention to thecommunication on the VOTE thread.On Wed, Jun 5, 2019 at 9:19 AM Ahmet ...
   Author: Thomas Weise , 2019-06-05, 16:22
[BEAM-7348] Option to expire SDK worker environments - Beam - [issue]
...We discovered that Python SDK workers are susceptible to memory leaks that are quite hard to identify and/or fix. This becomes an issue in streaming pipelines, where the workers run "forever...    Author: Thomas Weise , 2019-06-04, 19:19
[BEAM-6829] Duplicate metric warnings clutter log - Beam - [issue]
...Logs fill up quickly with these warnings: WARN org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a Metric with the name ......    Author: Thomas Weise , 2019-06-04, 10:01
[FLINK-10921] Prioritize shard consumers in Kinesis Consumer by event time - Flink - [issue]
...Shard consumer threads currently emit records directly. In order to align shards by event time, decouple shard consumer threads and emitter with a queue, as described in [1].[1&#...    Author: Thomas Weise , 2019-05-31, 19:17
[DISCUSS] Autoformat python code with Black - Beam - [mail # dev]
...Thanks Ismaël for bringing this up. Dealing with Py lint issues has beenpainful and unproductive.For the Java side it became ./gradlew spotlessApply and there is no lookingback. To get there...
   Author: Thomas Weise , 2019-05-29, 17:27