commits
Thread
Date
Earlier messages
Messages by Thread
[GitHub] incubator-beam pull request #1680: [BEAM-XXX] Make KVCoder more efficient by...
dhalperi
[jira] [Commented] (BEAM-1201) Remove producesSortedKeys from Source
ASF GitHub Bot (JIRA)
[jira] [Updated] (BEAM-1201) Remove producesSortedKeys from BoundedSource
Daniel Halperin (JIRA)
[jira] [Updated] (BEAM-1201) Remove producesSortedKeys from Source
Daniel Halperin (JIRA)
[GitHub] incubator-beam pull request #1679: [BEAM-1201] Remove BoundedSource.produces...
dhalperi
[jira] [Commented] (BEAM-469) NullableCoder optimized encoding via passthrough context
Daniel Halperin (JIRA)
[jira] [Commented] (BEAM-469) NullableCoder optimized encoding via passthrough context
ASF GitHub Bot (JIRA)
[1/3] incubator-beam git commit: Add Parameters to finishSpecifying
tgroh
[3/3] incubator-beam git commit: This closes #1582
tgroh
[2/3] incubator-beam git commit: Use CountingSource in ForceStreamingTest
tgroh
[1/2] incubator-beam git commit: Add support for date partitioned table names
robertwb
[2/2] incubator-beam git commit: Closes #1534
robertwb
[1/2] incubator-beam git commit: Fixing inconsistencies in PipelineOptions
robertwb
[2/2] incubator-beam git commit: Closes #1526
robertwb
[jira] [Created] (BEAM-1202) Coders should have meaningful equals methods
Thomas Groh (JIRA)
[jira] [Updated] (BEAM-1202) Coders should have meaningful equals methods
Thomas Groh (JIRA)
[jira] [Created] (BEAM-1201) Remove producesSortedKeys from Source
Daniel Halperin (JIRA)
[01/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-core module to TestPipeline as a JUnit rule. Plus, fixed some checkstyle errors from previous modules' migration.
kenn
[12/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-mongodb module to TestPipeline as a JUnit rule.
kenn
[21/51] [abbrv] incubator-beam git commit: This closes #1652: Move InMemoryTimerInternals to runners-core
kenn
[15/51] [abbrv] incubator-beam git commit: Add some key-preserving to KeyedPValueTrackingVisitor
kenn
[20/51] [abbrv] incubator-beam git commit: Move InMemoryTimerInternals to runners-core
kenn
[25/51] [abbrv] incubator-beam git commit: [BEAM-1097] Provide a better error message for non-existing gcpTempLocation
kenn
[19/51] [abbrv] incubator-beam git commit: Restore SDK's InMemoryTimerInternals, deprecated
kenn
[32/51] [abbrv] incubator-beam git commit: This closes #1668: Remove deprecated InMemoryTimerInternals from SDK
kenn
[22/51] [abbrv] incubator-beam git commit: This closes #1581: [BEAM-1117] Port direct runner StatefulParDo to KeyedWorkItem
kenn
[06/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-jms module to TestPipeline as a JUnit rule.
kenn
[11/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-java8tests module to TestPipeline as a JUnit rule + fixed WithTimestampsJava8Test.withTimestampsLambdaShouldApplyTimestamps.
kenn
[18/51] [abbrv] incubator-beam git commit: Port direct runner StatefulParDo to KeyedWorkItem
kenn
[17/51] [abbrv] incubator-beam git commit: Move responsibility for knowing about keyedness into EvaluationContext
kenn
[26/51] [abbrv] incubator-beam git commit: Remove deprecated AggregatorFactory from SDK
kenn
[07/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-jdbc module to TestPipeline as a JUnit rule.
kenn
[03/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-core module to TestPipeline as a JUnit rule. Plus, fixed some checkstyle errors from previous modules' migration.
kenn
[31/51] [abbrv] incubator-beam git commit: This closes #1569
kenn
[33/51] [abbrv] incubator-beam git commit: Require TimeDomain to delete a timer
kenn
[13/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-kinesis module to TestPipeline as a JUnit rule.
kenn
[24/51] [abbrv] incubator-beam git commit: Provide a better error message for non-existing gcpTempLocation
kenn
[30/51] [abbrv] incubator-beam git commit: Provide local tags in PInput, POutput expansions
kenn
[14/51] [abbrv] incubator-beam git commit: This closes #1664: [BEAM-1176] Migrating tests to use TestPipeline as a JUnit rule
kenn
[39/51] [abbrv] incubator-beam git commit: This closes #1160: Support set and delete of timer by ID in InMemoryTimerInternals
kenn
[29/51] [abbrv] incubator-beam git commit: Remove deprecated InMemoryTimerInternals from SDK
kenn
[16/51] [abbrv] incubator-beam git commit: Propagate key through ParDo if DoFn is key-preserving
kenn
[23/51] [abbrv] incubator-beam git commit: Fixup usage of canonical name with name since canonical name != name for inner classes.
kenn
[05/51] [abbrv] incubator-beam git commit: Migrated the beam-runners-core module to TestPipeline as a JUnit rule.
kenn
[10/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-extensions-join-library module to TestPipeline as a JUnit rule.
kenn
[09/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-extensions-sorter module to TestPipeline as a JUnit rule.
kenn
[04/51] [abbrv] incubator-beam git commit: Migrated the beam-runners-direct-java module to TestPipeline as a JUnit rule.
kenn
[02/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-core module to TestPipeline as a JUnit rule. Plus, fixed some checkstyle errors from previous modules' migration.
kenn
[08/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-google-cloud-platform module to TestPipeline as a JUnit rule.
kenn
[34/51] [abbrv] incubator-beam git commit: Move ExecutionContext and related classes to runners-core
kenn
[27/51] [abbrv] incubator-beam git commit: Update Dataflow worker to beam-master-20161220
kenn
[37/51] [abbrv] incubator-beam git commit: This closes #1666: Move ExecutionContext and related classes to runners-core
kenn
[48/51] [abbrv] incubator-beam git commit: Use informative Instant formatter in WatermarkHold
kenn
[42/51] [abbrv] incubator-beam git commit: This closes #1670: Fixes for direct runner expansion and evaluation of stateful ParDo
kenn
[40/51] [abbrv] incubator-beam git commit: Actually propagate and commit state in direct runner
kenn
[28/51] [abbrv] incubator-beam git commit: This closes #1665: Remove deprecated AggregatorFactory from SDK
kenn
[36/51] [abbrv] incubator-beam git commit: This closes #1673: Require TimeDomain to delete a timer
kenn
[51/51] [abbrv] incubator-beam git commit: This closes #1676: Merge master (57d9bbd) into python-sdk
kenn
[38/51] [abbrv] incubator-beam git commit: Support set and delete of timer by ID in InMemoryTimerInternals
kenn
[35/51] [abbrv] incubator-beam git commit: Update Dataflow worker to beam-master-20161221
kenn
[47/51] [abbrv] incubator-beam git commit: Hold output watermark according to pending timers
kenn
[43/51] [abbrv] incubator-beam git commit: Add informative Instant formatter to BoundedWindow
kenn
[41/51] [abbrv] incubator-beam git commit: Fix windowing in direct runner Stateful ParDo
kenn
[44/51] [abbrv] incubator-beam git commit: Add static Window.withOutputTimeFn to match build method
kenn
[45/51] [abbrv] incubator-beam git commit: Add UsesTestStream for use with JUnit @Category
kenn
[46/51] [abbrv] incubator-beam git commit: Allow setting timer by ID in DirectTimerInternals
kenn
[49/51] [abbrv] incubator-beam git commit: This closes #1669: Preliminaries for timers in the direct runner
kenn
[50/51] [abbrv] incubator-beam git commit: Merge remote-tracking branch 'origin/master' into python-sdk
kenn
[jira] [Commented] (BEAM-1198) ViewFn: explicitly decouple runner materialization of side inputs from SDK-specific mapping
ASF GitHub Bot (JIRA)
[GitHub] incubator-beam pull request #1678: [BEAM-1198, BEAM-846, BEAM-260] Refactor ...
kennknowles
[jira] [Assigned] (BEAM-1198) ViewFn: explicitly decouple runner materialization of side inputs from SDK-specific mapping
Kenneth Knowles (JIRA)
[GitHub] incubator-beam pull request #1677: Add a Test for Flatten with Heterogeneous...
tgroh
[GitHub] incubator-beam pull request #1676: Merge remote-tracking branch 'origin/mast...
aaltay
[GitHub] incubator-beam pull request #1676: Merge remote-tracking branch 'origin/mast...
asfgit
[jira] [Created] (BEAM-1200) PubsubIO should allow for a user to supply the function which computes the watermark that is reported
Luke Cwik (JIRA)
[1/7] incubator-beam git commit: Add informative Instant formatter to BoundedWindow
kenn
[7/7] incubator-beam git commit: This closes #1669: Preliminaries for timers in the direct runner
kenn
[4/7] incubator-beam git commit: Allow setting timer by ID in DirectTimerInternals
kenn
[2/7] incubator-beam git commit: Hold output watermark according to pending timers
kenn
[3/7] incubator-beam git commit: Use informative Instant formatter in WatermarkHold
kenn
[5/7] incubator-beam git commit: Add static Window.withOutputTimeFn to match build method
kenn
[6/7] incubator-beam git commit: Add UsesTestStream for use with JUnit @Category
kenn
[jira] [Commented] (BEAM-1194) DataflowRunner should test a variety of valid tempLocation/stagingLocation/etc formats.
ASF GitHub Bot (JIRA)
[jira] [Commented] (BEAM-1194) DataflowRunner should test a variety of valid tempLocation/stagingLocation/etc formats.
ASF GitHub Bot (JIRA)
[GitHub] incubator-beam pull request #1675: [Beam-1186] Migrating the remaining tests...
staslev
[jira] [Created] (BEAM-1199) Condense recordAsOutput, finishSpecifyingOutput from POutput
Thomas Groh (JIRA)
[jira] [Comment Edited] (BEAM-846) Decouple side input window mapping from WindowFn
Kenneth Knowles (JIRA)
[jira] [Updated] (BEAM-1193) Give Coders URNs and document their binary formats outside the Java code base
Kenneth Knowles (JIRA)
[jira] [Updated] (BEAM-653) Refine specification for WindowFn.isCompatible()
Kenneth Knowles (JIRA)
[1/3] incubator-beam git commit: Actually propagate and commit state in direct runner
kenn
[3/3] incubator-beam git commit: This closes #1670: Fixes for direct runner expansion and evaluation of stateful ParDo
kenn
[2/3] incubator-beam git commit: Fix windowing in direct runner Stateful ParDo
kenn
[jira] [Created] (BEAM-1198) ViewFn: explicitly decouple runner materialization of side inputs from SDK-specific mapping
Kenneth Knowles (JIRA)
[jira] [Closed] (BEAM-1003) Enable caching of side-input dependent computations
Kenneth Knowles (JIRA)
[jira] [Updated] (BEAM-260) WindowMappingFn: Know the getSideInputWindow upper bound to release side input resources
Kenneth Knowles (JIRA)
[jira] [Updated] (BEAM-260) WindowMappingFn: Know the getSideInputWindow upper bound to release side input resources
Kenneth Knowles (JIRA)
[01/50] incubator-beam git commit: Closes #1622
kenn
[34/50] incubator-beam git commit: This closes #1640: Show timestamps on log lines in Jenkins
kenn
[17/50] incubator-beam git commit: This closes #1614: Spark runner: Force streaming execution on batch pipelines for testing
kenn
[07/50] incubator-beam git commit: Revert "Removes ArgumentProvider.windowingInternals"
kenn
[45/50] incubator-beam git commit: Disable automatic archiving of Maven builds
kenn
[13/50] incubator-beam git commit: Test that SimpleDoFnRunner wraps exceptions in startBundle and finishBundle
kenn
[03/50] incubator-beam git commit: checkstyle: missed newline in DistributionCell
kenn
[06/50] incubator-beam git commit: Revert "Moves DoFnAdapters to runners-core"
kenn
[24/50] incubator-beam git commit: This closes #1595, makes TestPipeline a JUnit rule
kenn
[48/50] incubator-beam git commit: [BEAM-79] Update to latest Gearpump API
kenn
[42/50] incubator-beam git commit: This closes #1631: Change counter name in TestDataflowRunner
kenn
[47/50] incubator-beam git commit: Merge branch 'master' of https://github.com/apache/incubator-beam into gearpump-runner
kenn
[21/50] incubator-beam git commit: This closes #1612: [BEAM-27] Support timer setting and receiving in SimpleDoFnRunner
kenn
[26/50] incubator-beam git commit: [BEAM-716] Use AutoValue in JmsIO
kenn
[11/50] incubator-beam git commit: This closes #1648: Undeletes DoFnInvokers.of(OldDoFn)
kenn
[12/50] incubator-beam git commit: Make TimerSpec and StateSpec fields accessible
kenn
[19/50] incubator-beam git commit: BigQueryIO: fix streaming write, typo in API
kenn
[22/50] incubator-beam git commit: [BEAM-85, BEAM-298] Make TestPipeline a JUnit Rule checking proper usage
kenn
[08/50] incubator-beam git commit: Revert "Removes code for wrapping DoFn as an OldDoFn"
kenn
[36/50] incubator-beam git commit: This closes #1657: Fix seed job fetch spec
kenn
[04/50] incubator-beam git commit: Closes #1649
kenn
[39/50] incubator-beam git commit: More escaping in Jenkins timestamp spec
kenn
[32/50] incubator-beam git commit: This closes #1655: [BEAM-1178] Make naming of logger objects consistent
kenn
[38/50] incubator-beam git commit: Closes #1638
kenn
[05/50] incubator-beam git commit: Revert "Move InMemoryTimerInternals to runners-core"
kenn
[25/50] incubator-beam git commit: Fix grammar error (repeated for)
kenn
[09/50] incubator-beam git commit: View.asMap: minor javadoc fixes
kenn
[10/50] incubator-beam git commit: Closes #1650
kenn
[29/50] incubator-beam git commit: [BEAM-1178] Make naming of logger objects consistent
kenn
[35/50] incubator-beam git commit: Fix seed job fetch spec
kenn
[41/50] incubator-beam git commit: Change counter name in TestDataflowRunner
kenn
[14/50] incubator-beam git commit: Add timer support to DoFnRunner(s)
kenn
[16/50] incubator-beam git commit: [BEAM-853] Force streaming execution on batch pipelines for testing. Expose the adapted source.
kenn
[28/50] incubator-beam git commit: [BEAM-716] This closes #1577
kenn
[27/50] incubator-beam git commit: [BEAM-716] Fix javadoc on with* methods [BEAM-959] Improve check preconditions in JmsIO
kenn
[23/50] incubator-beam git commit: Empty TestPipeline need not be run
kenn
[33/50] incubator-beam git commit: Show timestamps on log lines in Jenkins
kenn
[20/50] incubator-beam git commit: Change counter name in TestDataflowRunner
kenn
[37/50] incubator-beam git commit: Add RunnableOnService test for Metrics
kenn
[46/50] incubator-beam git commit: Closes #1656
kenn
[18/50] incubator-beam git commit: Closes #1651
kenn
[31/50] incubator-beam git commit: This closes #1632
kenn
[50/50] incubator-beam git commit: This closes #1663: Merge master (b3de17b) into gearpump-runner
kenn
[44/50] incubator-beam git commit: [BEAM-59] initial interfaces and classes of Beam FileSystem
kenn
[43/50] incubator-beam git commit: [BEAM-59] initial interfaces and classes of Beam FileSystem.
kenn
[49/50] incubator-beam git commit: [BEAM-79] Upgrade to beam-0.5.0-incubating-SNAPSHOT
kenn
[40/50] incubator-beam git commit: This closes #1659: More escaping in Jenkins timestamp spec
kenn
[02/50] incubator-beam git commit: Make {Metric, Counter, Distribution}Cell public
kenn
[30/50] incubator-beam git commit: [BEAM-1165] Fix unexpected file creation when checking dependencies
kenn
[15/50] incubator-beam git commit: Use empty SideInputReader, fixes NPE in SimpleDoFnRunnerTest
kenn
[jira] [Created] (BEAM-1197) Slowly-changing external data as a side input
Eugene Kirpichov (JIRA)
[jira] [Updated] (BEAM-430) Introducing gcpTempLocation that default to tempLocation
Luke Cwik (JIRA)
[jira] [Closed] (BEAM-430) Introducing gcpTempLocation that default to tempLocation
Luke Cwik (JIRA)
[jira] [Resolved] (BEAM-430) Introducing gcpTempLocation that default to tempLocation
Luke Cwik (JIRA)
[jira] [Reopened] (BEAM-430) Introducing gcpTempLocation that default to tempLocation
Luke Cwik (JIRA)
[GitHub] incubator-beam pull request #662: [BEAM-115] WIP: JSON Schema definition of ...
kennknowles
Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #2195
Apache Jenkins Server
Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #2196
Apache Jenkins Server
Re: Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #2195
Dan Halperin
[jira] [Created] (BEAM-1196) Serialize/deserialize Pipeline/TransformHierarchy to JSON
Kenneth Knowles (JIRA)
[jira] [Created] (BEAM-1195) Give triggers URNs / JSON formats
Kenneth Knowles (JIRA)
[jira] [Updated] (BEAM-1194) DataflowRunner should test a variety of valid tempLocation/stagingLocation/etc formats.
Daniel Halperin (JIRA)
[jira] [Created] (BEAM-1194) DataflowRunner should test a variety of valid tempLocation/stagingLocation/etc formats.
Daniel Halperin (JIRA)
[jira] [Updated] (BEAM-1192) Give transforms URNs, use them instead of instanceof checks
Kenneth Knowles (JIRA)
[jira] [Updated] (BEAM-1192) Give transforms URNs, use them instead of instanceof checks
Kenneth Knowles (JIRA)
[jira] [Created] (BEAM-1193) Give Coders URNs and document their binary formats outside the Java code base
Kenneth Knowles (JIRA)
[1/2] incubator-beam git commit: Support set and delete of timer by ID in InMemoryTimerInternals
kenn
[2/2] incubator-beam git commit: This closes #1160: Support set and delete of timer by ID in InMemoryTimerInternals
kenn
[1/3] incubator-beam git commit: Move ExecutionContext and related classes to runners-core
kenn
[2/3] incubator-beam git commit: Update Dataflow worker to beam-master-20161221
kenn
[3/3] incubator-beam git commit: This closes #1666: Move ExecutionContext and related classes to runners-core
kenn
Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Apex #83
Apache Jenkins Server
Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Apex #84
Apache Jenkins Server
Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Apex #85
Apache Jenkins Server
Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Apex #86
Apache Jenkins Server
Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Apex #87
Apache Jenkins Server
[jira] [Updated] (BEAM-115) Beam Runner API
Kenneth Knowles (JIRA)
[jira] [Created] (BEAM-1192) Add URNs to known transforms instead of using instanceof checks
Kenneth Knowles (JIRA)
[1/2] incubator-beam git commit: Require TimeDomain to delete a timer
kenn
[2/2] incubator-beam git commit: This closes #1673: Require TimeDomain to delete a timer
kenn
[jira] [Resolved] (BEAM-1178) Make naming of logger objects consistent
JIRA
[jira] [Reopened] (BEAM-1178) Make naming of logger objects consistent
JIRA
[jira] [Resolved] (BEAM-1165) Unexpected file created when checking dependencies on clean repo
JIRA
[jira] [Reopened] (BEAM-1165) Unexpected file created when checking dependencies on clean repo
JIRA
[1/2] incubator-beam git commit: Remove deprecated InMemoryTimerInternals from SDK
kenn
[2/2] incubator-beam git commit: This closes #1668: Remove deprecated InMemoryTimerInternals from SDK
kenn
[GitHub] incubator-beam pull request #1674: [BEAM-1146] Decrease spark runner startup...
aviemzur
[jira] [Assigned] (BEAM-1145) Remove classifier from shaded spark runner artifact
Aviem Zur (JIRA)
[jira] [Assigned] (BEAM-1144) Spark runner fails to deserialize MicrobatchSource in cluster mode
Aviem Zur (JIRA)
[jira] [Assigned] (BEAM-1146) Decrease spark runner startup overhead
Aviem Zur (JIRA)
[jira] [Created] (BEAM-1191) Eliminate OldDoFn from the SDK
Kenneth Knowles (JIRA)
[jira] [Resolved] (BEAM-498) Make DoFnWithContext the new DoFn
Kenneth Knowles (JIRA)
[GitHub] incubator-beam pull request #1673: [BEAM-27] Require TimeDomain to delete a ...
kennknowles
[GitHub] incubator-beam pull request #1673: [BEAM-27] Require TimeDomain to delete a ...
asfgit
[GitHub] incubator-beam pull request #1672: [Beam-625] Peak memory reduction in Avro ...
katsiapis
[GitHub] incubator-beam pull request #1671: [BEAM-XXX] Add DataflowLocationIT
dhalperi
[GitHub] incubator-beam pull request #1671: [BEAM-1194] Add DataflowLocationIT
dhalperi
[GitHub] incubator-beam pull request #1671: [BEAM-1194] Add DataflowLocationIT
dhalperi
[jira] [Comment Edited] (BEAM-1190) FileBasedSource should ignore files that matched the glob but don't exist
Daniel Halperin (JIRA)
[jira] [Comment Edited] (BEAM-1190) FileBasedSource should ignore files that matched the glob but don't exist
Paul Findlay (JIRA)
[jira] [Comment Edited] (BEAM-1190) FileBasedSource should ignore files that matched the glob but don't exist
Daniel Halperin (JIRA)
Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Spark #517
Apache Jenkins Server
Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Spark #518
Apache Jenkins Server
Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Spark #518
Apache Jenkins Server
Earlier messages