Marko Kreen [Thu, 18 Oct 2012 12:20:49 +0000 (05:20 -0700)]
Merge pull request #14 from beaglecode/get_working_in_smartos
Add check to see if the socket library is required
Marko Kreen [Thu, 18 Oct 2012 12:19:03 +0000 (05:19 -0700)]
Merge pull request #15 from askoja/master
Two more merge related tests
Asko Oja [Thu, 18 Oct 2012 10:23:54 +0000 (10:23 +0000)]
Two merge related tests created.
merge_all tests simple merge from two partitions into one target
Also tests adding columns through cascade
merge_qnode tests same thing as merge all but uses also qnodes
Marko Kreen [Thu, 18 Oct 2012 08:28:00 +0000 (11:28 +0300)]
Move find-copy logic into separate module
Marko Kreen [Thu, 18 Oct 2012 08:15:35 +0000 (11:15 +0300)]
Move --find-copy-node logic to 'copy'
This allows use of this switch also in merge situations,
where the node is different in each partition.
Marko Kreen [Thu, 18 Oct 2012 08:13:40 +0000 (11:13 +0300)]
Fix compare expression - md5() was in wrong place
Marko Kreen [Tue, 16 Oct 2012 11:51:12 +0000 (14:51 +0300)]
londiste execute: when ddl is already applied, restore db mode
When doing early exit, the code forgot to set proper mode.
Marko Kreen [Tue, 16 Oct 2012 11:05:35 +0000 (14:05 +0300)]
londiste: don't filter EXECUTE or TRUNCATE events
They used to be filtered in merge nodes, but it does not
make sense anymore.
EXECUTE tracking is global now, not per-queue, thus filtering
is wrong now.
TRUNCATE does not seem to make sense in case of merged queue, but
filtering also does not make sense. So let it pass down,
maybe there is scenariou where it is useful.
Marko Kreen [Tue, 16 Oct 2012 11:04:45 +0000 (14:04 +0300)]
Allow overrided options with --set to show up in --ini output
Tony Arkles [Fri, 12 Oct 2012 04:16:33 +0000 (04:16 +0000)]
Add check to see if the socket library is required
This is necessary to get Skytools to build successfully on SmartOS, where you
have to explicitly add -lsocket when using socket calls.
Marko Kreen [Tue, 9 Oct 2012 19:43:10 +0000 (22:43 +0300)]
copy-cond: only dst handler condition is useful
Marko Kreen [Tue, 9 Oct 2012 14:39:51 +0000 (07:39 -0700)]
Merge pull request #13 from askoja/master
Copy condition refactor
Asko Oja [Tue, 9 Oct 2012 13:23:43 +0000 (13:23 +0000)]
Merge branch 'master' of https://github.com/markokr/skytools
Marko Kreen [Tue, 9 Oct 2012 10:18:17 +0000 (13:18 +0300)]
v3.1.1
Marko Kreen [Tue, 9 Oct 2012 10:34:34 +0000 (13:34 +0300)]
Add debian/copyright to tgz
Marko Kreen [Tue, 9 Oct 2012 10:25:08 +0000 (13:25 +0300)]
Fix missed renames
Marko Kreen [Tue, 9 Oct 2012 08:48:30 +0000 (11:48 +0300)]
Merge remote-tracking branch 'intgit/master'
Marko Kreen [Tue, 9 Oct 2012 08:46:42 +0000 (11:46 +0300)]
--sync-watermark: don't allow subtree wm get above upstream wm
In case root is lagging, the subtree should not drop events.
Asko Oja [Mon, 8 Oct 2012 14:38:10 +0000 (14:38 +0000)]
Londiste compare and repair fixes
Deprecated Londiste command line parameter --copy-condition.
Londiste handler part.py must be used instead as it leaves
configuration in maintainable state.
Fixed Londiste compare and repair for one to many and
many to one repliaction use cases. Now filtering
condition is applied on both ends and datasets compared
should be the same.
Cleaned up database splitting howto.
Marko Kreen [Mon, 8 Oct 2012 07:21:20 +0000 (10:21 +0300)]
Fix queue_splitter3 manpage.
Marko Kreen [Fri, 5 Oct 2012 19:18:04 +0000 (22:18 +0300)]
New syncer logic for non-root provider
Table-based locking is broken if provider is not root
as it blocks whole node.
Implement different logic for such case that pauses upstream
worker to get well-defined sync point.
Marko Kreen [Fri, 5 Oct 2012 13:18:05 +0000 (16:18 +0300)]
Remove bublin.py - its unmaintained
It was supposed to support more elastic clustering,
but the effort has stalled, and the code is unfinished.
Remove it as it makes maintenance harder.
Marko Kreen [Fri, 5 Oct 2012 12:16:16 +0000 (15:16 +0300)]
londiste: add regtest alternatives for 8.3
8.3 does not have TRUNCATE trigger, so tests
that expect it will fail.
Marko Kreen [Fri, 5 Oct 2012 09:28:19 +0000 (12:28 +0300)]
londiste.drop_table_triggers: use decode() instead cast
text->bytea cast does not work on GP, use decode(val, 'escape')
to get same effect.
martinko [Thu, 4 Oct 2012 17:17:29 +0000 (19:17 +0200)]
Merge branch 'master' of skype-git:/git/dba/skytools-3
martinko [Thu, 4 Oct 2012 13:02:11 +0000 (15:02 +0200)]
skytools.scripting: speed up stat counters
Marko Kreen [Wed, 3 Oct 2012 11:26:54 +0000 (14:26 +0300)]
Survive empty PYTHON from PGXS
Marko Kreen [Wed, 3 Oct 2012 11:10:18 +0000 (04:10 -0700)]
Merge pull request #12 from emiel/master
Allow for building with different python versions
Emiel van de Laar [Tue, 2 Oct 2012 20:09:09 +0000 (22:09 +0200)]
Fix support for '--with-python=PYTHON' configure flag
Marko Kreen [Fri, 28 Sep 2012 13:49:11 +0000 (16:49 +0300)]
sql: sync versions in all files
Seems there aretoo many places where version needs to be mentioned..
Marko Kreen [Fri, 28 Sep 2012 13:20:53 +0000 (16:20 +0300)]
Remove 'workaround' as it was pgq_coop own bug
Marko Kreen [Fri, 28 Sep 2012 13:20:35 +0000 (16:20 +0300)]
sql: always install contrib files
Marko Kreen [Fri, 28 Sep 2012 12:44:15 +0000 (15:44 +0300)]
common-pgxs: use awk instead sed when finding source files
Marko Kreen [Mon, 24 Sep 2012 13:48:30 +0000 (16:48 +0300)]
Merge remote-tracking branch 'intgit/master'
Marko Kreen [Mon, 24 Sep 2012 13:46:27 +0000 (16:46 +0300)]
draft news
Marko Kreen [Mon, 24 Sep 2012 12:58:59 +0000 (15:58 +0300)]
londiste: bump schema version to 3.1.1
Marko Kreen [Mon, 24 Sep 2012 12:54:04 +0000 (15:54 +0300)]
Rename queue_splitter & _mover docs with '3' suffix
It seems whole "configurable suffix" idea is a mess
and should be removed.
Marko Kreen [Mon, 24 Sep 2012 09:41:47 +0000 (12:41 +0300)]
pgqd: Make connection handling more robust
There are reports of fatals() and stalls
when server goes down. Plug potential holes.
* check for DB_CLOSED in tick_handler
* check for TUPLES_OK everywhere
Marko Kreen [Wed, 19 Sep 2012 12:03:18 +0000 (15:03 +0300)]
Support for extensions upgrade
Needed for pgq & pgq_coop that have changed.
Also move more common code to common-pgxs.mk
Asko Oja [Wed, 19 Sep 2012 12:42:34 +0000 (15:42 +0300)]
adjusted default keepalive_stats from 61 to 300 seconds
Asko Oja [Wed, 19 Sep 2012 11:59:00 +0000 (14:59 +0300)]
Added keepalive_stats parameter for consumer that controls how often idle consumer logs idle time. Also added rounding to milliseconds for logged durations
Marko Kreen [Wed, 19 Sep 2012 09:47:50 +0000 (12:47 +0300)]
Refresh libusual
Marko Kreen [Tue, 18 Sep 2012 13:39:07 +0000 (16:39 +0300)]
londiste compare improvements
* Calculate common column names, to allow different order
or different subset.
* Use different hash function on 8.3 <> something else comparision
as hashtext() changed in 8.4.
* Always calculate final hash as bigint.
Asko Oja [Tue, 18 Sep 2012 13:02:14 +0000 (16:02 +0300)]
compare workaroud for hashtext change between 8.3 and 8.4
Marko Kreen [Tue, 18 Sep 2012 11:37:25 +0000 (14:37 +0300)]
pgq_coop.next_batch: check and create subconsumers after locking main consumer
Otherwise, there is race with other consumers who might remove
just-checked subconsumer.
Asko Oja [Tue, 18 Sep 2012 11:12:26 +0000 (14:12 +0300)]
consumer logs again idle time spent waiting for events
Marko Kreen [Tue, 18 Sep 2012 11:10:04 +0000 (14:10 +0300)]
Merge remote-tracking branch 'intgit/master'
Marko Kreen [Tue, 18 Sep 2012 11:04:40 +0000 (14:04 +0300)]
Change londiste_create_part regtest to use specific fields
Otherwise test fails due to information_schema unstability.
Marko Kreen [Tue, 18 Sep 2012 10:40:45 +0000 (13:40 +0300)]
londiste.local_remove_table: resture DDL if still attached to table
Multi-TX COPY can happen on merge nodes. If table
is removed during such copy, the DDL is removed from table
and put to 'dropped_ddl' column.
If dropped_ddl is not empty, the table is truncated and
DDL is restored. Reason for truncate is that table is
unsynced anyway, so no point keeping the data.
Tarvi Pillessaar [Thu, 13 Sep 2012 07:16:28 +0000 (10:16 +0300)]
scripts: update doc as well
Tarvi Pillessaar [Wed, 12 Sep 2012 12:38:52 +0000 (15:38 +0300)]
scripts: changed queue_mover and queue_splitter service_name
Marko Kreen [Wed, 12 Sep 2012 08:37:24 +0000 (11:37 +0300)]
pgq_node.demote_root: decrease lock level
Otherwise demote can get stuck on pg_dump.
Also lock all event tables, not only current
as the current one can change.
Marko Kreen [Wed, 29 Aug 2012 13:46:41 +0000 (16:46 +0300)]
Merge branch 'master' of git://github.com/markokr/skytools
Martin Pihlak [Thu, 16 Aug 2012 09:47:10 +0000 (12:47 +0300)]
Merge branch 'master' of internal-git:/git/dba/skytools-3
Martin Pihlak [Thu, 16 Aug 2012 09:43:37 +0000 (12:43 +0300)]
Don't complain if a nonexistent WAL file is encountered during cleanup.
This is to avoid crashes when some cleanup command (such as pg_archivecleanup)
has already removed the wal files.
Marko Kreen [Thu, 16 Aug 2012 09:04:56 +0000 (02:04 -0700)]
Merge pull request #9 from dgorley/master
Updates to Documentation
Doug Gorley [Thu, 16 Aug 2012 03:19:48 +0000 (20:19 -0700)]
Some cleanup and grammar corrections to documentation.
martinko [Wed, 15 Aug 2012 13:19:34 +0000 (15:19 +0200)]
python/qadmin.py: updated script version, added pgq version, amended messages
Marko Kreen [Wed, 15 Aug 2012 12:02:15 +0000 (15:02 +0300)]
Merge remote-tracking branch 'martino/master'
Marko Kreen [Sun, 12 Aug 2012 19:13:10 +0000 (22:13 +0300)]
source.cfg: include debian/pg_buildext in tgz
martinko [Sat, 4 Aug 2012 18:16:58 +0000 (20:16 +0200)]
skytools.scripting: log config reload, updated comment.
martinko [Sat, 4 Aug 2012 14:25:56 +0000 (16:25 +0200)]
skytools.scripting: added support for script __version__
martinko [Sat, 4 Aug 2012 06:41:32 +0000 (08:41 +0200)]
skytools.__init__: added symbols for natsort module
martinko [Fri, 3 Aug 2012 11:08:50 +0000 (13:08 +0200)]
skytools.scripting: added shutdown() to BaseScript
This should be used for cleanup code instead of abusing stop(),
which is called from signal handler.
martinko [Fri, 3 Aug 2012 05:21:30 +0000 (07:21 +0200)]
qadmin updated
martinko [Thu, 2 Aug 2012 20:03:59 +0000 (22:03 +0200)]
python/qadmin.py: unified results displaying
martinko [Thu, 2 Aug 2012 20:02:52 +0000 (22:02 +0200)]
doc/qadmin.txt: small fixes
martinko [Thu, 2 Aug 2012 18:27:37 +0000 (20:27 +0200)]
python/qadmin.py: added "show version" command
"start with something simple and easy, young man."
martinko [Thu, 26 Jul 2012 10:20:30 +0000 (12:20 +0200)]
scripts/skytools_upgrade.py: added "dry run" option and updated manual page
--not-really:: Don't actually do anything.
martinko [Wed, 25 Jul 2012 08:51:25 +0000 (10:51 +0200)]
scripts/scriptmgr.py: status command can optionally be more selective
martinko [Tue, 24 Jul 2012 23:05:55 +0000 (01:05 +0200)]
doc/scriptmgr.txt: manual update
catch up with the previous commit
martinko [Tue, 24 Jul 2012 12:04:52 +0000 (14:04 +0200)]
scripts/scriptmgr.py: added option for specifying service type
-t SVC, --type=SVC apply command to all jobs of this service type
martinko [Tue, 24 Jul 2012 08:50:10 +0000 (10:50 +0200)]
Merge branch 'master' of skype-git:/git/dba/skytools-3
Marko Kreen [Thu, 19 Jul 2012 11:26:34 +0000 (14:26 +0300)]
source.cfg: add new files
Marko Kreen [Thu, 19 Jul 2012 11:15:45 +0000 (14:15 +0300)]
Add manpages for new scripts.
Also clean up minor issues in common text fragments.
Marko Kreen [Thu, 19 Jul 2012 08:41:08 +0000 (11:41 +0300)]
v3.1
Marko Kreen [Thu, 19 Jul 2012 08:30:02 +0000 (11:30 +0300)]
Bump schema versions.
Everything is 3.1.0.0 now.
Marko Kreen [Thu, 19 Jul 2012 08:27:52 +0000 (11:27 +0300)]
sql/pgq: Don't tag batch_id_seq as dumpable, pg_dump is broken.
This means it's value will be lost during dump+restore.
Marko Kreen [Wed, 18 Jul 2012 10:06:59 +0000 (13:06 +0300)]
pgq_coop: correct expected output for extension install
Marko Kreen [Wed, 18 Jul 2012 09:33:08 +0000 (12:33 +0300)]
tests/merge/addcol-data2.sql: missing file
Marko Kreen [Wed, 18 Jul 2012 09:31:42 +0000 (12:31 +0300)]
find_sql_functions: grep sql function signatures.
Dumb parser, but works on skytools modules.
Marko Kreen [Wed, 18 Jul 2012 09:27:51 +0000 (12:27 +0300)]
tests/simplecons - simple_consumer & simple_local_consumer tests
Marko Kreen [Tue, 17 Jul 2012 14:49:14 +0000 (17:49 +0300)]
pgq.LocalConsumer: fix exception message
Marko Kreen [Tue, 17 Jul 2012 12:35:58 +0000 (15:35 +0300)]
simple_consumer: sync with simple_local_consumer changes
Marko Kreen [Tue, 17 Jul 2012 12:30:04 +0000 (15:30 +0300)]
simple_local_consumer: function caller based on LocalConsumer
Consumer that runs a SQL for each event.
Marko Kreen [Tue, 17 Jul 2012 12:29:24 +0000 (15:29 +0300)]
pgq.Consumer: 'table_filter' - filter for ev_extra1
Marko Kreen [Fri, 13 Jul 2012 15:47:55 +0000 (18:47 +0300)]
londiste.create_partitions(): support triggers
Marko Kreen [Fri, 13 Jul 2012 10:46:30 +0000 (13:46 +0300)]
londiste: --find-copy-node switch for add-table
This will find node where tables are available for copy
by walking upwards to root.
Marko Kreen [Fri, 13 Jul 2012 09:24:20 +0000 (12:24 +0300)]
News update
Marko Kreen [Thu, 12 Jul 2012 14:00:34 +0000 (17:00 +0300)]
CascadedWorker: don't move watermark on source further than incoming batch.
This can happen on merge-leaf-on-branch, where incomong queue
can be behind the combined-queue on branch.
Marko Kreen [Thu, 12 Jul 2012 13:10:00 +0000 (16:10 +0300)]
londiste execute: fix downstream apply
- Downgrade "already applied" message from WARN to INFO
Unnecessary to warn about expected situation.
- ExecAttr: urldecoding fixes
This path was not tested properly.
- Test execute-through-combined-queue
Marko Kreen [Wed, 11 Jul 2012 15:42:58 +0000 (18:42 +0300)]
Convert DB modules to extensions
Keep installing old module files under contrib/ still.
Marko Kreen [Mon, 9 Jul 2012 11:46:48 +0000 (14:46 +0300)]
pgq.LocalConsumer: consumer that tracks processed ticks in local file
Marko Kreen [Mon, 9 Jul 2012 11:56:30 +0000 (14:56 +0300)]
testlib.sh: few improvements
title2, title3, run_qadmin, cat_file
Marko Kreen [Mon, 9 Jul 2012 09:49:25 +0000 (12:49 +0300)]
pgq.maint_operations: include londiste.periodic_maintenance
Marko Kreen [Mon, 9 Jul 2012 09:47:02 +0000 (12:47 +0300)]
londiste.periodic_maintenance: cleanup for applied_execute
Marko Kreen [Mon, 9 Jul 2012 09:39:07 +0000 (12:39 +0300)]
londiste.applied_execute: drop queue_name from pkey
Reason - we want execute work also when parallel queues
from partitioned databases are merged together into
single queue. Thus we need to be able to detect if same
changes have been applied through different queue.
Marko Kreen [Mon, 9 Jul 2012 09:36:36 +0000 (12:36 +0300)]
londiste execute: fix filter
Marko Kreen [Fri, 6 Jul 2012 11:23:32 +0000 (14:23 +0300)]
londiste replay: skip provider checks if copy_node is used
Because the table does not need to exist on current provider then.
Perhaps it would be safer to go and check this new node,
but copy can wait for good state on its own too.
Marko Kreen [Thu, 5 Jul 2012 15:47:47 +0000 (18:47 +0300)]
londiste execute: support meta attributes in sql
THis allows use of EXECUTE in sitations where table
can be missing on few nodes.
Currenly, this needed to to be solved with temp update functions
that detect local situation or avoiding Londiste completely.
Both which are non-optimal solutions.